#include "collectd.h"
-#include "plugin.h" /* plugin_register_*, plugin_dispatch_values */
#include "common.h" /* auxiliary functions */
+#include "plugin.h" /* plugin_register_*, plugin_dispatch_values */
#include "utils_tail.h"
-#include <sys/mman.h>
-#include <sys/stat.h>
#include <fcntl.h>
#include <stdlib.h>
#include <string.h>
+#include <sys/mman.h>
+#include <sys/stat.h>
struct metric_definition_s {
- char *name;
- char *type;
- char *instance;
- int data_source_type;
- ssize_t value_from;
- struct metric_definition_s *next;
+ char *name;
+ char *type;
+ char *instance;
+ int data_source_type;
+ ssize_t value_from;
+ struct metric_definition_s *next;
};
typedef struct metric_definition_s metric_definition_t;
struct instance_definition_s {
- char *instance;
- char *path;
- cu_tail_t *tail;
- metric_definition_t **metric_list;
- size_t metric_list_len;
- cdtime_t interval;
- ssize_t time_from;
- struct instance_definition_s *next;
+ char *instance;
+ char *path;
+ cu_tail_t *tail;
+ metric_definition_t **metric_list;
+ size_t metric_list_len;
+ cdtime_t interval;
+ ssize_t time_from;
+ struct instance_definition_s *next;
};
typedef struct instance_definition_s instance_definition_t;
/* Private */
static metric_definition_t *metric_head = NULL;
-static int tcsv_submit (instance_definition_t *id,
- metric_definition_t *md,
- value_t v, cdtime_t t)
-{
- /* Registration variables */
- value_list_t vl = VALUE_LIST_INIT;
+static int tcsv_submit(instance_definition_t *id, metric_definition_t *md,
+ value_t v, cdtime_t t) {
+ /* Registration variables */
+ value_list_t vl = VALUE_LIST_INIT;
- /* Register */
- vl.values_len = 1;
- vl.values = &v;
+ /* Register */
+ vl.values_len = 1;
+ vl.values = &v;
- sstrncpy(vl.plugin, "tail_csv", sizeof(vl.plugin));
- if (id->instance != NULL)
- sstrncpy(vl.plugin_instance, id->instance, sizeof(vl.plugin_instance));
- sstrncpy(vl.type, md->type, sizeof(vl.type));
- if (md->instance != NULL)
- sstrncpy(vl.type_instance, md->instance, sizeof(vl.type_instance));
+ sstrncpy(vl.plugin, "tail_csv", sizeof(vl.plugin));
+ if (id->instance != NULL)
+ sstrncpy(vl.plugin_instance, id->instance, sizeof(vl.plugin_instance));
+ sstrncpy(vl.type, md->type, sizeof(vl.type));
+ if (md->instance != NULL)
+ sstrncpy(vl.type_instance, md->instance, sizeof(vl.type_instance));
- vl.time = t;
- vl.interval = id->interval;
+ vl.time = t;
+ vl.interval = id->interval;
- return (plugin_dispatch_values(&vl));
+ return (plugin_dispatch_values(&vl));
}
-static cdtime_t parse_time (char const *tbuf)
-{
- double t;
- char *endptr = NULL;
+static cdtime_t parse_time(char const *tbuf) {
+ double t;
+ char *endptr = NULL;
- errno = 0;
- t = strtod (tbuf, &endptr);
- if ((errno != 0) || (endptr == NULL) || (endptr[0] != 0))
- return (cdtime ());
+ errno = 0;
+ t = strtod(tbuf, &endptr);
+ if ((errno != 0) || (endptr == NULL) || (endptr[0] != 0))
+ return (cdtime());
- return (DOUBLE_TO_CDTIME_T (t));
+ return (DOUBLE_TO_CDTIME_T(t));
}
-static int tcsv_read_metric (instance_definition_t *id,
- metric_definition_t *md,
- char **fields, size_t fields_num)
-{
- value_t v;
- cdtime_t t = 0;
- int status;
+static int tcsv_read_metric(instance_definition_t *id, metric_definition_t *md,
+ char **fields, size_t fields_num) {
+ value_t v;
+ cdtime_t t = 0;
+ int status;
- if (md->data_source_type == -1)
- return (EINVAL);
+ if (md->data_source_type == -1)
+ return (EINVAL);
- assert (md->value_from >= 0);
- if (((size_t) md->value_from) >= fields_num)
- return (EINVAL);
+ assert(md->value_from >= 0);
+ if (((size_t)md->value_from) >= fields_num)
+ return (EINVAL);
- status = parse_value (fields[md->value_from], &v, md->data_source_type);
- if (status != 0)
- return (status);
+ status = parse_value(fields[md->value_from], &v, md->data_source_type);
+ if (status != 0)
+ return (status);
- if (id->time_from >= 0) {
- if (((size_t) id->time_from) >= fields_num)
- return (EINVAL);
- t = parse_time (fields[id->time_from]);
- }
+ if (id->time_from >= 0) {
+ if (((size_t)id->time_from) >= fields_num)
+ return (EINVAL);
+ t = parse_time(fields[id->time_from]);
+ }
- return (tcsv_submit (id, md, v, t));
+ return (tcsv_submit(id, md, v, t));
}
-static _Bool tcsv_check_index (ssize_t index, size_t fields_num, char const *name)
-{
- if (index < 0)
- return 1;
- else if (((size_t) index) < fields_num)
- return 1;
-
- ERROR ("tail_csv plugin: Metric \"%s\": Request for index %zd when "
- "only %zu fields are available.",
- name, index, fields_num);
- return (0);
+static _Bool tcsv_check_index(ssize_t index, size_t fields_num,
+ char const *name) {
+ if (index < 0)
+ return 1;
+ else if (((size_t)index) < fields_num)
+ return 1;
+
+ ERROR("tail_csv plugin: Metric \"%s\": Request for index %zd when "
+ "only %zu fields are available.",
+ name, index, fields_num);
+ return (0);
}
-static int tcsv_read_buffer (instance_definition_t *id,
- char *buffer, size_t buffer_size)
-{
- char **metrics;
- size_t metrics_num;
-
- char *ptr;
- size_t i;
-
- /* Remove newlines at the end of line. */
- while (buffer_size > 0) {
- if ((buffer[buffer_size - 1] == '\n')
- || (buffer[buffer_size - 1] == '\r')) {
- buffer[buffer_size - 1] = 0;
- buffer_size--;
- } else {
- break;
- }
+static int tcsv_read_buffer(instance_definition_t *id, char *buffer,
+ size_t buffer_size) {
+ char **metrics;
+ size_t metrics_num;
+
+ char *ptr;
+ size_t i;
+
+ /* Remove newlines at the end of line. */
+ while (buffer_size > 0) {
+ if ((buffer[buffer_size - 1] == '\n') ||
+ (buffer[buffer_size - 1] == '\r')) {
+ buffer[buffer_size - 1] = 0;
+ buffer_size--;
+ } else {
+ break;
}
+ }
- /* Ignore empty lines. */
- if ((buffer_size == 0) || (buffer[0] == '#'))
- return (0);
-
- /* Count the number of fields. */
- metrics_num = 1;
- for (i = 0; i < buffer_size; i++) {
- if (buffer[i] == ',')
- metrics_num++;
- }
-
- if (metrics_num == 1) {
- ERROR("tail_csv plugin: last line of `%s' does not contain "
- "enough values.", id->path);
- return (-1);
- }
+ /* Ignore empty lines. */
+ if ((buffer_size == 0) || (buffer[0] == '#'))
+ return (0);
- /* Create a list of all values */
- metrics = calloc (metrics_num, sizeof (*metrics));
- if (metrics == NULL) {
- ERROR ("tail_csv plugin: calloc failed.");
- return (ENOMEM);
- }
+ /* Count the number of fields. */
+ metrics_num = 1;
+ for (i = 0; i < buffer_size; i++) {
+ if (buffer[i] == ',')
+ metrics_num++;
+ }
+
+ if (metrics_num == 1) {
+ ERROR("tail_csv plugin: last line of `%s' does not contain "
+ "enough values.",
+ id->path);
+ return (-1);
+ }
+
+ /* Create a list of all values */
+ metrics = calloc(metrics_num, sizeof(*metrics));
+ if (metrics == NULL) {
+ ERROR("tail_csv plugin: calloc failed.");
+ return (ENOMEM);
+ }
+
+ ptr = buffer;
+ metrics[0] = ptr;
+ i = 1;
+ for (ptr = buffer; *ptr != 0; ptr++) {
+ if (*ptr != ',')
+ continue;
+
+ *ptr = 0;
+ metrics[i] = ptr + 1;
+ i++;
+ }
+ assert(i == metrics_num);
+
+ /* Register values */
+ for (i = 0; i < id->metric_list_len; ++i) {
+ metric_definition_t *md = id->metric_list[i];
+
+ if (!tcsv_check_index(md->value_from, metrics_num, md->name) ||
+ !tcsv_check_index(id->time_from, metrics_num, md->name))
+ continue;
+
+ tcsv_read_metric(id, md, metrics, metrics_num);
+ }
+
+ /* Free up resources */
+ sfree(metrics);
+ return (0);
+}
- ptr = buffer;
- metrics[0] = ptr;
- i = 1;
- for (ptr = buffer; *ptr != 0; ptr++) {
- if (*ptr != ',')
- continue;
+static int tcsv_read(user_data_t *ud) {
+ instance_definition_t *id;
+ id = ud->data;
- *ptr = 0;
- metrics[i] = ptr + 1;
- i++;
+ if (id->tail == NULL) {
+ id->tail = cu_tail_create(id->path);
+ if (id->tail == NULL) {
+ ERROR("tail_csv plugin: cu_tail_create (\"%s\") failed.", id->path);
+ return (-1);
}
- assert (i == metrics_num);
+ }
- /* Register values */
- for (i = 0; i < id->metric_list_len; ++i){
- metric_definition_t *md = id->metric_list[i];
-
- if (!tcsv_check_index (md->value_from, metrics_num, md->name)
- || !tcsv_check_index (id->time_from, metrics_num, md->name))
- continue;
+ while (42) {
+ char buffer[1024];
+ size_t buffer_len;
+ int status;
- tcsv_read_metric (id, md, metrics, metrics_num);
+ status = cu_tail_readline(id->tail, buffer, (int)sizeof(buffer));
+ if (status != 0) {
+ ERROR("tail_csv plugin: File \"%s\": cu_tail_readline failed "
+ "with status %i.",
+ id->path, status);
+ return (-1);
}
- /* Free up resources */
- sfree (metrics);
- return (0);
-}
-
-static int tcsv_read (user_data_t *ud) {
- instance_definition_t *id;
- id = ud->data;
-
- if (id->tail == NULL)
- {
- id->tail = cu_tail_create (id->path);
- if (id->tail == NULL)
- {
- ERROR ("tail_csv plugin: cu_tail_create (\"%s\") failed.",
- id->path);
- return (-1);
- }
- }
+ buffer_len = strlen(buffer);
+ if (buffer_len == 0)
+ break;
- while (42)
- {
- char buffer[1024];
- size_t buffer_len;
- int status;
-
- status = cu_tail_readline (id->tail, buffer, (int) sizeof (buffer));
- if (status != 0)
- {
- ERROR ("tail_csv plugin: File \"%s\": cu_tail_readline failed "
- "with status %i.", id->path, status);
- return (-1);
- }
-
- buffer_len = strlen (buffer);
- if (buffer_len == 0)
- break;
-
- tcsv_read_buffer (id, buffer, buffer_len);
- }
+ tcsv_read_buffer(id, buffer, buffer_len);
+ }
- return (0);
+ return (0);
}
-static void tcsv_metric_definition_destroy(void *arg){
- metric_definition_t *md;
- metric_definition_t *next;
+static void tcsv_metric_definition_destroy(void *arg) {
+ metric_definition_t *md;
+ metric_definition_t *next;
- md = arg;
- if (md == NULL)
- return;
+ md = arg;
+ if (md == NULL)
+ return;
- next = md->next;
- md->next = NULL;
+ next = md->next;
+ md->next = NULL;
- sfree(md->name);
- sfree(md->type);
- sfree(md->instance);
- sfree(md);
+ sfree(md->name);
+ sfree(md->type);
+ sfree(md->instance);
+ sfree(md);
- tcsv_metric_definition_destroy (next);
+ tcsv_metric_definition_destroy(next);
}
static int tcsv_config_get_index(oconfig_item_t *ci, ssize_t *ret_index) {
- if ((ci->values_num != 1) || (ci->values[0].type != OCONFIG_TYPE_NUMBER)){
- WARNING("tail_csv plugin: The \"%s\" config option needs exactly one "
- "integer argument.", ci->key);
- return (-1);
- }
-
- if (ci->values[0].value.number < 0) {
- WARNING("tail_csv plugin: The \"%s\" config option must be positive "
- "(or zero).", ci->key);
- return (-1);
- }
-
- *ret_index = (ssize_t) ci->values[0].value.number;
- return (0);
+ if ((ci->values_num != 1) || (ci->values[0].type != OCONFIG_TYPE_NUMBER)) {
+ WARNING("tail_csv plugin: The \"%s\" config option needs exactly one "
+ "integer argument.",
+ ci->key);
+ return (-1);
+ }
+
+ if (ci->values[0].value.number < 0) {
+ WARNING("tail_csv plugin: The \"%s\" config option must be positive "
+ "(or zero).",
+ ci->key);
+ return (-1);
+ }
+
+ *ret_index = (ssize_t)ci->values[0].value.number;
+ return (0);
}
/* Parse metric */
-static int tcsv_config_add_metric(oconfig_item_t *ci){
- metric_definition_t *md;
- int status;
-
- md = calloc(1, sizeof(*md));
- if (md == NULL)
- return (-1);
- md->name = NULL;
- md->type = NULL;
- md->instance = NULL;
- md->data_source_type = -1;
- md->value_from = -1;
- md->next = NULL;
-
- status = cf_util_get_string (ci, &md->name);
- if (status != 0) {
- sfree (md);
- return (-1);
- }
-
- for (int i = 0; i < ci->children_num; ++i){
- oconfig_item_t *option = ci->children + i;
-
- if (strcasecmp("Type", option->key) == 0)
- status = cf_util_get_string(option, &md->type);
- else if (strcasecmp("Instance", option->key) == 0)
- status = cf_util_get_string(option, &md->instance);
- else if (strcasecmp("ValueFrom", option->key) == 0)
- status = tcsv_config_get_index (option, &md->value_from);
- else {
- WARNING("tail_csv plugin: Option `%s' not allowed here.", option->key);
- status = -1;
- }
-
- if (status != 0)
- break;
- }
-
- if (status != 0){
- tcsv_metric_definition_destroy(md);
- return (-1);
- }
-
- /* Verify all necessary options have been set. */
- if (md->type == NULL) {
- WARNING("tail_csv plugin: Option `Type' must be set.");
- status = -1;
- } else if (md->value_from < 0) {
- WARNING("tail_csv plugin: Option `ValueFrom' must be set.");
- status = -1;
- }
- if (status != 0) {
- tcsv_metric_definition_destroy(md);
- return (status);
- }
-
- if (metric_head == NULL)
- metric_head = md;
+static int tcsv_config_add_metric(oconfig_item_t *ci) {
+ metric_definition_t *md;
+ int status;
+
+ md = calloc(1, sizeof(*md));
+ if (md == NULL)
+ return (-1);
+ md->name = NULL;
+ md->type = NULL;
+ md->instance = NULL;
+ md->data_source_type = -1;
+ md->value_from = -1;
+ md->next = NULL;
+
+ status = cf_util_get_string(ci, &md->name);
+ if (status != 0) {
+ sfree(md);
+ return (-1);
+ }
+
+ for (int i = 0; i < ci->children_num; ++i) {
+ oconfig_item_t *option = ci->children + i;
+
+ if (strcasecmp("Type", option->key) == 0)
+ status = cf_util_get_string(option, &md->type);
+ else if (strcasecmp("Instance", option->key) == 0)
+ status = cf_util_get_string(option, &md->instance);
+ else if (strcasecmp("ValueFrom", option->key) == 0)
+ status = tcsv_config_get_index(option, &md->value_from);
else {
- metric_definition_t *last;
- last = metric_head;
- while (last->next != NULL)
- last = last->next;
- last->next = md;
+ WARNING("tail_csv plugin: Option `%s' not allowed here.", option->key);
+ status = -1;
}
- return (0);
+ if (status != 0)
+ break;
+ }
+
+ if (status != 0) {
+ tcsv_metric_definition_destroy(md);
+ return (-1);
+ }
+
+ /* Verify all necessary options have been set. */
+ if (md->type == NULL) {
+ WARNING("tail_csv plugin: Option `Type' must be set.");
+ status = -1;
+ } else if (md->value_from < 0) {
+ WARNING("tail_csv plugin: Option `ValueFrom' must be set.");
+ status = -1;
+ }
+ if (status != 0) {
+ tcsv_metric_definition_destroy(md);
+ return (status);
+ }
+
+ if (metric_head == NULL)
+ metric_head = md;
+ else {
+ metric_definition_t *last;
+ last = metric_head;
+ while (last->next != NULL)
+ last = last->next;
+ last->next = md;
+ }
+
+ return (0);
}
-static void tcsv_instance_definition_destroy(void *arg){
- instance_definition_t *id;
+static void tcsv_instance_definition_destroy(void *arg) {
+ instance_definition_t *id;
- id = arg;
- if (id == NULL)
- return;
+ id = arg;
+ if (id == NULL)
+ return;
- if (id->tail != NULL)
- cu_tail_destroy (id->tail);
- id->tail = NULL;
+ if (id->tail != NULL)
+ cu_tail_destroy(id->tail);
+ id->tail = NULL;
- sfree(id->instance);
- sfree(id->path);
- sfree(id->metric_list);
- sfree(id);
+ sfree(id->instance);
+ sfree(id->path);
+ sfree(id->metric_list);
+ sfree(id);
}
-static int tcsv_config_add_instance_collect(instance_definition_t *id, oconfig_item_t *ci) {
- metric_definition_t *metric;
- metric_definition_t **metric_list;
- size_t metric_list_size;
-
- if (ci->values_num < 1) {
- WARNING("tail_csv plugin: The `Collect' config option needs at least one argument.");
- return (-1);
+static int tcsv_config_add_instance_collect(instance_definition_t *id,
+ oconfig_item_t *ci) {
+ metric_definition_t *metric;
+ metric_definition_t **metric_list;
+ size_t metric_list_size;
+
+ if (ci->values_num < 1) {
+ WARNING("tail_csv plugin: The `Collect' config option needs at least one "
+ "argument.");
+ return (-1);
+ }
+
+ metric_list_size = id->metric_list_len + (size_t)ci->values_num;
+ metric_list =
+ realloc(id->metric_list, sizeof(*id->metric_list) * metric_list_size);
+ if (metric_list == NULL)
+ return (-1);
+ id->metric_list = metric_list;
+
+ for (int i = 0; i < ci->values_num; i++) {
+ char *metric_name;
+
+ if (ci->values[i].type != OCONFIG_TYPE_STRING) {
+ WARNING("tail_csv plugin: All arguments to `Collect' must be strings.");
+ continue;
}
+ metric_name = ci->values[i].value.string;
- metric_list_size = id->metric_list_len + (size_t) ci->values_num;
- metric_list = realloc (id->metric_list, sizeof (*id->metric_list) * metric_list_size);
- if (metric_list == NULL)
- return (-1);
- id->metric_list = metric_list;
-
- for (int i = 0; i < ci->values_num; i++) {
- char *metric_name;
-
- if (ci->values[i].type != OCONFIG_TYPE_STRING) {
- WARNING("tail_csv plugin: All arguments to `Collect' must be strings.");
- continue;
- }
- metric_name = ci->values[i].value.string;
-
- for (metric = metric_head; metric != NULL; metric = metric->next)
- if (strcasecmp(metric_name, metric->name) == 0)
- break;
-
- if (metric == NULL) {
- WARNING ("tail_csv plugin: `Collect' argument not found `%s'.", metric_name);
- continue;
- }
+ for (metric = metric_head; metric != NULL; metric = metric->next)
+ if (strcasecmp(metric_name, metric->name) == 0)
+ break;
- id->metric_list[id->metric_list_len] = metric;
- id->metric_list_len++;
+ if (metric == NULL) {
+ WARNING("tail_csv plugin: `Collect' argument not found `%s'.",
+ metric_name);
+ continue;
}
- return (0);
+ id->metric_list[id->metric_list_len] = metric;
+ id->metric_list_len++;
+ }
+
+ return (0);
}
/* <File /> block */
-static int tcsv_config_add_file(oconfig_item_t *ci)
-{
- instance_definition_t* id;
- int status = 0;
-
- /* Registration variables */
- char cb_name[DATA_MAX_NAME_LEN];
-
- id = calloc(1, sizeof(*id));
- if (id == NULL)
- return (-1);
- id->instance = NULL;
- id->path = NULL;
- id->metric_list = NULL;
- id->time_from = -1;
- id->next = NULL;
-
- status = cf_util_get_string (ci, &id->path);
- if (status != 0) {
- sfree (id);
- return (status);
- }
-
- /* Use default interval. */
- id->interval = plugin_get_interval();
-
- for (int i = 0; i < ci->children_num; ++i){
- oconfig_item_t *option = ci->children + i;
- status = 0;
-
- if (strcasecmp("Instance", option->key) == 0)
- status = cf_util_get_string(option, &id->instance);
- else if (strcasecmp("Collect", option->key) == 0)
- status = tcsv_config_add_instance_collect(id, option);
- else if (strcasecmp("Interval", option->key) == 0)
- cf_util_get_cdtime(option, &id->interval);
- else if (strcasecmp("TimeFrom", option->key) == 0)
- status = tcsv_config_get_index (option, &id->time_from);
- else {
- WARNING("tail_csv plugin: Option `%s' not allowed here.", option->key);
- status = -1;
- }
-
- if (status != 0)
- break;
- }
-
- if (status != 0){
- tcsv_instance_definition_destroy(id);
- return (-1);
- }
-
- /* Verify all necessary options have been set. */
- if (id->path == NULL){
- WARNING("tail_csv plugin: Option `Path' must be set.");
- status = -1;
- } else if (id->metric_list == NULL){
- WARNING("tail_csv plugin: Option `Collect' must be set.");
- status = -1;
- }
-
- if (status != 0){
- tcsv_instance_definition_destroy(id);
- return (-1);
- }
-
- ssnprintf (cb_name, sizeof (cb_name), "tail_csv/%s", id->path);
-
- status = plugin_register_complex_read(NULL, cb_name, tcsv_read, id->interval,
- &(user_data_t) {
- .data = id,
- .free_func = tcsv_instance_definition_destroy,
- });
- if (status != 0){
- ERROR("tail_csv plugin: Registering complex read function failed.");
- tcsv_instance_definition_destroy(id);
- return (-1);
+static int tcsv_config_add_file(oconfig_item_t *ci) {
+ instance_definition_t *id;
+ int status = 0;
+
+ /* Registration variables */
+ char cb_name[DATA_MAX_NAME_LEN];
+
+ id = calloc(1, sizeof(*id));
+ if (id == NULL)
+ return (-1);
+ id->instance = NULL;
+ id->path = NULL;
+ id->metric_list = NULL;
+ id->time_from = -1;
+ id->next = NULL;
+
+ status = cf_util_get_string(ci, &id->path);
+ if (status != 0) {
+ sfree(id);
+ return (status);
+ }
+
+ /* Use default interval. */
+ id->interval = plugin_get_interval();
+
+ for (int i = 0; i < ci->children_num; ++i) {
+ oconfig_item_t *option = ci->children + i;
+ status = 0;
+
+ if (strcasecmp("Instance", option->key) == 0)
+ status = cf_util_get_string(option, &id->instance);
+ else if (strcasecmp("Collect", option->key) == 0)
+ status = tcsv_config_add_instance_collect(id, option);
+ else if (strcasecmp("Interval", option->key) == 0)
+ cf_util_get_cdtime(option, &id->interval);
+ else if (strcasecmp("TimeFrom", option->key) == 0)
+ status = tcsv_config_get_index(option, &id->time_from);
+ else {
+ WARNING("tail_csv plugin: Option `%s' not allowed here.", option->key);
+ status = -1;
}
- return (0);
+ if (status != 0)
+ break;
+ }
+
+ if (status != 0) {
+ tcsv_instance_definition_destroy(id);
+ return (-1);
+ }
+
+ /* Verify all necessary options have been set. */
+ if (id->path == NULL) {
+ WARNING("tail_csv plugin: Option `Path' must be set.");
+ status = -1;
+ } else if (id->metric_list == NULL) {
+ WARNING("tail_csv plugin: Option `Collect' must be set.");
+ status = -1;
+ }
+
+ if (status != 0) {
+ tcsv_instance_definition_destroy(id);
+ return (-1);
+ }
+
+ ssnprintf(cb_name, sizeof(cb_name), "tail_csv/%s", id->path);
+
+ status = plugin_register_complex_read(
+ NULL, cb_name, tcsv_read, id->interval,
+ &(user_data_t){
+ .data = id, .free_func = tcsv_instance_definition_destroy,
+ });
+ if (status != 0) {
+ ERROR("tail_csv plugin: Registering complex read function failed.");
+ tcsv_instance_definition_destroy(id);
+ return (-1);
+ }
+
+ return (0);
}
/* Parse blocks */
-static int tcsv_config(oconfig_item_t *ci){
- for (int i = 0; i < ci->children_num; ++i){
- oconfig_item_t *child = ci->children + i;
- if (strcasecmp("Metric", child->key) == 0)
- tcsv_config_add_metric(child);
- else if (strcasecmp("File", child->key) == 0)
- tcsv_config_add_file(child);
- else
- WARNING("tail_csv plugin: Ignore unknown config option `%s'.", child->key);
- }
-
- return (0);
+static int tcsv_config(oconfig_item_t *ci) {
+ for (int i = 0; i < ci->children_num; ++i) {
+ oconfig_item_t *child = ci->children + i;
+ if (strcasecmp("Metric", child->key) == 0)
+ tcsv_config_add_metric(child);
+ else if (strcasecmp("File", child->key) == 0)
+ tcsv_config_add_file(child);
+ else
+ WARNING("tail_csv plugin: Ignore unknown config option `%s'.",
+ child->key);
+ }
+
+ return (0);
} /* int tcsv_config */
static int tcsv_init(void) { /* {{{ */
- static _Bool have_init = 0;
- metric_definition_t *md;
-
- if (have_init)
- return (0);
-
- for (md = metric_head; md != NULL; md = md->next) {
- data_set_t const *ds;
-
- /* Retrieve the data source type from the types db. */
- ds = plugin_get_ds(md->type);
- if (ds == NULL)
- {
- ERROR ("tail_csv plugin: Failed to look up type \"%s\" for "
- "metric \"%s\". It may not be defined in the types.db "
- "file. Please read the types.db(5) manual page for more "
- "details.",
- md->type, md->name);
- continue;
- }
- else if (ds->ds_num != 1)
- {
- ERROR ("tail_csv plugin: The type \"%s\" has %zu data sources. "
- "Only types with a single data source are supported.",
- ds->type, ds->ds_num);
- continue;
- }
-
- md->data_source_type = ds->ds->type;
- }
+ static _Bool have_init = 0;
+ metric_definition_t *md;
+ if (have_init)
return (0);
+
+ for (md = metric_head; md != NULL; md = md->next) {
+ data_set_t const *ds;
+
+ /* Retrieve the data source type from the types db. */
+ ds = plugin_get_ds(md->type);
+ if (ds == NULL) {
+ ERROR("tail_csv plugin: Failed to look up type \"%s\" for "
+ "metric \"%s\". It may not be defined in the types.db "
+ "file. Please read the types.db(5) manual page for more "
+ "details.",
+ md->type, md->name);
+ continue;
+ } else if (ds->ds_num != 1) {
+ ERROR("tail_csv plugin: The type \"%s\" has %zu data sources. "
+ "Only types with a single data source are supported.",
+ ds->type, ds->ds_num);
+ continue;
+ }
+
+ md->data_source_type = ds->ds->type;
+ }
+
+ return (0);
} /* }}} int tcsv_init */
-static int tcsv_shutdown (void) {
- tcsv_metric_definition_destroy (metric_head);
- metric_head = NULL;
+static int tcsv_shutdown(void) {
+ tcsv_metric_definition_destroy(metric_head);
+ metric_head = NULL;
- return (0);
+ return (0);
}
-void module_register(void){
- plugin_register_complex_config("tail_csv", tcsv_config);
- plugin_register_init("tail_csv", tcsv_init);
- plugin_register_shutdown("tail_csv", tcsv_shutdown);
+void module_register(void) {
+ plugin_register_complex_config("tail_csv", tcsv_config);
+ plugin_register_init("tail_csv", tcsv_init);
+ plugin_register_shutdown("tail_csv", tcsv_shutdown);
}
/* vim: set sw=4 sts=4 et : */
projects / collectd.git / blobdiff