+ 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;
+
+ dp_time_t first_value_time;
+ dp_time_t interval;
+ size_t data_points_num;
+ double *data_points = NULL;
+
+ unsigned long ds_index;
+ size_t i;
+
+ status = ident_to_rrdfile (ident, config, filename, sizeof (filename));
+ if (status != 0)
+ return (status);
+
+ 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 (data_points); \
+ 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);
+
+ memset (&first_value_time, 0, sizeof (first_value_time));
+ first_value_time.tv_sec = rrd_start;
+ memset (&interval, 0, sizeof (interval));
+ interval.tv_sec = (time_t) step;
+ data_points_num = (size_t) ((rrd_end - rrd_start) / step);
+ data_points = calloc (data_points_num, sizeof (*data_points));
+ if (data_points == NULL)
+ BAIL_OUT (ENOMEM);
+
+ for (i = 0; i < data_points_num; i++)
+ {
+ unsigned long index = (ds_count * ((unsigned long) i)) + ds_index;
+ data_points[i] = (double) data[index];
+ }