Handle Z_BU_F_ERROR in zlib_read

knizhnik · knizhnik · commit 7d616ce12458 · 2019-02-15T11:10:15.000+03:00
diff --git a/src/common/zpq_stream.c b/src/common/zpq_stream.c
@@ -296,7 +296,7 @@ zlib_read(ZpqStream *zstream, void *buf, size_t size, size_t *processed)
 		if (zs->rx.avail_in != 0) /* If there is some data in receiver buffer, then decompress it */
 		{
 			rc = inflate(&zs->rx, Z_SYNC_FLUSH);
-			if (rc != Z_OK)
+			if (rc != Z_OK && rc != Z_BUF_ERROR)
 			{
 				return ZPQ_DECOMPRESS_ERROR;
 			}

Original file line number	Diff line number	Diff line change
`@@ -296,7 +296,7 @@ zlib_read(ZpqStream zstream, void buf, size_t size, size_t *processed)`
`296`	`296`	`if (zs->rx.avail_in != 0) /* If there is some data in receiver buffer, then decompress it */`
`297`	`297`	`{`
`298`	`298`	`rc = inflate(&zs->rx, Z_SYNC_FLUSH);`
`299`		`- if (rc != Z_OK)`
	`299`	`+ if (rc != Z_OK && rc != Z_BUF_ERROR)`
`300`	`300`	`{`
`301`	`301`	`return ZPQ_DECOMPRESS_ERROR;`
`302`	`302`	`}`