X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Ftail_csv.c;h=f303988553d09f696c231b212cf2cfb8ee9a4314;hb=6fe9925aebdc99cee1ae3d00a0a869477400c8e5;hp=faeb56f8eeb71c7e9a9de03cd98775248b1a7b29;hpb=a9683eb26fde194a19c698ca828f1b638185b868;p=collectd.git

diff --git a/src/tail_csv.c b/src/tail_csv.c
index faeb56f8..f3039885 100644
--- a/src/tail_csv.c
+++ b/src/tail_csv.c
@@ -23,540 +23,537 @@
 
 #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 *plugin_name;
+  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;
-
-    /* Register */
-    vl.values_len = 1;
-    vl.values = &v;
-
-    sstrncpy(vl.host, hostname_g, sizeof (vl.host));
-    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;
-
-    return (plugin_dispatch_values(&vl));
-}
-
-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 ());
+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;
 
-    return (DOUBLE_TO_CDTIME_T (t));
-}
+  /* Register */
+  vl.values_len = 1;
+  vl.values = &v;
 
-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;
+  sstrncpy(vl.plugin, (id->plugin_name != NULL) ? id->plugin_name : "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));
 
-    if (md->data_source_type == -1)
-        return (EINVAL);
+  vl.time = t;
+  vl.interval = id->interval;
 
-    assert (md->value_from >= 0);
-    if (((size_t) md->value_from) >= fields_num)
-        return (EINVAL);
+  return plugin_dispatch_values(&vl);
+}
 
-    status = parse_value (fields[md->value_from], &v, md->data_source_type);
-    if (status != 0)
-        return (status);
+static cdtime_t parse_time(char const *tbuf) {
+  double t;
+  char *endptr = NULL;
 
-    if (id->time_from >= 0) {
-        if (((size_t) id->time_from) >= fields_num)
-            return (EINVAL);
-        t = parse_time (fields[id->time_from]);
-    }
+  errno = 0;
+  t = strtod(tbuf, &endptr);
+  if ((errno != 0) || (endptr == NULL) || (endptr[0] != 0))
+    return cdtime();
 
-    return (tcsv_submit (id, md, v, t));
+  return DOUBLE_TO_CDTIME_T(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 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_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;
-        }
-    }
+  if (md->data_source_type == -1)
+    return EINVAL;
 
-    /* Ignore empty lines. */
-    if ((buffer_size == 0) || (buffer[0] == '#'))
-        return (0);
+  assert(md->value_from >= 0);
+  if (((size_t)md->value_from) >= fields_num)
+    return EINVAL;
 
-    /* Count the number of fields. */
-    metrics_num = 1;
-    for (i = 0; i < buffer_size; i++) {
-        if (buffer[i] == ',')
-            metrics_num++;
-    }
+  status = parse_value(fields[md->value_from], &v, md->data_source_type);
+  if (status != 0)
+    return status;
 
-    if (metrics_num == 1) {
-        ERROR("tail_csv plugin: last line of `%s' does not contain "
-                "enough values.", id->path);
-        return (-1);
-    }
+  if (id->time_from >= 0) {
+    if (((size_t)id->time_from) >= fields_num)
+      return EINVAL;
+    t = parse_time(fields[id->time_from]);
+  }
 
-    /* Create a list of all values */
-    metrics = calloc (metrics_num, sizeof (*metrics));
-    if (metrics == NULL) {
-        ERROR ("tail_csv plugin: calloc failed.");
-        return (ENOMEM);
-    }
+  return tcsv_submit(id, md, v, t);
+}
 
-    ptr = buffer;
-    metrics[0] = ptr;
-    i = 1;
-    for (ptr = buffer; *ptr != 0; ptr++) {
-        if (*ptr != ',')
-            continue;
+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;
+}
 
-        *ptr = 0;
-        metrics[i] = ptr + 1;
-        i++;
+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;
     }
-    assert (i == metrics_num);
-
-    /* Register values */
-    for (i = 0; i < id->metric_list_len; ++i){
-        metric_definition_t *md = id->metric_list[i];
+  }
+
+  /* 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;
+  }
+
+  /* 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;
+}
 
-        if (!tcsv_check_index (md->value_from, metrics_num, md->name)
-                || !tcsv_check_index (id->time_from, metrics_num, md->name))
-            continue;
+static int tcsv_read(user_data_t *ud) {
+  instance_definition_t *id;
+  id = ud->data;
 
-        tcsv_read_metric (id, md, metrics, metrics_num);
+  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;
     }
+  }
 
-    /* Free up resources */
-    sfree (metrics);
-    return (0);
-}
+  while (42) {
+    char buffer[1024];
+    size_t buffer_len;
+    int status;
 
-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);
-        }
+    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;
     }
 
-    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);
-    }
+    buffer_len = strlen(buffer);
+    if (buffer_len == 0)
+      break;
 
-    return (0);
+    tcsv_read_buffer(id, buffer, buffer_len);
+  }
+
+  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->plugin_name);
+  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->plugin_name = NULL;
+  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 if (strcasecmp("Plugin", option->key) == 0)
+      status = cf_util_get_string(option, &id->plugin_name);
+    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 soure 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;
     }
 
-    return (0);
+    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 : */