X-Git-Url: http://git.bytex64.net/?a=blobdiff_plain;f=database%2Fdatabase.c;h=a45c92bc3dbdaa7f1cb8f9fc902215aa26f5703a;hb=35b7988fc55d794a4d6fa466c61b21be176e64d0;hp=cb5cf0c58b43a7c5465fc2d2ad20017aef032f94;hpb=54789cc8538714fc3622646721f6f2ecceae94ac;p=blerg.git diff --git a/database/database.c b/database/database.c index cb5cf0c..a45c92b 100644 --- a/database/database.c +++ b/database/database.c @@ -13,6 +13,7 @@ #include #include #include "database.h" +#include "subscription.h" #include "util.h" #include "config.h" @@ -246,11 +247,12 @@ int blerg_store(struct blerg *blerg, const char *data, int len) { blerg->index[seg_rec].length = len; blerg->index[seg_rec].timestamp = time(NULL); - tag_scan(blerg->name, data, len, record); - flock(blerg->data_fd, LOCK_UN); flock(blerg->index_fd, LOCK_UN); + tag_scan(blerg->name, data, len, record); + subscription_notify(blerg->name, record); + return record; }