libarchive/libarchive/archive_write_add_filter_zstd.c

93 	struct private_data *data;
97 	data = calloc(1, sizeof(*data));
98 	if (data == NULL) {
102 	f->data = data;
109 	data->compression_level = CLEVEL_DEFAULT;
111 	data->cstream = ZSTD_createCStream();
112 	if (data->cstream == NULL) {
113 		free(data);
121 	data->pdata = __archive_write_program_allocate("zstd");
122 	if (data->pdata == NULL) {
123 		free(data);
136 	struct private_data *data = (struct private_data *)f->data;
138 	ZSTD_freeCStream(data->cstream);
139 	free(data->out.dst);
141 	__archive_write_program_free(data->pdata);
143 	free(data);
144 	f->data = NULL;
180 	struct private_data *data = (struct private_data *)f->data;
205 		data->compression_level = level;
222 	struct private_data *data = (struct private_data *)f->data;
224 	if (data->out.dst == NULL) {
235 		data->out.size = bs;
236 		data->out.pos = 0;
237 		data->out.dst
238 		    = (unsigned char *)malloc(data->out.size);
239 		if (data->out.dst == NULL) {
241 			    "Can't allocate data for compression buffer");
248 	if (ZSTD_isError(ZSTD_initCStream(data->cstream,
249 	    data->compression_level))) {
259  * Write data to the compressed stream.
265 	struct private_data *data = (struct private_data *)f->data;
269 	data->total_in += length;
271 	if ((ret = drive_compressor(f, data, 0, buff, length)) != ARCHIVE_OK)
283 	struct private_data *data = (struct private_data *)f->data;
286 	return drive_compressor(f, data, 1, NULL, 0);
290  * Utility function to push input data through compressor,
298     struct private_data *data, int finishing, const void *src, size_t length)
303 		if (data->out.pos == data->out.size) {
305 			    data->out.dst, data->out.size);
308 			data->out.pos = 0;
317 			    ZSTD_compressStream(data->cstream, &data->out, &in)
318 			    : ZSTD_endStream(data->cstream, &data->out);
331 				    data->out.dst, data->out.pos);
343 	struct private_data *data = (struct private_data *)f->data;
351 	if (data->compression_level < CLEVEL_STD_MIN) {
354 		archive_string_sprintf(&as2, " --fast=%d", -data->compression_level);
360 		archive_string_sprintf(&as2, " -%d", data->compression_level);
365 	if (data->compression_level > CLEVEL_STD_MAX) {
370 	r = __archive_write_program_open(f, data->pdata, as.s);
379 	struct private_data *data = (struct private_data *)f->data;
381 	return __archive_write_program_write(f, data->pdata, buff, length);
387 	struct private_data *data = (struct private_data *)f->data;
389 	return __archive_write_program_close(f, data->pdata);