src/rrdd.c: Ignore SIGPIPE.

[rrdd.git] / src / rrdd.c

diff --git a/src/rrdd.c b/src/rrdd.c
index 6625da3..14543ce 100644 (file)
--- a/src/rrdd.c
+++ b/src/rrdd.c
@@ -122,6 +122,7 @@ static void *queue_thread_main (void *args) /* {{{ */
     char *file;
     char **values;
     int values_num;
+    int status;
     int i;
 
     if (cache_queue_head == NULL)
@@ -159,6 +160,14 @@ static void *queue_thread_main (void *args) /* {{{ */
     RRDD_LOG (LOG_DEBUG, "queue_thread_main: rrd_update (%s, %i, %p)",
         file, values_num, (void *) values);
 
+    status = rrd_update_r (file, NULL, values_num, values);
+    if (status != 0)
+    {
+      RRDD_LOG (LOG_ERR, "queue_thread_main: "
+          "rrd_update_r failed with status %i.",
+          status);
+    }
+
     free (file);
     for (i = 0; i < values_num; i++)
       free (values[i]);
@@ -345,6 +354,28 @@ static void *connection_thread_main (void *args) /* {{{ */
   
   fd = *((int *) args);
 
+  RRDD_LOG (LOG_DEBUG, "connection_thread_main: Adding myself to "
+      "connetion_threads[]..");
+  pthread_mutex_lock (&connetion_threads_lock);
+  {
+    pthread_t *temp;
+
+    temp = (pthread_t *) realloc (connetion_threads,
+        sizeof (pthread_t) * (connetion_threads_num + 1));
+    if (temp == NULL)
+    {
+      RRDD_LOG (LOG_ERR, "connection_thread_main: realloc failed.");
+    }
+    else
+    {
+      connetion_threads = temp;
+      connetion_threads[connetion_threads_num] = pthread_self ();
+      connetion_threads_num++;
+    }
+  }
+  pthread_mutex_unlock (&connetion_threads_lock);
+  RRDD_LOG (LOG_DEBUG, "connection_thread_main: done");
+
   while (do_shutdown == 0)
   {
     struct pollfd pollfd;
@@ -533,27 +564,9 @@ static void *listen_thread_main (void *args) /* {{{ */
       continue;
     }
 
-    /* FIXME: bug: if the new thread is run first, it may run into the
-     *   assert (i < connetion_threads_num);
-     * assertion. */
-    pthread_mutex_lock (&connetion_threads_lock);
-    {
-      pthread_t *temp;
-
-      temp = (pthread_t *) realloc (connetion_threads,
-          sizeof (pthread_t) * (connetion_threads_num + 1));
-      if (temp == NULL)
-      {
-        RRDD_LOG (LOG_ERR, "listen_thread_main: realloc failed.");
-      }
-      else
-      {
-        connetion_threads = temp;
-        connetion_threads[connetion_threads_num] = tid;
-        connetion_threads_num++;
-      }
-    }
-    pthread_mutex_unlock (&connetion_threads_lock);
+    RRDD_LOG (LOG_DEBUG, "listen_thread_main: pthread_create succeeded: "
+        "tid = %lu",
+        *((unsigned long *) &tid));
   } /* while (do_shutdown == 0) */
 
   close_listen_sockets ();
@@ -619,6 +632,10 @@ static int daemonize (void) /* {{{ */
     memset (&sa, 0, sizeof (sa));
     sa.sa_handler = sig_term_handler;
     sigaction (SIGINT, &sa, NULL);
+
+    memset (&sa, 0, sizeof (sa));
+    sa.sa_handler = SIG_IGN;
+    sigaction (SIGPIPE, &sa, NULL);
   }
 
   openlog ("rrdd", LOG_PID, LOG_DAEMON);
@@ -648,7 +665,10 @@ static int cleanup (void) /* {{{ */
 
   do_shutdown++;
 
+  RRDD_LOG (LOG_DEBUG, "cleanup: Joining queue_thread..");
+  pthread_cond_signal (&cache_cond);
   pthread_join (queue_thread, /* return = */ NULL);
+  RRDD_LOG (LOG_DEBUG, "cleanup: done");
 
   closelog ();