Searched refs:compress (Results 1 - 18 of 18) sorted by relevance

/systemd/src/import/
H A Dexport-raw.h24 #include "import-compress.h"
36 int raw_export_start(RawExport *export, const char *path, int fd, ImportCompressType compress);
H A Dexport-tar.h24 #include "import-compress.h"
36 int tar_export_start(TarExport *export, const char *path, int fd, ImportCompressType compress);
H A Dexport-raw.c54 ImportCompress compress; member in struct:RawExport
81 import_compress_free(&e->compress);
157 if (!e->tried_reflink && e->compress.type == IMPORT_COMPRESS_UNCOMPRESSED) {
172 if (!e->tried_sendfile && e->compress.type == IMPORT_COMPRESS_UNCOMPRESSED) {
209 r = import_compress_finish(&e->compress, &e->buffer, &e->buffer_size, &e->buffer_allocated);
212 r = import_compress(&e->compress, input, l, &e->buffer, &e->buffer_size, &e->buffer_allocated);
295 int raw_export_start(RawExport *e, const char *path, int fd, ImportCompressType compress) { argument
302 assert(compress < _IMPORT_COMPRESS_TYPE_MAX);
303 assert(compress != IMPORT_COMPRESS_UNKNOWN);
335 r = import_compress_init(&e->compress, compres
[all...]
H A Dexport-tar.c47 ImportCompress compress; member in struct:TarExport
86 import_compress_free(&e->compress);
167 if (!e->tried_splice && e->compress.type == IMPORT_COMPRESS_UNCOMPRESSED) {
204 r = import_compress_finish(&e->compress, &e->buffer, &e->buffer_size, &e->buffer_allocated);
207 r = import_compress(&e->compress, input, l, &e->buffer, &e->buffer_size, &e->buffer_allocated);
254 int tar_export_start(TarExport *e, const char *path, int fd, ImportCompressType compress) { argument
261 assert(compress < _IMPORT_COMPRESS_TYPE_MAX);
262 assert(compress != IMPORT_COMPRESS_UNKNOWN);
305 r = import_compress_init(&e->compress, compress);
[all...]
H A Dimport-tar.c33 #include "import-compress.h"
65 ImportCompress compress; member in struct:TarImport
101 import_compress_free(&i->compress);
288 if (i->compress.type == IMPORT_COMPRESS_UNKNOWN) {
300 if (i->compress.type == IMPORT_COMPRESS_UNKNOWN) {
301 r = import_uncompress_detect(&i->compress, i->buffer, i->buffer_size);
314 r = import_uncompress(&i->compress, i->buffer, i->buffer_size, tar_import_write, i);
H A Dpull-job.h25 #include "import-compress.h"
91 ImportCompress compress; member in struct:PullJob
H A Dimport-raw.c34 #include "import-compress.h"
65 ImportCompress compress; member in struct:RawImport
94 import_compress_free(&i->compress);
301 if (i->compress.type != IMPORT_COMPRESS_UNCOMPRESSED)
359 if (i->compress.type == IMPORT_COMPRESS_UNKNOWN) {
371 if (i->compress.type == IMPORT_COMPRESS_UNKNOWN) {
372 r = import_uncompress_detect(&i->compress, i->buffer, i->buffer_size);
393 r = import_uncompress(&i->compress, i->buffer, i->buffer_size, raw_import_write, i);
H A Dpull-job.c42 import_compress_free(&j->compress);
259 r = import_uncompress(&j->compress, p, sz, pull_job_write_uncompressed, j);
310 r = import_uncompress_detect(&j->compress, j->payload, j->payload_size);
316 log_debug("Stream is compressed: %s", import_compress_type_to_string(j->compress.type));
/systemd/src/journal-remote/
H A Djournal-remote-write.c56 static int do_rotate(JournalFile **f, bool compress, bool seal) { argument
57 int r = journal_file_rotate(f, compress, seal);
128 bool compress,
139 r = do_rotate(&w->journal, compress, seal);
153 r = do_rotate(&w->journal, compress, seal);
125 writer_write(Writer *w, struct iovec_wrapper *iovw, dual_timestamp *ts, bool compress, bool seal) argument
H A Djournal-remote-parse.h69 int process_source(RemoteSource *source, bool compress, bool seal);
H A Djournal-remote-write.h63 bool compress,
H A Djournal-remote-parse.c442 int process_source(RemoteSource *source, bool compress, bool seal) { argument
465 r = writer_write(source->writer, &source->iovw, &source->ts, compress, seal);
/systemd/src/journal/
H A Dtest-compress.c25 #include "compress.h"
58 compress_blob_t compress,
71 r = compress(data, data_len, compressed, sizeof(compressed), &csize);
101 compress_blob_t compress,
120 r = compress(data, data_len, compressed, BUFSIZE_1, &csize);
127 r = compress(data, data_len, compressed, BUFSIZE_2, &csize);
150 compress_stream_t compress,
172 assert_se(compress(src, dst, -1) == 0);
57 test_compress_decompress(int compression, compress_blob_t compress, decompress_blob_t decompress, const char *data, size_t data_len, bool may_fail) argument
100 test_decompress_startswith(int compression, compress_blob_t compress, decompress_sw_t decompress_sw, const char *data, size_t data_len, bool may_fail) argument
148 test_compress_stream(int compression, const char* cat, compress_stream_t compress, decompress_stream_t decompress, const char *srcfile) argument
H A Dtest-compress-benchmark.c21 #include "compress.h"
88 compress_t compress, decompress_t decompress) {
113 r = compress(text, size, buf, size, &j);
87 test_compress_decompress(const char* label, const char* type, compress_t compress, decompress_t decompress) argument
H A Djournal-file.h135 bool compress,
149 bool compress,
226 int journal_file_rotate(JournalFile **f, bool compress, bool seal);
H A Djournald-server.h95 bool compress; member in struct:Server
H A Djournald-server.c254 r = journal_file_open_reliably(fname, flags, 0640, s->compress, seal, metrics, s->mmap, NULL, &f);
256 r = journal_file_open(fname, flags, 0640, s->compress, seal, metrics, s->mmap, NULL, &f);
336 r = journal_file_rotate(f, s->compress, seal);
1725 s->compress = true;
H A Djournal-file.c32 #include "compress.h"
2709 bool compress,
2743 f->compress_lz4 = compress;
2745 f->compress_xz = compress;
2906 int journal_file_rotate(JournalFile **f, bool compress, bool seal) { argument
2946 r = journal_file_open(old_file->path, old_file->flags, old_file->mode, compress, seal, NULL, old_file->mmap, old_file, &new_file);
2957 bool compress,
2968 r = journal_file_open(fname, flags, mode, compress, seal, metrics, mmap_cache, template, ret);
3009 return journal_file_open(fname, flags, mode, compress, seal, metrics, mmap_cache, template, ret);
2705 journal_file_open( const char *fname, int flags, mode_t mode, bool compress, bool seal, JournalMetrics *metrics, MMapCache *mmap_cache, JournalFile *template, JournalFile **ret) argument
2953 journal_file_open_reliably( const char *fname, int flags, mode_t mode, bool compress, bool seal, JournalMetrics *metrics, MMapCache *mmap_cache, JournalFile *template, JournalFile **ret) argument

Completed in 3355 milliseconds