author | Marc Fournier <marc.fournier@camptocamp.com> | |
Sun, 8 Nov 2015 20:26:26 +0000 (21:26 +0100) | ||
committer | Marc Fournier <marc.fournier@camptocamp.com> | |
Sun, 8 Nov 2015 20:26:26 +0000 (21:26 +0100) |
1 | 2 | |||
---|---|---|---|---|
src/Makefile.am | patch | | diff1 | | diff2 | | blob | history |
src/daemon/Makefile.am | patch | | diff1 | | diff2 | | blob | history |
src/daemon/plugin.c | patch | | diff1 | | diff2 | | blob | history |
src/daemon/utils_ignorelist.c | patch | | | | diff2 | | blob | history |
src/snmp.c | patch | | diff1 | | diff2 | | blob | history |
diff --cc src/Makefile.am
Simple merge
diff --cc src/daemon/Makefile.am
Simple merge
diff --cc src/daemon/plugin.c
Simple merge
diff --cc src/daemon/utils_ignorelist.c
index 0000000000000000000000000000000000000000,7b1c7d2547e915db1931eecdbeb9e34590e9e117..a8ca7dbb7f3aecbb2c6ea90519c2583aae0c30f5
mode 000000,100644..100644
mode 000000,100644..100644
--- /dev/null
-static int ignorelist_append_regex(ignorelist_t *il, const char *entry)
+ /**
+ * collectd - src/utils_ignorelist.c
+ * Copyright (C) 2006 Lubos Stanek <lubek at users.sourceforge.net>
+ * Copyright (C) 2008 Florian Forster <octo at collectd.org>
+ *
+ * This program is free software; you can redistribute it and/
+ * or modify it under the terms of the GNU General Public Li-
+ * cence as published by the Free Software Foundation; either
+ * version 2 of the Licence, or any later version.
+ *
+ * This program is distributed in the hope that it will be use-
+ * ful, but WITHOUT ANY WARRANTY; without even the implied war-
+ * ranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+ * See the GNU General Public Licence for more details.
+ *
+ * You should have received a copy of the GNU General Public
+ * Licence along with this program; if not, write to the Free
+ * Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139,
+ * USA.
+ *
+ * Authors:
+ * Lubos Stanek <lubek at users.sourceforge.net>
+ * Florian Forster <octo at collectd.org>
+ **/
+ /**
+ * ignorelist handles plugin's list of configured collectable
+ * entries with global ignore action
+ **/
+ /**
+ * Usage:
+ *
+ * Define plugin's global pointer variable of type ignorelist_t:
+ * ignorelist_t *myconfig_ignore;
+ * If you know the state of the global ignore (IgnoreSelected),
+ * allocate the variable with:
+ * myconfig_ignore = ignorelist_create (YourKnownIgnore);
+ * If you do not know the state of the global ignore,
+ * initialize the global variable and set the ignore flag later:
+ * myconfig_ignore = ignorelist_init ();
+ * Append single entries in your cf_register'ed callback function:
+ * ignorelist_add (myconfig_ignore, newentry);
+ * When you hit the IgnoreSelected config option,
+ * offer it to the list:
+ * ignorelist_ignore (myconfig_ignore, instantly_got_value_of_ignore);
+ * That is all for the ignorelist initialization.
+ * Later during read and write (plugin's registered functions) get
+ * the information whether this entry would be collected or not:
+ * if (ignorelist_match (myconfig_ignore, thisentry))
+ * return;
+ **/
+
+ #if HAVE_CONFIG_H
+ # include "config.h"
+ #endif
+
+ #include "common.h"
+ #include "plugin.h"
+ #include "utils_ignorelist.h"
+
+ /*
+ * private prototypes
+ */
+ struct ignorelist_item_s
+ {
+ #if HAVE_REGEX_H
+ regex_t *rmatch; /* regular expression entry identification */
+ #endif
+ char *smatch; /* string entry identification */
+ struct ignorelist_item_s *next;
+ };
+ typedef struct ignorelist_item_s ignorelist_item_t;
+
+ struct ignorelist_s
+ {
+ int ignore; /* ignore entries */
+ ignorelist_item_t *head; /* pointer to the first entry */
+ };
+
+ /* *** *** *** ********************************************* *** *** *** */
+ /* *** *** *** *** *** *** private functions *** *** *** *** *** *** */
+ /* *** *** *** ********************************************* *** *** *** */
+
+ static inline void ignorelist_append (ignorelist_t *il, ignorelist_item_t *item)
+ {
+ assert ((il != NULL) && (item != NULL));
+
+ item->next = il->head;
+ il->head = item;
+ }
+
+ #if HAVE_REGEX_H
- int rcompile;
- regex_t *regtemp;
- int errsize;
- char *regerr = NULL;
- ignorelist_item_t *new;
++static int ignorelist_append_regex(ignorelist_t *il, const char *re_str)
+ {
- /* create buffer */
- if ((regtemp = malloc(sizeof(regex_t))) == NULL)
++ regex_t *re;
++ ignorelist_item_t *entry;
++ int status;
+
- ERROR ("cannot allocate new config entry");
- return (1);
++ re = malloc (sizeof (*re));
++ if (re == NULL)
+ {
- memset (regtemp, '\0', sizeof(regex_t));
++ ERROR ("utils_ignorelist: malloc failed");
++ return (ENOMEM);
+ }
- /* compile regex */
- if ((rcompile = regcomp (regtemp, entry, REG_EXTENDED)) != 0)
++ memset (re, 0, sizeof (*re));
+
- /* prepare message buffer */
- errsize = regerror(rcompile, regtemp, NULL, 0);
- if (errsize)
- regerr = smalloc(errsize);
- /* get error message */
- if (regerror (rcompile, regtemp, regerr, errsize))
- {
- fprintf (stderr, "Cannot compile regex %s: %i/%s",
- entry, rcompile, regerr);
- ERROR ("Cannot compile regex %s: %i/%s",
- entry, rcompile, regerr);
- }
- else
- {
- fprintf (stderr, "Cannot compile regex %s: %i",
- entry, rcompile);
- ERROR ("Cannot compile regex %s: %i",
- entry, rcompile);
- }
-
- if (errsize)
- sfree (regerr);
- regfree (regtemp);
- sfree (regtemp);
- return (1);
++ status = regcomp (re, re_str, REG_EXTENDED);
++ if (status != 0)
+ {
- DEBUG("regex compiled: %s - %i", entry, rcompile);
++ char errbuf[1024] = "";
++ regerror (status, re, errbuf, sizeof (errbuf));
++ ERROR ("utils_ignorelist: regcomp failed: %s", errbuf);
++ regfree (re);
++ sfree (re);
++ return (status);
+ }
- /* create new entry */
- if ((new = malloc(sizeof(ignorelist_item_t))) == NULL)
+
- ERROR ("cannot allocate new config entry");
- regfree (regtemp);
- sfree (regtemp);
- return (1);
++ entry = malloc (sizeof (*entry));
++ if (entry == NULL)
+ {
- memset (new, '\0', sizeof(ignorelist_item_t));
- new->rmatch = regtemp;
-
- /* append new entry */
- ignorelist_append (il, new);
++ ERROR ("utils_ignorelist: malloc failed");
++ regfree (re);
++ sfree (re);
++ return (ENOMEM);
+ }
-} /* int ignorelist_append_regex(ignorelist_t *il, const char *entry) */
++ memset (entry, 0, sizeof (*entry));
++ entry->rmatch = re;
+
++ ignorelist_append (il, entry);
+ return (0);
- * return 1 for success
++} /* int ignorelist_append_regex */
+ #endif
+
+ static int ignorelist_append_string(ignorelist_t *il, const char *entry)
+ {
+ ignorelist_item_t *new;
+
+ /* create new entry */
+ if ((new = malloc(sizeof(ignorelist_item_t))) == NULL )
+ {
+ ERROR ("cannot allocate new entry");
+ return (1);
+ }
+ memset (new, '\0', sizeof(ignorelist_item_t));
+ new->smatch = sstrdup(entry);
+
+ /* append new entry */
+ ignorelist_append (il, new);
+
+ return (0);
+ } /* int ignorelist_append_string(ignorelist_t *il, const char *entry) */
+
+ #if HAVE_REGEX_H
+ /*
+ * check list for entry regex match
+ * return 1 if found
+ */
+ static int ignorelist_match_regex (ignorelist_item_t *item, const char *entry)
+ {
+ assert ((item != NULL) && (item->rmatch != NULL)
+ && (entry != NULL) && (strlen (entry) > 0));
+
+ /* match regex */
+ if (regexec (item->rmatch, entry, 0, NULL, 0) == 0)
+ return (1);
+
+ return (0);
+ } /* int ignorelist_match_regex (ignorelist_item_t *item, const char *entry) */
+ #endif
+
+ /*
+ * check list for entry string match
+ * return 1 if found
+ */
+ static int ignorelist_match_string (ignorelist_item_t *item, const char *entry)
+ {
+ assert ((item != NULL) && (item->smatch != NULL)
+ && (entry != NULL) && (strlen (entry) > 0));
+
+ if (strcmp (entry, item->smatch) == 0)
+ return (1);
+
+ return (0);
+ } /* int ignorelist_match_string (ignorelist_item_t *item, const char *entry) */
+
+
+ /* *** *** *** ******************************************** *** *** *** */
+ /* *** *** *** *** *** *** public functions *** *** *** *** *** *** */
+ /* *** *** *** ******************************************** *** *** *** */
+
+ /*
+ * create the ignorelist_t with known ignore state
+ * return pointer to ignorelist_t
+ */
+ ignorelist_t *ignorelist_create (int invert)
+ {
+ ignorelist_t *il;
+
+ /* smalloc exits if it failes */
+ il = (ignorelist_t *) smalloc (sizeof (ignorelist_t));
+ memset (il, '\0', sizeof (ignorelist_t));
+
+ /*
+ * ->ignore == 0 => collect
+ * ->ignore == 1 => ignore
+ */
+ il->ignore = invert ? 0 : 1;
+
+ return (il);
+ } /* ignorelist_t *ignorelist_create (int ignore) */
+
+ /*
+ * free memory used by ignorelist_t
+ */
+ void ignorelist_free (ignorelist_t *il)
+ {
+ ignorelist_item_t *this;
+ ignorelist_item_t *next;
+
+ if (il == NULL)
+ return;
+
+ for (this = il->head; this != NULL; this = next)
+ {
+ next = this->next;
+ #if HAVE_REGEX_H
+ if (this->rmatch != NULL)
+ {
+ regfree (this->rmatch);
+ sfree (this->rmatch);
+ this->rmatch = NULL;
+ }
+ #endif
+ if (this->smatch != NULL)
+ {
+ sfree (this->smatch);
+ this->smatch = NULL;
+ }
+ sfree (this);
+ }
+
+ sfree (il);
+ il = NULL;
+ } /* void ignorelist_destroy (ignorelist_t *il) */
+
+ /*
+ * set ignore state of the ignorelist_t
+ */
+ void ignorelist_set_invert (ignorelist_t *il, int invert)
+ {
+ if (il == NULL)
+ {
+ DEBUG("ignore call with ignorelist_t == NULL");
+ return;
+ }
+
+ il->ignore = invert ? 0 : 1;
+ } /* void ignorelist_set_invert (ignorelist_t *il, int ignore) */
+
+ /*
+ * append entry into ignorelist_t
- int ret;
++ * return 0 for success
+ */
+ int ignorelist_add (ignorelist_t *il, const char *entry)
+ {
- DEBUG("I'm about to add regex entry: %s", entry_copy);
- ret = ignorelist_append_regex(il, entry_copy);
+ size_t entry_len;
+
+ if (il == NULL)
+ {
+ DEBUG ("add called with ignorelist_t == NULL");
+ return (1);
+ }
+
+ entry_len = strlen (entry);
+
+ /* append nothing */
+ if (entry_len == 0)
+ {
+ DEBUG("not appending: empty entry");
+ return (1);
+ }
+
+ #if HAVE_REGEX_H
+ /* regex string is enclosed in "/.../" */
+ if ((entry_len > 2) && (entry[0] == '/') && entry[entry_len - 1] == '/')
+ {
+ char *entry_copy;
+ size_t entry_copy_size;
++ int status;
+
+ /* We need to copy `entry' since it's const */
+ entry_copy_size = entry_len - 1;
+ entry_copy = smalloc (entry_copy_size);
+ sstrncpy (entry_copy, entry + 1, entry_copy_size);
+
- else
++ status = ignorelist_append_regex(il, entry_copy);
+ sfree (entry_copy);
++ return status;
+ }
- {
- DEBUG("to add entry: %s", entry);
- ret = ignorelist_append_string(il, entry);
- }
+ #endif
- return (ret);
+
++ return ignorelist_append_string(il, entry);
+ } /* int ignorelist_add (ignorelist_t *il, const char *entry) */
+
+ /*
+ * check list for entry
+ * return 1 for ignored entry
+ */
+ int ignorelist_match (ignorelist_t *il, const char *entry)
+ {
+ ignorelist_item_t *traverse;
+
+ /* if no entries, collect all */
+ if ((il == NULL) || (il->head == NULL))
+ return (0);
+
+ if ((entry == NULL) || (strlen (entry) == 0))
+ return (0);
+
+ /* traverse list and check entries */
+ for (traverse = il->head; traverse != NULL; traverse = traverse->next)
+ {
+ #if HAVE_REGEX_H
+ if (traverse->rmatch != NULL)
+ {
+ if (ignorelist_match_regex (traverse, entry))
+ return (il->ignore);
+ }
+ else
+ #endif
+ {
+ if (ignorelist_match_string (traverse, entry))
+ return (il->ignore);
+ }
+ } /* for traverse */
+
+ return (1 - il->ignore);
+ } /* int ignorelist_match (ignorelist_t *il, const char *entry) */
+
diff --cc src/snmp.c
Simple merge