X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Frrd_daemon.c;h=17dca62bd53ad8889c5e2fab579f11f29a74ae65;hb=4d5b22c20f6ae93aa53f37b12757a6a64cd63b05;hp=3295c7eb3c9053c1386427cebef02a80db604e7a;hpb=3ad3cec5db1ba33a23e3e0fbb8c19198cab59c3d;p=rrdtool.git diff --git a/src/rrd_daemon.c b/src/rrd_daemon.c index 3295c7e..17dca62 100644 --- a/src/rrd_daemon.c +++ b/src/rrd_daemon.c @@ -310,9 +310,6 @@ static int enqueue_cache_item (cache_item_t *ci, /* {{{ */ { int did_insert = 0; - RRDD_LOG (LOG_DEBUG, "enqueue_cache_item: Adding %s to the update queue.", - ci->file); - if (ci == NULL) return (-1); @@ -549,9 +546,6 @@ static void *queue_thread_main (void *args __attribute__((unused))) /* {{{ */ pthread_mutex_unlock (&cache_lock); - 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, (void *) values); if (status != 0) { @@ -574,8 +568,6 @@ static void *queue_thread_main (void *args __attribute__((unused))) /* {{{ */ } /* while (do_shutdown == 0) */ pthread_mutex_unlock (&cache_lock); - RRDD_LOG (LOG_DEBUG, "queue_thread_main: Exiting."); - return (NULL); } /* }}} void *queue_thread_main */ @@ -944,9 +936,6 @@ static int handle_request_update (int fd, /* {{{ */ ci->flags = CI_FLAGS_IN_TREE; g_tree_insert (cache_tree, (void *) ci->file, (void *) ci); - - RRDD_LOG (LOG_DEBUG, "handle_request_update: Created new tree node %s.", - ci->file); } /* }}} */ assert (ci != NULL); @@ -1329,11 +1318,7 @@ static void *listen_thread_main (void *args __attribute__((unused))) /* {{{ */ int i; for (i = 0; i < config_listen_address_list_len; i++) - { - RRDD_LOG (LOG_DEBUG, "listen_thread_main: config_listen_address_list[%i] " - "= %s", i, config_listen_address_list[i]); open_listen_socket (config_listen_address_list[i]); - } if (config_listen_address_list_len < 1) open_listen_socket (RRDCACHED_DEFAULT_ADDRESS); @@ -1381,6 +1366,7 @@ static void *listen_thread_main (void *args __attribute__((unused))) /* {{{ */ struct sockaddr_storage client_sa; socklen_t client_sa_size; pthread_t tid; + pthread_attr_t attr; if (pollfds[i].revents == 0) continue; @@ -1409,7 +1395,10 @@ static void *listen_thread_main (void *args __attribute__((unused))) /* {{{ */ continue; } - status = pthread_create (&tid, /* attr = */ NULL, connection_thread_main, + pthread_attr_init (&attr); + pthread_attr_setdetachstate (&attr, PTHREAD_CREATE_DETACHED); + + status = pthread_create (&tid, &attr, connection_thread_main, /* args = */ (void *) client_sd); if (status != 0) { @@ -1436,8 +1425,6 @@ static void *listen_thread_main (void *args __attribute__((unused))) /* {{{ */ } pthread_mutex_unlock (&connetion_threads_lock); - RRDD_LOG (LOG_DEBUG, "listen_thread_main: Exiting."); - return (NULL); } /* }}} void *listen_thread_main */ @@ -1494,7 +1481,7 @@ static int daemonize (void) /* {{{ */ memset (&sa_term, 0, sizeof (sa_term)); sa_term.sa_handler = sig_term_handler; - sigaction (SIGINT, &sa_term, NULL); + sigaction (SIGTERM, &sa_term, NULL); memset (&sa_pipe, 0, sizeof (sa_pipe)); sa_pipe.sa_handler = SIG_IGN; @@ -1525,14 +1512,10 @@ static int daemonize (void) /* {{{ */ static int cleanup (void) /* {{{ */ { - RRDD_LOG (LOG_DEBUG, "cleanup ()"); - 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"); remove_pidfile ();