Lines Matching refs:state
16 /* Initialize state for writing a gzip file. Mark initialization by setting
17 state->size to non-zero. Return -1 on failure or 0 on success. */
18 local int gz_init(state)
19 gz_statep state;
22 z_streamp strm = &(state->strm);
25 state->in = (unsigned char *)malloc(state->want);
26 if (state->in == NULL) {
27 gz_error(state, Z_MEM_ERROR, "out of memory");
31 /* only need output buffer and deflate state if compressing */
32 if (!state->direct) {
34 state->out = (unsigned char *)malloc(state->want);
35 if (state->out == NULL) {
36 free(state->in);
37 gz_error(state, Z_MEM_ERROR, "out of memory");
45 ret = deflateInit2(strm, state->level, Z_DEFLATED,
46 MAX_WBITS + 16, DEF_MEM_LEVEL, state->strategy);
48 free(state->out);
49 free(state->in);
50 gz_error(state, Z_MEM_ERROR, "out of memory");
55 /* mark state as initialized */
56 state->size = state->want;
59 if (!state->direct) {
60 strm->avail_out = state->size;
61 strm->next_out = state->out;
62 state->x.next = strm->next_out;
70 then the deflate() state is reset to start a new gzip stream. If gz->direct
73 local int gz_comp(state, flush)
74 gz_statep state;
79 z_streamp strm = &(state->strm);
82 if (state->size == 0 && gz_init(state) == -1)
86 if (state->direct) {
87 got = write(state->fd, strm->next_in, strm->avail_in);
89 gz_error(state, Z_ERRNO, zstrerror());
103 have = (unsigned)(strm->next_out - state->x.next);
104 if (have && ((got = write(state->fd, state->x.next, have)) < 0 ||
106 gz_error(state, Z_ERRNO, zstrerror());
110 strm->avail_out = state->size;
111 strm->next_out = state->out;
113 state->x.next = strm->next_out;
120 gz_error(state, Z_STREAM_ERROR,
136 local int gz_zero(state, len)
137 gz_statep state;
142 z_streamp strm = &(state->strm);
145 if (strm->avail_in && gz_comp(state, Z_NO_FLUSH) == -1)
151 n = GT_OFF(state->size) || (z_off64_t)state->size > len ?
152 (unsigned)len : state->size;
154 memset(state->in, 0, n);
158 strm->next_in = state->in;
159 state->x.pos += n;
160 if (gz_comp(state, Z_NO_FLUSH) == -1)
174 gz_statep state;
180 state = (gz_statep)file;
181 strm = &(state->strm);
184 if (state->mode != GZ_WRITE || state->err != Z_OK)
190 gz_error(state, Z_DATA_ERROR, "requested length does not fit in int");
199 if (state->size == 0 && gz_init(state) == -1)
203 if (state->seek) {
204 state->seek = 0;
205 if (gz_zero(state, state->skip) == -1)
210 if (len < state->size) {
216 strm->next_in = state->in;
217 have = (unsigned)((strm->next_in + strm->avail_in) - state->in);
218 copy = state->size - have;
221 memcpy(state->in + have, buf, copy);
223 state->x.pos += copy;
226 if (len && gz_comp(state, Z_NO_FLUSH) == -1)
232 if (strm->avail_in && gz_comp(state, Z_NO_FLUSH) == -1)
238 state->x.pos += len;
239 if (gz_comp(state, Z_NO_FLUSH) == -1)
254 gz_statep state;
260 state = (gz_statep)file;
261 strm = &(state->strm);
264 if (state->mode != GZ_WRITE || state->err != Z_OK)
268 if (state->seek) {
269 state->seek = 0;
270 if (gz_zero(state, state->skip) == -1)
274 /* try writing to input buffer for speed (state->size == 0 if buffer not
276 if (state->size) {
278 strm->next_in = state->in;
279 have = (unsigned)((strm->next_in + strm->avail_in) - state->in);
280 if (have < state->size) {
281 state->in[have] = c;
283 state->x.pos++;
316 gz_statep state;
322 state = (gz_statep)file;
323 strm = &(state->strm);
326 if (state->mode != GZ_WRITE || state->err != Z_OK)
330 if (state->size == 0 && gz_init(state) == -1)
334 if (state->seek) {
335 state->seek = 0;
336 if (gz_zero(state, state->skip) == -1)
341 if (strm->avail_in && gz_comp(state, Z_NO_FLUSH) == -1)
345 size = (int)(state->size);
346 state->in[size - 1] = 0;
349 (void)vsprintf((char *)(state->in), format, va);
351 if (state->in[len] == 0) break;
353 len = vsprintf((char *)(state->in), format, va);
357 (void)vsnprintf((char *)(state->in), size, format, va);
358 len = strlen((char *)(state->in));
360 len = vsnprintf((char *)(state->in), size, format, va);
365 if (len <= 0 || len >= (int)size || state->in[size - 1] != 0)
370 strm->next_in = state->in;
371 state->x.pos += len;
397 gz_statep state;
403 state = (gz_statep)file;
404 strm = &(state->strm);
411 if (state->mode != GZ_WRITE || state->err != Z_OK)
415 if (state->size == 0 && gz_init(state) == -1)
419 if (state->seek) {
420 state->seek = 0;
421 if (gz_zero(state, state->skip) == -1)
426 if (strm->avail_in && gz_comp(state, Z_NO_FLUSH) == -1)
430 size = (int)(state->size);
431 state->in[size - 1] = 0;
434 sprintf((char *)(state->in), format, a1, a2, a3, a4, a5, a6, a7, a8,
437 if (state->in[len] == 0) break;
439 len = sprintf((char *)(state->in), format, a1, a2, a3, a4, a5, a6, a7, a8,
444 snprintf((char *)(state->in), size, format, a1, a2, a3, a4, a5, a6, a7, a8,
446 len = strlen((char *)(state->in));
448 len = snprintf((char *)(state->in), size, format, a1, a2, a3, a4, a5, a6,
455 if (len <= 0 || len >= (int)size || state->in[size - 1] != 0)
460 strm->next_in = state->in;
461 state->x.pos += len;
472 gz_statep state;
477 state = (gz_statep)file;
480 if (state->mode != GZ_WRITE || state->err != Z_OK)
488 if (state->seek) {
489 state->seek = 0;
490 if (gz_zero(state, state->skip) == -1)
495 gz_comp(state, flush);
496 return state->err;
505 gz_statep state;
511 state = (gz_statep)file;
512 strm = &(state->strm);
515 if (state->mode != GZ_WRITE || state->err != Z_OK)
519 if (level == state->level && strategy == state->strategy)
523 if (state->seek) {
524 state->seek = 0;
525 if (gz_zero(state, state->skip) == -1)
530 if (state->size) {
532 if (strm->avail_in && gz_comp(state, Z_PARTIAL_FLUSH) == -1)
533 return state->err;
536 state->level = level;
537 state->strategy = strategy;
546 gz_statep state;
551 state = (gz_statep)file;
554 if (state->mode != GZ_WRITE)
558 if (state->seek) {
559 state->seek = 0;
560 if (gz_zero(state, state->skip) == -1)
561 ret = state->err;
565 if (gz_comp(state, Z_FINISH) == -1)
566 ret = state->err;
567 if (state->size) {
568 if (!state->direct) {
569 (void)deflateEnd(&(state->strm));
570 free(state->out);
572 free(state->in);
574 gz_error(state, Z_OK, NULL);
575 free(state->path);
576 if (close(state->fd) == -1)
578 free(state);