Let plugin_dispatch_values() set value_list.time in case of 'now'.
[collectd.git] / src / dns.c
index b97ce28..d82cbd8 100644 (file)
--- a/src/dns.c
+++ b/src/dns.c
@@ -1,11 +1,10 @@
 /**
  * collectd - src/dns.c
- * Copyright (C) 2006  Florian octo Forster
+ * Copyright (C) 2006,2007  Florian octo 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
- * Free Software Foundation; either version 2 of the License, or (at your
- * option) any later version.
+ * Free Software Foundation; only version 2 of the License is applicable.
  *
  * This program is distributed in the hope that it will be useful, but
  * WITHOUT ANY WARRANTY; without even the implied warranty of
 #include "common.h"
 #include "plugin.h"
 #include "configfile.h"
-#include "utils_debug.h"
 
-#if HAVE_SYS_POLL_H
-# include <sys/poll.h>
-#endif
-
-#define MODULE_NAME "dns"
-
-#if HAVE_LIBPCAP
-# define NAMED_HAVE_CONFIG 1
-#else
-# define NAMED_HAVE_CONFIG 0
-#endif
-
-#if HAVE_LIBPCAP
-# include "utils_dns.h"
-# define NAMED_HAVE_READ 1
-#else
-# define NAMED_HAVE_READ 0
-#endif
+#include "utils_dns.h"
+#include <pthread.h>
+#include <pcap.h>
+#include <poll.h>
 
+/*
+ * Private data types
+ */
 struct counter_list_s
 {
        unsigned int key;
@@ -53,77 +40,49 @@ struct counter_list_s
 };
 typedef struct counter_list_s counter_list_t;
 
-static char *traffic_file   = "dns/dns_traffic.rrd";
-static char *qtype_file   = "dns/qtype-%s.rrd";
-static char *opcode_file  = "dns/opcode-%s.rrd";
-static char *rcode_file   = "dns/rcode-%s.rrd";
-
-static char *traffic_ds_def[] =
-{
-       /* Limit to 1GBit/s */
-       "DS:queries:COUNTER:"COLLECTD_HEARTBEAT":0:125000000",
-       "DS:responses:COUNTER:"COLLECTD_HEARTBEAT":0:125000000",
-       NULL
-};
-static int traffic_ds_num = 2;
-
-static char *qtype_ds_def[] =
-{
-       "DS:value:COUNTER:"COLLECTD_HEARTBEAT":0:65535",
-       NULL
-};
-static int qtype_ds_num = 1;
-
-static char *opcode_ds_def[] =
-{
-       "DS:value:COUNTER:"COLLECTD_HEARTBEAT":0:65535",
-       NULL
-};
-static int opcode_ds_num = 1;
-
-static char *rcode_ds_def[] =
-{
-       "DS:value:COUNTER:"COLLECTD_HEARTBEAT":0:65535",
-       NULL
-};
-static int rcode_ds_num = 1;
-
-#if NAMED_HAVE_CONFIG
-#if HAVE_LIBPCAP
-static char *config_keys[] =
+/*
+ * Private variables
+ */
+static const char *config_keys[] =
 {
        "Interface",
        "IgnoreSource",
        NULL
 };
 static int config_keys_num = 2;
-#endif /* HAVE_LIBPCAP */
-#endif /* NAMED_HAVE_CONFIG */
 
-#if HAVE_LIBPCAP
 #define PCAP_SNAPLEN 1460
 static char   *pcap_device = NULL;
-static int     pipe_fd = -1;
 
-static unsigned int    tr_queries;
-static unsigned int    tr_responses;
+static counter_t       tr_queries;
+static counter_t       tr_responses;
 static counter_list_t *qtype_list;
 static counter_list_t *opcode_list;
 static counter_list_t *rcode_list;
-#endif
 
