Fix multiple bugs in astreamer pipeline code. astreamer_tar_parser_content() sent the wrong data pointer when forwarding MEMBER_TRAILER padding to the next streamer. After astreamer_buffer_until() buffers the padding bytes, the 'data' pointer has been advanced past them, but the code passed 'data' instead of bbs_buffer.data. This caused the downstream consumer to receive bytes from after the padding rather than the padding itself, and could read past the end of the input buffer.
astreamer_gzip_decompressor_content() only checked for Z_STREAM_ERROR from inflate(), silently ignoring Z_DATA_ERROR (corrupted data) and Z_MEM_ERROR (out of memory). Fix by treating any return other than Z_OK, Z_STREAM_END, and Z_BUF_ERROR as fatal. astreamer_gzip_decompressor_free() missed calling inflateEnd() to release zlib's internal decompression state. astreamer_tar_parser_free() neglected to pfree() the streamer struct itself, leaking it. astreamer_extractor_content() did not check the return value of fclose() when closing an extracted file. A deferred write error (e.g., disk full on buffered I/O) would be silently lost. Discussion: https://postgr.es/m/results/[email protected] Reviewed-By: Tom Lane <[email protected]> Backpatch-through: 15 Branch ------ master Details ------- https://git.postgresql.org/pg/commitdiff/01d58d7e3ff3f7482ff478cb4a49c48aad276138 Modified Files -------------- src/fe_utils/astreamer_file.c | 4 +++- src/fe_utils/astreamer_gzip.c | 10 ++++++++-- src/fe_utils/astreamer_tar.c | 4 +++- 3 files changed, 14 insertions(+), 4 deletions(-)
