X-Git-Url: http://sru.miketaylor.org.uk/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmetaproxy_prog.cpp;h=6ecc5f0d6fb5a75b41e1df8aaec33e1ba83df1e5;hb=4c528bfa11ac8640b5bf8f7018d0d096d30081df;hp=ce60c60a116f556ad73df353a3058b498ea47c11;hpb=aff78cecdb2c7292899ae15ee8a5fd41accef2b5;p=metaproxy-moved-to-github.git diff --git a/src/metaproxy_prog.cpp b/src/metaproxy_prog.cpp index ce60c60..6ecc5f0 100644 --- a/src/metaproxy_prog.cpp +++ b/src/metaproxy_prog.cpp @@ -50,38 +50,51 @@ mp::RouterFleXML *routerp = 0; #if HAVE_UNISTD_H static pid_t process_group = 0; -static void sig_term_handler(int s) +static void sig_usr1_handler(int s) { + yaz_log(YLOG_LOG, "metaproxy received SIGUSR1"); routerp->stop(); -#if 0 + yaz_daemon_stop(); +} + +static void sig_term_handler(int s) +{ + yaz_log(YLOG_LOG, "metaproxy received SIGTERM"); + yaz_log(YLOG_LOG, "metaproxy stop"); kill(-process_group, SIGTERM); /* kill all children processes as well */ _exit(0); -#endif } #endif -static void handler_debug(void *data) +static void work_common(void *data) { #if HAVE_UNISTD_H process_group = getpgid(0); // save process group ID - + signal(SIGTERM, sig_term_handler); + signal(SIGUSR1, sig_usr1_handler); #endif routerp = (mp::RouterFleXML*) data; routerp->start(); mp::Package pack; - pack.router(*routerp).move(); /* should never exit */ + pack.router(*routerp).move(); + yaz_log(YLOG_LOG, "metaproxy stop"); /* only for graceful stop */ _exit(0); } + +static void work_debug(void *data) +{ + work_common(data); +} -static void handler_normal(void *data) +static void work_normal(void *data) { #if HAVE_UNISTD_H /* make the current working process group leader */ setpgid(0, 0); #endif - handler_debug(data); + work_common(data); } static int sc_main( @@ -172,7 +185,7 @@ static int sc_main( return 1; } - yaz_log(YLOG_LOG, "Metaproxy start " VERSION + yaz_log(YLOG_LOG, "metaproxy start " VERSION #ifdef VERSION_SHA1 " " VERSION_SHA1 #endif @@ -218,7 +231,7 @@ static int sc_main( yaz_sc_running(s); yaz_daemon("metaproxy", mode, mode == YAZ_DAEMON_DEBUG ? - handler_debug : handler_normal, router, pidfile, uid); + work_debug : work_normal, router, pidfile, uid); } } catch (std::logic_error &e) {