Attempting to fix sqlite3 processor commit delay
authorBrian Flowers <git-admn@bsflowers.net>
Tue, 20 Sep 2016 07:21:37 +0000 (03:21 -0400)
committerBrian Flowers <git-admn@bsflowers.net>
Tue, 20 Sep 2016 07:21:37 +0000 (03:21 -0400)
bdsm.d/sqlite3.processor
bdsm.sh

index 076b0f4..63b9af6 100644 (file)
@@ -54,7 +54,7 @@ start()
   
   cat /home/bdsm/in.fifo | awk -F'|' '{ \
     printf("INSERT INTO MEASUREMENTS(timestamp,host,attribute,value) \
-      VALUES (%s,\"%s\", \"%s\", \"%s\");\n",$1,$2, $3, $4) }' | \
+      VALUES (%s,\"%s\", \"%s\", \"%s\"); COMMIT;\n",$1,$2, $3, $4) }' | \
   sqlite3 bdsm.sqlite3 &
   echo $! > /home/bdsm/.processor.pid
 }
diff --git a/bdsm.sh b/bdsm.sh
index 3239aaa..85f4309 100755 (executable)
--- a/bdsm.sh
+++ b/bdsm.sh
@@ -43,6 +43,16 @@ failure()
   exit 255
 }
 
+
+# VARIABLES
+###############################################################################
+
+if [ -f "/home/bdsm/bdsm.d/$1.processor" ]; then
+  processor="${1}"
+else
+  processor=""
+fi
+
 # UTILITY FUNCTIONS
 ###############################################################################
 error()