2 * Compress input and feed it to a block-oriented back end.
14 #define ALLOC_CHUNK 65536
16 int init_data(struct backend *be, const char *argv[])
18 be->now = posix_time();
21 memset(&be->zstream, 0, sizeof be->zstream);
23 be->zstream.next_out = NULL;
25 be->zstream.avail_out = be->alloc = 0;
26 be->dbytes = be->zbytes = 0;
28 /* Initialize a gzip data stream */
29 if (deflateInit2(&be->zstream, 9, Z_DEFLATED,
30 16+15, 9, Z_DEFAULT_STRATEGY) < 0)
36 static int do_deflate(struct backend *be, int flush)
42 rv = deflate(&be->zstream, flush);
43 be->zbytes = be->alloc - be->zstream.avail_out;
44 if (be->zstream.avail_out)
45 return rv; /* Not an issue of output space... */
47 buf = realloc(be->outbuf, be->alloc + ALLOC_CHUNK);
51 be->alloc += ALLOC_CHUNK;
52 be->zstream.next_out = (void *)(buf + be->zbytes);
53 be->zstream.avail_out = be->alloc - be->zbytes;
58 int write_data(struct backend *be, const void *buf, size_t len)
62 be->zstream.next_in = (void *)buf;
63 be->zstream.avail_in = len;
67 while (be->zstream.avail_in) {
68 rv = do_deflate(be, Z_NO_FLUSH);
70 printf("do_deflate returned %d\n", rv);
77 /* Output the data and shut down the stream */
78 int flush_data(struct backend *be)
82 while (rv != Z_STREAM_END) {
83 rv = do_deflate(be, Z_FINISH);
88 printf("Uploading data, %u bytes... ", be->zbytes);
95 be->dbytes = be->zbytes = be->alloc = 0;