irq plugin: Use the standard ignorelist for filtering interrupts.
authorFlorian Forster <octo@collectd.org>
Fri, 2 Sep 2011 01:40:24 +0000 (21:40 -0400)
committerFlorian Forster <octo@collectd.org>
Fri, 2 Sep 2011 01:48:42 +0000 (21:48 -0400)
Change-Id: I7d15318c3c1d519d5e7bc715566a9b298f087bcc

src/irq.c

index 7e73829..96bf7f0 100644 (file)
--- a/src/irq.c
+++ b/src/irq.c
@@ -1,6 +1,7 @@
 /**
  * collectd - src/irq.c
  * Copyright (C) 2007  Peter Holik
+ * Copyright (C) 2011  Florian Forster
  *
  * This program is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License as published by the
@@ -24,6 +25,7 @@
 #include "common.h"
 #include "plugin.h"
 #include "configfile.h"
+#include "utils_ignorelist.h"
 
 #if !KERNEL_LINUX
 # error "No applicable input method."
@@ -39,71 +41,33 @@ static const char *config_keys[] =
 };
 static int config_keys_num = STATIC_ARRAY_SIZE (config_keys);
 
-static char         **irq_list;
-static unsigned int   irq_list_num = 0;
+static ignorelist_t *ignorelist = NULL;
 
-/* 
- * irq_list_action:
- * 0 => default is to collect selected irqs
- * 1 => ignore selcted irqs
+/*
+ * Private functions
  */
-static int irq_list_action;
-
 static int irq_config (const char *key, const char *value)
 {
+       if (ignorelist == NULL)
+               ignorelist = ignorelist_create (/* invert = */ 1);
+
        if (strcasecmp (key, "Irq") == 0)
        {
-               char **temp;
-
-               temp = realloc (irq_list, (irq_list_num + 1) * sizeof (*irq_list));
-               if (temp == NULL)
-               {
-                       fprintf (stderr, "irq plugin: Cannot allocate more memory.\n");
-                       ERROR ("irq plugin: Cannot allocate more memory.");
-                       return (1);
-               }
-               irq_list = temp;
-
-               irq_list[irq_list_num] = strdup (value);
-               if (irq_list[irq_list_num] == NULL)
-               {
-                       ERROR ("irq plugin: strdup(3) failed.");
-                       return (1);
-               }
-
-               irq_list_num++;
+               ignorelist_add (ignorelist, value);
        }
        else if (strcasecmp (key, "IgnoreSelected") == 0)
        {
+               int invert = 1;
                if (IS_TRUE (value))
-                       irq_list_action = 1;
-               else
-                       irq_list_action = 0;
+                       invert = 0;
+               ignorelist_set_invert (ignorelist, invert);
        }
        else
        {
                return (-1);
        }
-       return (0);
-}
-
-/*
- * Check if this interface/instance should be ignored. This is called from
- * both, `submit' and `write' to give client and server the ability to
- * ignore certain stuff..
- */
-static int check_ignore_irq (const char *irq)
-{
-       unsigned int i;
-
-       if (irq_list_num < 1)
-               return (0);
 
-       for (i = 0; i < irq_list_num; i++)
-               if (strcmp (irq, irq_list[i]) == 0)
-                       return (irq_list_action);
-
-       return (1 - irq_list_action);
+       return (0);
 }
 
 static void irq_submit (const char *irq_name, derive_t value)
@@ -111,7 +75,7 @@ static void irq_submit (const char *irq_name, derive_t value)
        value_t values[1];
        value_list_t vl = VALUE_LIST_INIT;
 
-       if (check_ignore_irq (irq_name))
+       if (ignorelist_match (ignorelist, irq_name) != 0)
                return;
 
        values[0].derive = value;