diff options
Diffstat (limited to 'lib/commit.c')
-rw-r--r-- | lib/commit.c | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/lib/commit.c b/lib/commit.c index 12cc027..202a138 100644 --- a/lib/commit.c +++ b/lib/commit.c @@ -1,36 +1,35 @@ +#include "commit.h" #include <errno.h> #include <string.h> #include <zstd.h> -#include "commit.h" -static void nfl_commit_default(FILE* f, nflog_entry_t* store, uint32_t store_size); -static void nfl_commit_lz4(FILE* f, nflog_entry_t* store, uint32_t store_size); -static void nfl_commit_zstd(FILE* f, nflog_entry_t* store, uint32_t store_size); +static void nfl_commit_default(FILE *f, nflog_entry_t *store, + uint32_t store_size); +static void nfl_commit_lz4(FILE *f, nflog_entry_t *store, uint32_t store_size); +static void nfl_commit_zstd(FILE *f, nflog_entry_t *store, uint32_t store_size); -typedef void (*nflog_commit_run_table_t)(FILE* f, nflog_entry_t* store, uint32_t size); +typedef void (*nflog_commit_run_table_t)(FILE *f, nflog_entry_t *store, + uint32_t size); static const nflog_commit_run_table_t commit_run_table[] = { - nfl_commit_default, - nfl_commit_lz4, - nfl_commit_zstd -}; + nfl_commit_default, nfl_commit_lz4, nfl_commit_zstd}; -void nfl_commit_init() { - /* TODO */ -} +void nfl_commit_init() { /* TODO */ } -static void nfl_commit_default(FILE* f, nflog_entry_t* store, uint32_t store_size) { +static void nfl_commit_default(FILE *f, nflog_entry_t *store, + uint32_t store_size) { uint32_t written; written = fwrite(store, 1, store_size, f); ERR(written != store_size, strerror(errno)); } -static void nfl_commit_lz4(FILE* f, nflog_entry_t* store, uint32_t store_size) { +static void nfl_commit_lz4(FILE *f, nflog_entry_t *store, uint32_t store_size) { /* TODO */ } -static void nfl_commit_zstd(FILE* f, nflog_entry_t* store, uint32_t store_size) { +static void nfl_commit_zstd(FILE *f, nflog_entry_t *store, + uint32_t store_size) { size_t const bufsize = ZSTD_compressBound(store_size); - void* buf; + void *buf; ERR((buf = malloc(bufsize)), NULL); @@ -44,8 +43,9 @@ static void nfl_commit_zstd(FILE* f, nflog_entry_t* store, uint32_t store_size) free(buf); } -void nfl_commit_worker(nflog_header_t* header, nflog_entry_t* store, const char* filename) { - FILE* f; +void nfl_commit_worker(nflog_header_t *header, nflog_entry_t *store, + const char *filename) { + FILE *f; uint32_t written; debug("Comm worker #%u: commit to file %s\n", header->id, filename); |