diff options
author | Yunchih Chen <yunchih.cat@gmail.com> | 2018-03-02 18:08:47 +0800 |
---|---|---|
committer | Yunchih Chen <yunchih.cat@gmail.com> | 2018-03-02 18:08:47 +0800 |
commit | 87e6bdc58160b85664c43ebc731a07ae8bceed79 (patch) | |
tree | fb571dde267521c9ea8aa18a6ffb84e7c4e3799a /commit.c | |
parent | cb02fbda5ca090b6e69288967b831d9f8f3184ef (diff) | |
download | nfcollect-87e6bdc58160b85664c43ebc731a07ae8bceed79.tar nfcollect-87e6bdc58160b85664c43ebc731a07ae8bceed79.tar.gz nfcollect-87e6bdc58160b85664c43ebc731a07ae8bceed79.tar.bz2 nfcollect-87e6bdc58160b85664c43ebc731a07ae8bceed79.tar.lz nfcollect-87e6bdc58160b85664c43ebc731a07ae8bceed79.tar.xz nfcollect-87e6bdc58160b85664c43ebc731a07ae8bceed79.tar.zst nfcollect-87e6bdc58160b85664c43ebc731a07ae8bceed79.zip |
Implement receive thread synchronization
Diffstat (limited to 'commit.c')
-rw-r--r-- | commit.c | 3 |
1 files changed, 1 insertions, 2 deletions
@@ -12,7 +12,7 @@ void nfl_commit_worker(nflog_header_t* header, nflog_entry_t* store, const char* debug("Comm worker #%u: commit to file %s\n", header->id, filename); ERR((f = fopen(filename, "wb")) == NULL, strerror(errno)); - + // commit header written = fwrite(header, 1, sizeof(nflog_header_t), f); ERR(written != sizeof(nflog_header_t), strerror(errno)); @@ -25,4 +25,3 @@ void nfl_commit_worker(nflog_header_t* header, nflog_entry_t* store, const char* // Do fsync ? fclose(f); } - |