Lines Matching refs:stream
40 z_stream stream;
41 int z_err; /* error code for last stream operation */
90 s->stream.zalloc = (alloc_func)0;
91 s->stream.zfree = (free_func)0;
92 s->stream.opaque = (voidpf)0;
93 s->stream.next_in = s->inbuf = Z_NULL;
94 s->stream.next_out = s->outbuf = Z_NULL;
95 s->stream.avail_in = s->stream.avail_out = 0;
129 err = deflateInit2(&(s->stream), level,
133 s->stream.next_out = s->outbuf = (Byte*)ALLOC(Z_BUFSIZE);
139 s->stream.next_in = s->inbuf = (Byte*)ALLOC(Z_BUFSIZE);
141 err = inflateInit2(&(s->stream), -MAX_WBITS);
144 * after the compressed stream in order to complete decompression and
146 * present after the compressed stream.
152 s->stream.avail_out = Z_BUFSIZE;
173 s->startpos = (ftell(s->file) - s->stream.avail_in);
218 if (s->stream.avail_out == 0) {
220 s->stream.next_out = s->outbuf;
224 s->stream.avail_out = Z_BUFSIZE;
227 return deflateParams (&(s->stream), level, strategy);
233 IN assertion: the stream s has been sucessfully opened for reading.
239 if (s->stream.avail_in == 0) {
241 s->stream.avail_in = fread(s->inbuf, 1, Z_BUFSIZE, s->file);
242 if (s->stream.avail_in == 0) {
247 s->stream.next_in = s->inbuf;
249 s->stream.avail_in--;
250 return *(s->stream.next_in)++;
254 Check the gzip header of a gz_stream opened for reading. Set the stream
258 IN assertion: the stream s has already been created sucessfully;
259 s->stream.avail_in is zero for the first time, but may be non-zero
274 if (len != 0) s->stream.avail_in++, s->stream.next_in--;
276 s->stream.avail_in++, s->stream.next_in--;
279 s->z_err = s->stream.avail_in != 0 ? Z_OK : Z_STREAM_END;
324 if (s->stream.state != NULL) {
329 err = deflateEnd(&(s->stream));
332 err = inflateEnd(&(s->stream));
361 Byte *next_out; /* == stream.next_out but not forced far (for MSDOS) */
369 s->stream.next_out = (Bytef*)buf;
370 s->stream.avail_out = len;
372 while (s->stream.avail_out != 0) {
376 uInt n = s->stream.avail_in;
377 if (n > s->stream.avail_out) n = s->stream.avail_out;
379 zmemcpy(s->stream.next_out, s->stream.next_in, n);
381 s->stream.next_out = next_out;
382 s->stream.next_in += n;
383 s->stream.avail_out -= n;
384 s->stream.avail_in -= n;
386 if (s->stream.avail_out > 0) {
387 s->stream.avail_out -= fread(next_out, 1, s->stream.avail_out,
390 len -= s->stream.avail_out;
391 s->stream.total_in += (uLong)len;
392 s->stream.total_out += (uLong)len;
396 if (s->stream.avail_in == 0 && !s->z_eof) {
399 s->stream.avail_in = fread(s->inbuf, 1, Z_BUFSIZE, s->file);
400 if (s->stream.avail_in == 0) {
407 s->stream.next_in = s->inbuf;
409 s->z_err = inflate(&(s->stream), Z_NO_FLUSH);
413 s->crc = crc32(s->crc, start, (uInt)(s->stream.next_out - start));
414 start = s->stream.next_out;
421 * be different from s->stream.total_out) in case of
426 uLong total_in = s->stream.total_in;
427 uLong total_out = s->stream.total_out;
429 inflateReset(&(s->stream));
430 s->stream.total_in = total_in;
431 s->stream.total_out = total_out;
438 s->crc = crc32(s->crc, start, (uInt)(s->stream.next_out - start));
440 return (int)(len - s->stream.avail_out);
494 s->stream.next_in = (Bytef*)buf;
495 s->stream.avail_in = len;
497 while (s->stream.avail_in != 0) {
499 if (s->stream.avail_out == 0) {
501 s->stream.next_out = s->outbuf;
506 s->stream.avail_out = Z_BUFSIZE;
508 s->z_err = deflate(&(s->stream), Z_NO_FLUSH);
513 return (int)(len - s->stream.avail_in);
609 s->stream.avail_in = 0; /* should be zero already anyway */
612 len = Z_BUFSIZE - s->stream.avail_out;
619 s->stream.next_out = s->outbuf;
620 s->stream.avail_out = Z_BUFSIZE;
623 s->z_err = deflate(&(s->stream), flush);
631 done = (s->stream.avail_out != 0 || s->z_err == Z_STREAM_END);
655 the beginning of the uncompressed stream, or -1 in case of error.
676 offset -= s->stream.total_in;
694 return (z_off_t)s->stream.total_in;
701 offset += s->stream.total_out;
707 s->stream.avail_in = 0;
708 s->stream.next_in = s->inbuf;
711 s->stream.total_in = s->stream.total_out = (uLong)offset;
716 if ((uLong)offset >= s->stream.total_out) {
717 offset -= s->stream.total_out;
734 return (z_off_t)s->stream.total_out;
749 s->stream.avail_in = 0;
750 s->stream.next_in = s->inbuf;
758 (void) inflateReset(&s->stream);
765 uncompressed data stream.
775 input stream, otherwise zero.
837 putLong (s->file, s->stream.total_in);
864 m = (char*)(*errnum == Z_ERRNO ? zstrerror(errno) : s->stream.msg);