X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/7fcbf9e43e05c7c8fad4771b7cf8ac9c6ddc655a..a41a1e87182410ec6c2eeaddb0cd961ec554c404:/token.c diff --git a/token.c b/token.c index 862af0f0..8ba32b99 100644 --- a/token.c +++ b/token.c @@ -264,17 +264,14 @@ send_deflated_token(int f, int token, struct map_struct *buf, OFF_T offset, history and hash table */ tx_strm.next_in = (Bytef *) map_ptr(buf, offset, toklen); tx_strm.avail_in = toklen; - do { - tx_strm.next_out = (Bytef *)obuf; - tx_strm.avail_out = AVAIL_OUT_SIZE(CHUNK_SIZE); - r = deflate(&tx_strm, Z_INSERT_ONLY); - if (r != Z_OK) { - rprintf(FERROR, - "deflate on token returned %d (%d bytes left)\n", - r, tx_strm.avail_in); - exit_cleanup(RERR_STREAMIO); - } - } while (tx_strm.avail_in != 0); + tx_strm.next_out = (Bytef *) obuf; + tx_strm.avail_out = AVAIL_OUT_SIZE(CHUNK_SIZE); + r = deflate(&tx_strm, Z_INSERT_ONLY); + if (r != Z_OK || tx_strm.avail_in != 0) { + rprintf(FERROR, "deflate on token returned %d (%d bytes left)\n", + r, tx_strm.avail_in); + exit_cleanup(RERR_STREAMIO); + } } }