Witam.
Natknalem sie na ta niespodzianke juz pare dni temu ale jakos nie
mialem kiedy o tym napisac.
Otoz z lmsd zniknela opcja blokujaca demonizowanie sie lmsd co w
pratkyce uniemozliwia puszczanie go z innitaba co jest jednym z
najbardziej sensownych (imho) sposobow odpalania najwazniejszych
procesow. Postanowilem to sobie dorobic i jakaz byla moja niespodzianka
gdy po chwili mialem dzialajacych kilka demonow. Przygladajac sie
zrodlom natknolem sie na kolejny fork uruchamianacy nazwijmy to 'worker
thread' co samo w sobie jest bardzo pozyteczne. Problem polegal na tym
ze to potomek przejmowal role petli czekajcej na kolejne zdarzenie a
proces macierzysty zaczynal odwalac czarna robote poczym sie konczyl. A
init widzac ze proces zakonczyl dzialanie odpalal go ponownie.
Musze przyznac ze najpierw myslalem ze to zwykla pomylka (jakie Alec
ostatnio ci sie czesto zdarzaja ;-) ale po chwili zastanowienia doszlem
do wniosku ze to wykonana specjalnie atrapa majaca ukryc problem z
zombie'sami bedacymi nieuchronnym skutkiem odpalania
niesynchronizowanych potomkow.
W zalaczeniu jest patch ktory:
- doklada spowrotem opcje -f (run in foreground" albo jak kto woli
"don't fork"),
- poprawia blad z forkowaniem "worker thread'a" czyli sprawia ze caly
program zachowuje sie jak na daemona przystalo (m.in nie skacze po
pidach i nie zostawia zombich)
- dodaje warunek zapobiegajacy bezsensownemu odpalaniu system() gdy
zmienna command jest pusta (brak opcji -c "[..]")
- zmienia logike funkcji crontab_match, dzieki czemu 'instancjie' z
pustym polem crontab nie sa odpalane przy kazdej mozliwej okazji tylko
podczas zadania reloadu.
- no i na koniec potwierdzenie wykonania reloadu jest zapisywane do bazy
tylko w tedy jesli reload byl zadany (updatowanie za kazdym razem jest
mylace jesli demon odpala takie zadania jak ping i niepotrzebnie obciaza
baze)
Grzegorz Stanislawski
Index: lmsd.c
===================================================================
RCS file: /home/cvsroot/lms/daemon/lmsd.c,v
retrieving revision 1.6
diff -u -r1.6 lmsd.c
--- lmsd.c 25 Apr 2005 13:48:15 -0000 1.6
+++ lmsd.c 25 Apr 2005 19:53:52 -0000
@@ -30,10 +30,12 @@
#include <stdio.h>
#include <string.h>
#include <dlfcn.h>
-
+#include <sys/types.h>
+#include <sys/wait.h>
+
#include "lmsd.h"
-int quit = 0, port = 0;
+int quit = 0, port = 0, dontfork=0;
char *db, *user, *passwd, *host, *dhost;
unsigned char *command = NULL;
unsigned char *iopt = NULL;
@@ -41,6 +43,13 @@
static void parse_command_line(int argc, char **argv);
static void free_module(MODULE *module);
static int crontab_match(time_t tt, char *crontab);
+struct sigaction act,orig;
+//signal handler for SIGCHLD reaps zombie children
+void sig_child(int signo)
+{
+ while(waitpid(-1, NULL, WNOHANG) > 0)
+ continue;
+}
int main(int argc, char *argv[])
{
@@ -95,8 +104,17 @@
g->config_getbool = &config_getbool;
g->config_getdouble = &config_getdouble;
+ // catch SIGCHLD to catch zombies ;-)
+ act.sa_handler = sig_child;
+ sigemptyset(&act.sa_mask);
+ act.sa_flags = 0;
+ sigaction (SIGCHLD, &act, &orig) ;
+ // termination signals handling
+ signal(SIGINT, termination_handler);
+ signal(SIGTERM, termination_handler);
+
// daemonize
- if ( !quit ) {
+ if ( !quit && !dontfork) {
int fval = fork();
switch (fval)
{
@@ -114,10 +132,6 @@
}
}
- // termination signals handling
- signal(SIGINT, termination_handler);
- signal(SIGTERM, termination_handler);
-
// main loop ****************************************************
for (;;)
{
@@ -134,9 +148,13 @@
tt = cron_sync_sleep();
}
- // run shell command, i.e. secure connections tuneling
- system(command);
-
+ // run shell command, i.e. secure connections tuneling
+ if(command!=NULL) {
+#ifdef DEBUG1
+ syslog(LOG_INFO, "executing command %s.", command);
+#endif
+ system(command);
+ }
// try to connect to database
if( !(g->conn = db_connect(db,user,passwd,host,port)) )
{
@@ -243,16 +261,13 @@
// forking reload - we can do a job for longer than one minute
if( i_no )
{
- switch (fork())
- {
- case -1:
+ int fval = fork();
+ if (fval <0) {
syslog(LOG_CRIT, "Fork error. Can't reload.");
if ( quit ) termination_handler(1);
- break;
- case 0: // continue main loop
- if( quit ) exit(0); // quiet parent exit
- break;
- default:
+ } else if (fval==0) { //child
+// //restore old handler so we can wait() for childs executed by modules
+// sigaction (SIGCHLD,&orig, NULL) ;
#ifdef DEBUG1
syslog(LOG_INFO, "DEBUG: [lmsd] Reloading...");
#endif
@@ -272,6 +287,7 @@
mod->file = strdup(instances[i].module);
mod->instance = strdup(instances[i].name);
mod->dlh = dlopen(mod->file, RTLD_NOW);
+ syslog(LOG_INFO, "module '%s': loaded", mod->file);
if( !mod->dlh )
{
@@ -304,15 +320,19 @@
free_module(mod);
}
- // write reload timestamp
- db_pexec(g->conn, "UPDATE daemonhosts SET lastreload=%NOW%, reload=0 WHERE name='?'", dhost);
- db_disconnect(g->conn);
-
+ // write reload timestamp only when reload was requested
+ if(reload) {
+ db_pexec(g->conn, "UPDATE daemonhosts SET lastreload=%NOW%, reload=0 WHERE name='?'", dhost);
+ db_disconnect(g->conn);
+ }
// exit child (reload) thread
- if( quit )
- termination_handler(0); // write info to syslog
- else
- exit(0);
+#ifdef DEBUG1
+ syslog(LOG_INFO, "Reload child exiting...");
+#endif
+
+ exit(0);
+ }else { //parent
+ sleep(100);
}
for(i=0; i<i_no; i++)
@@ -340,7 +360,7 @@
sscanf(REVISION, "$Id: lmsd.c,v %s", revision);
- while ( (opt = getopt(argc, argv, "qvi:h:p:d:u:H:c:")) != -1 )
+ while ( (opt = getopt(argc, argv, "qfvi:h:p:d:u:H:c:")) != -1 )
{
switch (opt)
{
@@ -350,6 +370,9 @@
case 'q':
quit = 1;
break;
+ case 'f':
+ dontfork = 1;
+ break;
case 'i':
iopt = optarg;
break;
@@ -380,6 +403,7 @@
printf(" -H daemon_host\t\thost name where runs daemon (default: `hostname`)\n");
printf(" -c command\t\tshell command to run before database connecting (default: empty)\n");
printf(" -q \t\t\tdo a reload and quit\n");
+ printf(" -f \t\t\tdo not fork to background\n");
printf(" -v \t\t\tprint version and copyright info\n");
printf(" -i \"instance[ ...]\" list of instances to reload\n");
exit(1);
@@ -404,8 +428,8 @@
{
if( cron_parse_time(&ct, crontab) != PARSE_OK )
return 0;
- if( !cron_match_time(&ct, &tt) )
- return 0;
+ if( cron_match_time(&ct, &tt) )
+ return 1;
}
- return 1;
+ return 0;
}
