Chris@43: /* gzwrite.c -- zlib functions for writing gzip files Chris@43: * Copyright (C) 2004, 2005, 2010, 2011, 2012, 2013 Mark Adler Chris@43: * For conditions of distribution and use, see copyright notice in zlib.h Chris@43: */ Chris@43: Chris@43: #include "gzguts.h" Chris@43: Chris@43: /* Local functions */ Chris@43: local int gz_init OF((gz_statep)); Chris@43: local int gz_comp OF((gz_statep, int)); Chris@43: local int gz_zero OF((gz_statep, z_off64_t)); Chris@43: Chris@43: /* Initialize state for writing a gzip file. Mark initialization by setting Chris@43: state->size to non-zero. Return -1 on failure or 0 on success. */ Chris@43: local int gz_init(state) Chris@43: gz_statep state; Chris@43: { Chris@43: int ret; Chris@43: z_streamp strm = &(state->strm); Chris@43: Chris@43: /* allocate input buffer */ Chris@43: state->in = (unsigned char *)malloc(state->want); Chris@43: if (state->in == NULL) { Chris@43: gz_error(state, Z_MEM_ERROR, "out of memory"); Chris@43: return -1; Chris@43: } Chris@43: Chris@43: /* only need output buffer and deflate state if compressing */ Chris@43: if (!state->direct) { Chris@43: /* allocate output buffer */ Chris@43: state->out = (unsigned char *)malloc(state->want); Chris@43: if (state->out == NULL) { Chris@43: free(state->in); Chris@43: gz_error(state, Z_MEM_ERROR, "out of memory"); Chris@43: return -1; Chris@43: } Chris@43: Chris@43: /* allocate deflate memory, set up for gzip compression */ Chris@43: strm->zalloc = Z_NULL; Chris@43: strm->zfree = Z_NULL; Chris@43: strm->opaque = Z_NULL; Chris@43: ret = deflateInit2(strm, state->level, Z_DEFLATED, Chris@43: MAX_WBITS + 16, DEF_MEM_LEVEL, state->strategy); Chris@43: if (ret != Z_OK) { Chris@43: free(state->out); Chris@43: free(state->in); Chris@43: gz_error(state, Z_MEM_ERROR, "out of memory"); Chris@43: return -1; Chris@43: } Chris@43: } Chris@43: Chris@43: /* mark state as initialized */ Chris@43: state->size = state->want; Chris@43: Chris@43: /* initialize write buffer if compressing */ Chris@43: if (!state->direct) { Chris@43: strm->avail_out = state->size; Chris@43: strm->next_out = state->out; Chris@43: state->x.next = strm->next_out; Chris@43: } Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* Compress whatever is at avail_in and next_in and write to the output file. Chris@43: Return -1 if there is an error writing to the output file, otherwise 0. Chris@43: flush is assumed to be a valid deflate() flush value. If flush is Z_FINISH, Chris@43: then the deflate() state is reset to start a new gzip stream. If gz->direct Chris@43: is true, then simply write to the output file without compressing, and Chris@43: ignore flush. */ Chris@43: local int gz_comp(state, flush) Chris@43: gz_statep state; Chris@43: int flush; Chris@43: { Chris@43: int ret, got; Chris@43: unsigned have; Chris@43: z_streamp strm = &(state->strm); Chris@43: Chris@43: /* allocate memory if this is the first time through */ Chris@43: if (state->size == 0 && gz_init(state) == -1) Chris@43: return -1; Chris@43: Chris@43: /* write directly if requested */ Chris@43: if (state->direct) { Chris@43: got = write(state->fd, strm->next_in, strm->avail_in); Chris@43: if (got < 0 || (unsigned)got != strm->avail_in) { Chris@43: gz_error(state, Z_ERRNO, zstrerror()); Chris@43: return -1; Chris@43: } Chris@43: strm->avail_in = 0; Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* run deflate() on provided input until it produces no more output */ Chris@43: ret = Z_OK; Chris@43: do { Chris@43: /* write out current buffer contents if full, or if flushing, but if Chris@43: doing Z_FINISH then don't write until we get to Z_STREAM_END */ Chris@43: if (strm->avail_out == 0 || (flush != Z_NO_FLUSH && Chris@43: (flush != Z_FINISH || ret == Z_STREAM_END))) { Chris@43: have = (unsigned)(strm->next_out - state->x.next); Chris@43: if (have && ((got = write(state->fd, state->x.next, have)) < 0 || Chris@43: (unsigned)got != have)) { Chris@43: gz_error(state, Z_ERRNO, zstrerror()); Chris@43: return -1; Chris@43: } Chris@43: if (strm->avail_out == 0) { Chris@43: strm->avail_out = state->size; Chris@43: strm->next_out = state->out; Chris@43: } Chris@43: state->x.next = strm->next_out; Chris@43: } Chris@43: Chris@43: /* compress */ Chris@43: have = strm->avail_out; Chris@43: ret = deflate(strm, flush); Chris@43: if (ret == Z_STREAM_ERROR) { Chris@43: gz_error(state, Z_STREAM_ERROR, Chris@43: "internal error: deflate stream corrupt"); Chris@43: return -1; Chris@43: } Chris@43: have -= strm->avail_out; Chris@43: } while (have); Chris@43: Chris@43: /* if that completed a deflate stream, allow another to start */ Chris@43: if (flush == Z_FINISH) Chris@43: deflateReset(strm); Chris@43: Chris@43: /* all done, no errors */ Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* Compress len zeros to output. Return -1 on error, 0 on success. */ Chris@43: local int gz_zero(state, len) Chris@43: gz_statep state; Chris@43: z_off64_t len; Chris@43: { Chris@43: int first; Chris@43: unsigned n; Chris@43: z_streamp strm = &(state->strm); Chris@43: Chris@43: /* consume whatever's left in the input buffer */ Chris@43: if (strm->avail_in && gz_comp(state, Z_NO_FLUSH) == -1) Chris@43: return -1; Chris@43: Chris@43: /* compress len zeros (len guaranteed > 0) */ Chris@43: first = 1; Chris@43: while (len) { Chris@43: n = GT_OFF(state->size) || (z_off64_t)state->size > len ? Chris@43: (unsigned)len : state->size; Chris@43: if (first) { Chris@43: memset(state->in, 0, n); Chris@43: first = 0; Chris@43: } Chris@43: strm->avail_in = n; Chris@43: strm->next_in = state->in; Chris@43: state->x.pos += n; Chris@43: if (gz_comp(state, Z_NO_FLUSH) == -1) Chris@43: return -1; Chris@43: len -= n; Chris@43: } Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* -- see zlib.h -- */ Chris@43: int ZEXPORT gzwrite(file, buf, len) Chris@43: gzFile file; Chris@43: voidpc buf; Chris@43: unsigned len; Chris@43: { Chris@43: unsigned put = len; Chris@43: gz_statep state; Chris@43: z_streamp strm; Chris@43: Chris@43: /* get internal structure */ Chris@43: if (file == NULL) Chris@43: return 0; Chris@43: state = (gz_statep)file; Chris@43: strm = &(state->strm); Chris@43: Chris@43: /* check that we're writing and that there's no error */ Chris@43: if (state->mode != GZ_WRITE || state->err != Z_OK) Chris@43: return 0; Chris@43: Chris@43: /* since an int is returned, make sure len fits in one, otherwise return Chris@43: with an error (this avoids the flaw in the interface) */ Chris@43: if ((int)len < 0) { Chris@43: gz_error(state, Z_DATA_ERROR, "requested length does not fit in int"); Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* if len is zero, avoid unnecessary operations */ Chris@43: if (len == 0) Chris@43: return 0; Chris@43: Chris@43: /* allocate memory if this is the first time through */ Chris@43: if (state->size == 0 && gz_init(state) == -1) Chris@43: return 0; Chris@43: Chris@43: /* check for seek request */ Chris@43: if (state->seek) { Chris@43: state->seek = 0; Chris@43: if (gz_zero(state, state->skip) == -1) Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* for small len, copy to input buffer, otherwise compress directly */ Chris@43: if (len < state->size) { Chris@43: /* copy to input buffer, compress when full */ Chris@43: do { Chris@43: unsigned have, copy; Chris@43: Chris@43: if (strm->avail_in == 0) Chris@43: strm->next_in = state->in; Chris@43: have = (unsigned)((strm->next_in + strm->avail_in) - state->in); Chris@43: copy = state->size - have; Chris@43: if (copy > len) Chris@43: copy = len; Chris@43: memcpy(state->in + have, buf, copy); Chris@43: strm->avail_in += copy; Chris@43: state->x.pos += copy; Chris@43: buf = (const char *)buf + copy; Chris@43: len -= copy; Chris@43: if (len && gz_comp(state, Z_NO_FLUSH) == -1) Chris@43: return 0; Chris@43: } while (len); Chris@43: } Chris@43: else { Chris@43: /* consume whatever's left in the input buffer */ Chris@43: if (strm->avail_in && gz_comp(state, Z_NO_FLUSH) == -1) Chris@43: return 0; Chris@43: Chris@43: /* directly compress user buffer to file */ Chris@43: strm->avail_in = len; Chris@43: strm->next_in = (z_const Bytef *)buf; Chris@43: state->x.pos += len; Chris@43: if (gz_comp(state, Z_NO_FLUSH) == -1) Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* input was all buffered or compressed (put will fit in int) */ Chris@43: return (int)put; Chris@43: } Chris@43: Chris@43: /* -- see zlib.h -- */ Chris@43: int ZEXPORT gzputc(file, c) Chris@43: gzFile file; Chris@43: int c; Chris@43: { Chris@43: unsigned have; Chris@43: unsigned char buf[1]; Chris@43: gz_statep state; Chris@43: z_streamp strm; Chris@43: Chris@43: /* get internal structure */ Chris@43: if (file == NULL) Chris@43: return -1; Chris@43: state = (gz_statep)file; Chris@43: strm = &(state->strm); Chris@43: Chris@43: /* check that we're writing and that there's no error */ Chris@43: if (state->mode != GZ_WRITE || state->err != Z_OK) Chris@43: return -1; Chris@43: Chris@43: /* check for seek request */ Chris@43: if (state->seek) { Chris@43: state->seek = 0; Chris@43: if (gz_zero(state, state->skip) == -1) Chris@43: return -1; Chris@43: } Chris@43: Chris@43: /* try writing to input buffer for speed (state->size == 0 if buffer not Chris@43: initialized) */ Chris@43: if (state->size) { Chris@43: if (strm->avail_in == 0) Chris@43: strm->next_in = state->in; Chris@43: have = (unsigned)((strm->next_in + strm->avail_in) - state->in); Chris@43: if (have < state->size) { Chris@43: state->in[have] = c; Chris@43: strm->avail_in++; Chris@43: state->x.pos++; Chris@43: return c & 0xff; Chris@43: } Chris@43: } Chris@43: Chris@43: /* no room in buffer or not initialized, use gz_write() */ Chris@43: buf[0] = c; Chris@43: if (gzwrite(file, buf, 1) != 1) Chris@43: return -1; Chris@43: return c & 0xff; Chris@43: } Chris@43: Chris@43: /* -- see zlib.h -- */ Chris@43: int ZEXPORT gzputs(file, str) Chris@43: gzFile file; Chris@43: const char *str; Chris@43: { Chris@43: int ret; Chris@43: unsigned len; Chris@43: Chris@43: /* write string */ Chris@43: len = (unsigned)strlen(str); Chris@43: ret = gzwrite(file, str, len); Chris@43: return ret == 0 && len != 0 ? -1 : ret; Chris@43: } Chris@43: Chris@43: #if defined(STDC) || defined(Z_HAVE_STDARG_H) Chris@43: #include Chris@43: Chris@43: /* -- see zlib.h -- */ Chris@43: int ZEXPORTVA gzvprintf(gzFile file, const char *format, va_list va) Chris@43: { Chris@43: int size, len; Chris@43: gz_statep state; Chris@43: z_streamp strm; Chris@43: Chris@43: /* get internal structure */ Chris@43: if (file == NULL) Chris@43: return -1; Chris@43: state = (gz_statep)file; Chris@43: strm = &(state->strm); Chris@43: Chris@43: /* check that we're writing and that there's no error */ Chris@43: if (state->mode != GZ_WRITE || state->err != Z_OK) Chris@43: return 0; Chris@43: Chris@43: /* make sure we have some buffer space */ Chris@43: if (state->size == 0 && gz_init(state) == -1) Chris@43: return 0; Chris@43: Chris@43: /* check for seek request */ Chris@43: if (state->seek) { Chris@43: state->seek = 0; Chris@43: if (gz_zero(state, state->skip) == -1) Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* consume whatever's left in the input buffer */ Chris@43: if (strm->avail_in && gz_comp(state, Z_NO_FLUSH) == -1) Chris@43: return 0; Chris@43: Chris@43: /* do the printf() into the input buffer, put length in len */ Chris@43: size = (int)(state->size); Chris@43: state->in[size - 1] = 0; Chris@43: #ifdef NO_vsnprintf Chris@43: # ifdef HAS_vsprintf_void Chris@43: (void)vsprintf((char *)(state->in), format, va); Chris@43: for (len = 0; len < size; len++) Chris@43: if (state->in[len] == 0) break; Chris@43: # else Chris@43: len = vsprintf((char *)(state->in), format, va); Chris@43: # endif Chris@43: #else Chris@43: # ifdef HAS_vsnprintf_void Chris@43: (void)vsnprintf((char *)(state->in), size, format, va); Chris@43: len = strlen((char *)(state->in)); Chris@43: # else Chris@43: len = vsnprintf((char *)(state->in), size, format, va); Chris@43: # endif Chris@43: #endif Chris@43: Chris@43: /* check that printf() results fit in buffer */ Chris@43: if (len <= 0 || len >= (int)size || state->in[size - 1] != 0) Chris@43: return 0; Chris@43: Chris@43: /* update buffer and position, defer compression until needed */ Chris@43: strm->avail_in = (unsigned)len; Chris@43: strm->next_in = state->in; Chris@43: state->x.pos += len; Chris@43: return len; Chris@43: } Chris@43: Chris@43: int ZEXPORTVA gzprintf(gzFile file, const char *format, ...) Chris@43: { Chris@43: va_list va; Chris@43: int ret; Chris@43: Chris@43: va_start(va, format); Chris@43: ret = gzvprintf(file, format, va); Chris@43: va_end(va); Chris@43: return ret; Chris@43: } Chris@43: Chris@43: #else /* !STDC && !Z_HAVE_STDARG_H */ Chris@43: Chris@43: /* -- see zlib.h -- */ Chris@43: int ZEXPORTVA gzprintf (file, format, a1, a2, a3, a4, a5, a6, a7, a8, a9, a10, Chris@43: a11, a12, a13, a14, a15, a16, a17, a18, a19, a20) Chris@43: gzFile file; Chris@43: const char *format; Chris@43: int a1, a2, a3, a4, a5, a6, a7, a8, a9, a10, Chris@43: a11, a12, a13, a14, a15, a16, a17, a18, a19, a20; Chris@43: { Chris@43: int size, len; Chris@43: gz_statep state; Chris@43: z_streamp strm; Chris@43: Chris@43: /* get internal structure */ Chris@43: if (file == NULL) Chris@43: return -1; Chris@43: state = (gz_statep)file; Chris@43: strm = &(state->strm); Chris@43: Chris@43: /* check that can really pass pointer in ints */ Chris@43: if (sizeof(int) != sizeof(void *)) Chris@43: return 0; Chris@43: Chris@43: /* check that we're writing and that there's no error */ Chris@43: if (state->mode != GZ_WRITE || state->err != Z_OK) Chris@43: return 0; Chris@43: Chris@43: /* make sure we have some buffer space */ Chris@43: if (state->size == 0 && gz_init(state) == -1) Chris@43: return 0; Chris@43: Chris@43: /* check for seek request */ Chris@43: if (state->seek) { Chris@43: state->seek = 0; Chris@43: if (gz_zero(state, state->skip) == -1) Chris@43: return 0; Chris@43: } Chris@43: Chris@43: /* consume whatever's left in the input buffer */ Chris@43: if (strm->avail_in && gz_comp(state, Z_NO_FLUSH) == -1) Chris@43: return 0; Chris@43: Chris@43: /* do the printf() into the input buffer, put length in len */ Chris@43: size = (int)(state->size); Chris@43: state->in[size - 1] = 0; Chris@43: #ifdef NO_snprintf Chris@43: # ifdef HAS_sprintf_void Chris@43: sprintf((char *)(state->in), format, a1, a2, a3, a4, a5, a6, a7, a8, Chris@43: a9, a10, a11, a12, a13, a14, a15, a16, a17, a18, a19, a20); Chris@43: for (len = 0; len < size; len++) Chris@43: if (state->in[len] == 0) break; Chris@43: # else Chris@43: len = sprintf((char *)(state->in), format, a1, a2, a3, a4, a5, a6, a7, a8, Chris@43: a9, a10, a11, a12, a13, a14, a15, a16, a17, a18, a19, a20); Chris@43: # endif Chris@43: #else Chris@43: # ifdef HAS_snprintf_void Chris@43: snprintf((char *)(state->in), size, format, a1, a2, a3, a4, a5, a6, a7, a8, Chris@43: a9, a10, a11, a12, a13, a14, a15, a16, a17, a18, a19, a20); Chris@43: len = strlen((char *)(state->in)); Chris@43: # else Chris@43: len = snprintf((char *)(state->in), size, format, a1, a2, a3, a4, a5, a6, Chris@43: a7, a8, a9, a10, a11, a12, a13, a14, a15, a16, a17, a18, Chris@43: a19, a20); Chris@43: # endif Chris@43: #endif Chris@43: Chris@43: /* check that printf() results fit in buffer */ Chris@43: if (len <= 0 || len >= (int)size || state->in[size - 1] != 0) Chris@43: return 0; Chris@43: Chris@43: /* update buffer and position, defer compression until needed */ Chris@43: strm->avail_in = (unsigned)len; Chris@43: strm->next_in = state->in; Chris@43: state->x.pos += len; Chris@43: return len; Chris@43: } Chris@43: Chris@43: #endif Chris@43: Chris@43: /* -- see zlib.h -- */ Chris@43: int ZEXPORT gzflush(file, flush) Chris@43: gzFile file; Chris@43: int flush; Chris@43: { Chris@43: gz_statep state; Chris@43: Chris@43: /* get internal structure */ Chris@43: if (file == NULL) Chris@43: return -1; Chris@43: state = (gz_statep)file; Chris@43: Chris@43: /* check that we're writing and that there's no error */ Chris@43: if (state->mode != GZ_WRITE || state->err != Z_OK) Chris@43: return Z_STREAM_ERROR; Chris@43: Chris@43: /* check flush parameter */ Chris@43: if (flush < 0 || flush > Z_FINISH) Chris@43: return Z_STREAM_ERROR; Chris@43: Chris@43: /* check for seek request */ Chris@43: if (state->seek) { Chris@43: state->seek = 0; Chris@43: if (gz_zero(state, state->skip) == -1) Chris@43: return -1; Chris@43: } Chris@43: Chris@43: /* compress remaining data with requested flush */ Chris@43: gz_comp(state, flush); Chris@43: return state->err; Chris@43: } Chris@43: Chris@43: /* -- see zlib.h -- */ Chris@43: int ZEXPORT gzsetparams(file, level, strategy) Chris@43: gzFile file; Chris@43: int level; Chris@43: int strategy; Chris@43: { Chris@43: gz_statep state; Chris@43: z_streamp strm; Chris@43: Chris@43: /* get internal structure */ Chris@43: if (file == NULL) Chris@43: return Z_STREAM_ERROR; Chris@43: state = (gz_statep)file; Chris@43: strm = &(state->strm); Chris@43: Chris@43: /* check that we're writing and that there's no error */ Chris@43: if (state->mode != GZ_WRITE || state->err != Z_OK) Chris@43: return Z_STREAM_ERROR; Chris@43: Chris@43: /* if no change is requested, then do nothing */ Chris@43: if (level == state->level && strategy == state->strategy) Chris@43: return Z_OK; Chris@43: Chris@43: /* check for seek request */ Chris@43: if (state->seek) { Chris@43: state->seek = 0; Chris@43: if (gz_zero(state, state->skip) == -1) Chris@43: return -1; Chris@43: } Chris@43: Chris@43: /* change compression parameters for subsequent input */ Chris@43: if (state->size) { Chris@43: /* flush previous input with previous parameters before changing */ Chris@43: if (strm->avail_in && gz_comp(state, Z_PARTIAL_FLUSH) == -1) Chris@43: return state->err; Chris@43: deflateParams(strm, level, strategy); Chris@43: } Chris@43: state->level = level; Chris@43: state->strategy = strategy; Chris@43: return Z_OK; Chris@43: } Chris@43: Chris@43: /* -- see zlib.h -- */ Chris@43: int ZEXPORT gzclose_w(file) Chris@43: gzFile file; Chris@43: { Chris@43: int ret = Z_OK; Chris@43: gz_statep state; Chris@43: Chris@43: /* get internal structure */ Chris@43: if (file == NULL) Chris@43: return Z_STREAM_ERROR; Chris@43: state = (gz_statep)file; Chris@43: Chris@43: /* check that we're writing */ Chris@43: if (state->mode != GZ_WRITE) Chris@43: return Z_STREAM_ERROR; Chris@43: Chris@43: /* check for seek request */ Chris@43: if (state->seek) { Chris@43: state->seek = 0; Chris@43: if (gz_zero(state, state->skip) == -1) Chris@43: ret = state->err; Chris@43: } Chris@43: Chris@43: /* flush, free memory, and close file */ Chris@43: if (gz_comp(state, Z_FINISH) == -1) Chris@43: ret = state->err; Chris@43: if (state->size) { Chris@43: if (!state->direct) { Chris@43: (void)deflateEnd(&(state->strm)); Chris@43: free(state->out); Chris@43: } Chris@43: free(state->in); Chris@43: } Chris@43: gz_error(state, Z_OK, NULL); Chris@43: free(state->path); Chris@43: if (close(state->fd) == -1) Chris@43: ret = Z_ERRNO; Chris@43: free(state); Chris@43: return ret; Chris@43: }