Sensor gaussian model skeleton

6 files changed, 172 insertions, 10 deletions

diff --git a/src/sensor/Makefile.am b/src/sensor/Makefile.am
index ca6760c29..a1c8881fa 100644
--- a/src/sensor/Makefile.am
+++ b/src/sensor/Makefile.am
@@ -4,6 +4,8 @@ pkgcfgdir= $(pkgdatadir)/config.d/
 
 libexecdir= $(pkglibdir)/libexec/
 
+plugindir = $(libdir)/gnunet
+
 dist_pkgcfg_DATA = \
   sensor.conf
 
@@ -47,6 +49,21 @@ libgnunetsensor_la_LIBADD = \
 libgnunetsensor_la_LDFLAGS = \
   $(GNUNET_LDFLAGS)
 
+plugin_LTLIBRARIES = \
+  libgnunet_plugin_sensor_model_gaussian.la
+  
+libgnunet_plugin_sensor_model_gaussian_la_SOURCES = \
+  plugin_sensor_model_gaussian.c
+libgnunet_plugin_sensor_model_gaussian_la_LIBADD = \
+  $(top_builddir)/src/sensor/libgnunetsensor.la  \
+  $(top_builddir)/src/util/libgnunetutil.la $(XLIBS) \
+  $(LTLIBINTL)
+libgnunet_plugin_sensor_model_gaussian_la_LDFLAGS = \
+ $(GN_PLUGIN_LDFLAGS)
+libgnunet_plugin_sensor_model_gaussian_la_DEPENDENCIES = \
+  $(top_builddir)/src/util/libgnunetutil.la \
+  libgnunetsensor.la
+
 check_PROGRAMS = \
  test_sensor_api
 
diff --git a/src/sensor/gnunet-service-sensor-analysis.c b/src/sensor/gnunet-service-sensor-analysis.c
index 8ab486094..5a613559b 100644
--- a/src/sensor/gnunet-service-sensor-analysis.c
+++ b/src/sensor/gnunet-service-sensor-analysis.c
@@ -84,28 +84,58 @@ static const char *analysis_datatypes[] = { "uint64", "double", NULL };
  */
 static struct GNUNET_CONTAINER_MultiHashMap *sensor_models;
 
+/**
+ * My peer id
+ */
+struct GNUNET_PeerIdentity peerid;
+
 /*
  * TODO: document
  */
