Skip to content

Commit b44560e

Browse files
committed
rpc: drop n==0 special case in send_data(); retry in loop per review
1 parent 829d6b6 commit b44560e

File tree

1 file changed

+1
-9
lines changed

1 file changed

+1
-9
lines changed

ggml/src/ggml-rpc/ggml-rpc.cpp

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -333,17 +333,11 @@ static bool send_data(sockfd_t sockfd, const void * data, size_t size) {
333333
bytes_sent, size_to_send);
334334
return false;
335335
}
336-
if (n == 0) {
337-
GGML_LOG_ERROR("send returned 0 (peer closed?)\n");
338-
return false;
339-
}
340-
bytes_sent += (size_t)n;
336+
bytes_sent += (size_t)n;
341337
}
342338
return true;
343339
}
344340

345-
346-
347341
static bool recv_data(sockfd_t sockfd, void * data, size_t size) {
348342
size_t bytes_recv = 0;
349343
while (bytes_recv < size) {
@@ -363,8 +357,6 @@ static bool recv_data(sockfd_t sockfd, void * data, size_t size) {
363357
return true;
364358
}
365359

366-
367-
368360
static bool send_msg(sockfd_t sockfd, const void * msg, size_t msg_size) {
369361
if (!send_data(sockfd, &msg_size, sizeof(msg_size))) {
370362
return false;

0 commit comments

Comments
 (0)