libarchive/libarchive/archive_write_add_filter_bzip2.c

86 	struct private_data *data;
91 	data = calloc(1, sizeof(*data));
92 	if (data == NULL) {
96 	data->compression_level = 9; /* default */
98 	f->data = data;
108 	data->pdata = __archive_write_program_allocate();
109 	if (data->pdata == NULL) {
110 		free(data);
114 	data->compression_level = 0;
128 	struct private_data *data = (struct private_data *)f->data;
134 		data->compression_level = value[0] - '0';
138 		if (data->compression_level < 1)
139 			data->compression_level = 1;
167 	struct private_data *data = (struct private_data *)f->data;
174 	if (data->compressed == NULL) {
185 		data->compressed_buffer_size = bs;
186 		data->compressed
187 		    = (char *)malloc(data->compressed_buffer_size);
188 		if (data->compressed == NULL) {
190 			    "Can't allocate data for compression buffer");
195 	memset(&data->stream, 0, sizeof(data->stream));
196 	data->stream.next_out = data->compressed;
197 	data->stream.avail_out = data->compressed_buffer_size;
201 	ret = BZ2_bzCompressInit(&(data->stream),
202 	    data->compression_level, 0, 30);
204 		f->data = data;
236  * Write data to the compressed stream.
238  * Returns ARCHIVE_OK if all data written, error otherwise.
244 	struct private_data *data = (struct private_data *)f->data;
247 	data->total_in += length;
249 	/* Compress input data to output buffer */
250 	SET_NEXT_IN(data, buff);
251 	data->stream.avail_in = length;
252 	if (drive_compressor(f, data, 0))
264 	struct private_data *data = (struct private_data *)f->data;
268 	ret = drive_compressor(f, data, 1);
272 		    data->compressed,
273 		    data->compressed_buffer_size - data->stream.avail_out);
276 	switch (BZ2_bzCompressEnd(&(data->stream))) {
292 	struct private_data *data = (struct private_data *)f->data;
293 	free(data->compressed);
294 	free(data);
295 	f->data = NULL;
300  * Utility function to push input data through compressor, writing
308     struct private_data *data, int finishing)
313 		if (data->stream.avail_out == 0) {
315 			    data->compressed,
316 			    data->compressed_buffer_size);
321 			data->stream.next_out = data->compressed;
322 			data->stream.avail_out = data->compressed_buffer_size;
326 		if (!finishing && data->stream.avail_in == 0)
329 		ret = BZ2_bzCompress(&(data->stream),
336 			if (!finishing && data->stream.avail_in == 0)
361 	struct private_data *data = (struct private_data *)f->data;
369 	if (data->compression_level > 0) {
371 		archive_strappend_char(&as, '0' + data->compression_level);
375 	r = __archive_write_program_open(f, data->pdata, as.s);
384 	struct private_data *data = (struct private_data *)f->data;
386 	return __archive_write_program_write(f, data->pdata, buff, length);
392 	struct private_data *data = (struct private_data *)f->data;
394 	return __archive_write_program_close(f, data->pdata);
400 	struct private_data *data = (struct private_data *)f->data;
402 	__archive_write_program_free(data->pdata);
403 	free(data);