15 unsigned get,
max = ((unsigned)-1 >> 2) + 1;
22 ret = read(state->fd, buf + *have,
get);
25 *have += (unsigned)ret;
26 }
while (*have < len);
49 if (state->eof == 0) {
51 unsigned char *p = state->in;
52 unsigned const char *q = strm->next_in;
53 unsigned n = strm->avail_in;
58 if (
gz_load(state, state->in + strm->avail_in,
59 state->size - strm->avail_in, &got) == -1)
61 strm->avail_in += got;
62 strm->next_in = state->in;
80 if (state->size == 0) {
82 state->in = (
unsigned char *)
malloc(state->want);
83 state->out = (
unsigned char *)
malloc(state->want << 1);
84 if (state->in == NULL || state->out == NULL) {
90 state->size = state->want;
93 state->strm.zalloc =
Z_NULL;
94 state->strm.zfree =
Z_NULL;
95 state->strm.opaque =
Z_NULL;
96 state->strm.avail_in = 0;
97 state->strm.next_in =
Z_NULL;
108 if (strm->avail_in < 2) {
111 if (strm->avail_in == 0)
122 if (strm->avail_in > 1 &&
123 strm->next_in[0] == 31 && strm->next_in[1] == 139) {
132 if (state->direct == 0) {
142 state->x.next = state->out;
143 memcpy(state->x.next, strm->next_in, strm->avail_in);
144 state->x.have = strm->avail_in;
162 had = strm->avail_out;
165 if (strm->avail_in == 0 &&
gz_avail(state) == -1)
167 if (strm->avail_in == 0) {
176 "internal error: inflate stream corrupt");
185 strm->msg == NULL ?
"compressed data error" : strm->msg);
191 state->x.have = had - strm->avail_out;
192 state->x.next = strm->next_out - state->x.have;
216 if (state->how ==
LOOK)
220 if (
gz_load(state, state->out, state->size << 1, &(state->x.have))
223 state->x.next = state->out;
226 strm->avail_out = state->size << 1;
227 strm->next_out = state->out;
231 }
while (state->x.have == 0 && (!state->eof || strm->avail_in));
244 (
unsigned)len : state->x.have;
252 else if (state->eof && state->strm.avail_in == 0)
279 if (
gz_skip(state, state->skip) == -1)
293 if (state->x.have < n)
295 memcpy(buf, state->x.next, n);
301 else if (state->eof && state->strm.avail_in == 0) {
308 else if (state->how ==
LOOK || n < (state->size << 1)) {
318 else if (state->how ==
COPY) {
319 if (
gz_load(state, (
unsigned char *)buf, n, &n) == -1)
325 state->strm.avail_out = n;
326 state->strm.next_out = (
unsigned char *)buf;
335 buf = (
char *)buf + n;
366 len = (unsigned)
gz_read(state, buf, len);
393 if (size && len / size != nitems) {
399 return len ?
gz_read(state, buf, len) / size : 0;
409 unsigned char buf[1];
426 return *(state->x.next)++;
430 return gz_read(state, buf, 1) < 1 ? -1 : buf[0];
447 if (state->mode ==
GZ_READ && state->how ==
LOOK && state->x.have == 0)
458 if (
gz_skip(state, state->skip) == -1)
467 if (state->x.have == 0) {
469 state->x.next = state->out + (state->size << 1) - 1;
470 state->x.next[0] = (
unsigned char)c;
477 if (state->x.have == (state->size << 1)) {
483 if (state->x.next == state->out) {
484 unsigned char *src = state->out + state->x.have;
485 unsigned char *dest = state->out + (state->size << 1);
486 while (src > state->out)
488 state->x.next = dest;
492 state->x.next[0] = (
unsigned char)c;
506 if (file == NULL || buf == NULL || len < 1)
518 if (
gz_skip(state, state->skip) == -1)
526 left = (unsigned)len - 1;
529 if (state->x.have == 0 &&
gz_fetch(state) == -1)
531 if (state->x.have == 0) {
537 n = state->x.have > left ? left : state->x.have;
538 eol = (
unsigned char *)memchr(state->x.next,
'\n', n);
540 n = (unsigned)(eol - state->x.next) + 1;
543 memcpy(buf, state->x.next, n);
549 }
while (left && eol == NULL);
569 if (state->mode ==
GZ_READ && state->how ==
LOOK && state->x.have == 0)
573 return state->direct;
599 ret = close(state->fd);
int ZEXPORT gzdirect(gzFile file)
local int gz_fetch(gz_statep state)
int ZEXPORT inflateReset(z_streamp strm)
local int gz_skip(gz_statep state, z_off64_t len)
local int gz_load(gz_statep state, unsigned char *buf, unsigned len, unsigned *have)
local z_size_t gz_read(gz_statep state, voidp buf, z_size_t len)
int ZEXPORT gzgetc_(gzFile file)
int ZEXPORT gzungetc(int c, gzFile file)
constexpr const _Tp & max(const _Tp &a, const _Tp &b)
#define inflateInit2(strm, windowBits)
int ZEXPORT gzclose_r(gzFile file)
local int gz_decomp(gz_statep state)
z_size_t ZEXPORT gzfread(voidp buf, z_size_t size, z_size_t nitems, gzFile file)
char *ZEXPORT gzgets(gzFile file, char *buf, int len)
void ZLIB_INTERNAL gz_error(gz_statep, int, const char *)
int ZEXPORT gzgetc(gzFile file)
local int gz_avail(gz_statep state)
local int gz_look(gz_statep state)
int ZEXPORT inflate(z_streamp strm, int flush)
int ZEXPORT gzread(gzFile file, voidp buf, unsigned len)
int ZEXPORT inflateEnd(z_streamp strm)