Signed-off-by: Jens Axboe <axboe@kernel.dk>
stream.avail_out = this_chunk;
stream.next_out = p;
err = inflate(&stream, Z_NO_FLUSH);
stream.avail_out = this_chunk;
stream.next_out = p;
err = inflate(&stream, Z_NO_FLUSH);
+ /* may be Z_OK, or Z_STREAM_END */
+ if (err < 0) {
log_err("fio: inflate error %d\n", err);
free(ret);
ret = NULL;
log_err("fio: inflate error %d\n", err);
free(ret);
ret = NULL;
stream.avail_out = FIO_SERVER_MAX_FRAGMENT_PDU;
stream.next_out = out_pdu;
stream.avail_out = FIO_SERVER_MAX_FRAGMENT_PDU;
stream.next_out = out_pdu;
- assert(deflate(&stream, Z_FINISH) == Z_OK);
+ ret = deflate(&stream, Z_FINISH);
+ /* may be Z_OK, or Z_STREAM_END */
+ if (ret < 0)
+ goto err_zlib;
this_len = FIO_SERVER_MAX_FRAGMENT_PDU - stream.avail_out;
this_len = FIO_SERVER_MAX_FRAGMENT_PDU - stream.avail_out;