diff options
author | Simon Rettberg | 2020-06-10 16:14:50 +0200 |
---|---|---|
committer | Simon Rettberg | 2020-06-10 16:14:50 +0200 |
commit | cbd74e10a3e7fe4ae27e32d91e2b1cd1b95e3729 (patch) | |
tree | b82fb7bbfd7a058215e2143d8d8d53a4e4ec733a | |
parent | [SERVER] Likewise, flush entire payload on RTT measurement (diff) | |
download | dnbd3-cbd74e10a3e7fe4ae27e32d91e2b1cd1b95e3729.tar.gz dnbd3-cbd74e10a3e7fe4ae27e32d91e2b1cd1b95e3729.tar.xz dnbd3-cbd74e10a3e7fe4ae27e32d91e2b1cd1b95e3729.zip |
[SERVER] Know when to stop
-rw-r--r-- | src/server/altservers.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/server/altservers.c b/src/server/altservers.c index fbbac81..838a475 100644 --- a/src/server/altservers.c +++ b/src/server/altservers.c @@ -598,7 +598,7 @@ static void altservers_findUplinkInternal(dnbd3_uplink_t *uplink) char buffer[DNBD3_BLOCK_SIZE]; uint32_t todo = length; ssize_t ret; - while ( ( ret = recv( sock, buffer, MIN( DNBD3_BLOCK_SIZE, todo ), MSG_WAITALL ) ) > 0 ) { + while ( todo != 0 && ( ret = recv( sock, buffer, MIN( DNBD3_BLOCK_SIZE, todo ), MSG_WAITALL ) ) > 0 ) { todo -= (uint32_t)ret; } if ( todo != 0 ) { |