+static int
+destroy_sensor_model (void *cls,
+    const struct GNUNET_HashCode *key,
+    void *value)
+{
+  struct SensorModel *sensor_model = value;
+
+  if (NULL == sensor_model)
+    return GNUNET_YES;
+  LOG (GNUNET_ERROR_TYPE_DEBUG,
+        "Destroying sensor model for `%s'.\n",
+        sensor_model->sensor->name);
+  if (NULL != sensor_model->wc)
+  {
+    GNUNET_PEERSTORE_watch_cancel(sensor_model->wc);
+    sensor_model->wc = NULL;
+  }
+  return GNUNET_YES;
+}
+
+/*
+ * Stop the sensor analysis module
+ */
 void SENSOR_analysis_stop()
 {
+
+  LOG (GNUNET_ERROR_TYPE_DEBUG, "Stopping sensor analysis module.\n");
   if (NULL != model)
   {
     GNUNET_break (NULL == GNUNET_PLUGIN_unload (model_lib_name, model));
     GNUNET_free (model_lib_name);
     model_lib_name = NULL;
   }
-  if (NULL != peerstore)
-  {
-    GNUNET_PEERSTORE_disconnect(peerstore);
-    peerstore = NULL;
-  }
   if (NULL != sensor_models)
   {
-    /* TODO: iterate over sensor models and destroy */
+    GNUNET_CONTAINER_multihashmap_iterate(sensor_models, &destroy_sensor_model, NULL);
     GNUNET_CONTAINER_multihashmap_destroy(sensor_models);
     sensor_models = NULL;
   }
+  if (NULL != peerstore)
+  {
+    GNUNET_PEERSTORE_disconnect(peerstore);
+    peerstore = NULL;
+  }
 }
 
 /*
@@ -137,7 +167,7 @@ init_sensor_model (void *cls,
   is_numeric = GNUNET_NO;
   for (i = 0; NULL != analysis_datatypes[i]; i++)
   {
-    if (0 == strcasecmp (analysis_datatypes[i], sensor->expected_datatype))
+    if (0 == strcmp (analysis_datatypes[i], sensor->expected_datatype))
     {
       is_numeric = GNUNET_YES;
       break;
@@ -146,17 +176,22 @@ init_sensor_model (void *cls,
   if (GNUNET_NO == is_numeric)
     return GNUNET_YES;
   sensor_model = GNUNET_new(struct SensorModel);
+  sensor_model->sensor = sensor;
   sensor_model->wc = GNUNET_PEERSTORE_watch(peerstore,
-          "sensor", NULL, sensor->name,
+          "sensor", &peerid, sensor->name,
           &sensor_watcher, sensor_model);
   GNUNET_CONTAINER_multihashmap_put(sensor_models, key,
       sensor_model, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY);
+  LOG (GNUNET_ERROR_TYPE_DEBUG,
+      "Created sensor model for `%s'.\n", sensor->name);
   return GNUNET_YES;
 }
 
 /*
- * TODO: document
+ * Start the sensor analysis module
  *
+ * @param c our service configuration
+ * @param sensors_mhm multihashmap of loaded sensors
  * @return #GNUNET_OK if started successfully, #GNUNET_SYSERR otherwise
  */
 int
@@ -195,6 +230,7 @@ SENSOR_analysis_start(const struct GNUNET_CONFIGURATION_Handle *c,
     SENSOR_analysis_stop();
     return GNUNET_SYSERR;
   }
+  GNUNET_CRYPTO_get_peer_identity(cfg, &peerid);
   sensor_models = GNUNET_CONTAINER_multihashmap_create(10, GNUNET_NO);
   GNUNET_CONTAINER_multihashmap_iterate(sensors, &init_sensor_model, NULL);
 
