X-Git-Url: http://git.bytex64.net/?a=blobdiff_plain;f=database%2Fdatabase.c;h=a45c92bc3dbdaa7f1cb8f9fc902215aa26f5703a;hb=ec8746b44dc85fd3e3b42835f779890684a9e90a;hp=cb5cf0c58b43a7c5465fc2d2ad20017aef032f94;hpb=dead5bdc521b34c85256737b616f4072a78dc2fb;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 <sys/file.h>
 #include <fcntl.h>
 #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;
 }