| /systemd-251/src/import/ |
| D | export-raw.c | 40 ImportCompress compress; member
67 import_compress_free(&e->compress); in raw_export_unref()
142 if (!e->tried_reflink && e->compress.type == IMPORT_COMPRESS_UNCOMPRESSED) { in raw_export_process()
157 if (!e->tried_sendfile && e->compress.type == IMPORT_COMPRESS_UNCOMPRESSED) { in raw_export_process()
194 … r = import_compress_finish(&e->compress, &e->buffer, &e->buffer_size, &e->buffer_allocated); in raw_export_process()
197 … r = import_compress(&e->compress, input, l, &e->buffer, &e->buffer_size, &e->buffer_allocated); in raw_export_process()
276 int raw_export_start(RawExport *e, const char *path, int fd, ImportCompressType compress) { in raw_export_start() argument
283 assert(compress < _IMPORT_COMPRESS_TYPE_MAX); in raw_export_start()
284 assert(compress != IMPORT_COMPRESS_UNKNOWN); in raw_export_start()
314 r = import_compress_init(&e->compress, compress); in raw_export_start()
|
| D | export-tar.c | 30 ImportCompress compress; member
67 import_compress_free(&e->compress); in tar_export_unref()
166 if (!e->tried_splice && e->compress.type == IMPORT_COMPRESS_UNCOMPRESSED) { in tar_export_process()
203 … r = import_compress_finish(&e->compress, &e->buffer, &e->buffer_size, &e->buffer_allocated); in tar_export_process()
206 … r = import_compress(&e->compress, input, l, &e->buffer, &e->buffer_size, &e->buffer_allocated); in tar_export_process()
253 int tar_export_start(TarExport *e, const char *path, int fd, ImportCompressType compress) { in tar_export_start() argument
260 assert(compress < _IMPORT_COMPRESS_TYPE_MAX); in tar_export_start()
261 assert(compress != IMPORT_COMPRESS_UNKNOWN); in tar_export_start()
304 r = import_compress_init(&e->compress, compress); in tar_export_start()
|
| D | import-tar.c | 48 ImportCompress compress; member
77 import_compress_free(&i->compress); in tar_import_unref()
281 if (i->compress.type == IMPORT_COMPRESS_UNKNOWN) { in tar_import_process()
285 import_uncompress_force_off(&i->compress); in tar_import_process()
287 r = import_uncompress_detect(&i->compress, i->buffer, i->buffer_size); in tar_import_process()
301 r = import_uncompress(&i->compress, i->buffer, i->buffer_size, tar_import_write, i); in tar_import_process()
|
| D | import-raw.c | 47 ImportCompress compress; member
75 import_compress_free(&i->compress); in raw_import_unref()
322 if (i->compress.type != IMPORT_COMPRESS_UNCOMPRESSED) in raw_import_try_reflink()
415 if (i->compress.type == IMPORT_COMPRESS_UNKNOWN) { in raw_import_process()
419 import_uncompress_force_off(&i->compress); in raw_import_process()
421 r = import_uncompress_detect(&i->compress, i->buffer, i->buffer_size); in raw_import_process()
441 r = import_uncompress(&i->compress, i->buffer, i->buffer_size, raw_import_write, i); in raw_import_process()
|
| D | meson.build | 41 'import-compress.c',
42 'import-compress.h',
|
| D | pull-job.c | 42 import_compress_free(&j->compress); in pull_job_unref()
107 import_compress_free(&j->compress); in pull_job_restart()
394 r = import_uncompress(&j->compress, p, sz, pull_job_write_uncompressed, j); in pull_job_write_compressed()
454 r = import_uncompress_detect(&j->compress, j->payload, j->payload_size); in pull_job_detect_compression()
460 log_debug("Stream is compressed: %s", import_compress_type_to_string(j->compress.type)); in pull_job_detect_compression()
|
| D | export-raw.h | 18 int raw_export_start(RawExport *export, const char *path, int fd, ImportCompressType compress);
|
| D | export-tar.h | 18 int tar_export_start(TarExport *export, const char *path, int fd, ImportCompressType compress);
|
| D | pull-job.h | 70 ImportCompress compress; member
|
| /systemd-251/src/test/ |
| D | test-compress.c | 51 compress_blob_t compress, in test_compress_decompress() argument
65 r = compress(data, data_len, compressed, sizeof(compressed), &csize); in test_compress_decompress()
95 compress_blob_t compress, in test_decompress_startswith() argument
114 r = compress(data, data_len, compressed, BUFSIZE_1, &csize); in test_decompress_startswith()
121 r = compress(data, data_len, compressed, BUFSIZE_2, &csize); in test_decompress_startswith()
142 compress_blob_t compress, in test_decompress_startswith_short() argument
153 r = compress(TEXT, sizeof TEXT, buf, sizeof buf, &csize); in test_decompress_startswith_short()
169 compress_stream_t compress, in test_compress_stream() argument
198 assert_se(compress(src, dst, -1, &uncompressed_size) == flag); in test_compress_stream()
|
| D | test-compress-benchmark.c | 77 compress_t compress, decompress_t decompress) { in test_compress_decompress() argument
103 r = compress(text, size, buf, size, &j); in test_compress_decompress()
|
| D | meson.build | 175 [files('test-compress.c'),
179 [files('test-compress-benchmark.c'),
|
| /systemd-251/src/journal/ |
| D | journald-server.c | 276 file_flags = (s->compress.enabled ? JOURNAL_COMPRESS : 0) | (seal ? JOURNAL_SEAL : 0); in open_journal()
284 s->compress.threshold_bytes, in open_journal()
297 s->compress.threshold_bytes, in open_journal()
489 (s->compress.enabled ? JOURNAL_COMPRESS : 0)| in do_rotate()
492 …r = managed_journal_file_rotate(f, s->mmap, file_flags, s->compress.threshold_bytes, s->deferred_c… in do_rotate()
607 (s->compress.enabled ? JOURNAL_COMPRESS : 0) | in vacuum_offline_user_journals()
610 s->compress.threshold_bytes, in vacuum_offline_user_journals()
2292 .compress.enabled = true, in server_init()
2293 .compress.threshold_bytes = UINT64_MAX, in server_init()
2701 JournalCompressOptions* compress = data; in config_parse_compress() local
[all …]
|
| D | journald-gperf.gperf | 23 Journal.Compress, config_parse_compress, 0, offsetof(Server, compress)
|
| D | journald-server.h | 108 JournalCompressOptions compress; member
|
| /systemd-251/src/fuzz/ |
| D | meson.build | 12 [files('fuzz-compress.c')],
|
| /systemd-251/src/basic/ |
| D | meson.build | 453 'compress.c',
454 'compress.h')
459 'basic-compress',
|