aboutsummaryrefslogtreecommitdiffstats
path: root/commit.c
diff options
context:
space:
mode:
authorYunchih Chen <yunchih.cat@gmail.com>2018-03-02 18:08:47 +0800
committerYunchih Chen <yunchih.cat@gmail.com>2018-03-02 18:08:47 +0800
commit87e6bdc58160b85664c43ebc731a07ae8bceed79 (patch)
treefb571dde267521c9ea8aa18a6ffb84e7c4e3799a /commit.c
parentcb02fbda5ca090b6e69288967b831d9f8f3184ef (diff)
downloadnfcollect-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.c3
1 files changed, 1 insertions, 2 deletions
diff --git a/commit.c b/commit.c
index 076f100..a19aefe 100644
--- a/commit.c
+++ b/commit.c
@@ -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);
}
-