diff --git a/src/sensor/gnunet-service-sensor.c b/src/sensor/gnunet-service-sensor.c
index 96856c3bf..681f132b6 100644
--- a/src/sensor/gnunet-service-sensor.c
+++ b/src/sensor/gnunet-service-sensor.c
@@ -159,6 +159,7 @@ static void
 shutdown_task (void *cls,
                const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
+  SENSOR_analysis_stop();
   GNUNET_CONTAINER_multihashmap_iterate(sensors, &destroy_sensor, NULL);
   GNUNET_CONTAINER_multihashmap_destroy(sensors);
   if(NULL != statistics)
@@ -1000,6 +1001,7 @@ run (void *cls,
   sensors = GNUNET_CONTAINER_multihashmap_create(10, GNUNET_NO);
   reload_sensors();
   schedule_all_sensors();
+  SENSOR_analysis_start(c, sensors);
   statistics = GNUNET_STATISTICS_create("sensor", cfg);
   GNUNET_CRYPTO_get_peer_identity(cfg, &peerid);
   peerstore = GNUNET_PEERSTORE_connect(cfg);
diff --git a/src/sensor/plugin_sensor_model_gaussian.c b/src/sensor/plugin_sensor_model_gaussian.c
new file mode 100644
index 000000000..ee316035e
--- /dev/null
+++ b/src/sensor/plugin_sensor_model_gaussian.c
@@ -0,0 +1,89 @@
+/*
+ * This file is part of GNUnet
+ * (C) 2013 Christian Grothoff (and other contributing authors)
+ *
+ * GNUnet is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published
+ * by the Free Software Foundation; either version 3, or (at your
+ * option) any later version.
+ *
+ * GNUnet is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with GNUnet; see the file COPYING.  If not, write to the
+ * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ * Boston, MA 02111-1307, USA.
+ */
+
+/*
+ * @file sensor/plugin_sensor_model_gaussian.c
+ * @brief Gaussian model for sensor analysis
+ * @author Omar Tarabai
+ */
+
+#include "platform.h"
+#include "gnunet_sensor_model_plugin.h"
+#include "gnunet_sensor_service.h"
+#include "sensor.h"
+
+#define LOG(kind,...) GNUNET_log_from (kind, "sensor-model-gaussian", __VA_ARGS__)
+
+/*
+ * Plugin state information
+ */
+struct Plugin
+{
+
+  /*
+   * Configuration handle
+   */
+  const struct GNUNET_CONFIGURATION_Handle *cfg;
+
+};
+
+/*
+ * Entry point for the plugin.
+ *
+ * @param cls The struct GNUNET_CONFIGURATION_Handle.
+ * @return NULL on error, otherwise the plugin context
+ */
+void *
+libgnunet_plugin_sensor_model_gaussian_init (void *cls)
+{
+  static struct Plugin plugin;
+  const struct GNUNET_CONFIGURATION_Handle *cfg = cls;
+  struct GNUNET_SENSOR_ModelFunctions *api;
+
+  if (NULL != plugin.cfg)
+    return NULL;                /* can only initialize once! */
+  memset (&plugin, 0, sizeof (struct Plugin));
+  plugin.cfg = cfg;
+  api = GNUNET_new (struct GNUNET_SENSOR_ModelFunctions);
+  api->cls = &plugin;
+  LOG(GNUNET_ERROR_TYPE_DEBUG, "Guassian model plugin is running\n");
+  return api;
+}
+
+/*
+ * Exit point from the plugin.
+ *
+ * @param cls The plugin context (as returned by "init")
+ * @return Always NULL
+ */
+void *
+libgnunet_plugin_sensor_model_gaussian_done (void *cls)
+{
+  struct GNUNET_SENSOR_ModelFunctions *api = cls;
+  struct Plugin *plugin = api->cls;
+
+  plugin->cfg = NULL;
+  GNUNET_free (api);
+  LOG (GNUNET_ERROR_TYPE_DEBUG, "Guassian model plugin is finished\n");
+  return NULL;
+
+}
+
+/* end of plugin_sensor_model_gaussian.c */
diff --git a/src/sensor/sensor.conf.in b/src/sensor/sensor.conf.in
index c1978ef8d..5c023d130 100644
--- a/src/sensor/sensor.conf.in
+++ b/src/sensor/sensor.conf.in
@@ -5,3 +5,5 @@ HOME = $SERVICEHOME
 # PORT = 2106
 @UNIXONLY@ PORT = 2087
 
+[sensor-analysis]
+model = gaussian
\ No newline at end of file
diff --git a/src/sensor/sensor.h b/src/sensor/sensor.h
index a505d47d3..0a301327d 100644
--- a/src/sensor/sensor.h
+++ b/src/sensor/sensor.h
@@ -19,7 +19,7 @@
  */
 /**
  * @file sensor/sensor.h
- * @brief IPC messages
+ * @brief IPC messages and private service declarations
  * @author Omar Tarabai
  */
 
@@ -61,3 +61,19 @@ struct SensorInfoMessage
 };
 
 GNUNET_NETWORK_STRUCT_END
+
+/*
+ * Stop the sensor analysis module
+ */
+void SENSOR_analysis_stop();
+
+/*
+ * Start the sensor analysis module
+ *
+ * @param c our service configuration
+ * @param sensors_mhm multihashmap of loaded sensors
+ * @return #GNUNET_OK if started successfully, #GNUNET_SYSERR otherwise
+ */
+int
+SENSOR_analysis_start(const struct GNUNET_CONFIGURATION_Handle *c,
+    struct GNUNET_CONTAINER_MultiHashMap *sensors_mhm);