+static pthread_t       listen_thread;
+static int             listen_thread_init = 0;
+/* The `traffic' mutex if for `tr_queries' and `tr_responses' */
+static pthread_mutex_t traffic_mutex = PTHREAD_MUTEX_INITIALIZER;
+static pthread_mutex_t qtype_mutex   = PTHREAD_MUTEX_INITIALIZER;
+static pthread_mutex_t opcode_mutex  = PTHREAD_MUTEX_INITIALIZER;
+static pthread_mutex_t rcode_mutex   = PTHREAD_MUTEX_INITIALIZER;
+
+/*
+ * Private functions
+ */
 static counter_list_t *counter_list_search (counter_list_t **list, unsigned int key)
 {
        counter_list_t *entry;
 
-       DBG ("counter_list_search (list = %p, key = %u)",
+       DEBUG ("counter_list_search (list = %p, key = %u)",
                        (void *) *list, key);
 
        for (entry = *list; entry != NULL; entry = entry->next)
                if (entry->key == key)
                        break;
 
-       DBG ("return (%p)", (void *) entry);
+       DEBUG ("return (%p)", (void *) entry);
        return (entry);
 }
 
@@ -132,7 +91,7 @@ static counter_list_t *counter_list_create (counter_list_t **list,
 {
        counter_list_t *entry;
 
-       DBG ("counter_list_create (list = %p, key = %u, value = %u)",
+       DEBUG ("counter_list_create (list = %p, key = %u, value = %u)",
                        (void *) *list, key, value);
 
        entry = (counter_list_t *) malloc (sizeof (counter_list_t));
@@ -158,7 +117,7 @@ static counter_list_t *counter_list_create (counter_list_t **list,
                last->next = entry;
        }
 
-       DBG ("return (%p)", (void *) entry);
+       DEBUG ("return (%p)", (void *) entry);
        return (entry);
 }
 
@@ -167,7 +126,7 @@ static void counter_list_add (counter_list_t **list,
 {
        counter_list_t *entry;
 
-       DBG ("counter_list_add (list = %p, key = %u, increment = %u)",
+       DEBUG ("counter_list_add (list = %p, key = %u, increment = %u)",
                        (void *) *list, key, increment);
 
        entry = counter_list_search (list, key);
@@ -180,57 +139,11 @@ static void counter_list_add (counter_list_t **list,
        {
                counter_list_create (list, key, increment);
        }
-       DBG ("return ()");
+       DEBUG ("return ()");
 }
 
-static int counter_list_send (counter_list_t *list, int fd)
-{
-       counter_list_t *cl;
-       unsigned int values[2 * T_MAX];
-       unsigned int values_num;
-
-       if (fd < 0)
-               return (-1);
-
-       values_num = 0;
-
-       for (cl = list;
-                       (cl != NULL) && (values_num < T_MAX);
-                       cl = cl->next)
-       {
-               values[2 * values_num] = cl->key;
-               values[(2 * values_num) + 1] = cl->value;
-               values_num++;
-       }
-
-       DBG ("swrite (fd = %i, values_num = %i)", fd, values_num);
-       if (swrite (fd, (const void *) &values_num, sizeof (values_num)) != 0)
-       {
-               DBG ("Writing to fd failed: %s", strerror (errno));
-               syslog (LOG_ERR, "dns plugin: Writing to fd failed: %s",
-                               strerror (errno));
-               return (-1);
-       }
-
-       if (values_num == 0)
-               return (0);
-
-       DBG ("swrite (fd = %i, values = %p, size = %i)",
-                       fd, (void *) values, (int) (sizeof (int) * values_num));
-       if (swrite (fd, (const void *) values, 2 * sizeof (int) * values_num) != 0)
-       {
-               DBG ("Writing to pipe failed: %s", strerror (errno));
-               syslog (LOG_ERR, "dns plugin: Writing to pipe failed: %s",
-                               strerror (errno));
-               return (-1);
-       }
-
-       return (values_num);
-}
-#if NAMED_HAVE_CONFIG
-static int dns_config (char *key, char *value)
+static int dns_config (const char *key, const char *value)
 {
-#if HAVE_LIBPCAP
        if (strcasecmp (key, "Interface") == 0)
        {
                if (pcap_device != NULL)
@@ -249,429 +162,238 @@ static int dns_config (char *key, char *value)
        }
 
        return (0);
-#endif /* HAVE_LIBPCAP */
 }
-#endif /* NAMED_HAVE_CONFIG */
 
 static void dns_child_callback (const rfc1035_header_t *dns)
 {
        if (dns->qr == 0)
        {
                /* This is a query */
+               pthread_mutex_lock (&traffic_mutex);
                tr_queries += dns->length;
+               pthread_mutex_unlock (&traffic_mutex);
+
+               pthread_mutex_lock (&qtype_mutex);
                counter_list_add (&qtype_list,  dns->qtype,  1);
+               pthread_mutex_unlock (&qtype_mutex);
        }
        else
        {
                /* This is a reply */
+               pthread_mutex_lock (&traffic_mutex);
                tr_responses += dns->length;
+               pthread_mutex_unlock (&traffic_mutex);
+
+               pthread_mutex_lock (&rcode_mutex);
                counter_list_add (&rcode_list,  dns->rcode,  1);
+               pthread_mutex_unlock (&rcode_mutex);
        }
 
        /* FIXME: Are queries, replies or both interesting? */
+       pthread_mutex_lock (&opcode_mutex);
        counter_list_add (&opcode_list, dns->opcode, 1);
+       pthread_mutex_unlock (&opcode_mutex);
 }
 
-static void dns_child_loop (void)
+static void *dns_child_loop (void *dummy)
 {
        pcap_t *pcap_obj;
        char    pcap_error[PCAP_ERRBUF_SIZE];
        struct  bpf_program fp;
 
-       struct pollfd poll_fds[2];
        int status;
 
-       /* Don't catch these signals */
-       signal (SIGINT, SIG_DFL);
-       signal (SIGTERM, SIG_DFL);
+       /* Don't block any signals */
+       {
+               sigset_t sigmask;
+               sigemptyset (&sigmask);
+               pthread_sigmask (SIG_SETMASK, &sigmask, NULL);
+       }
 
        /* Passing `pcap_device == NULL' is okay and the same as passign "any" */
-       DBG ("Creating PCAP object..");
+       DEBUG ("Creating PCAP object..");
        pcap_obj = pcap_open_live (pcap_device,
                        PCAP_SNAPLEN,
                        0 /* Not promiscuous */,
-                       0 /* no read timeout */,
+                       interval_g,
                        pcap_error);
        if (pcap_obj == NULL)
        {
-               syslog (LOG_ERR, "dns plugin: Opening interface `%s' failed: %s",
+               ERROR ("dns plugin: Opening interface `%s' "
+                               "failed: %s",
                                (pcap_device != NULL) ? pcap_device : "any",
                                pcap_error);
-               close (pipe_fd);
-               pipe_fd = -1;
-               return;
+               return (NULL);
        }
 
        memset (&fp, 0, sizeof (fp));
        if (pcap_compile (pcap_obj, &fp, "udp port 53", 1, 0) < 0)
        {
-               DBG ("pcap_compile failed");
-               syslog (LOG_ERR, "dns plugin: pcap_compile failed");
-               close (pipe_fd);
-               pipe_fd = -1;
-               return;
+               ERROR ("dns plugin: pcap_compile failed");
+               return (NULL);
        }
        if (pcap_setfilter (pcap_obj, &fp) < 0)
        {
-               DBG ("pcap_setfilter failed");
-               syslog (LOG_ERR, "dns plugin: pcap_setfilter failed");
-               close (pipe_fd);
-               pipe_fd = -1;
-               return;
+               ERROR ("dns plugin: pcap_setfilter failed");
+               return (NULL);
        }
 
-       DBG ("PCAP object created.");
+       DEBUG ("PCAP object created.");
 
        dnstop_set_pcap_obj (pcap_obj);
        dnstop_set_callback (dns_child_callback);
 
-       /* Set up pipe end */
-       poll_fds[0].fd = pipe_fd;
-       poll_fds[0].events = POLLOUT;
+       status = pcap_loop (pcap_obj,
+                       -1 /* loop forever */,
+                       handle_pcap /* callback */,
+                       NULL /* Whatever this means.. */);
+       if (status < 0)
+               ERROR ("dns plugin: Listener thread is exiting "
+                               "abnormally: %s", pcap_geterr (pcap_obj));
 
-       /* Set up pcap device */
-       poll_fds[1].fd = pcap_fileno (pcap_obj);
-       poll_fds[1].events = POLLIN | POLLPRI;
+       DEBUG ("child is exiting");
 
-       while (pipe_fd > 0)
-       {
-               DBG ("poll (...)");
-               status = poll (poll_fds, 2, -1 /* wait forever for a change */);
-
-               /* Signals are not caught, but this is very handy when
-                * attaching to the process with a debugger. -octo */
-               if ((status < 0) && (errno == EINTR))
-               {
-                       errno = 0;
-                       continue;
-               }
-
-               if (status < 0)
-               {
-                       syslog (LOG_ERR, "dns plugin: poll(2) failed: %s",
-                                       strerror (errno));
-                       break;
-               }
-
-               if (poll_fds[0].revents & (POLLERR | POLLHUP | POLLNVAL))
-               {
-                       DBG ("Pipe closed. Exiting.");
-                       syslog (LOG_NOTICE, "dns plugin: Pipe closed. Exiting.");
-                       break;
-               }
-               else if (poll_fds[0].revents & POLLOUT)
-               {
-                       DBG ("Sending data..");
-
-                       DBG ("swrite (pipe_fd = %i, tr_queries = %i)", pipe_fd, tr_queries);
-                       if (swrite (pipe_fd, (const void *) &tr_queries, sizeof (tr_queries)) != 0)
-                       {
-                               DBG ("Writing to pipe_fd failed: %s", strerror (errno));
-                               syslog (LOG_ERR, "dns plugin: Writing to pipe_fd failed: %s",
-                                               strerror (errno));
-                               return;
-                       }
-
-                       DBG ("swrite (pipe_fd = %i, tr_responses = %i)", pipe_fd, tr_responses);
-                       if (swrite (pipe_fd, (const void *) &tr_responses, sizeof (tr_responses)) != 0)
-                       {
-                               DBG ("Writing to pipe_fd failed: %s", strerror (errno));
-                               syslog (LOG_ERR, "dns plugin: Writing to pipe_fd failed: %s",
-                                               strerror (errno));
-                               return;
-                       }
-
-                       counter_list_send (qtype_list, pipe_fd);
-                       counter_list_send (opcode_list, pipe_fd);
-                       counter_list_send (rcode_list, pipe_fd);
-               }
-
-               if (poll_fds[1].revents & (POLLERR | POLLHUP | POLLNVAL))
-               {
-                       DBG ("pcap-device closed. Exiting.");
-                       syslog (LOG_ERR, "dns plugin: pcap-device closed. Exiting.");
-                       break;
-               }
-               else if (poll_fds[1].revents & (POLLIN | POLLPRI))
-               {
-                       status = pcap_dispatch (pcap_obj,
-                                       10 /* Only handle 10 packets at a time */,
-                                       handle_pcap /* callback */,
-                                       NULL /* Whatever this means.. */);
-                       if (status < 0)
-                       {
-                               DBG ("pcap_dispatch failed: %s", pcap_geterr (pcap_obj));
-                               syslog (LOG_ERR, "dns plugin: pcap_dispatch failed: %s",
-                                               pcap_geterr (pcap_obj));
-                               break;
-                       }
-               }
-       } /* while (42) */
-
-       DBG ("child is exiting");
-
-       close (pipe_fd);
-       pipe_fd = -1;
        pcap_close (pcap_obj);
+       listen_thread_init = 0;
+       pthread_exit (NULL);
+
+       return (NULL);
 } /* static void dns_child_loop (void) */
 
-static void dns_init (void)
+static int dns_init (void)
 {
-#if HAVE_LIBPCAP
-       int pipe_fds[2];
-       pid_t pid_child;
+       /* clean up an old thread */
+       int status;
 
+       pthread_mutex_lock (&traffic_mutex);
        tr_queries   = 0;
        tr_responses = 0;
+       pthread_mutex_unlock (&traffic_mutex);
 
-       if (pipe (pipe_fds) != 0)
-       {
-               syslog (LOG_ERR, "dns plugin: pipe(2) failed: %s",
-                               strerror (errno));
-               return;
-       }
+       if (listen_thread_init != 0)
+               return (-1);
 
-       /* Fork off child */
-       pid_child = fork ();
-       if (pid_child < 0)
+       status = pthread_create (&listen_thread, NULL, dns_child_loop,
+                       (void *) 0);
+       if (status != 0)
        {
-               syslog (LOG_ERR, "dns plugin: fork(2) failed: %s",
-                               strerror (errno));
-               close (pipe_fds[0]);
-               close (pipe_fds[1]);
-               return;
-       }
-       else if (pid_child != 0)
-       {
-               /* parent: Close the writing end, keep the reading end. */
-               pipe_fd = pipe_fds[0];
-               close (pipe_fds[1]);
-       }
-       else
-       {
-               /* child: Close the reading end, keep the writing end. */
-               pipe_fd = pipe_fds[1];
-               close (pipe_fds[0]);
-
-               dns_child_loop ();
-               exit (0);
+               char errbuf[1024];
+               ERROR ("dns plugin: pthread_create failed: %s",
+                               sstrerror (errno, errbuf, sizeof (errbuf)));
+               return (-1);
        }
 
-       /* fcntl (pipe_fd, F_SETFL, O_NONBLOCK); */
-#endif
-}
-
-static void traffic_write (char *host, char *inst, char *val)
-{
-       rrd_update_file (host, traffic_file, val,
-                       traffic_ds_def, traffic_ds_num);
-}
-
-static void qtype_write (char *host, char *inst, char *val)
-{
-       char file[512];
-       int status;
-
-       status = snprintf (file, 512, qtype_file, inst);
-       if (status < 1)
-               return;
-       else if (status >= 512)
-               return;
-
-       rrd_update_file (host, file, val, qtype_ds_def, qtype_ds_num);
-}
-
-static void rcode_write (char *host, char *inst, char *val)
-{
-       char file[512];
-       int status;
-
-       status = snprintf (file, 512, rcode_file, inst);
-       if (status < 1)
-               return;
-       else if (status >= 512)
-               return;
-
-       rrd_update_file (host, file, val, rcode_ds_def, rcode_ds_num);
-}
-
-static void opcode_write (char *host, char *inst, char *val)
-{
-       char file[512];
-       int status;
-
-       status = snprintf (file, 512, opcode_file, inst);
-       if (status < 1)
-               return;
-       else if (status >= 512)
-               return;
-
-       rrd_update_file (host, file, val, opcode_ds_def, opcode_ds_num);
-}
+       listen_thread_init = 1;
 
-static void traffic_submit (unsigned int queries, unsigned int replies)
-{
-       char buffer[64];
-       int  status;
-
-       status = snprintf (buffer, 64, "N:%u:%u", queries, replies);
-       if ((status < 1) || (status >= 64))
-               return;
-
-       plugin_submit ("dns_traffic", "-", buffer);
-}
+       return (0);
+} /* int dns_init */
 
-static void qtype_submit (int qtype, unsigned int counter)
+static void submit_counter (const char *type, const char *type_instance,
+               counter_t value)
 {
-       char inst[32];
-       char buffer[32];
-       int  status;
+       value_t values[1];
+       value_list_t vl = VALUE_LIST_INIT;
 
-       strncpy (inst, qtype_str (qtype), 32);
-       inst[31] = '\0';
+       values[0].counter = value;
 
-       status = snprintf (buffer, 32, "N:%u", counter);
-       if ((status < 1) || (status >= 32))
-               return;
+       vl.values = values;
+       vl.values_len = 1;
+       sstrncpy (vl.host, hostname_g, sizeof (vl.host));
+       sstrncpy (vl.plugin, "dns", sizeof (vl.plugin));
+       sstrncpy (vl.type, type, sizeof (vl.type));
+       sstrncpy (vl.type_instance, type_instance, sizeof (vl.type_instance));
 
-       plugin_submit ("dns_qtype", inst, buffer);
-}
+       plugin_dispatch_values (&vl);
+} /* void submit_counter */
 
-static void rcode_submit (int rcode, unsigned int counter)
+static void submit_octets (counter_t queries, counter_t responses)
 {
-       char inst[32];
-       char buffer[32];
-       int  status;
+       value_t values[2];
+       value_list_t vl = VALUE_LIST_INIT;
 
-       strncpy (inst, rcode_str (rcode), 32);
-       inst[31] = '\0';
+       values[0].counter = queries;
+       values[1].counter = responses;
 
-       status = snprintf (buffer, 32, "N:%u", counter);
-       if ((status < 1) || (status >= 32))
-               return;
+       vl.values = values;
+       vl.values_len = 2;
+       sstrncpy (vl.host, hostname_g, sizeof (vl.host));
+       sstrncpy (vl.plugin, "dns", sizeof (vl.plugin));
+       sstrncpy (vl.type, "dns_octets", sizeof (vl.type));
 
-       plugin_submit ("dns_rcode", inst, buffer);
-}
+       plugin_dispatch_values (&vl);
+} /* void submit_counter */
 
-static void opcode_submit (int opcode, unsigned int counter)
+static int dns_read (void)
 {
-       char inst[32];
-       char buffer[32];
-       int  status;
-
-       strncpy (inst, opcode_str (opcode), 32);
-       inst[31] = '\0';
+       unsigned int keys[T_MAX];
+       unsigned int values[T_MAX];
+       int len;
+       int i;
 
-       status = snprintf (buffer, 32, "N:%u", counter);
-       if ((status < 1) || (status >= 32))
-               return;
+       counter_list_t *ptr;
 
-       plugin_submit ("dns_opcode", inst, buffer);
-}
+       pthread_mutex_lock (&traffic_mutex);
+       values[0] = tr_queries;
+       values[1] = tr_responses;
+       pthread_mutex_unlock (&traffic_mutex);
 
-#if NAMED_HAVE_READ
-static unsigned int dns_read_array (unsigned int *values)
-{
-       unsigned int values_num;
+       if ((values[0] != 0) || (values[1] != 0))
+               submit_octets (values[0], values[1]);
 
-       if (pipe_fd < 0)
-               return (0);
-
-       if (sread (pipe_fd, (void *) &values_num, sizeof (values_num)) != 0)
+       pthread_mutex_lock (&qtype_mutex);
+       for (ptr = qtype_list, len = 0;
+                       (ptr != NULL) && (len < T_MAX);
+                       ptr = ptr->next, len++)
        {
-               DBG ("Reading from the pipe failed: %s",
-                               strerror (errno));
-               syslog (LOG_ERR, "dns plugin: Reading from the pipe failed: %s",
-                               strerror (errno));
-               pipe_fd = -1;
-               return (0);
+               keys[len]   = ptr->key;
+               values[len] = ptr->value;
        }
-       DBG ("sread (pipe_fd = %i, values_num = %u)", pipe_fd, values_num);
-
-       assert (values_num <= T_MAX);
-
-       if (values_num == 0)
-               return (0);
+       pthread_mutex_unlock (&qtype_mutex);
 
-       if (sread (pipe_fd, (void *) values, 2 * sizeof (unsigned int) * values_num) != 0)
+       for (i = 0; i < len; i++)
        {
-               DBG ("Reading from the pipe failed: %s",
-                               strerror (errno));
-               syslog (LOG_ERR, "dns plugin: Reading from the pipe failed: %s",
-                               strerror (errno));
-               pipe_fd = -1;
-               return (0);
+               DEBUG ("qtype = %u; counter = %u;", keys[i], values[i]);
+               submit_counter ("dns_qtype", qtype_str (keys[i]), values[i]);
        }
 
-       return (values_num);
-}
-
-static void dns_read (void)
-{
-       unsigned int values[2 * T_MAX];
-       unsigned int values_num;
-       int i;
-
-       if (pipe_fd < 0)
-               return;
-
-       if (sread (pipe_fd, (void *) &tr_queries, sizeof (tr_queries)) != 0)
+       pthread_mutex_lock (&opcode_mutex);
+       for (ptr = opcode_list, len = 0;
+                       (ptr != NULL) && (len < T_MAX);
+                       ptr = ptr->next, len++)
        {
-               DBG ("Reading from the pipe failed: %s",
-                               strerror (errno));
-               syslog (LOG_ERR, "dns plugin: Reading from the pipe failed: %s",
-                               strerror (errno));
-               pipe_fd = -1;
-               return;
+               keys[len]   = ptr->key;
+               values[len] = ptr->value;
        }
-       DBG ("sread (pipe_fd = %i, tr_queries = %u)", pipe_fd, tr_queries);
+       pthread_mutex_unlock (&opcode_mutex);
 
-       if (sread (pipe_fd, (void *) &tr_responses, sizeof (tr_responses)) != 0)
+       for (i = 0; i < len; i++)
        {
-               DBG ("Reading from the pipe failed: %s",
-                               strerror (errno));
-               syslog (LOG_ERR, "dns plugin: Reading from the pipe failed: %s",
-                               strerror (errno));
-               pipe_fd = -1;
-               return;
+               DEBUG ("opcode = %u; counter = %u;", keys[i], values[i]);
+               submit_counter ("dns_opcode", opcode_str (keys[i]), values[i]);
        }
-       DBG ("sread (pipe_fd = %i, tr_responses = %u)", pipe_fd, tr_responses);
-
-       traffic_submit (tr_queries, tr_responses);
 
-       values_num = dns_read_array (values);
-       for (i = 0; i < values_num; i++)
+       pthread_mutex_lock (&rcode_mutex);
+       for (ptr = rcode_list, len = 0;
+                       (ptr != NULL) && (len < T_MAX);
+                       ptr = ptr->next, len++)
        {
-               DBG ("qtype = %u; counter = %u;", values[2 * i], values[(2 * i) + 1]);
-               qtype_submit (values[2 * i], values[(2 * i) + 1]);
+               keys[len]   = ptr->key;
+               values[len] = ptr->value;
        }
+       pthread_mutex_unlock (&rcode_mutex);
 
-       values_num = dns_read_array (values);
-       for (i = 0; i < values_num; i++)
+       for (i = 0; i < len; i++)
        {
-               DBG ("opcode = %u; counter = %u;", values[2 * i], values[(2 * i) + 1]);
-               opcode_submit (values[2 * i], values[(2 * i) + 1]);
+               DEBUG ("rcode = %u; counter = %u;", keys[i], values[i]);
+               submit_counter ("dns_rcode", rcode_str (keys[i]), values[i]);
        }
 
-       values_num = dns_read_array (values);
-       for (i = 0; i < values_num; i++)
-       {
-               DBG ("rcode = %u; counter = %u;", values[2 * i], values[(2 * i) + 1]);
-               rcode_submit (values[2 * i], values[(2 * i) + 1]);
-       }
-}
-#else /* if !NAMED_HAVE_READ */
-# define dns_read NULL
-#endif
+       return (0);
+} /* int dns_read */
 
 void module_register (void)
 {
-       plugin_register (MODULE_NAME, dns_init, dns_read, NULL);
-       plugin_register ("dns_traffic", NULL, NULL, traffic_write);
-       plugin_register ("dns_qtype", NULL, NULL, qtype_write);
-       plugin_register ("dns_rcode", NULL, NULL, rcode_write);
-       plugin_register ("dns_opcode", NULL, NULL, opcode_write);
-       cf_register (MODULE_NAME, dns_config, config_keys, config_keys_num);
-}
-
-#undef MODULE_NAME
+       plugin_register_config ("dns", dns_config, config_keys, config_keys_num);
+       plugin_register_init ("dns", dns_init);
+       plugin_register_read ("dns", dns_read);
+} /* void module_register */