Lines Matching refs:bzs
99 bz_stream bzs;
106 bz_stream bzs;
113 /* bzs->avail_in is only 32 bit, so we store the true length
180 if (OutputBuffer_InitAndGrow(&buffer, -1, &c->bzs.next_out, &c->bzs.avail_out) < 0) {
183 c->bzs.next_in = data;
184 c->bzs.avail_in = 0;
191 if (c->bzs.avail_in == 0 && len > 0) {
192 c->bzs.avail_in = (unsigned int)Py_MIN(len, UINT_MAX);
193 len -= c->bzs.avail_in;
197 if (action == BZ_RUN && c->bzs.avail_in == 0)
200 if (c->bzs.avail_out == 0) {
201 if (OutputBuffer_Grow(&buffer, &c->bzs.next_out, &c->bzs.avail_out) < 0) {
207 bzerror = BZ2_bzCompress(&c->bzs, action);
218 result = OutputBuffer_Finish(&buffer, c->bzs.avail_out);
331 self->bzs.opaque = NULL;
332 self->bzs.bzalloc = BZ2_Malloc;
333 self->bzs.bzfree = BZ2_Free;
334 bzerror = BZ2_bzCompressInit(&self->bzs, compresslevel, 0, 0);
386 BZ2_bzCompressEnd(&self->bzs);
431 /* Decompress data of length d->bzs_avail_in_real in d->bzs.next_in. The output
433 returned, so some of the input may not be consumed. d->bzs.next_in and
443 bz_stream *bzs = &d->bzs;
445 if (OutputBuffer_InitAndGrow(&buffer, max_length, &bzs->next_out, &bzs->avail_out) < 0) {
455 bzs->avail_in = (unsigned int)Py_MIN(d->bzs_avail_in_real, UINT_MAX);
456 d->bzs_avail_in_real -= bzs->avail_in;
459 bzret = BZ2_bzDecompress(bzs);
462 d->bzs_avail_in_real += bzs->avail_in;
471 } else if (bzs->avail_out == 0) {
472 if (OutputBuffer_GetDataSize(&buffer, bzs->avail_out) == max_length) {
475 if (OutputBuffer_Grow(&buffer, &bzs->next_out, &bzs->avail_out) < 0) {
481 result = OutputBuffer_Finish(&buffer, bzs->avail_out);
497 bz_stream *bzs = &d->bzs;
500 if (bzs->next_in != NULL) {
505 - (bzs->next_in + d->bzs_avail_in_real);
513 size_t offset = bzs->next_in - d->input_buffer;
527 bzs->next_in = d->input_buffer + offset;
530 memmove(d->input_buffer, bzs->next_in,
532 bzs->next_in = d->input_buffer;
534 memcpy((void*)(bzs->next_in + d->bzs_avail_in_real), data, len);
539 bzs->next_in = data;
546 bzs->next_in = NULL;
554 PyBytes_FromStringAndSize(bzs->next_in, d->bzs_avail_in_real));
560 bzs->next_in = NULL;
590 memcpy(d->input_buffer, bzs->next_in, d->bzs_avail_in_real);
591 bzs->next_in = d->input_buffer;
665 bzerror = BZ2_bzDecompressInit(&self->bzs, 0, 0);
709 BZ2_bzDecompressEnd(&self->bzs);