* @brief sensor service implementation
* @author Omar Tarabai
*/
-#include <inttypes.h>
#include "platform.h"
#include "gnunet_util_lib.h"
#include "sensor.h"
-#include "gnunet_statistics_service.h"
-#include "gnunet_peerstore_service.h"
/**
* Our configuration.
static struct GNUNET_CONTAINER_MultiHashMap *sensors;
/**
- * Handle to statistics service
+ * Start the monitoring module ?
*/
-static struct GNUNET_STATISTICS_Handle *statistics;
+static int start_monitoring;
/**
- * Handle to peerstore service
+ * Start the analysis module ?
*/
-static struct GNUNET_PEERSTORE_Handle *peerstore;
+static int start_analysis;
/**
- * Service name
+ * Start the reporting module ?
*/
-static char *subsystem = "sensor";
+static int start_reporting;
/**
- * My peer id
+ * Start the update module ?
*/
-static struct GNUNET_PeerIdentity peerid;
+static int start_update;
/**
reset ();
-/**
- * Change the state of the sensor.
- * Write the change to file to make it persistent.
- *
- * @param sensor sensor info struct
- * @param state new enabled state: #GNUNET_YES / #GNUNET_NO
- */
-static void
-set_sensor_enabled (struct GNUNET_SENSOR_SensorInfo *sensor, int state)
-{
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sensor `%s': Setting enabled to %d.\n",
- sensor->name, state);
- sensor->enabled = GNUNET_NO;
- GNUNET_assert (NULL != sensor->cfg);
- GNUNET_CONFIGURATION_set_value_string (sensor->cfg, sensor->name, "ENABLED",
- (GNUNET_YES == state) ? "YES" : "NO");
- GNUNET_CONFIGURATION_write (sensor->cfg, sensor->def_file);
-}
-
-
/**
* Stops components and destroys sensors
*/
static void
stop ()
{
- SENSOR_update_stop ();
- SENSOR_analysis_stop ();
- SENSOR_reporting_value_stop ();
- SENSOR_reporting_anomaly_stop ();
+ if (GNUNET_YES == start_update)
+ SENSOR_update_stop ();
+ if (GNUNET_YES == start_analysis)
+ SENSOR_analysis_stop ();
+ if (GNUNET_YES == start_reporting)
+ SENSOR_reporting_stop ();
+ if (GNUNET_YES == start_monitoring)
+ SENSOR_monitoring_stop ();
GNUNET_SENSOR_destroy_sensors (sensors);
}
shutdown_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
{
stop ();
- if (NULL != statistics)
- {
- GNUNET_STATISTICS_destroy (statistics, GNUNET_YES);
- statistics = NULL;
- }
- if (NULL != peerstore)
- {
- GNUNET_PEERSTORE_disconnect (peerstore, GNUNET_YES);
- peerstore = NULL;
- }
if (NULL != sensor_dir)
{
GNUNET_free (sensor_dir);
/**
- * A client disconnected. Remove all of its data structure entries.
+ * Handle a force anomaly request from client.
*
- * @param cls closure, NULL
+ * @param cls closure
* @param client identification of the client
+ * @param message the actual message
*/
static void
-handle_client_disconnect (void *cls, struct GNUNET_SERVER_Client *client)
+handle_anomaly_force (void *cls, struct GNUNET_SERVER_Client *client,
+ const struct GNUNET_MessageHeader *message)
{
+ struct ForceAnomalyMessage *anomaly_msg;
+ struct GNUNET_SENSOR_SensorInfo *sensor;
+
+ anomaly_msg = (struct ForceAnomalyMessage *) message;
+ sensor =
+ GNUNET_CONTAINER_multihashmap_get (sensors,
+ &anomaly_msg->sensor_name_hash);
+ if (NULL == sensor)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+ "Force anomaly message received for a sensor we don't have.\n");
+ GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
+ return;
+ }
+ SENSOR_reporting_anomaly_update (sensor, ntohs (anomaly_msg->anomalous));
+ GNUNET_SERVER_receive_done (client, GNUNET_YES);
}
}
-/**
- * Do a series of checks to determine if sensor should execute
- *
- * @return #GNUNET_YES / #GNUNET_NO
- */
-static int
-should_run_sensor (struct GNUNET_SENSOR_SensorInfo *sensorinfo)
-{
- struct GNUNET_TIME_Absolute now;
-
- if (GNUNET_NO == sensorinfo->enabled)
- {
- GNUNET_log (GNUNET_ERROR_TYPE_INFO,
- "Sensor `%s' is disabled, will not run\n", sensorinfo->name);
- return GNUNET_NO;
- }
- now = GNUNET_TIME_absolute_get ();
- if (NULL != sensorinfo->start_time &&
- now.abs_value_us < sensorinfo->start_time->abs_value_us)
- {
- GNUNET_log (GNUNET_ERROR_TYPE_INFO,
- "Start time for sensor `%s' not reached yet, will not run\n",
- sensorinfo->name);
- return GNUNET_NO;
- }
- if (NULL != sensorinfo->end_time &&
- now.abs_value_us >= sensorinfo->end_time->abs_value_us)
- {
- GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Sensor `%s' expired, disabling.\n",
- sensorinfo->name);
- set_sensor_enabled (sensorinfo, GNUNET_NO);
- return GNUNET_NO;
- }
- return GNUNET_YES;
-}
-
-
-/**
- * Callback function to process statistic values
- *
- * @param cls `struct GNUNET_SENSOR_SensorInfo *`
- * @param ss name of subsystem that created the statistic
- * @param name the name of the datum
- * @param value the current value
- * @param is_persistent #GNUNET_YES if the value is persistent, #GNUNET_NO if not
- * @return #GNUNET_OK to continue, #GNUNET_SYSERR to abort iteration
- */
-static int
-sensor_statistics_iterator (void *cls, const char *ss, const char *name,
- uint64_t value, int is_persistent)
-{
- struct GNUNET_SENSOR_SensorInfo *sensorinfo = cls;
- double dvalue = (double) value;
- struct GNUNET_TIME_Absolute expiry;
-
- GNUNET_log (GNUNET_ERROR_TYPE_INFO,
- "Received a value for sensor `%s': %" PRIu64 "\n",
- sensorinfo->name, value);
- expiry = GNUNET_TIME_relative_to_absolute (sensorinfo->lifetime);
- GNUNET_PEERSTORE_store (peerstore, subsystem, &peerid, sensorinfo->name,
- &dvalue, sizeof (dvalue), expiry,
- GNUNET_PEERSTORE_STOREOPTION_MULTIPLE, NULL, NULL);
- return GNUNET_SYSERR; /* We only want one value */
-}
-
-
-/**
- * Continuation called after sensor gets all gnunet statistics values
- *
- * @param cls `struct GNUNET_SENSOR_SensorInfo *`
- * @param success #GNUNET_OK if statistics were
- * successfully obtained, #GNUNET_SYSERR if not.
- */
-static void
-end_sensor_run_stat (void *cls, int success)
-{
- struct GNUNET_SENSOR_SensorInfo *sensorinfo = cls;
-
- sensorinfo->gnunet_stat_get_handle = NULL;
- sensorinfo->running = GNUNET_NO;
-}
-
-
-/**
- * Tries to parse a received sensor value to its
- * expected datatype
- *
- * @param value the string value received, should be null terminated
- * @param sensor sensor information struct
- * @param ret pointer to parsed value
- * @return size of new parsed value, 0 for error
- */
-static size_t
-parse_sensor_value (const char *value, struct GNUNET_SENSOR_SensorInfo *sensor,
- void **ret)
-{
- double *dval;
- char *endptr;
-
- *ret = NULL;
- if ('\0' == *value)
- return 0;
- if (0 == strcmp ("numeric", sensor->expected_datatype))
- {
- dval = GNUNET_new (double);
-
- *dval = strtod (value, &endptr);
- if (value == endptr)
- return 0;
- *ret = dval;
- return sizeof (double);
- }
- if (0 == strcmp ("string", sensor->expected_datatype))
- {
- *ret = GNUNET_strdup (value);
- return strlen (value) + 1;
- }
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- _
- ("Unknown value type expected by sensor, this should not happen.\n"));
- return 0;
-}
-
-
-/**
- * Callback for output of executed sensor process
- *
- * @param cls `struct GNUNET_SENSOR_SensorInfo *`
- * @param line line of output from a command, NULL for the end
- */
-static void
-sensor_process_callback (void *cls, const char *line)
-{
- struct GNUNET_SENSOR_SensorInfo *sensorinfo = cls;
- void *value;
- size_t valsize;
- struct GNUNET_TIME_Absolute expiry;
-
- if (NULL == line)
- {
- GNUNET_OS_command_stop (sensorinfo->ext_cmd);
- sensorinfo->ext_cmd = NULL;
- sensorinfo->running = GNUNET_NO;
- sensorinfo->ext_cmd_value_received = GNUNET_NO;
- return;
- }
- if (GNUNET_YES == sensorinfo->ext_cmd_value_received)
- return; /* We only want one *valid* value */
- GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Received a value for sensor `%s': %s\n",
- sensorinfo->name, line);
- valsize = parse_sensor_value (line, sensorinfo, &value);
- if (valsize == 0) /* invalid value, FIXME: should we disable the sensor now? */
- {
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- _("Received an invalid value for sensor `%s': %s\n"),
- sensorinfo->name, line);
- }
- else
- {
- sensorinfo->ext_cmd_value_received = GNUNET_YES;
- expiry = GNUNET_TIME_relative_to_absolute (sensorinfo->lifetime);
- GNUNET_PEERSTORE_store (peerstore, subsystem, &peerid, sensorinfo->name,
- value, valsize, expiry,
- GNUNET_PEERSTORE_STOREOPTION_MULTIPLE, NULL, NULL);
- GNUNET_free (value);
- }
-}
-
-
-/**
- * Checks if the given file is a path
- *
- * @return #GNUNET_YES / #GNUNET_NO
- */
-static int
-is_path (char *filename)
-{
- size_t filename_len;
- int i;
-
- filename_len = strlen (filename);
- for (i = 0; i < filename_len; i++)
- {
- if (DIR_SEPARATOR == filename[i])
- return GNUNET_YES;
- }
- return GNUNET_NO;
-}
-
-
-/**
- * Actual execution of a sensor
- *
- * @param cls 'struct SensorInfo'
- * @param tc unsed
- */
-static void
-sensor_run (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
-{
- struct GNUNET_SENSOR_SensorInfo *sensorinfo = cls;
- int check_result;
- char *process_path;
-
- sensorinfo->execution_task =
- GNUNET_SCHEDULER_add_delayed (sensorinfo->interval, &sensor_run,
- sensorinfo);
- if (GNUNET_YES == sensorinfo->running) //FIXME: should we try to kill?
- {
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Sensor `%s' running for too long, will try again next interval\n",
- sensorinfo->name);
- return;
- }
- if (GNUNET_NO == should_run_sensor (sensorinfo))
- return;
- sensorinfo->running = GNUNET_YES;
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Starting the execution of sensor `%s'\n", sensorinfo->name);
- if (0 == strcmp ("gnunet-statistics", sensorinfo->source))
- {
- sensorinfo->gnunet_stat_get_handle = GNUNET_STATISTICS_get (statistics, sensorinfo->gnunet_stat_service, sensorinfo->gnunet_stat_name, sensorinfo->interval, //try to get values only for the interval of the sensor
- &end_sensor_run_stat,
- &sensor_statistics_iterator,
- sensorinfo);
- }
- else if (0 == strcmp ("process", sensorinfo->source))
- {
- if (GNUNET_YES == is_path (sensorinfo->ext_process))
- {
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- _
- ("Sensor `%s': External process should not be a path, disabling sensor.\n"),
- sensorinfo->name);
- set_sensor_enabled (sensorinfo, GNUNET_NO);
- return;
- }
- //check if the process exists in $PATH
- process_path = GNUNET_strdup (sensorinfo->ext_process);
- check_result =
- GNUNET_OS_check_helper_binary (process_path, GNUNET_NO, NULL);
- if (GNUNET_SYSERR == check_result)
- {
- //search in sensor directory
- GNUNET_free (process_path);
- GNUNET_asprintf (&process_path, "%s%s-files%s%s", sensor_dir,
- sensorinfo->name, DIR_SEPARATOR_STR,
- sensorinfo->ext_process);
- GNUNET_free (sensor_dir);
- check_result =
- GNUNET_OS_check_helper_binary (process_path, GNUNET_NO, NULL);
- }
- if (GNUNET_SYSERR == check_result)
- {
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- _
- ("Sensor `%s' process `%s' problem: binary doesn't exist or not executable\n"),
- sensorinfo->name, sensorinfo->ext_process);
- set_sensor_enabled (sensorinfo, GNUNET_NO);
- sensorinfo->running = GNUNET_NO;
- GNUNET_free (process_path);
- return;
- }
- sensorinfo->ext_cmd_value_received = GNUNET_NO;
- sensorinfo->ext_cmd =
- GNUNET_OS_command_run (&sensor_process_callback, sensorinfo,
- GNUNET_TIME_UNIT_FOREVER_REL, process_path,
- sensorinfo->ext_process, sensorinfo->ext_args,
- NULL);
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Process started for sensor `%s'\n",
- sensorinfo->name);
- GNUNET_free (process_path);
- }
- else
- {
- sensorinfo->running = GNUNET_NO;
- GNUNET_break (0); /* shouldn't happen */
- }
-}
-
-
-/**
- * Starts the execution of a sensor
- *
- * @param cls unused
- * @param key hash of sensor name, key to hashmap (unused)
- * @param value a `struct GNUNET_SENSOR_SensorInfo *`
- * @return #GNUNET_YES if we should continue to
- * iterate,
- * #GNUNET_NO if not.
- */
-static int
-schedule_sensor (void *cls, const struct GNUNET_HashCode *key, void *value)
-{
- struct GNUNET_SENSOR_SensorInfo *sensorinfo = value;
-
- if (GNUNET_NO == should_run_sensor (sensorinfo))
- return GNUNET_YES;
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Scheduling sensor `%s' to run after %" PRIu64 " microseconds\n",
- sensorinfo->name, sensorinfo->interval.rel_value_us);
- if (GNUNET_SCHEDULER_NO_TASK != sensorinfo->execution_task)
- {
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- _
- ("Sensor `%s' execution task already set, this should not happen\n"),
- sensorinfo->name);
- return GNUNET_NO;
- }
- sensorinfo->execution_task =
- GNUNET_SCHEDULER_add_delayed (sensorinfo->interval, &sensor_run,
- sensorinfo);
- return GNUNET_YES;
-}
-
-
-/**
- * Starts the execution of all enabled sensors
- */
-static void
-schedule_all_sensors ()
-{
- GNUNET_CONTAINER_multihashmap_iterate (sensors, &schedule_sensor, NULL);
-}
-
-
/**
* Loads sensors and starts different service components
*/
start ()
{
sensors = GNUNET_SENSOR_load_all_sensors (sensor_dir);
- schedule_all_sensors ();
- SENSOR_reporting_value_start (cfg, sensors);
- SENSOR_reporting_anomaly_start (cfg, sensors);
- SENSOR_analysis_start (cfg, sensors);
- SENSOR_update_start (cfg, sensors, &reset);
+ if (GNUNET_YES == start_monitoring)
+ SENSOR_monitoring_start (cfg, sensors);
+ if (GNUNET_YES == start_reporting)
+ SENSOR_reporting_start (cfg, sensors);
+ if (GNUNET_YES == start_analysis)
+ SENSOR_analysis_start (cfg, sensors);
+ if (GNUNET_YES == start_update)
+ SENSOR_update_start (cfg, sensors, &reset);
}
0},
{&handle_get_all_sensors, NULL, GNUNET_MESSAGE_TYPE_SENSOR_GETALL,
sizeof (struct GNUNET_MessageHeader)},
+ {
+ &handle_anomaly_force, NULL, GNUNET_MESSAGE_TYPE_SENSOR_ANOMALY_FORCE,
+ sizeof (struct ForceAnomalyMessage)},
{NULL, NULL, 0, 0}
};
cfg = c;
if (GNUNET_OK !=
- GNUNET_CONFIGURATION_get_value_filename (cfg, "SENSOR", "SENSOR_DIR",
+ GNUNET_CONFIGURATION_get_value_filename (cfg, "sensor", "SENSOR_DIR",
&sensor_dir))
+ {
sensor_dir = GNUNET_SENSOR_get_default_sensor_dir ();
- statistics = GNUNET_STATISTICS_create ("sensor", cfg);
- GNUNET_CRYPTO_get_peer_identity (cfg, &peerid);
- peerstore = GNUNET_PEERSTORE_connect (cfg);
+ }
+ start_monitoring = GNUNET_YES;
+ start_analysis = GNUNET_YES;
+ start_reporting = GNUNET_YES;
+ start_update = GNUNET_YES;
+ if (GNUNET_NO ==
+ GNUNET_CONFIGURATION_get_value_yesno (cfg, "sensor", "START_MONITORING"))
+ {
+ start_monitoring = GNUNET_NO;
+ }
+ if (GNUNET_NO ==
+ GNUNET_CONFIGURATION_get_value_yesno (cfg, "sensor", "START_REPORTING"))
+ {
+ start_reporting = GNUNET_NO;
+ }
+ if (GNUNET_NO ==
+ GNUNET_CONFIGURATION_get_value_yesno (cfg, "sensor", "START_ANALYSIS"))
+ {
+ start_analysis = GNUNET_NO;
+ }
+ if (GNUNET_NO ==
+ GNUNET_CONFIGURATION_get_value_yesno (cfg, "sensor", "START_UPDATE"))
+ {
+ start_update = GNUNET_NO;
+ }
GNUNET_SERVER_add_handlers (server, handlers);
- GNUNET_SERVER_disconnect_notify (server, &handle_client_disconnect, NULL);
GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_FOREVER_REL, &shutdown_task,
NULL);
start ();
projects / oweals / gnunet.git / blobdiff