Searched refs:buffer_size (Results 1 - 15 of 15) sorted by relevance

/systemd/src/journal/
H A Djournald-audit.h25 void server_process_audit_message(Server *s, const void *buffer, size_t buffer_size, const struct ucred *ucred, const union sockaddr_union *sa, socklen_t salen);
H A Djournald-native.h31 void server_process_native_message(Server *s, const void *buffer, size_t buffer_size, const struct ucred *ucred, const struct timeval *tv, const char *label, size_t label_len);
H A Dcompress.h58 void **buffer, size_t *buffer_size,
62 void **buffer, size_t *buffer_size,
67 void **buffer, size_t *buffer_size,
H A Dcompress.c243 void **buffer, size_t *buffer_size,
258 assert(buffer_size);
260 assert(*buffer_size == 0 || *buffer);
266 if (!(greedy_realloc(buffer, buffer_size, ALIGN_8(prefix_len + 1), 1)))
273 s.avail_out = *buffer_size;
281 if (*buffer_size - s.avail_out >= prefix_len + 1)
288 s.avail_out += *buffer_size;
290 if (!(greedy_realloc(buffer, buffer_size, *buffer_size * 2, 1)))
293 s.next_out = *buffer + *buffer_size
242 decompress_startswith_xz(const void *src, uint64_t src_size, void **buffer, size_t *buffer_size, const void *prefix, size_t prefix_len, uint8_t extra) argument
301 decompress_startswith_lz4(const void *src, uint64_t src_size, void **buffer, size_t *buffer_size, const void *prefix, size_t prefix_len, uint8_t extra) argument
350 decompress_startswith(int compression, const void *src, uint64_t src_size, void **buffer, size_t *buffer_size, const void *prefix, size_t prefix_len, uint8_t extra) argument
[all...]
H A Djournald-native.c84 const void *buffer, size_t buffer_size,
98 assert(buffer || buffer_size == 0);
101 remaining = buffer_size;
301 (const uint8_t*) iovec[j].iov_base >= (const uint8_t*) buffer + buffer_size)
82 server_process_native_message( Server *s, const void *buffer, size_t buffer_size, const struct ucred *ucred, const struct timeval *tv, const char *label, size_t label_len) argument
H A Djournald-audit.c429 size_t buffer_size,
438 if (buffer_size < ALIGN(sizeof(struct nlmsghdr)))
457 if (!NLMSG_OK(nl, buffer_size)) {
426 server_process_audit_message( Server *s, const void *buffer, size_t buffer_size, const struct ucred *ucred, const union sockaddr_union *sa, socklen_t salen) argument
H A Djournald-server.h85 size_t buffer_size; member in struct:Server
H A Dtest-compress.c50 void **buffer, size_t *buffer_size,
H A Djournald-server.c1209 if (!GREEDY_REALLOC(s->buffer, s->buffer_size, m))
1213 iovec.iov_len = s->buffer_size - 1; /* Leave room for trailing NUL we add later */
/systemd/src/import/
H A Dimport-compress.c243 static int enlarge_buffer(void **buffer, size_t *buffer_size, size_t *buffer_allocated) { argument
247 if (*buffer_allocated > *buffer_size)
250 l = MAX(16*1024U, (*buffer_size * 2));
261 int import_compress(ImportCompress *c, const void *data, size_t size, void **buffer, size_t *buffer_size, size_t *buffer_allocated) { argument
266 assert(buffer_size);
277 *buffer_size = 0;
289 r = enlarge_buffer(buffer, buffer_size, buffer_allocated);
293 c->xz.next_out = (uint8_t*) *buffer + *buffer_size;
294 c->xz.avail_out = *buffer_allocated - *buffer_size;
300 *buffer_size
373 import_compress_finish(ImportCompress *c, void **buffer, size_t *buffer_size, size_t *buffer_allocated) argument
[all...]
H A Dexport-raw.c59 size_t buffer_size; member in struct:RawExport
193 while (e->buffer_size <= 0) {
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);
220 l = write(e->output_fd, e->buffer, e->buffer_size);
229 assert((size_t) l <= e->buffer_size);
230 memmove(e->buffer, (uint8_t*) e->buffer + l, e->buffer_size - l);
231 e->buffer_size -= l;
H A Dexport-tar.c52 size_t buffer_size; member in struct:TarExport
188 while (e->buffer_size <= 0) {
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);
215 l = write(e->output_fd, e->buffer, e->buffer_size);
224 assert((size_t) l <= e->buffer_size);
225 memmove(e->buffer, (uint8_t*) e->buffer + l, e->buffer_size - l);
226 e->buffer_size -= l;
H A Dimport-compress.h57 int import_compress(ImportCompress *c, const void *data, size_t size, void **buffer, size_t *buffer_size, size_t *buffer_allocated);
58 int import_compress_finish(ImportCompress *c, void **buffer, size_t *buffer_size, size_t *buffer_allocated);
H A Dimport-tar.c72 size_t buffer_size; member in struct:TarImport
277 assert(i->buffer_size < sizeof(i->buffer));
279 l = read(i->input_fd, i->buffer + i->buffer_size, sizeof(i->buffer) - i->buffer_size);
298 i->buffer_size += l;
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);
320 i->written_compressed += i->buffer_size;
321 i->buffer_size = 0;
H A Dimport-raw.c72 size_t buffer_size; member in struct:RawImport
312 if ((uint64_t) p != (uint64_t) i->buffer_size)
348 assert(i->buffer_size < sizeof(i->buffer));
350 l = read(i->input_fd, i->buffer + i->buffer_size, sizeof(i->buffer) - i->buffer_size);
369 i->buffer_size += l;
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);
399 i->written_compressed += i->buffer_size;
400 i->buffer_size
[all...]

Completed in 822 milliseconds