From 611c2f4a09c0e803c8c9fa1bf26b59e9ab607d71 Mon Sep 17 00:00:00 2001 From: Romain Forlot Date: Fri, 18 May 2018 15:40:29 +0200 Subject: Fix: not retrieve timestamp from arguments Change-Id: I7aaaa4c544428899d7e383b3bbd2ae29312ca15b Signed-off-by: Romain Forlot --- src/plugins/influxdb.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'src') diff --git a/src/plugins/influxdb.c b/src/plugins/influxdb.c index 4c69e98..c2fe118 100644 --- a/src/plugins/influxdb.c +++ b/src/plugins/influxdb.c @@ -159,7 +159,8 @@ void unpacking_from_api(void *s, json_object *valueJ, const char *key) if(strcasecmp("name", key) == 0) serie->name = json_object_get_string(valueJ); else if(strcasecmp("timestamp", key) == 0) - serie->timestamp = get_ts(); + serie->timestamp = (json_object_is_type(valueJ, json_type_int)) ? + json_object_get_int64(valueJ) : 0; else if(strcasecmp("metadata", key) == 0) wrap_json_object_for_all(valueJ, unpack_metadata, (void*)&serie->serie_columns.tags); else if(strcasecmp("value", key) == 0 || strcasecmp("values", key) == 0) @@ -178,8 +179,9 @@ int unpack_metric_from_api(json_object *m, struct series_t *serie) { wrap_json_object_for_all(m, unpacking_from_api, serie); - if(!serie->timestamp) + if(! serie->timestamp) { serie->timestamp = get_ts(); + } return 0; } -- cgit 1.2.3-korg