aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorOmar Tarabai <tarabai@devegypt.com>2014-06-23 12:02:36 +0000
committerOmar Tarabai <tarabai@devegypt.com>2014-06-23 12:02:36 +0000
commit2ff52dabfadd9390d0751f9f9bdf463d76a80ec5 (patch)
treede8cef3a453329d04b2954d8513a8adecac0b6ed /src
parent181b1a97669739b0b1d8b788aa25547b8f1d6c8e (diff)
downloadgnunet-2ff52dabfadd9390d0751f9f9bdf463d76a80ec5.tar.gz
gnunet-2ff52dabfadd9390d0751f9f9bdf463d76a80ec5.zip
sensor: using data lifetime value
Diffstat (limited to 'src')
-rw-r--r--src/sensor/gnunet-service-sensor.c7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/sensor/gnunet-service-sensor.c b/src/sensor/gnunet-service-sensor.c
index 2fc882196..f1c49683e 100644
--- a/src/sensor/gnunet-service-sensor.c
+++ b/src/sensor/gnunet-service-sensor.c
@@ -99,6 +99,7 @@ struct SensorInfo
99 99
100 /* 100 /*
101 * Lifetime of an information sample after which it is deleted from storage 101 * Lifetime of an information sample after which it is deleted from storage
102 * If not supplied, will default to the interval value
102 */ 103 */
103 struct GNUNET_TIME_Relative lifetime; 104 struct GNUNET_TIME_Relative lifetime;
104 105
@@ -459,7 +460,7 @@ load_sensor_from_cfg(struct GNUNET_CONFIGURATION_Handle *cfg, const char *sectio
459 sensor->lifetime = GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, time_sec); 460 sensor->lifetime = GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, time_sec);
460 } 461 }
461 else 462 else
462 sensor->lifetime = GNUNET_TIME_UNIT_FOREVER_REL; 463 sensor->lifetime = sensor->interval;
463 //capabilities TODO 464 //capabilities TODO
464 //source 465 //source
465 if(GNUNET_OK != GNUNET_CONFIGURATION_get_value_choice(cfg, sectionname, "SOURCE", sources, (const char **)&sensor->source)) 466 if(GNUNET_OK != GNUNET_CONFIGURATION_get_value_choice(cfg, sectionname, "SOURCE", sources, (const char **)&sensor->source))
@@ -850,7 +851,7 @@ int sensor_statistics_iterator (void *cls,
850 struct GNUNET_TIME_Absolute expiry; 851 struct GNUNET_TIME_Absolute expiry;
851 852
852 GNUNET_log(GNUNET_ERROR_TYPE_INFO, "Received a value for sensor `%s': %" PRIu64 "\n", sensorinfo->name, value); 853 GNUNET_log(GNUNET_ERROR_TYPE_INFO, "Received a value for sensor `%s': %" PRIu64 "\n", sensorinfo->name, value);
853 expiry = GNUNET_TIME_relative_to_absolute(sensorinfo->interval); 854 expiry = GNUNET_TIME_relative_to_absolute(sensorinfo->lifetime);
854 GNUNET_PEERSTORE_store(peerstore, 855 GNUNET_PEERSTORE_store(peerstore,
855 subsystem, 856 subsystem,
856 &peerid, 857 &peerid,
@@ -962,7 +963,7 @@ void sensor_process_callback (void *cls, const char *line)
962 else 963 else
963 { 964 {
964 sensorinfo->ext_cmd_value_received = GNUNET_YES; 965 sensorinfo->ext_cmd_value_received = GNUNET_YES;
965 expiry = GNUNET_TIME_relative_to_absolute(sensorinfo->interval); 966 expiry = GNUNET_TIME_relative_to_absolute(sensorinfo->lifetime);
966 GNUNET_PEERSTORE_store(peerstore, 967 GNUNET_PEERSTORE_store(peerstore,
967 subsystem, 968 subsystem,
968 &peerid, 969 &peerid,