X-Git-Url: https://git.octo.it/?p=collection4.git;a=blobdiff_plain;f=src%2Fgraph_ident.c;h=abf396de3ba4417518cb52a49a53a534433f5039;hp=c3d4e54c54c17557fa0c688583b337efa14314d3;hb=3fbe261b1de541590f5d3be1bef49b3b3605f392;hpb=89bc58e9605fef04667f0e0b9004863b4f46d304 diff --git a/src/graph_ident.c b/src/graph_ident.c index c3d4e54..abf396d 100644 --- a/src/graph_ident.c +++ b/src/graph_ident.c @@ -1,3 +1,28 @@ +/** + * collection4 - graph_ident.c + * Copyright (C) 2010 Florian octo Forster + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, + * Boston, MA 02110-1301 USA + * + * Authors: + * Florian octo Forster + **/ + +#include "config.h" + #include #include #include @@ -7,10 +32,14 @@ #include /* PATH_MAX */ #include #include +#include +#include #include "graph_ident.h" #include "common.h" +#include "data_provider.h" #include "filesystem.h" +#include "utils_cgi.h" #include #include @@ -70,8 +99,10 @@ static char *part_copy_with_selector (const char *selector, /* {{{ */ static _Bool part_matches (const char *selector, /* {{{ */ const char *part) { +#if C4_DEBUG if ((selector == NULL) && (part == NULL)) return (1); +#endif if (selector == NULL) /* && (part != NULL) */ return (0); @@ -203,7 +234,7 @@ void ident_destroy (graph_ident_t *ident) /* {{{ */ } /* }}} void ident_destroy */ /* ident_get_* methods {{{ */ -const char *ident_get_host (graph_ident_t *ident) /* {{{ */ +const char *ident_get_host (const graph_ident_t *ident) /* {{{ */ { if (ident == NULL) return (NULL); @@ -211,7 +242,7 @@ const char *ident_get_host (graph_ident_t *ident) /* {{{ */ return (ident->host); } /* }}} char *ident_get_host */ -const char *ident_get_plugin (graph_ident_t *ident) /* {{{ */ +const char *ident_get_plugin (const graph_ident_t *ident) /* {{{ */ { if (ident == NULL) return (NULL); @@ -219,7 +250,7 @@ const char *ident_get_plugin (graph_ident_t *ident) /* {{{ */ return (ident->plugin); } /* }}} char *ident_get_plugin */ -const char *ident_get_plugin_instance (graph_ident_t *ident) /* {{{ */ +const char *ident_get_plugin_instance (const graph_ident_t *ident) /* {{{ */ { if (ident == NULL) return (NULL); @@ -227,7 +258,7 @@ const char *ident_get_plugin_instance (graph_ident_t *ident) /* {{{ */ return (ident->plugin_instance); } /* }}} char *ident_get_plugin_instance */ -const char *ident_get_type (graph_ident_t *ident) /* {{{ */ +const char *ident_get_type (const graph_ident_t *ident) /* {{{ */ { if (ident == NULL) return (NULL); @@ -235,7 +266,7 @@ const char *ident_get_type (graph_ident_t *ident) /* {{{ */ return (ident->type); } /* }}} char *ident_get_type */ -const char *ident_get_type_instance (graph_ident_t *ident) /* {{{ */ +const char *ident_get_type_instance (const graph_ident_t *ident) /* {{{ */ { if (ident == NULL) return (NULL); @@ -243,7 +274,7 @@ const char *ident_get_type_instance (graph_ident_t *ident) /* {{{ */ return (ident->type_instance); } /* }}} char *ident_get_type_instance */ -const char *ident_get_field (graph_ident_t *ident, /* {{{ */ +const char *ident_get_field (const graph_ident_t *ident, /* {{{ */ graph_ident_field_t field) { if ((ident == NULL) || (field >= _GIF_LAST)) @@ -377,12 +408,10 @@ int ident_compare (const graph_ident_t *i0, /* {{{ */ _Bool ident_matches (const graph_ident_t *selector, /* {{{ */ const graph_ident_t *ident) { - if ((selector == NULL) && (ident == NULL)) +#if C4_DEBUG + if ((selector == NULL) || (ident == NULL)) return (0); - else if (selector == NULL) - return (-1); - else if (ident == NULL) - return (1); +#endif if (!part_matches (selector->host, ident->host)) return (0); @@ -402,6 +431,27 @@ _Bool ident_matches (const graph_ident_t *selector, /* {{{ */ return (1); } /* }}} _Bool ident_matches */ +_Bool ident_intersect (const graph_ident_t *s0, /* {{{ */ + const graph_ident_t *s1) +{ +#define INTERSECT_PART(p) do { \ + if (!IS_ANY (s0->p) && !IS_ALL (s0->p) \ + && !IS_ANY (s1->p) && !IS_ALL (s1->p) \ + && (strcmp (s0->p, s1->p) != 0)) \ + return (0); \ +} while (0) + + INTERSECT_PART (host); + INTERSECT_PART (plugin); + INTERSECT_PART (plugin_instance); + INTERSECT_PART (type); + INTERSECT_PART (type_instance); + +#undef INTERSECT_PART + + return (1); +} /* }}} _Bool ident_intersect */ + char *ident_to_string (const graph_ident_t *ident) /* {{{ */ { char buffer[PATH_MAX]; @@ -457,27 +507,210 @@ char *ident_to_file (const graph_ident_t *ident) /* {{{ */ return (strdup (buffer)); } /* }}} char *ident_to_file */ -char *ident_to_json (const graph_ident_t *ident) /* {{{ */ +int ident_to_json (const graph_ident_t *ident, /* {{{ */ + yajl_gen handler) { - char buffer[4096]; + yajl_gen_status status; - buffer[0] = 0; + if ((ident == NULL) || (handler == NULL)) + return (EINVAL); - strlcat (buffer, "{\"host\":\"", sizeof (buffer)); - strlcat (buffer, ident->host, sizeof (buffer)); - strlcat (buffer, "\",\"plugin\":\"", sizeof (buffer)); - strlcat (buffer, ident->plugin, sizeof (buffer)); - strlcat (buffer, "\",\"plugin_instance\":\"", sizeof (buffer)); - strlcat (buffer, ident->plugin_instance, sizeof (buffer)); - strlcat (buffer, "\",\"type\":\"", sizeof (buffer)); - strlcat (buffer, ident->type, sizeof (buffer)); - strlcat (buffer, "\",\"type_instance\":\"", sizeof (buffer)); - strlcat (buffer, ident->type_instance, sizeof (buffer)); - strlcat (buffer, "\"}", sizeof (buffer)); +#define ADD_STRING(str) do { \ + status = yajl_gen_string (handler, \ + (unsigned char *) (str), \ + (unsigned int) strlen (str)); \ + if (status != yajl_gen_status_ok) \ + return ((int) status); \ +} while (0) - return (strdup (buffer)); + yajl_gen_map_open (handler); + ADD_STRING ("host"); + ADD_STRING (ident->host); + ADD_STRING ("plugin"); + ADD_STRING (ident->plugin); + ADD_STRING ("plugin_instance"); + ADD_STRING (ident->plugin_instance); + ADD_STRING ("type"); + ADD_STRING (ident->type); + ADD_STRING ("type_instance"); + ADD_STRING (ident->type_instance); + yajl_gen_map_close (handler); + +#undef ADD_FIELD + + return (0); } /* }}} char *ident_to_json */ +/* {{{ ident_data_to_json */ +struct ident_data_to_json__data_s +{ + dp_time_t begin; + dp_time_t end; + dp_time_t interval; + yajl_gen handler; +}; +typedef struct ident_data_to_json__data_s ident_data_to_json__data_t; + +#define yajl_gen_string_cast(h,s,l) \ + yajl_gen_string (h, (unsigned char *) s, (unsigned int) l) + +static int ident_data_to_json__get_ident_data ( + __attribute__((unused)) graph_ident_t *ident, /* {{{ */ + __attribute__((unused)) const char *ds_name, + dp_time_t first_value_time, dp_time_t interval, + size_t data_points_num, double *data_points, + void *user_data) +{ + ident_data_to_json__data_t *data = user_data; + size_t i; + + double first_value_time_double; + double interval_double; + double interval_requested; + size_t points_consolidate; + + first_value_time_double = ((double) first_value_time.tv_sec) + + (((double) first_value_time.tv_nsec) / 1000000000.0); + interval_double = ((double) interval.tv_sec) + + (((double) interval.tv_nsec) / 1000000000.0); + interval_requested = ((double) data->interval.tv_sec) + + (((double) data->interval.tv_nsec) / 1000000000.0); + + if (interval_requested < (2.0 * interval_double)) + points_consolidate = 1; + else + points_consolidate = (size_t) (interval_requested / interval_double); + assert (points_consolidate >= 1); + + if (points_consolidate > 1) + { + size_t offset = data_points_num % points_consolidate; + + first_value_time_double += ((double) offset) * interval_double; + interval_double *= ((double) points_consolidate); + } + + yajl_gen_map_open (data->handler); + + yajl_gen_string_cast (data->handler, "first_value_time", strlen ("first_value_time")); + yajl_gen_double (data->handler, first_value_time_double); + + yajl_gen_string_cast (data->handler, "interval", strlen ("interval")); + yajl_gen_double (data->handler, interval_double); + + yajl_gen_string_cast (data->handler, "data", strlen ("data")); + yajl_gen_array_open (data->handler); + + for (i = (data_points_num % points_consolidate); + i < data_points_num; + i += points_consolidate) + { + size_t j; + + double sum = 0.0; + long num = 0; + + for (j = 0; j < points_consolidate; j++) + { + if (isnan (data_points[i+j])) + continue; + + sum += data_points[i+j]; + num++; + } + + if (num == 0) + yajl_gen_null (data->handler); + else + yajl_gen_double (data->handler, sum / ((double) num)); + } + + yajl_gen_array_close (data->handler); + + return (0); +} /* }}} int ident_data_to_json__get_ident_data */ + +/* Called for each DS name */ +static int ident_data_to_json__get_ds_name (graph_ident_t *ident, /* {{{ */ + const char *ds_name, void *user_data) +{ + ident_data_to_json__data_t *data = user_data; + int status; + + yajl_gen_map_open (data->handler); + + yajl_gen_string_cast (data->handler, "file", strlen ("file")); + ident_to_json (ident, data->handler); + + yajl_gen_string_cast (data->handler, "data_source", strlen ("data_source")); + yajl_gen_string_cast (data->handler, ds_name, strlen (ds_name)); + + status = data_provider_get_ident_data (ident, ds_name, + data->begin, data->end, + ident_data_to_json__get_ident_data, + data); + + yajl_gen_map_close (data->handler); + + return (status); +} /* }}} int ident_data_to_json__get_ds_name */ + +int ident_data_to_json (graph_ident_t *ident, /* {{{ */ + dp_time_t begin, dp_time_t end, dp_time_t res, + yajl_gen handler) +{ + ident_data_to_json__data_t data; + int status; + + data.begin = begin; + data.end = end; + data.interval = res; + data.handler = handler; + + /* Iterate over all DS names */ + status = data_provider_get_ident_ds_names (ident, + ident_data_to_json__get_ds_name, &data); + if (status != 0) + fprintf (stderr, "ident_data_to_json: data_provider_get_ident_ds_names " + "failed with status %i\n", status); + + return (status); +} /* }}} int ident_data_to_json */ +/* }}} ident_data_to_json */ + +int ident_describe (const graph_ident_t *ident, /* {{{ */ + const graph_ident_t *selector, + char *buffer, size_t buffer_size) +{ + if ((ident == NULL) || (selector == NULL) + || (buffer == NULL) || (buffer_size < 2)) + return (EINVAL); + + buffer[0] = 0; + +#define CHECK_FIELD(field) do { \ + if (strcasecmp (selector->field, ident->field) != 0) \ + { \ + if (buffer[0] != 0) \ + strlcat (buffer, "/", buffer_size); \ + strlcat (buffer, ident->field, buffer_size); \ + } \ +} while (0) + + CHECK_FIELD (host); + CHECK_FIELD (plugin); + CHECK_FIELD (plugin_instance); + CHECK_FIELD (type); + CHECK_FIELD (type_instance); + +#undef CHECK_FIELD + + if (buffer[0] == 0) + strlcat (buffer, "default", buffer_size); + + return (0); +} /* }}} int ident_describe */ + time_t ident_get_mtime (const graph_ident_t *ident) /* {{{ */ { char *file;