X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Fsnmp.c;h=9aa63f7915475e3e34175ac305f9243f07629cc1;hb=1a252483e9c58ac64069a60d16ada29d5994d125;hp=7b3295f5c5613fa345e96781b8d1b0a3259004af;hpb=fbbe83cf893e34370bee2ece872c4655b13778f8;p=collectd.git diff --git a/src/snmp.c b/src/snmp.c index 7b3295f5..9aa63f79 100644 --- a/src/snmp.c +++ b/src/snmp.c @@ -46,8 +46,9 @@ typedef struct oid_s oid_t; struct instance_s { bool configured; - bool is_plugin; oid_t oid; + char *prefix; + char *value; }; typedef struct instance_s instance_t; @@ -55,11 +56,10 @@ struct data_definition_s { char *name; /* used to reference this from the `Collect' option */ char *type; /* used to find the data_set */ bool is_table; - instance_t instance; + instance_t type_instance; + instance_t plugin_instance; + instance_t host; char *plugin_name; - char *plugin_instance; - char *type_instance; - char *instance_prefix; oid_t *values; size_t values_len; double scale; @@ -119,7 +119,8 @@ typedef struct csnmp_cell_value_s csnmp_cell_value_t; typedef enum { OID_TYPE_SKIP = 0, OID_TYPE_VARIABLE, - OID_TYPE_INSTANCE, + OID_TYPE_TYPEINSTANCE, + OID_TYPE_PLUGININSTANCE, OID_TYPE_HOST, } csnmp_oid_type_t; @@ -210,6 +211,21 @@ static void csnmp_host_definition_destroy(void *arg) /* {{{ */ sfree(hd); } /* }}} void csnmp_host_definition_destroy */ +static void csnmp_data_definition_destroy(data_definition_t *dd) { + sfree(dd->name); + sfree(dd->type); + sfree(dd->plugin_name); + sfree(dd->plugin_instance.prefix); + sfree(dd->plugin_instance.value); + sfree(dd->type_instance.prefix); + sfree(dd->type_instance.value); + sfree(dd->host.prefix); + sfree(dd->host.value); + sfree(dd->values); + sfree(dd->ignores); + sfree(dd); +} /* void csnmp_data_definition_destroy */ + /* Many functions to handle the configuration. {{{ */ /* First there are many functions which do configuration stuff. It's a big * bloated and messy, I'm afraid. */ @@ -219,7 +235,7 @@ static void csnmp_host_definition_destroy(void *arg) /* {{{ */ * csnmp_config * +-> call_snmp_init_once * +-> csnmp_config_add_data - * ! +-> csnmp_config_add_data_instance + * ! +-> csnmp_config_configure_data_instance * ! +-> csnmp_config_add_data_values * +-> csnmp_config_add_host * +-> csnmp_config_add_host_version @@ -236,38 +252,29 @@ static void call_snmp_init_once(void) { have_init = 1; } /* void call_snmp_init_once */ -static int csnmp_config_add_data_instance_oid(data_definition_t *dd, - oconfig_item_t *ci, - bool is_plugin) { +static int csnmp_config_configure_data_instance(instance_t *instance, + oconfig_item_t *ci) { char buffer[DATA_MAX_NAME_LEN]; - int status; - status = cf_util_get_string_buffer(ci, buffer, sizeof(buffer)); + int status = cf_util_get_string_buffer(ci, buffer, sizeof(buffer)); if (status != 0) return status; - if (dd->instance.configured) { - ERROR("snmp plugin: Only one of options `TypeInstanceOID', " - "`PluginInstanceOID' or `Instance' can be used in `Data' block."); - return -1; - } - - dd->instance.is_plugin = is_plugin; - dd->instance.configured = true; + instance->configured = true; if (strlen(buffer) == 0) { return 0; } - dd->instance.oid.oid_len = MAX_OID_LEN; + instance->oid.oid_len = MAX_OID_LEN; - if (!read_objid(buffer, dd->instance.oid.oid, &dd->instance.oid.oid_len)) { + if (!read_objid(buffer, instance->oid.oid, &instance->oid.oid_len)) { ERROR("snmp plugin: read_objid (%s) failed.", buffer); return -1; } return 0; -} /* int csnmp_config_add_data_instance_oid */ +} /* int csnmp_config_configure_data_instance */ static int csnmp_config_add_data_values(data_definition_t *dd, oconfig_item_t *ci) { @@ -304,7 +311,7 @@ static int csnmp_config_add_data_values(data_definition_t *dd, } return 0; -} /* int csnmp_config_add_data_instance */ +} /* int csnmp_config_configure_data_instance */ static int csnmp_config_add_data_blacklist(data_definition_t *dd, oconfig_item_t *ci) { @@ -363,30 +370,43 @@ static int csnmp_config_add_data(oconfig_item_t *ci) { else if (strcasecmp("Instance", option->key) == 0) { if (dd->is_table) { /* Instance is OID */ - WARNING("snmp plugin: Option `Instance' is deprecated, please update " - "Data \"%s\" block to use option `TypeInstanceOID'.", - dd->name); - status = csnmp_config_add_data_instance_oid(dd, option, - false /* type instance */); + WARNING( + "snmp plugin: data %s: Option `Instance' is deprecated, please use " + "option `TypeInstanceOID'.", + dd->name); + status = + csnmp_config_configure_data_instance(&dd->type_instance, option); } else { /* Instance is a simple string */ - WARNING("snmp plugin: Option `Instance' is deprecated, please update " - "Data \"%s\" block to use option `TypeInstance'.", - dd->name); - status = cf_util_get_string(option, &dd->type_instance); + WARNING( + "snmp plugin: data %s: Option `Instance' is deprecated, please use " + "option `TypeInstance'.", + dd->name); + status = cf_util_get_string(option, &dd->type_instance.value); } + } else if (strcasecmp("InstancePrefix", option->key) == 0) { + WARNING("snmp plugin: data %s: Option `InstancePrefix' is deprecated, " + "please use " + "option `TypeInstancePrefix'.", + dd->name); + status = cf_util_get_string(option, &dd->type_instance.prefix); } else if (strcasecmp("PluginInstance", option->key) == 0) - status = cf_util_get_string(option, &dd->plugin_instance); + status = cf_util_get_string(option, &dd->plugin_instance.value); else if (strcasecmp("TypeInstance", option->key) == 0) - status = cf_util_get_string(option, &dd->type_instance); + status = cf_util_get_string(option, &dd->type_instance.value); else if (strcasecmp("PluginInstanceOID", option->key) == 0) - status = csnmp_config_add_data_instance_oid(dd, option, - true /* plugin instance */); + status = + csnmp_config_configure_data_instance(&dd->plugin_instance, option); + else if (strcasecmp("PluginInstancePrefix", option->key) == 0) + status = cf_util_get_string(option, &dd->plugin_instance.prefix); else if (strcasecmp("TypeInstanceOID", option->key) == 0) - status = csnmp_config_add_data_instance_oid(dd, option, - false /* type instance */); - else if (strcasecmp("InstancePrefix", option->key) == 0) - status = cf_util_get_string(option, &dd->instance_prefix); + status = csnmp_config_configure_data_instance(&dd->type_instance, option); + else if (strcasecmp("TypeInstancePrefix", option->key) == 0) + status = cf_util_get_string(option, &dd->type_instance.prefix); + else if (strcasecmp("HostOID", option->key) == 0) + status = csnmp_config_configure_data_instance(&dd->host, option); + else if (strcasecmp("HostPrefix", option->key) == 0) + status = cf_util_get_string(option, &dd->host.prefix); else if (strcasecmp("Values", option->key) == 0) status = csnmp_config_add_data_values(dd, option); else if (strcasecmp("Shift", option->key) == 0) @@ -398,7 +418,8 @@ static int csnmp_config_add_data(oconfig_item_t *ci) { else if (strcasecmp("InvertMatch", option->key) == 0) status = cf_util_get_boolean(option, &dd->invert_match); else { - WARNING("snmp plugin: Option `%s' not allowed here.", option->key); + WARNING("snmp plugin: data %s: Option `%s' not allowed here.", dd->name, + option->key); status = -1; } @@ -408,34 +429,62 @@ static int csnmp_config_add_data(oconfig_item_t *ci) { while (status == 0) { if (dd->is_table) { - if (dd->plugin_instance && dd->instance.is_plugin) { - WARNING("snmp plugin: Option `PluginInstance' will be ignored for " - "Data `%s'", + /* Set type_instance to SUBID by default */ + if (!dd->type_instance.configured && !dd->host.configured) + dd->type_instance.configured = true; + + if (dd->plugin_instance.value && dd->plugin_instance.configured) { + WARNING( + "snmp plugin: data %s: Option `PluginInstance' will be ignored.", + dd->name); + } + if (dd->type_instance.value && dd->type_instance.configured) { + WARNING("snmp plugin: data %s: Option `TypeInstance' will be ignored.", + dd->name); + } + if (dd->type_instance.prefix && !dd->type_instance.configured) { + WARNING("snmp plugin: data %s: Option `TypeInstancePrefix' will be " + "ignored.", + dd->name); + } + if (dd->plugin_instance.prefix && !dd->plugin_instance.configured) { + WARNING("snmp plugin: data %s: Option `PluginInstancePrefix' will be " + "ignored.", dd->name); } - if (dd->type_instance && !dd->instance.is_plugin) { - WARNING("snmp plugin: Option `TypeInstance' will be ignored for Data " - "`%s'", + if (dd->host.prefix && !dd->host.configured) { + WARNING("snmp plugin: data %s: Option `HostPrefix' will be ignored.", dd->name); } } else { - if (dd->instance.configured) { - if (dd->instance.is_plugin) { - WARNING("snmp plugin: Option `PluginInstanceOID' will be ignored for " - "Data `%s'", - dd->name); - } else { - WARNING("snmp plugin: Option `TypeInstanceOID' will be ignored for " - "Data `%s'", - dd->name); - } + if (dd->plugin_instance.oid.oid_len > 0) { + WARNING("snmp plugin: data %s: Option `PluginInstanceOID' will be " + "ignored.", + dd->name); } - - if (dd->instance_prefix) { - WARNING("snmp plugin: data %s: InstancePrefix is ignored when `Table' " - "is set to `false'.", + if (dd->type_instance.oid.oid_len > 0) { + WARNING( + "snmp plugin: data %s: Option `TypeInstanceOID' will be ignored.", + dd->name); + } + if (dd->type_instance.prefix) { + WARNING("snmp plugin: data %s: Option `TypeInstancePrefix' is ignored " + "when `Table' " + "set to `false'.", + dd->name); + } + if (dd->plugin_instance.prefix) { + WARNING("snmp plugin: data %s: Option `PluginInstancePrefix' is " + "ignored when " + "`Table' set to `false'.", dd->name); } + if (dd->host.prefix) { + WARNING( + "snmp plugin: data %s: Option `HostPrefix' is ignored when `Table' " + "set to `false'.", + dd->name); + } } if (dd->type == NULL) { @@ -453,15 +502,7 @@ static int csnmp_config_add_data(oconfig_item_t *ci) { } /* while (status == 0) */ if (status != 0) { - sfree(dd->name); - sfree(dd->type); - sfree(dd->plugin_name); - sfree(dd->plugin_instance); - sfree(dd->type_instance); - sfree(dd->instance_prefix); - sfree(dd->values); - sfree(dd->ignores); - sfree(dd); + csnmp_data_definition_destroy(dd); return -1; } @@ -470,11 +511,16 @@ static int csnmp_config_add_data(oconfig_item_t *ci) { dd->name, dd->type, (dd->is_table) ? "true" : "false", dd->values_len); DEBUG("snmp plugin: plugin_instance = %s, type_instance = %s,", - dd->plugin_instance, dd->type_instance); + dd->plugin_instance.value, dd->type_instance.value); - DEBUG("snmp plugin: instance_by_oid = %s, to_plugin_instance = %s }", - (dd->instance.oid.oid_len > 0) ? "true" : "SUBID", - (dd->instance.is_plugin) ? "true" : "false"); + DEBUG("snmp plugin: type_instance_by_oid = %s, plugin_instance_by_oid " + "= %s }", + (dd->type_instance.oid.oid_len > 0) + ? "true" + : ((dd->type_instance.configured) ? "SUBID" : "false"), + (dd->plugin_instance.oid.oid_len > 0) + ? "true" + : ((dd->plugin_instance.configured) ? "SUBID" : "false")); if (data_head == NULL) data_head = dd; @@ -1101,6 +1147,7 @@ static int csnmp_strvbcopy(char *dst, /* {{{ */ } /* }}} int csnmp_strvbcopy */ static csnmp_cell_char_t *csnmp_get_char_cell(const struct variable_list *vb, + const oid_t *root_oid, const host_definition_t *hd, const data_definition_t *dd) { @@ -1117,7 +1164,7 @@ static csnmp_cell_char_t *csnmp_get_char_cell(const struct variable_list *vb, oid_t vb_name; csnmp_oid_init(&vb_name, vb->name, vb->name_length); - if (csnmp_oid_suffix(&il->suffix, &vb_name, &dd->instance.oid) != 0) { + if (csnmp_oid_suffix(&il->suffix, &vb_name, root_oid) != 0) { sfree(il); return NULL; } @@ -1168,14 +1215,27 @@ static bool csnmp_ignore_instance(csnmp_cell_char_t *cell, return 0; } /* bool csnmp_ignore_instance */ +static void csnmp_cell_replace_reserved_chars(csnmp_cell_char_t *cell) { + for (char *ptr = cell->value; *ptr != '\0'; ptr++) { + if ((*ptr > 0) && (*ptr < 32)) + *ptr = ' '; + else if (*ptr == '/') + *ptr = '_'; + } +} + static int csnmp_dispatch_table(host_definition_t *host, data_definition_t *data, - csnmp_cell_char_t *instance_cells, + csnmp_cell_char_t *type_instance_cells, + csnmp_cell_char_t *plugin_instance_cells, + csnmp_cell_char_t *hostname_cells, csnmp_cell_value_t **value_cells) { const data_set_t *ds; value_list_t vl = VALUE_LIST_INIT; - csnmp_cell_char_t *instance_cell_ptr; + csnmp_cell_char_t *type_instance_cell_ptr = type_instance_cells; + csnmp_cell_char_t *plugin_instance_cell_ptr = plugin_instance_cells; + csnmp_cell_char_t *hostname_cell_ptr = hostname_cells; csnmp_cell_value_t *value_cell_ptr[data->values_len]; size_t i; @@ -1190,12 +1250,9 @@ static int csnmp_dispatch_table(host_definition_t *host, assert(ds->ds_num == data->values_len); assert(data->values_len > 0); - instance_cell_ptr = instance_cells; - for (i = 0; i < data->values_len; i++) value_cell_ptr[i] = value_cells[i]; - sstrncpy(vl.host, host->name, sizeof(vl.host)); sstrncpy(vl.plugin, data->plugin_name, sizeof(vl.plugin)); vl.interval = host->interval; @@ -1205,13 +1262,13 @@ static int csnmp_dispatch_table(host_definition_t *host, bool suffix_skipped = 0; /* Determine next suffix to handle. */ - if (instance_cells != NULL) { - if (instance_cell_ptr == NULL) { + if (type_instance_cells != NULL) { + if (type_instance_cell_ptr == NULL) { have_more = 0; continue; } - memcpy(¤t_suffix, &instance_cell_ptr->suffix, + memcpy(¤t_suffix, &type_instance_cell_ptr->suffix, sizeof(current_suffix)); } else { /* no instance configured */ @@ -1224,6 +1281,55 @@ static int csnmp_dispatch_table(host_definition_t *host, memcpy(¤t_suffix, &ptr->suffix, sizeof(current_suffix)); } + /* + char oid_buffer[1024] = {0}; + snprint_objid(oid_buffer, sizeof(oid_buffer) - 1, current_suffix.oid, + current_suffix.oid_len); + DEBUG("SNMP PLUGIN: SUFFIX %s", oid_buffer); + */ + + /* Update plugin_instance_cell_ptr to point expected suffix */ + if (plugin_instance_cells != NULL) { + while ((plugin_instance_cell_ptr != NULL) && + (csnmp_oid_compare(&plugin_instance_cell_ptr->suffix, + ¤t_suffix) < 0)) + plugin_instance_cell_ptr = plugin_instance_cell_ptr->next; + + if (plugin_instance_cell_ptr == NULL) { + have_more = 0; + continue; + } + + if (csnmp_oid_compare(&plugin_instance_cell_ptr->suffix, + ¤t_suffix) > 0) { + /* This suffix is missing in the subtree. Indicate this with the + * "suffix_skipped" flag and try the next instance / suffix. */ + suffix_skipped = 1; + NOTICE("snmp plugin: suffix skipped, variable not found for " + "TypeInstanceOID."); + } + } + + /* Update hostname_cell_ptr to point expected suffix */ + if (hostname_cells != NULL) { + while ( + (hostname_cell_ptr != NULL) && + (csnmp_oid_compare(&hostname_cell_ptr->suffix, ¤t_suffix) < 0)) + hostname_cell_ptr = hostname_cell_ptr->next; + + if (hostname_cell_ptr == NULL) { + have_more = 0; + continue; + } + + if (csnmp_oid_compare(&hostname_cell_ptr->suffix, ¤t_suffix) > 0) { + /* This suffix is missing in the subtree. Indicate this with the + * "suffix_skipped" flag and try the next instance / suffix. */ + suffix_skipped = 1; + NOTICE("snmp plugin: suffix skipped, variable not found for HostOID."); + } + } + /* Update all the value_cell_ptr to point at the entry with the same * trailing partial OID */ for (i = 0; i < data->values_len; i++) { @@ -1240,6 +1346,8 @@ static int csnmp_dispatch_table(host_definition_t *host, /* This suffix is missing in the subtree. Indicate this with the * "suffix_skipped" flag and try the next instance / suffix. */ suffix_skipped = 1; + NOTICE( + "snmp plugin: suffix skipped, variable not found for Value OID."); break; } } /* for (i = 0; i < columns; i++) */ @@ -1249,8 +1357,8 @@ static int csnmp_dispatch_table(host_definition_t *host, /* Matching the values failed. Start from the beginning again. */ if (suffix_skipped) { - if (instance_cells != NULL) - instance_cell_ptr = instance_cell_ptr->next; + if (type_instance_cells != NULL) + type_instance_cell_ptr = type_instance_cell_ptr->next; else value_cell_ptr[0] = value_cell_ptr[0]->next; @@ -1258,7 +1366,7 @@ static int csnmp_dispatch_table(host_definition_t *host, } /* if we reach this line, all value_cell_ptr[i] are non-NULL and are set - * to the same subid. instance_cell_ptr is either NULL or points to the + * to the same subid. type_instance_cell_ptr is either NULL or points to the * same subid, too. */ #if COLLECT_DEBUG for (i = 1; i < data->values_len; i++) { @@ -1266,41 +1374,67 @@ static int csnmp_dispatch_table(host_definition_t *host, assert(csnmp_oid_compare(&value_cell_ptr[i - 1]->suffix, &value_cell_ptr[i]->suffix) == 0); } - assert((instance_cell_ptr == NULL) || - (csnmp_oid_compare(&instance_cell_ptr->suffix, + assert((type_instance_cell_ptr == NULL) || + (csnmp_oid_compare(&type_instance_cell_ptr->suffix, + &value_cell_ptr[0]->suffix) == 0)); + assert((plugin_instance_cell_ptr == NULL) || + (csnmp_oid_compare(&plugin_instance_cell_ptr->suffix, + &value_cell_ptr[0]->suffix) == 0)); + assert((hostname_cell_ptr == NULL) || + (csnmp_oid_compare(&hostname_cell_ptr->suffix, &value_cell_ptr[0]->suffix) == 0)); #endif sstrncpy(vl.type, data->type, sizeof(vl.type)); { - char temp[DATA_MAX_NAME_LEN]; + if (data->host.configured) { + char temp[DATA_MAX_NAME_LEN]; + if (hostname_cell_ptr == NULL) + csnmp_oid_to_string(temp, sizeof(temp), ¤t_suffix); + else + sstrncpy(temp, hostname_cell_ptr->value, sizeof(temp)); - if (instance_cell_ptr == NULL) - csnmp_oid_to_string(temp, sizeof(temp), ¤t_suffix); - else - sstrncpy(temp, instance_cell_ptr->value, sizeof(temp)); + if (data->host.prefix == NULL) + sstrncpy(vl.host, temp, sizeof(vl.host)); + else + snprintf(vl.host, sizeof(vl.host), "%s%s", data->host.prefix, temp); + } else { + sstrncpy(vl.host, host->name, sizeof(vl.host)); + } - if (data->instance.is_plugin) { - if (data->instance_prefix == NULL) - sstrncpy(vl.plugin_instance, temp, sizeof(vl.plugin_instance)); + if (data->type_instance.configured) { + char temp[DATA_MAX_NAME_LEN]; + if (type_instance_cell_ptr == NULL) + csnmp_oid_to_string(temp, sizeof(temp), ¤t_suffix); else - snprintf(vl.plugin_instance, sizeof(vl.plugin_instance), "%s%s", - data->instance_prefix, temp); + sstrncpy(temp, type_instance_cell_ptr->value, sizeof(temp)); - if (data->type_instance) - sstrncpy(vl.type_instance, data->type_instance, - sizeof(vl.type_instance)); - } else { - if (data->instance_prefix == NULL) + if (data->type_instance.prefix == NULL) sstrncpy(vl.type_instance, temp, sizeof(vl.type_instance)); else snprintf(vl.type_instance, sizeof(vl.type_instance), "%s%s", - data->instance_prefix, temp); + data->type_instance.prefix, temp); + } else if (data->type_instance.value) { + sstrncpy(vl.type_instance, data->type_instance.value, + sizeof(vl.type_instance)); + } + + if (data->plugin_instance.configured) { + char temp[DATA_MAX_NAME_LEN]; + if (plugin_instance_cell_ptr == NULL) + csnmp_oid_to_string(temp, sizeof(temp), ¤t_suffix); + else + sstrncpy(temp, plugin_instance_cell_ptr->value, sizeof(temp)); - if (data->plugin_instance) - sstrncpy(vl.plugin_instance, data->plugin_instance, - sizeof(vl.plugin_instance)); + if (data->plugin_instance.prefix == NULL) + sstrncpy(vl.plugin_instance, temp, sizeof(vl.plugin_instance)); + else + snprintf(vl.plugin_instance, sizeof(vl.plugin_instance), "%s%s", + data->plugin_instance.prefix, temp); + } else if (data->plugin_instance.value) { + sstrncpy(vl.plugin_instance, data->plugin_instance.value, + sizeof(vl.plugin_instance)); } } @@ -1317,8 +1451,8 @@ static int csnmp_dispatch_table(host_definition_t *host, vl.values_len = 0; vl.values = NULL; - if (instance_cells != NULL) - instance_cell_ptr = instance_cell_ptr->next; + if (type_instance_cells != NULL) + type_instance_cell_ptr = type_instance_cell_ptr->next; else value_cell_ptr[0] = value_cell_ptr[0]->next; } /* while (have_more) */ @@ -1335,7 +1469,13 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { size_t oid_list_len = data->values_len; - if (data->instance.oid.oid_len > 0) + if (data->type_instance.oid.oid_len > 0) + oid_list_len++; + + if (data->plugin_instance.oid.oid_len > 0) + oid_list_len++; + + if (data->host.oid.oid_len > 0) oid_list_len++; /* Holds the last OID returned by the device. We use this in the GETNEXT @@ -1350,10 +1490,13 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { /* `value_list_head' and `value_cells_tail' implement a linked list for each * value. `instance_cells_head' and `instance_cells_tail' implement a linked - * list of - * instance names. This is used to jump gaps in the table. */ - csnmp_cell_char_t *instance_cells_head; - csnmp_cell_char_t *instance_cells_tail; + * list of instance names. This is used to jump gaps in the table. */ + csnmp_cell_char_t *type_instance_cells_head = NULL; + csnmp_cell_char_t *type_instance_cells_tail = NULL; + csnmp_cell_char_t *plugin_instance_cells_head = NULL; + csnmp_cell_char_t *plugin_instance_cells_tail = NULL; + csnmp_cell_char_t *hostname_cells_head = NULL; + csnmp_cell_char_t *hostname_cells_tail = NULL; csnmp_cell_value_t **value_cells_head; csnmp_cell_value_t **value_cells_tail; @@ -1386,9 +1529,22 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { /* We need a copy of all the OIDs, because GETNEXT will destroy them. */ memcpy(oid_list, data->values, data->values_len * sizeof(oid_t)); - if (data->instance.oid.oid_len > 0) { - memcpy(oid_list + i, &data->instance.oid, sizeof(oid_t)); - oid_list_todo[i] = OID_TYPE_INSTANCE; + if (data->type_instance.oid.oid_len > 0) { + memcpy(oid_list + i, &data->type_instance.oid, sizeof(oid_t)); + oid_list_todo[i] = OID_TYPE_TYPEINSTANCE; + i++; + } + + if (data->plugin_instance.oid.oid_len > 0) { + memcpy(oid_list + i, &data->plugin_instance.oid, sizeof(oid_t)); + oid_list_todo[i] = OID_TYPE_PLUGININSTANCE; + i++; + } + + if (data->host.oid.oid_len > 0) { + memcpy(oid_list + i, &data->host.oid, sizeof(oid_t)); + oid_list_todo[i] = OID_TYPE_HOST; + i++; } /* We're going to construct n linked lists, one for each "value". @@ -1403,9 +1559,6 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { return -1; } - instance_cells_head = NULL; - instance_cells_tail = NULL; - status = 0; while (status == 0) { req = snmp_pdu_create(SNMP_MSG_GETNEXT); @@ -1519,12 +1672,14 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { /* An instance is configured and the res variable we process is the * instance value */ - if (oid_list_todo[i] == OID_TYPE_INSTANCE) { + if (oid_list_todo[i] == OID_TYPE_TYPEINSTANCE) { if ((vb->type == SNMP_ENDOFMIBVIEW) || - (snmp_oid_ncompare( - data->instance.oid.oid, data->instance.oid.oid_len, vb->name, - vb->name_length, data->instance.oid.oid_len) != 0)) { - DEBUG("snmp plugin: host = %s; data = %s; Instance left its subtree.", + (snmp_oid_ncompare(data->type_instance.oid.oid, + data->type_instance.oid.oid_len, vb->name, + vb->name_length, + data->type_instance.oid.oid_len) != 0)) { + DEBUG("snmp plugin: host = %s; data = %s; TypeInstance left its " + "subtree.", host->name, data->name); oid_list_todo[i] = 0; continue; @@ -1532,7 +1687,8 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { /* Allocate a new `csnmp_cell_char_t', insert the instance name and * add it to the list */ - csnmp_cell_char_t *cell = csnmp_get_char_cell(vb, host, data); + csnmp_cell_char_t *cell = + csnmp_get_char_cell(vb, &data->type_instance.oid, host, data); if (cell == NULL) { ERROR("snmp plugin: host %s: csnmp_get_char_cell() failed.", host->name); @@ -1543,20 +1699,67 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { if (csnmp_ignore_instance(cell, data)) { sfree(cell); } else { - /**/ - for (char *ptr = cell->value; *ptr != '\0'; ptr++) { - if ((*ptr > 0) && (*ptr < 32)) - *ptr = ' '; - else if (*ptr == '/') - *ptr = '_'; - } - - DEBUG("snmp plugin: il->instance = `%s';", cell->value); - csnmp_cells_append(&instance_cells_head, &instance_cells_tail, cell); + csnmp_cell_replace_reserved_chars(cell); + + DEBUG("snmp plugin: il->type_instance = `%s';", cell->value); + csnmp_cells_append(&type_instance_cells_head, + &type_instance_cells_tail, cell); + } + } else if (oid_list_todo[i] == OID_TYPE_PLUGININSTANCE) { + if ((vb->type == SNMP_ENDOFMIBVIEW) || + (snmp_oid_ncompare(data->plugin_instance.oid.oid, + data->plugin_instance.oid.oid_len, vb->name, + vb->name_length, + data->plugin_instance.oid.oid_len) != 0)) { + DEBUG("snmp plugin: host = %s; data = %s; TypeInstance left its " + "subtree.", + host->name, data->name); + oid_list_todo[i] = 0; + continue; } + + /* Allocate a new `csnmp_cell_char_t', insert the instance name and + * add it to the list */ + csnmp_cell_char_t *cell = + csnmp_get_char_cell(vb, &data->plugin_instance.oid, host, data); + if (cell == NULL) { + ERROR("snmp plugin: host %s: csnmp_get_char_cell() failed.", + host->name); + status = -1; + break; + } + + csnmp_cell_replace_reserved_chars(cell); + + DEBUG("snmp plugin: il->plugin_instance = `%s';", cell->value); + csnmp_cells_append(&plugin_instance_cells_head, + &plugin_instance_cells_tail, cell); } else if (oid_list_todo[i] == OID_TYPE_HOST) { - /* todo */ - assert(1 == 0); + if ((vb->type == SNMP_ENDOFMIBVIEW) || + (snmp_oid_ncompare(data->host.oid.oid, data->host.oid.oid_len, + vb->name, vb->name_length, + data->host.oid.oid_len) != 0)) { + DEBUG("snmp plugin: host = %s; data = %s; Host left its subtree.", + host->name, data->name); + oid_list_todo[i] = 0; + continue; + } + + /* Allocate a new `csnmp_cell_char_t', insert the instance name and + * add it to the list */ + csnmp_cell_char_t *cell = + csnmp_get_char_cell(vb, &data->host.oid, host, data); + if (cell == NULL) { + ERROR("snmp plugin: host %s: csnmp_get_char_cell() failed.", + host->name); + status = -1; + break; + } + + csnmp_cell_replace_reserved_chars(cell); + + DEBUG("snmp plugin: il->hostname = `%s';", cell->value); + csnmp_cells_append(&hostname_cells_head, &hostname_cells_tail, cell); } else /* The variable we are processing is a normal value */ { assert(oid_list_todo[i] == OID_TYPE_VARIABLE); @@ -1568,10 +1771,10 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { csnmp_oid_init(&vb_name, vb->name, vb->name_length); - DEBUG( - "snmp plugin: src.oid_len = %d root.oid_len = %d is_endofmib = %s", - vb_name.oid_len, (data->values + i)->oid_len, - (vb->type == SNMP_ENDOFMIBVIEW) ? "true" : "false"); + DEBUG("snmp plugin: src.oid_len = %" PRIsz " root.oid_len = %" PRIsz + " is_endofmib = %s", + vb_name.oid_len, (data->values + i)->oid_len, + (vb->type == SNMP_ENDOFMIBVIEW) ? "true" : "false"); /* Calculate the current suffix. This is later used to check that the * suffix is increasing. This also checks if we left the subtree */ @@ -1631,13 +1834,27 @@ static int csnmp_read_table(host_definition_t *host, data_definition_t *data) { res = NULL; if (status == 0) - csnmp_dispatch_table(host, data, instance_cells_head, value_cells_head); + csnmp_dispatch_table(host, data, type_instance_cells_head, + plugin_instance_cells_head, hostname_cells_head, + value_cells_head); /* Free all allocated variables here */ - while (instance_cells_head != NULL) { - csnmp_cell_char_t *next = instance_cells_head->next; - sfree(instance_cells_head); - instance_cells_head = next; + while (type_instance_cells_head != NULL) { + csnmp_cell_char_t *next = type_instance_cells_head->next; + sfree(type_instance_cells_head); + type_instance_cells_head = next; + } + + while (plugin_instance_cells_head != NULL) { + csnmp_cell_char_t *next = plugin_instance_cells_head->next; + sfree(plugin_instance_cells_head); + plugin_instance_cells_head = next; + } + + while (hostname_cells_head != NULL) { + csnmp_cell_char_t *next = hostname_cells_head->next; + sfree(hostname_cells_head); + hostname_cells_head = next; } for (i = 0; i < data->values_len; i++) { @@ -1701,10 +1918,11 @@ static int csnmp_read_value(host_definition_t *host, data_definition_t *data) { sstrncpy(vl.host, host->name, sizeof(vl.host)); sstrncpy(vl.plugin, data->plugin_name, sizeof(vl.plugin)); sstrncpy(vl.type, data->type, sizeof(vl.type)); - if (data->type_instance) - sstrncpy(vl.type_instance, data->type_instance, sizeof(vl.type_instance)); - if (data->plugin_instance) - sstrncpy(vl.plugin_instance, data->plugin_instance, + if (data->type_instance.value) + sstrncpy(vl.type_instance, data->type_instance.value, + sizeof(vl.type_instance)); + if (data->plugin_instance.value) + sstrncpy(vl.plugin_instance, data->plugin_instance.value, sizeof(vl.plugin_instance)); vl.interval = host->interval; @@ -1817,15 +2035,7 @@ static int csnmp_shutdown(void) { while (data_this != NULL) { data_next = data_this->next; - sfree(data_this->name); - sfree(data_this->type); - sfree(data_this->plugin_name); - sfree(data_this->plugin_instance); - sfree(data_this->type_instance); - sfree(data_this->instance_prefix); - sfree(data_this->values); - sfree(data_this->ignores); - sfree(data_this); + csnmp_data_definition_destroy(data_this); data_this = data_next; }