Lines Matching full:zst
208 z_stream zst; member
218 zlib_error(zlibstate *state, z_stream zst, int err, const char *msg) in zlib_error() argument
221 /* In case of a version mismatch, zst.msg won't be initialized. in zlib_error()
222 Check for this case first, before looking at zst.msg. */ in zlib_error()
226 zmsg = zst.msg; in zlib_error()
299 arrange_input_buffer(z_stream *zst, Py_ssize_t *remains) in arrange_input_buffer() argument
301 zst->avail_in = (uInt)Py_MIN((size_t)*remains, UINT_MAX); in arrange_input_buffer()
302 *remains -= zst->avail_in; in arrange_input_buffer()
323 z_stream zst; in zlib_compress_impl() local
331 if (OutputBuffer_InitAndGrow(&buffer, -1, &zst.next_out, &zst.avail_out) < 0) { in zlib_compress_impl()
335 zst.opaque = NULL; in zlib_compress_impl()
336 zst.zalloc = PyZlib_Malloc; in zlib_compress_impl()
337 zst.zfree = PyZlib_Free; in zlib_compress_impl()
338 zst.next_in = ibuf; in zlib_compress_impl()
339 int err = deflateInit(&zst, level); in zlib_compress_impl()
352 deflateEnd(&zst); in zlib_compress_impl()
353 zlib_error(state, zst, err, "while compressing data"); in zlib_compress_impl()
358 arrange_input_buffer(&zst, &ibuflen); in zlib_compress_impl()
362 if (zst.avail_out == 0) { in zlib_compress_impl()
363 if (OutputBuffer_Grow(&buffer, &zst.next_out, &zst.avail_out) < 0) { in zlib_compress_impl()
364 deflateEnd(&zst); in zlib_compress_impl()
370 err = deflate(&zst, flush); in zlib_compress_impl()
374 deflateEnd(&zst); in zlib_compress_impl()
375 zlib_error(state, zst, err, "while compressing data"); in zlib_compress_impl()
379 } while (zst.avail_out == 0); in zlib_compress_impl()
380 assert(zst.avail_in == 0); in zlib_compress_impl()
385 err = deflateEnd(&zst); in zlib_compress_impl()
387 RetVal = OutputBuffer_Finish(&buffer, zst.avail_out); in zlib_compress_impl()
394 zlib_error(state, zst, err, "while finishing compression"); in zlib_compress_impl()
423 z_stream zst; in zlib_decompress_impl() local
437 &zst.next_out, &zst.avail_out) < 0) { in zlib_decompress_impl()
444 zst.opaque = NULL; in zlib_decompress_impl()
445 zst.zalloc = PyZlib_Malloc; in zlib_decompress_impl()
446 zst.zfree = PyZlib_Free; in zlib_decompress_impl()
447 zst.avail_in = 0; in zlib_decompress_impl()
448 zst.next_in = ibuf; in zlib_decompress_impl()
449 err = inflateInit2(&zst, wbits); in zlib_decompress_impl()
459 inflateEnd(&zst); in zlib_decompress_impl()
460 zlib_error(state, zst, err, "while preparing to decompress data"); in zlib_decompress_impl()
465 arrange_input_buffer(&zst, &ibuflen); in zlib_decompress_impl()
469 if (zst.avail_out == 0) { in zlib_decompress_impl()
471 &zst.next_out, &zst.avail_out) < 0) { in zlib_decompress_impl()
472 inflateEnd(&zst); in zlib_decompress_impl()
478 err = inflate(&zst, flush); in zlib_decompress_impl()
487 inflateEnd(&zst); in zlib_decompress_impl()
492 inflateEnd(&zst); in zlib_decompress_impl()
493 zlib_error(state, zst, err, "while decompressing data"); in zlib_decompress_impl()
497 } while (zst.avail_out == 0); in zlib_decompress_impl()
503 inflateEnd(&zst); in zlib_decompress_impl()
504 zlib_error(state, zst, err, "while decompressing data"); in zlib_decompress_impl()
508 err = inflateEnd(&zst); in zlib_decompress_impl()
510 zlib_error(state, zst, err, "while finishing decompression"); in zlib_decompress_impl()
514 RetVal = OutputBuffer_WindowFinish(&buffer, &window, zst.avail_out); in zlib_decompress_impl()
567 self->zst.opaque = NULL; in zlib_compressobj_impl()
568 self->zst.zalloc = PyZlib_Malloc; in zlib_compressobj_impl()
569 self->zst.zfree = PyZlib_Free; in zlib_compressobj_impl()
570 self->zst.next_in = NULL; in zlib_compressobj_impl()
571 self->zst.avail_in = 0; in zlib_compressobj_impl()
572 int err = deflateInit2(&self->zst, level, method, wbits, memLevel, strategy); in zlib_compressobj_impl()
579 err = deflateSetDictionary(&self->zst, in zlib_compressobj_impl()
600 zlib_error(state, self->zst, err, "while creating compression object"); in zlib_compressobj_impl()
624 err = inflateSetDictionary(&self->zst, in set_inflate_zdict()
628 zlib_error(state, self->zst, err, "while setting zdict"); in set_inflate_zdict()
661 self->zst.opaque = NULL; in zlib_decompressobj_impl()
662 self->zst.zalloc = PyZlib_Malloc; in zlib_decompressobj_impl()
663 self->zst.zfree = PyZlib_Free; in zlib_decompressobj_impl()
664 self->zst.next_in = NULL; in zlib_decompressobj_impl()
665 self->zst.avail_in = 0; in zlib_decompressobj_impl()
670 int err = inflateInit2(&self->zst, wbits); in zlib_decompressobj_impl()
699 zlib_error(state, self->zst, err, "while creating decompression object"); in zlib_decompressobj_impl()
721 deflateEnd(&self->zst); in Comp_dealloc()
729 inflateEnd(&self->zst); in Decomp_dealloc()
760 self->zst.next_in = data->buf; in zlib_Compress_compress_impl()
763 if (OutputBuffer_InitAndGrow(&buffer, -1, &self->zst.next_out, &self->zst.avail_out) < 0) { in zlib_Compress_compress_impl()
768 arrange_input_buffer(&self->zst, &ibuflen); in zlib_Compress_compress_impl()
771 if (self->zst.avail_out == 0) { in zlib_Compress_compress_impl()
772 if (OutputBuffer_Grow(&buffer, &self->zst.next_out, &self->zst.avail_out) < 0) { in zlib_Compress_compress_impl()
778 err = deflate(&self->zst, Z_NO_FLUSH); in zlib_Compress_compress_impl()
782 zlib_error(state, self->zst, err, "while compressing data"); in zlib_Compress_compress_impl()
786 } while (self->zst.avail_out == 0); in zlib_Compress_compress_impl()
787 assert(self->zst.avail_in == 0); in zlib_Compress_compress_impl()
791 RetVal = OutputBuffer_Finish(&buffer, self->zst.avail_out); in zlib_Compress_compress_impl()
812 if (self->zst.avail_in > 0) { in save_unconsumed_input()
816 left_size = (Byte *)data->buf + data->len - self->zst.next_in; in save_unconsumed_input()
828 self->zst.next_in, left_size); in save_unconsumed_input()
830 self->zst.avail_in = 0; in save_unconsumed_input()
834 if (self->zst.avail_in > 0 || PyBytes_GET_SIZE(self->unconsumed_tail)) { in save_unconsumed_input()
838 Py_ssize_t left_size = (Byte *)data->buf + data->len - self->zst.next_in; in save_unconsumed_input()
840 (char *)self->zst.next_in, left_size); in save_unconsumed_input()
892 self->zst.next_in = data->buf; in zlib_Decompress_decompress_impl()
895 …if (OutputBuffer_InitAndGrow(&buffer, max_length, &self->zst.next_out, &self->zst.avail_out) < 0) { in zlib_Decompress_decompress_impl()
900 arrange_input_buffer(&self->zst, &ibuflen); in zlib_Decompress_decompress_impl()
903 if (self->zst.avail_out == 0) { in zlib_Decompress_decompress_impl()
904 if (OutputBuffer_GetDataSize(&buffer, self->zst.avail_out) == max_length) { in zlib_Decompress_decompress_impl()
907 if (OutputBuffer_Grow(&buffer, &self->zst.next_out, &self->zst.avail_out) < 0) { in zlib_Decompress_decompress_impl()
913 err = inflate(&self->zst, Z_SYNC_FLUSH); in zlib_Decompress_decompress_impl()
932 } while (self->zst.avail_out == 0 || err == Z_NEED_DICT); in zlib_Decompress_decompress_impl()
949 zlib_error(state, self->zst, err, "while decompressing data"); in zlib_Decompress_decompress_impl()
953 RetVal = OutputBuffer_Finish(&buffer, self->zst.avail_out); in zlib_Decompress_decompress_impl()
997 self->zst.avail_in = 0; in zlib_Compress_flush_impl()
999 if (OutputBuffer_InitAndGrow(&buffer, -1, &self->zst.next_out, &self->zst.avail_out) < 0) { in zlib_Compress_flush_impl()
1004 if (self->zst.avail_out == 0) { in zlib_Compress_flush_impl()
1005 if (OutputBuffer_Grow(&buffer, &self->zst.next_out, &self->zst.avail_out) < 0) { in zlib_Compress_flush_impl()
1011 err = deflate(&self->zst, mode); in zlib_Compress_flush_impl()
1015 zlib_error(state, self->zst, err, "while flushing"); in zlib_Compress_flush_impl()
1018 } while (self->zst.avail_out == 0); in zlib_Compress_flush_impl()
1019 assert(self->zst.avail_in == 0); in zlib_Compress_flush_impl()
1025 err = deflateEnd(&self->zst); in zlib_Compress_flush_impl()
1027 zlib_error(state, self->zst, err, "while finishing compression"); in zlib_Compress_flush_impl()
1038 zlib_error(state, self->zst, err, "while flushing"); in zlib_Compress_flush_impl()
1042 RetVal = OutputBuffer_Finish(&buffer, self->zst.avail_out); in zlib_Compress_flush_impl()
1078 int err = deflateCopy(&retval->zst, &self->zst); in zlib_Compress_copy_impl()
1090 zlib_error(state, self->zst, err, "while copying compression object"); in zlib_Compress_copy_impl()
1165 int err = inflateCopy(&retval->zst, &self->zst); in zlib_Decompress_copy_impl()
1177 zlib_error(state, self->zst, err, "while copying decompression object"); in zlib_Decompress_copy_impl()
1276 self->zst.next_in = data.buf; in zlib_Decompress_flush_impl()
1280 &self->zst.next_out, &self->zst.avail_out) < 0) { in zlib_Decompress_flush_impl()
1285 arrange_input_buffer(&self->zst, &ibuflen); in zlib_Decompress_flush_impl()
1289 if (self->zst.avail_out == 0) { in zlib_Decompress_flush_impl()
1291 &self->zst.next_out, &self->zst.avail_out) < 0) { in zlib_Decompress_flush_impl()
1297 err = inflate(&self->zst, flush); in zlib_Decompress_flush_impl()
1316 } while (self->zst.avail_out == 0 || err == Z_NEED_DICT); in zlib_Decompress_flush_impl()
1329 err = inflateEnd(&self->zst); in zlib_Decompress_flush_impl()
1331 zlib_error(state, self->zst, err, "while finishing decompression"); in zlib_Decompress_flush_impl()
1336 RetVal = OutputBuffer_WindowFinish(&buffer, &window, self->zst.avail_out); in zlib_Decompress_flush_impl()