#include "graph_types.h"
#include "graph_ident.h"
-#include "graph_list.h"
#include "data_provider.h"
#include "filesystem.h"
#include "oconfig.h"
return (fs_foreach_dir (abs_dir, scan_plugin_cb, data));
} /* }}} int scan_host_cb */
-static int ident_to_rrdfile (const graph_ident_t *ident,
+static int ident_to_rrdfile (const graph_ident_t *ident, /* {{{ */
dp_rrdtool_t *config,
char *buffer, size_t buffer_size)
{
{ /* {{{ */
dp_rrdtool_t *config = priv;
- ident = NULL;
- ds_name = NULL;
- begin.tv_sec = 0;
- end.tv_sec = 0;
- cb = NULL;
- ud = NULL;
+ char filename[PATH_MAX + 1];
+ const char *cf = "AVERAGE"; /* FIXME */
+ time_t rrd_start;
+ time_t rrd_end;
+ unsigned long step;
+ unsigned long ds_count;
+ char **ds_namv;
+ rrd_value_t *data;
+ int status;
+
+ unsigned long ds_index;
+ unsigned long data_index;
+ unsigned long data_length;
+
+ dp_data_point_t *dp = NULL;
+ size_t dp_num = 0;
+
+ status = ident_to_rrdfile (ident, config, filename, sizeof (filename));
+ if (status != 0)
+ return (status);
- config = NULL;
+ rrd_start = (time_t) begin.tv_sec;
+ rrd_end = (time_t) end.tv_sec;
+ step = 0;
+ ds_count = 0;
+ ds_namv = NULL;
+ data = NULL;
+
+ status = rrd_fetch_r (filename, cf,
+ &rrd_start, &rrd_end,
+ &step, &ds_count, &ds_namv,
+ &data);
+ if (status != 0)
+ return (status);
+
+#define BAIL_OUT(ret_status) do { \
+ unsigned long i; \
+ for (i = 0; i < ds_count; i++) \
+ free (ds_namv[i]); \
+ free (ds_namv); \
+ free (data); \
+ free (dp); \
+ return (ret_status); \
+} while (0)
+
+ for (ds_index = 0; ds_index < ds_count; ds_index++)
+ if (strcmp (ds_name, ds_namv[ds_index]) == 0)
+ break;
+
+ if (ds_index >= ds_count)
+ BAIL_OUT (ENOENT);
+
+ /* Number of data points returned. */
+ data_length = (rrd_end - rrd_start) / step;
+
+ dp_num = (size_t) data_length;
+ dp = calloc (dp_num, sizeof (*dp));
+ if (dp == NULL)
+ BAIL_OUT (ENOMEM);
+
+ for (data_index = 0; data_index < data_length; data_index++)
+ {
+ unsigned long index = (ds_count * data_index) + ds_index;
+
+ dp[data_index].time.tv_sec = rrd_start + (data_index * step);
+ dp[data_index].time.tv_nsec = 0;
+ dp[data_index].value = (double) data[index];
+ }
+
+ status = (*cb) (ident, ds_name, dp, dp_num, ud);
+ if (status != 0)
+ BAIL_OUT (status);
- return (EINVAL);
+ BAIL_OUT (0);
+#undef BAIL_OUT
} /* }}} int get_ident_data */
static int print_graph (void *priv,
return (-1);
} /* }}} int print_graph */
-int dp_rrdtool_config (oconfig_item_t *ci)
+int dp_rrdtool_config (const oconfig_item_t *ci)
{ /* {{{ */
dp_rrdtool_t *conf;
dp.private_data = conf;
- gl_register_data_provider ("rrdtool", &dp);
+ data_provider_register ("rrdtool", &dp);
return (0);
} /* }}} int dp_rrdtool_config */