X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=graph_list.c;h=965fcbac4f6caad5913b9a0097dd2937ec773ffb;hb=7a6beaf075a32bfd93d314c00179f258c8e43ee5;hp=0e4428de2c3308096a8042da4e0e7b985ae5c95b;hpb=052657ddb5a25bf53e3ad4a0a5ec3c3afd48ec8c;p=collection4.git diff --git a/graph_list.c b/graph_list.c index 0e4428d..965fcba 100644 --- a/graph_list.c +++ b/graph_list.c @@ -1,379 +1,79 @@ #include #include +#include +#include #include #include #include -#include - -#include -#include #include "graph_list.h" +#include "graph_ident.h" +#include "graph_def.h" +#include "graph_config.h" #include "common.h" +#include "filesystem.h" +#include "utils_params.h" + +#include +#include /* * Defines */ #define UPDATE_INTERVAL 10 -#define ANY_TOKEN "/any/" -#define ALL_TOKEN "/all/" - -/* - * Data types - */ -struct graph_ident_s /* {{{ */ -{ - char *host; - char *plugin; - char *plugin_instance; - char *type; - char *type_instance; -}; /* }}} struct graph_ident_s */ - -struct graph_instance_s; -typedef struct graph_instance_s graph_instance_t; -struct graph_instance_s /* {{{ */ -{ - graph_ident_t select; - - graph_ident_t *files; - size_t files_num; - - graph_instance_t *next; -}; /* }}} struct graph_instance_s */ - -struct graph_config_s; -typedef struct graph_config_s graph_config_t; -struct graph_config_s /* {{{ */ -{ - graph_ident_t select; - - char *title; - char *vertical_label; - - graph_instance_t *instances; - - graph_config_t *next; -}; /* }}} struct graph_config_s */ - /* * Global variables */ -static graph_config_t *graph_config_head = NULL; +static graph_config_t **gl_active = NULL; +static size_t gl_active_num = 0; + +static graph_config_t **gl_staging = NULL; +static size_t gl_staging_num = 0; -static graph_ident_t *graph_list = NULL; -static size_t graph_list_length = 0; static time_t gl_last_update = 0; /* * Private functions */ -static int print_files (const graph_instance_t *inst) /* {{{ */ -{ - size_t i; - - for (i = 0; i < inst->files_num; i++) - { - graph_ident_t *file = inst->files + i; - - printf (" File \"%s/%s-%s/%s-%s\"\n", - file->host, - file->plugin, file->plugin_instance, - file->type, file->type_instance); - } - - return (0); -} /* }}} int print_instances */ - -static int print_instances (const graph_config_t *cfg) /* {{{ */ -{ - graph_instance_t *inst; - - for (inst = cfg->instances; inst != NULL; inst = inst->next) - { - printf (" Instance \"%s/%s-%s/%s-%s\"\n", - inst->select.host, - inst->select.plugin, inst->select.plugin_instance, - inst->select.type, inst->select.type_instance); - - print_files (inst); - } - - return (0); -} /* }}} int print_instances */ - -static int print_graphs (void) /* {{{ */ -{ - graph_config_t *cfg; - - for (cfg = graph_config_head; cfg != NULL; cfg = cfg->next) - { - printf ("Graph \"%s/%s-%s/%s-%s\"\n", - cfg->select.host, - cfg->select.plugin, cfg->select.plugin_instance, - cfg->select.type, cfg->select.type_instance); - - print_instances (cfg); - } - - return (0); -} /* }}} int print_graphs */ - - -/* "Safe" version of strcmp(3): Either or both pointers may be NULL. */ -static int strcmp_s (const char *s1, const char *s2) /* {{{ */ -{ - if ((s1 == NULL) && (s2 == NULL)) - return (0); - else if (s1 == NULL) - return (1); - else if (s2 == NULL) - return (-1); - assert ((s1 != NULL) && (s2 != NULL)); - - return (strcmp (s1, s2)); -} /* }}} int strcmp_s */ - -static _Bool part_matches (const char *sel, const char *val) /* {{{ */ -{ - if ((sel == NULL) && (val == NULL)) - return (1); - - if (sel == NULL) /* && (val != NULL) */ - return (0); - - if ((strcasecmp (ALL_TOKEN, sel) == 0) - || (strcasecmp (ANY_TOKEN, sel) == 0)) - return (1); - - if (val == NULL) /* && (sel != NULL) */ - return (0); - - if (strcmp (sel, val) == 0) - return (1); - - return (0); -} /* }}} _Bool part_matches */ - -static _Bool file_matches (const graph_ident_t *sel, /* {{{ */ - const graph_ident_t *val) +int gl_add_graph_internal (graph_config_t *cfg, /* {{{ */ + graph_config_t ***gl_array, size_t *gl_array_num) { - if ((sel == NULL) && (val == NULL)) - return (0); - else if (sel == NULL) - return (-1); - else if (val == NULL) - return (1); - - if (!part_matches (sel->host, val->host)) - return (0); - - if (!part_matches (sel->plugin, val->plugin)) - return (0); - - if (!part_matches (sel->plugin_instance, val->plugin_instance)) - return (0); - - if (!part_matches (sel->type, val->type)) - return (0); - - if (!part_matches (sel->type_instance, val->type_instance)) - return (0); - - return (1); -} /* }}} _Bool ident_compare */ - -/* - * Copy part of an identifier. If the "template" value is ANY_TOKEN, "value" is - * copied and returned. This function is used when creating graph_instance_t - * from graph_config_t. - */ -static char *identifier_copy_part (const char *template, const char *value) /* {{{ */ -{ - if (template == NULL) - { - return (NULL); - } - else if (strcasecmp (ANY_TOKEN, template) == 0) - { - /* ANY in the graph selection => concrete value in the instance. */ - if (value == NULL) - return (NULL); - else - return (strdup (value)); - } - else if (strcasecmp (ALL_TOKEN, template) == 0) - { - /* ALL in the graph selection => ALL in the instance. */ - return (strdup (ALL_TOKEN)); - } - else - { - assert (value != NULL); - assert (strcmp (template, value) == 0); - return (strdup (template)); - } -} /* }}} int identifier_copy_part */ - -static graph_instance_t *instance_create (graph_config_t *cfg, /* {{{ */ - const graph_ident_t *file) -{ - graph_instance_t *i; - - if ((cfg == NULL) || (file == NULL)) - return (NULL); - - i = malloc (sizeof (*i)); - if (i == NULL) - return (NULL); - memset (i, 0, sizeof (*i)); - - i->select.host = identifier_copy_part (cfg->select.host, file->host); - i->select.plugin = identifier_copy_part (cfg->select.plugin, file->plugin); - i->select.plugin_instance = identifier_copy_part (cfg->select.plugin_instance, - file->plugin_instance); - i->select.type = identifier_copy_part (cfg->select.type, file->type); - i->select.type_instance = identifier_copy_part (cfg->select.type_instance, - file->type_instance); - - i->files = NULL; - i->files_num = 0; - - i->next = NULL; - - if (cfg->instances == NULL) - cfg->instances = i; - else - { - graph_instance_t *last; - - last = cfg->instances; - while (last->next != NULL) - last = last->next; - - last->next = i; - } - - return (i); -} /* }}} graph_instance_t *instance_create */ - -static int instance_add_file (graph_instance_t *inst, /* {{{ */ - const graph_ident_t *file) -{ - graph_ident_t *tmp; - - tmp = realloc (inst->files, sizeof (*inst->files) * (inst->files_num + 1)); - if (tmp == NULL) - return (ENOMEM); - inst->files = tmp; - tmp = inst->files + inst->files_num; - - memset (tmp, 0, sizeof (*tmp)); - tmp->host = strdup (file->host); - tmp->plugin = strdup (file->plugin); - if (file->plugin_instance != NULL) - tmp->plugin_instance = strdup (file->plugin_instance); - else - tmp->plugin_instance = NULL; - tmp->type = strdup (file->type); - if (file->type_instance != NULL) - tmp->type_instance = strdup (file->type_instance); - else - tmp->type_instance = NULL; - - inst->files_num++; - - return (0); -} /* }}} int instance_add_file */ - -static graph_instance_t *graph_find_instance (graph_config_t *cfg, /* {{{ */ - const graph_ident_t *file) -{ - graph_instance_t *i; - - if ((cfg == NULL) || (file == NULL)) - return (NULL); - - for (i = cfg->instances; i != NULL; i = i->next) - if (file_matches (&i->select, file)) - return (i); - - return (NULL); -} /* }}} graph_instance_t *graph_find_instance */ - -static int graph_add_file (graph_config_t *cfg, const graph_ident_t *file) /* {{{ */ -{ - graph_instance_t *inst; - - inst = graph_find_instance (cfg, file); - if (inst == NULL) - { - inst = instance_create (cfg, file); - if (inst == NULL) - return (ENOMEM); - } + graph_config_t **tmp; - return (instance_add_file (inst, file)); -} /* }}} int graph_add_file */ - -static int graph_append (graph_config_t *cfg) /* {{{ */ -{ - graph_config_t *last; +#define ARRAY_PTR (*gl_array) +#define ARRAY_SIZE (*gl_array_num) if (cfg == NULL) return (EINVAL); - if (graph_config_head == NULL) - { - graph_config_head = cfg; - return (0); - } - - last = graph_config_head; - while (last->next != NULL) - last = last->next; - - last->next = cfg; - - return (0); -} /* }}} int graph_append */ - -static int graph_create_from_file (const graph_ident_t *file) /* {{{ */ -{ - graph_config_t *cfg; - - cfg = malloc (sizeof (*cfg)); - if (cfg == NULL) + tmp = realloc (ARRAY_PTR, sizeof (*ARRAY_PTR) * (ARRAY_SIZE + 1)); + if (tmp == NULL) return (ENOMEM); - memset (cfg, 0, sizeof (*cfg)); + ARRAY_PTR = tmp; - cfg->select.host = strdup (file->host); - cfg->select.plugin = strdup (file->plugin); - cfg->select.plugin_instance = strdup (file->plugin_instance); - cfg->select.type = strdup (file->type); - cfg->select.type_instance = strdup (file->type_instance); + ARRAY_PTR[ARRAY_SIZE] = cfg; + ARRAY_SIZE++; - cfg->title = NULL; - cfg->vertical_label = NULL; - cfg->instances = NULL; - cfg->next = NULL; +#undef ARRAY_SIZE +#undef ARRAY_PTR - graph_append (cfg); - - return (graph_add_file (cfg, file)); -} /* }}} int graph_create_from_file */ + return (0); +} /* }}} int gl_add_graph_internal */ -static int register_file (const graph_ident_t *file) /* {{{ */ +static int gl_register_file (const graph_ident_t *file, /* {{{ */ + __attribute__((unused)) void *user_data) { graph_config_t *cfg; int num_graphs = 0; + size_t i; - for (cfg = graph_config_head; cfg != NULL; cfg = cfg->next) + for (i = 0; i < gl_active_num; i++) { + graph_config_t *cfg = gl_active[i]; int status; - if (!file_matches (&cfg->select, file)) + if (!graph_matches (cfg, file)) continue; status = graph_add_file (cfg, file); @@ -388,342 +88,200 @@ static int register_file (const graph_ident_t *file) /* {{{ */ } if (num_graphs == 0) - graph_create_from_file (file); + { + cfg = graph_create (file); + gl_add_graph_internal (cfg, &gl_active, &gl_active_num); + graph_add_file (cfg, file); + } return (0); -} /* }}} int register_file */ +} /* }}} int gl_register_file */ -static int FIXME_graph_create_from_file (const graph_ident_t *file) /* {{{ */ +static const char *get_part_from_param (const char *prim_key, /* {{{ */ + const char *sec_key) { - graph_config_t *cfg; + const char *val; - cfg = malloc (sizeof (*cfg)); - if (cfg == NULL) - return (ENOMEM); - memset (cfg, 0, sizeof (*cfg)); + val = param (prim_key); + if (val != NULL) + return (val); + + return (param (sec_key)); +} /* }}} const char *get_part_from_param */ - cfg->select.host = strdup (file->host); - cfg->select.plugin = strdup (file->plugin); - cfg->select.plugin_instance = strdup (file->plugin_instance); - cfg->select.type = strdup (file->type); - cfg->select.type_instance = strdup (file->type_instance); - - cfg->title = NULL; - cfg->vertical_label = NULL; - cfg->instances = NULL; - cfg->next = NULL; - - graph_append (cfg); - - return (0); -} /* }}} int FIXME_graph_create_from_file */ - -static int read_graph_config (void) /* {{{ */ +static int gl_clear_instances (void) /* {{{ */ { - if (graph_config_head != NULL) - return (0); - - graph_ident_t ident; - - - ident.host = ANY_TOKEN; - ident.plugin = "cpu"; - ident.plugin_instance = ANY_TOKEN; - ident.type = "cpu"; - ident.type_instance = ALL_TOKEN; - FIXME_graph_create_from_file (&ident); - - ident.plugin = "memory"; - ident.plugin_instance = ""; - ident.type = "memory"; - FIXME_graph_create_from_file (&ident); - - ident.plugin = "swap"; - ident.plugin_instance = ""; - ident.type = "swap"; - FIXME_graph_create_from_file (&ident); - - ident.plugin = ANY_TOKEN; - ident.plugin_instance = ANY_TOKEN; - ident.type = "ps_state"; - FIXME_graph_create_from_file (&ident); + size_t i; - ident.host = ALL_TOKEN; - ident.plugin = "cpu"; - ident.plugin_instance = ALL_TOKEN; - ident.type = "cpu"; - ident.type_instance = "idle"; - FIXME_graph_create_from_file (&ident); + for (i = 0; i < gl_active_num; i++) + graph_clear_instances (gl_active[i]); return (0); -} /* }}} int read_graph_config */ +} /* }}} int gl_clear_instances */ - -static int gl_compare (const void *p0, const void *p1) /* {{{ */ +/* + * Global functions + */ +int gl_add_graph (graph_config_t *cfg) /* {{{ */ { - const graph_ident_t *gl0 = p0; - const graph_ident_t *gl1 = p1; - int status; - - status = strcmp (gl0->host, gl1->host); - if (status != 0) - return (status); - - status = strcmp (gl0->plugin, gl1->plugin); - if (status != 0) - return (status); - - status = strcmp_s (gl0->plugin_instance, gl1->plugin_instance); - if (status != 0) - return (status); - - status = strcmp (gl0->type, gl1->type); - if (status != 0) - return (status); + return (gl_add_graph_internal (cfg, &gl_staging, &gl_staging_num)); +} /* }}} int gl_add_graph */ - return (strcmp_s (gl0->type_instance, gl1->type_instance)); -} /* }}} int gl_compare */ - -static void gl_clear_entry (graph_ident_t *gl) /* {{{ */ -{ - if (gl == NULL) - return; - - free (gl->host); - free (gl->plugin); - free (gl->plugin_instance); - free (gl->type); - free (gl->type_instance); - - gl->host = NULL; - gl->plugin = NULL; - gl->plugin_instance = NULL; - gl->type = NULL; - gl->type_instance = NULL; -} /* }}} void gl_clear_entry */ - -static void gl_clear (void) /* {{{ */ +int gl_config_submit (void) /* {{{ */ { + graph_config_t **old; + size_t old_num; size_t i; - for (i = 0; i < graph_list_length; i++) - gl_clear_entry (graph_list + i); + old = gl_active; + old_num = gl_active_num; - free (graph_list); - graph_list = NULL; - graph_list_length = 0; - gl_last_update = 0; -} /* }}} void gl_clear */ - -static int gl_add_copy (graph_ident_t *gl) /* {{{ */ -{ - graph_ident_t *ptr; - int status; + gl_active = gl_staging; + gl_active_num = gl_staging_num; - if (gl == NULL) - return (EINVAL); + gl_staging = NULL; + gl_staging_num = 0; - ptr = realloc (graph_list, sizeof (*graph_list) * (graph_list_length + 1)); - if (ptr == NULL) - return (ENOMEM); - graph_list = ptr; - - ptr = graph_list + graph_list_length; - memset (ptr, 0, sizeof (*ptr)); - ptr->host = NULL; - ptr->plugin = NULL; - ptr->plugin_instance = NULL; - ptr->type = NULL; - ptr->type_instance = NULL; - -#define DUP_OR_BREAK(member) do { \ - ptr->member = NULL; \ - if (gl->member != NULL) \ - { \ - ptr->member = strdup (gl->member); \ - if (ptr->member == NULL) \ - break; \ - } \ -} while (0) - - status = ENOMEM; - do + for (i = 0; i < old_num; i++) { - DUP_OR_BREAK(host); - DUP_OR_BREAK(plugin); - DUP_OR_BREAK(plugin_instance); - DUP_OR_BREAK(type); - DUP_OR_BREAK(type_instance); - - status = 0; - } while (0); - -#undef DUP_OR_BREAK - - if (status != 0) - { - free (ptr->host); - free (ptr->plugin); - free (ptr->plugin_instance); - free (ptr->type); - free (ptr->type_instance); - return (status); + graph_destroy (old[i]); + old[i] = NULL; } + free (old); - graph_list_length++; return (0); -} /* }}} int gl_add_copy */ +} /* }}} int graph_config_submit */ -static int callback_type (const char *type, void *user_data) /* {{{ */ +int gl_graph_get_all (gl_cfg_callback callback, /* {{{ */ + void *user_data) { - graph_ident_t *gl; - int status; - - if ((type == NULL) || (user_data == NULL)) - return (EINVAL); + size_t i; - gl = user_data; - if ((gl->type != NULL) || (gl->type_instance != NULL)) + if (callback == NULL) return (EINVAL); - gl->type = strdup (type); - if (gl->type == NULL) - return (ENOMEM); + gl_update (); - gl->type_instance = strchr (gl->type, '-'); - if (gl->type_instance != NULL) - { - *gl->type_instance = 0; - gl->type_instance++; - } - else + for (i = 0; i < gl_active_num; i++) { - gl->type_instance = gl->type + strlen (gl->type); - } - - register_file (gl); - - status = gl_add_copy (gl); + int status; - free (gl->type); - gl->type = NULL; - gl->type_instance = NULL; + status = (*callback) (gl_active[i], user_data); + if (status != 0) + return (status); + } - return (status); -} /* }}} int callback_type */ + return (0); +} /* }}} int gl_graph_get_all */ -static int callback_plugin (const char *plugin, void *user_data) /* {{{ */ +graph_config_t *gl_graph_get_selected (void) /* {{{ */ { - graph_ident_t *gl; - int status; + const char *host = get_part_from_param ("graph_host", "host"); + const char *plugin = get_part_from_param ("graph_plugin", "plugin"); + const char *plugin_instance = get_part_from_param ("graph_plugin_instance", "plugin_instance"); + const char *type = get_part_from_param ("graph_type", "type"); + const char *type_instance = get_part_from_param ("graph_type_instance", "type_instance"); + graph_ident_t *ident; + size_t i; - if ((plugin == NULL) || (user_data == NULL)) - return (EINVAL); + if ((host == NULL) + || (plugin == NULL) || (plugin_instance == NULL) + || (type == NULL) || (type_instance == NULL)) + return (NULL); - gl = user_data; - if ((gl->plugin != NULL) || (gl->plugin_instance != NULL)) - return (EINVAL); + ident = ident_create (host, plugin, plugin_instance, type, type_instance); - gl->plugin = strdup (plugin); - if (gl->plugin == NULL) - return (ENOMEM); + gl_update (); - gl->plugin_instance = strchr (gl->plugin, '-'); - if (gl->plugin_instance != NULL) - { - *gl->plugin_instance = 0; - gl->plugin_instance++; - } - else + for (i = 0; i < gl_active_num; i++) { - gl->plugin_instance = gl->plugin + strlen (gl->plugin); + if (graph_compare (gl_active[i], ident) != 0) + continue; + + ident_destroy (ident); + return (gl_active[i]); } - status = foreach_type (gl->host, plugin, callback_type, gl); + ident_destroy (ident); + return (NULL); +} /* }}} graph_config_t *gl_graph_get_selected */ - free (gl->plugin); - gl->plugin = NULL; - gl->plugin_instance = NULL; +/* gl_instance_get_all, gl_graph_instance_get_all {{{ */ +struct gl_inst_callback_data /* {{{ */ +{ + graph_config_t *cfg; + gl_inst_callback callback; + void *user_data; +}; /* }}} struct gl_inst_callback_data */ - return (status); -} /* }}} int callback_plugin */ +static int gl_inst_callback_handler (graph_instance_t *inst, /* {{{ */ + void *user_data) +{ + struct gl_inst_callback_data *data = user_data; -static int callback_host (const char *host, void *user_data) /* {{{ */ + return ((*data->callback) (data->cfg, inst, data->user_data)); +} /* }}} int gl_inst_callback_handler */ + +int gl_graph_instance_get_all (graph_config_t *cfg, /* {{{ */ + gl_inst_callback callback, void *user_data) { - graph_ident_t *gl; - int status; + struct gl_inst_callback_data data = + { + cfg, + callback, + user_data + }; - if ((host == NULL) || (user_data == NULL)) + if ((cfg == NULL) || (callback == NULL)) return (EINVAL); - gl = user_data; - if (gl->host != NULL) - return (EINVAL); + return (inst_foreach (graph_get_instances (cfg), + gl_inst_callback_handler, &data)); +} /* }}} int gl_graph_instance_get_all */ - gl->host = strdup (host); - if (gl->host == NULL) - return (ENOMEM); +int gl_instance_get_all (gl_inst_callback callback, /* {{{ */ + void *user_data) +{ + size_t i; - status = foreach_plugin (host, callback_plugin, gl); + gl_update (); - free (gl->host); - gl->host = NULL; + for (i = 0; i < gl_active_num; i++) + { + int status; - return (status); -} /* }}} int callback_host */ + status = gl_graph_instance_get_all (gl_active[i], callback, user_data); + if (status != 0) + return (status); + } + + return (0); +} /* }}} int gl_instance_get_all */ +/* }}} gl_instance_get_all, gl_graph_instance_get_all */ -/* - * Global functions - */ int gl_update (void) /* {{{ */ { time_t now; - graph_ident_t gl; int status; + /* printf ("Content-Type: text/plain\n\n"); - - read_graph_config (); + */ now = time (NULL); if ((gl_last_update + UPDATE_INTERVAL) >= now) return (0); - gl_clear (); - - memset (&gl, 0, sizeof (gl)); - gl.host = NULL; - gl.plugin = NULL; - gl.plugin_instance = NULL; - gl.type = NULL; - gl.type_instance = NULL; + graph_read_config (); - status = foreach_host (callback_host, &gl); + gl_clear_instances (); + status = fs_scan (/* callback = */ gl_register_file, /* user data = */ NULL); - print_graphs (); - - if (graph_list_length > 1) - qsort (graph_list, graph_list_length, sizeof (*graph_list), gl_compare); + gl_last_update = now; return (status); } /* }}} int gl_update */ -int gl_foreach (gl_callback callback, void *user_data) /* {{{ */ -{ - size_t i; - - for (i = 0; i < graph_list_length; i++) - { - int status; - - status = (*callback) ((void *) (graph_list + i), user_data); - if (status != 0) - return (status); - } - - return (0); -} /* }}} int gl_foreach */ - /* vim: set sw=2 sts=2 et fdm=marker : */