+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/wait.h>
+#include <sys/time.h>
+#include <sys/resource.h>
+#include "common.h"
#include "log.h"
#include "daemon.h"
#include "web_server.h"
#include "popen.h"
-#include "config.h"
+#include "appconfig.h"
#include "web_client.h"
#include "rrd.h"
#include "rrd2json.h"
#include "main.h"
+int netdata_exit = 0;
+
+void netdata_cleanup_and_exit(int ret)
+{
+ kill_childs();
+ rrdset_free_all();
+ //unlink("/var/run/netdata.pid");
+ info("NetData exiting. Bye bye...");
+ exit(ret);
+}
+
struct netdata_static_thread {
char *name;
{NULL, NULL, NULL, 0, NULL, NULL, NULL}
};
+int killpid(pid_t pid, int sig)
+{
+ int ret = -1;
+ debug(D_EXIT, "Request to kill pid %d", pid);
+
+ errno = 0;
+ if(kill(pid, 0) == -1) {
+ switch(errno) {
+ case ESRCH:
+ error("Request to kill pid %d, but it is not running.", pid);
+ break;
+
+ case EPERM:
+ error("Request to kill pid %d, but I do not have enough permissions.", pid);
+ break;
+
+ default:
+ error("Request to kill pid %d, but I received an error.", pid);
+ break;
+ }
+ }
+ else {
+ errno = 0;
+
+ void (*old)(int);
+ old = signal(sig, SIG_IGN);
+ if(old == SIG_ERR) {
+ error("Cannot overwrite signal handler for signal %d", sig);
+ old = sig_handler;
+ }
+
+ ret = kill(pid, sig);
+
+ if(signal(sig, old) == SIG_ERR)
+ error("Cannot restore signal handler for signal %d", sig);
+
+ if(ret == -1) {
+ switch(errno) {
+ case ESRCH:
+ error("Cannot kill pid %d, but it is not running.", pid);
+ break;
+
+ case EPERM:
+ error("Cannot kill pid %d, but I do not have enough permissions.", pid);
+ break;
+
+ default:
+ error("Cannot kill pid %d, but I received an error.", pid);
+ break;
+ }
+ }
+ }
+
+ return ret;
+}
+
void kill_childs()
{
siginfo_t info;
pthread_join(w->thread, NULL);
}
- int i;
+ int i;
for (i = 0; static_threads[i].name != NULL ; i++) {
if(static_threads[i].thread) {
debug(D_EXIT, "Stopping %s thread", static_threads[i].name);
}
if(tc_child_pid) {
- debug(D_EXIT, "Killing tc-qos-helper procees");
- kill(tc_child_pid, SIGTERM);
- waitid(tc_child_pid, 0, &info, WEXITED);
+ info("Killing tc-qos-helper procees");
+ if(killpid(tc_child_pid, SIGTERM) != -1)
+ waitid(P_PID, tc_child_pid, &info, WEXITED);
}
tc_child_pid = 0;
if(cd->pid && !cd->obsolete) {
debug(D_EXIT, "killing %s plugin process", cd->id);
- kill(cd->pid, SIGTERM);
- waitid(cd->pid, 0, &info, WEXITED);
+ if(killpid(cd->pid, SIGTERM) != -1)
+ waitid(P_PID, cd->pid, &info, WEXITED);
}
}
+ // if, for any reason there is any child exited
+ // catch it here
+ waitid(P_PID, 0, &info, WEXITED|WNOHANG);
+
debug(D_EXIT, "All threads/childs stopped.");
}
{
int i;
int config_loaded = 0;
+ int dont_fork = 0;
+
+ // global initialization
+ get_HZ();
// set the name for logging
program_name = "netdata";
else if(strcmp(argv[i], "-u") == 0 && (i+1) < argc) { config_set("global", "run as user", argv[i+1]); i++; }
else if(strcmp(argv[i], "-l") == 0 && (i+1) < argc) { config_set("global", "history", argv[i+1]); i++; }
else if(strcmp(argv[i], "-t") == 0 && (i+1) < argc) { config_set("global", "update every", argv[i+1]); i++; }
+ else if(strcmp(argv[i], "-ch") == 0 && (i+1) < argc) { config_set("global", "host access prefix", argv[i+1]); i++; }
+ else if(strcmp(argv[i], "-nodeamon") == 0 || strcmp(argv[i], "-nd") == 0) dont_fork = 1;
else if(strcmp(argv[i], "--unittest") == 0) {
if(unit_test_storage()) exit(1);
exit(0);
fprintf(stderr, " -t UPDATE_TIMER can be from 1 to %d seconds. Default: %d.\n", UPDATE_EVERY_MAX, UPDATE_EVERY);
fprintf(stderr, " -p LISTEN_PORT can be from 1 to %d. Default: %d.\n", 65535, LISTEN_PORT);
fprintf(stderr, " -u USERNAME can be any system username to run as. Default: none.\n");
- fprintf(stderr, " -df FLAGS debug options. Default: 0x%8llx.\n", debug_flags);
+ fprintf(stderr, " -ch path to access host /proc and /sys when running in a container. Default: empty.\n");
+ fprintf(stderr, " -nd or -nodeamon to disable forking in the background. Default: unset.\n");
+ fprintf(stderr, " -df FLAGS debug options. Default: 0x%08llx.\n", debug_flags);
exit(1);
}
}
if(!config_loaded) load_config(NULL, 0);
+ // prepare configuration environment variables for the plugins
+ setenv("NETDATA_CONFIG_DIR" , config_get("global", "config directory" , CONFIG_DIR) , 1);
+ setenv("NETDATA_PLUGINS_DIR", config_get("global", "plugins directory" , PLUGINS_DIR), 1);
+ setenv("NETDATA_WEB_DIR" , config_get("global", "web files directory", WEB_DIR) , 1);
+ setenv("NETDATA_CACHE_DIR" , config_get("global", "cache directory" , CACHE_DIR) , 1);
+ setenv("NETDATA_LOG_DIR" , config_get("global", "log directory" , LOG_DIR) , 1);
+
+ // avoid extended to stat(/etc/localtime)
+ // http://stackoverflow.com/questions/4554271/how-to-avoid-excessive-stat-etc-localtime-calls-in-strftime-on-linux
+ setenv("TZ", ":/etc/localtime", 0);
+
+ // cd to /tmp to avoid any plugins writing files at random places
+ if(chdir("/tmp")) fprintf(stderr, "netdata: ERROR: Cannot cd to /tmp: %s", strerror(errno));
+
char *input_log_file = NULL;
char *output_log_file = NULL;
char *error_log_file = NULL;
char *access_log_file = NULL;
+ char *user = NULL;
{
char buffer[1024];
sprintf(buffer, "0x%08llx", 0ULL);
char *flags = config_get("global", "debug flags", buffer);
+ setenv("NETDATA_DEBUG_FLAGS", flags, 1);
+
debug_flags = strtoull(flags, NULL, 0);
debug(D_OPTIONS, "Debug flags set to '0x%8llx'.", debug_flags);
+ if(debug_flags != 0) {
+ struct rlimit rl = { RLIM_INFINITY, RLIM_INFINITY };
+ if(setrlimit(RLIMIT_CORE, &rl) != 0)
+ info("Cannot request unlimited core dumps for debugging... Proceeding anyway...");
+ }
+
+ // --------------------------------------------------------------------
+
+ global_host_prefix = config_get("global", "host access prefix", "");
+ setenv("NETDATA_HOST_PREFIX", global_host_prefix, 1);
+
// --------------------------------------------------------------------
output_log_file = config_get("global", "debug log", LOG_DIR "/debug.log");
}
else debug(D_OPTIONS, "update timer set to %d.", rrd_update_every);
+ // let the plugins know the min update_every
+ {
+ char buffer[50];
+ snprintf(buffer, 50, "%d", rrd_update_every);
+ setenv("NETDATA_UPDATE_EVERY", buffer, 1);
+ }
+
// --------------------------------------------------------------------
-
+
for (i = 0; static_threads[i].name != NULL ; i++) {
struct netdata_static_thread *st = &static_threads[i];
// --------------------------------------------------------------------
prepare_rundir();
- char *user = config_get("global", "run as user", (getuid() == 0)?"nobody":"");
- if(*user) {
- if(become_user(user) != 0) {
- fprintf(stderr, "Cannot become user %s.\n", user);
- exit(1);
- }
- else debug(D_OPTIONS, "Successfully became user %s.", user);
- }
+ user = config_get("global", "run as user" , (getuid() == 0)?NETDATA_USER:"");
+ web_files_uid();
// --------------------------------------------------------------------
// never become a problem
if(nice(20) == -1) fprintf(stderr, "Cannot lower my CPU priority. Error: %s.\n", strerror(errno));
-#ifndef NETDATA_NO_DAEMON
- if(become_daemon(0, input_log_file, output_log_file, error_log_file, access_log_file, &access_fd, &stdaccess) == -1) {
- fprintf(stderr, "Cannot demonize myself (%s).", strerror(errno));
+ if(become_daemon(dont_fork, 0, user, input_log_file, output_log_file, error_log_file, access_log_file, &access_fd, &stdaccess) == -1) {
+ fatal("Cannot demonize myself (%s).", strerror(errno));
exit(1);
}
-#endif
if(output_log_syslog || error_log_syslog || access_log_syslog)
openlog("netdata", LOG_PID, LOG_DAEMON);
// catch all signals
- for (i = 1 ; i < 65 ;i++) if(i != SIGSEGV && i != SIGFPE) signal(i, sig_handler);
-
+ for (i = 1 ; i < 65 ;i++) {
+ switch(i) {
+ case SIGSEGV:
+ case SIGFPE:
+ case SIGCHLD:
+ signal(i, SIG_DFL);
+ break;
+
+ default:
+ signal(i, sig_handler);
+ break;
+ }
+ }
+
for (i = 0; static_threads[i].name != NULL ; i++) {
struct netdata_static_thread *st = &static_threads[i];
else info("Not starting thread %s.", st->name);
}
- // the main process - the web server listener
- // this never ends
- // socket_listen_main(NULL);
+ // for future use - the main thread
while(1) {
- process_childs(1);
- sleep(1);
+ if(netdata_exit != 0) {
+ netdata_exit++;
+
+ if(netdata_exit > 5) {
+ netdata_cleanup_and_exit(0);
+ exit(0);
+ }
+ }
+ sleep(2);
}
exit(0);
projects / netdata.git / blobdiff