daemon storage

.gitignore

@@ -58,3 +58,5 @@ dockerbuild/
 
 # CMake
 compile_commands.json
+
+.build/*

CMakeLists.txt

@@ -29,13 +29,14 @@ set(SENSOR_SOURCES
     src/perf.h src/perf.c
     src/storage.h src/storage.c
     src/storage_socket.h src/storage_socket.c
+    src/storage_daemon.h src/storage_daemon.c
     src/storage_csv.h src/storage_csv.c
     src/sensor.c
 )
 
 set(SENSOR_INCLUDES "${CZMQ_STATIC_INCLUDE_DIRS}")
 set(SENSOR_DEFINITIONS "${CZMQ_STATIC_DEFINITIONS}")
-set(SENSOR_LIBRARIES "${CZMQ_STATIC_LIBRARIES}" pfm)
+set(SENSOR_LIBRARIES "${CZMQ_STATIC_LIBRARIES}" pfm pthread)
 
 if(WITH_MONGODB)
     pkg_check_modules(BSON REQUIRED libbson-1.0)

src/config.c

@@ -237,6 +237,11 @@ config_validate(struct config *config)
 	return -1;
     }
 
+    if (storage-> type == STORAGE_DAEMON && (!storage-> P_flag)) {
+	zsys_error ("config: the daemon storage module requires the 'P' flag to be set");
+	return -1;
+    }
+
 #ifdef HAVE_MONGODB
     if (storage->type == STORAGE_MONGODB && (!storage->U_flag || !storage->D_flag || !storage->C_flag)) {
 	zsys_error("config: the MongoDB storage module requires the 'U', 'D' and 'C' flags to be set");

src/sensor.c

@@ -48,6 +48,7 @@
 #include "storage.h"
 #include "storage_csv.h"
 #include "storage_socket.h"
+#include "storage_daemon.h"
 
 #ifdef HAVE_MONGODB
 #include "storage_mongodb.h"
@@ -68,9 +69,11 @@ setup_storage_module(struct config *config)
     switch (config->storage.type)
     {
         case STORAGE_CSV:
-            return storage_csv_create(config);
+	    return storage_csv_create(config);
         case STORAGE_SOCKET:
-            return storage_socket_create(config);
+	    return storage_socket_create(config);
+        case STORAGE_DAEMON:
+	    return storage_daemon_create(config);
 #ifdef HAVE_MONGODB
         case STORAGE_MONGODB:
             return storage_mongodb_create(config);

src/storage.c

@@ -38,6 +38,7 @@ const char *storage_types_name[] = {
     [STORAGE_UNKNOWN] = "unknown",
     [STORAGE_CSV] = "csv",
     [STORAGE_SOCKET] = "socket",
+    [STORAGE_DAEMON] = "daemon",
 #ifdef HAVE_MONGODB
     [STORAGE_MONGODB] = "mongodb",
 #endif
@@ -54,6 +55,10 @@ storage_module_get_type(const char *type_name)
         return STORAGE_SOCKET;
     }
 
+    if (strcasecmp(type_name, storage_types_name[STORAGE_DAEMON]) == 0) {
+	return STORAGE_DAEMON;
+    }
+
 #ifdef HAVE_MONGODB
     if (strcasecmp(type_name, storage_types_name[STORAGE_MONGODB]) == 0) {
         return STORAGE_MONGODB;

src/storage.h

@@ -43,6 +43,7 @@ enum storage_type
     STORAGE_UNKNOWN,
     STORAGE_CSV,
     STORAGE_SOCKET,
+    STORAGE_DAEMON,
 #ifdef HAVE_MONGODB
     STORAGE_MONGODB,
 #endif