2 * ion/libmainloop/signal.c
4 * Copyright (c) Tuomo Valkonen 1999-2008.
6 * See the included file LICENSE for details.
10 #include <sys/types.h>
19 #include <libtu/objp.h>
20 #include <libtu/types.h>
21 #include <libtu/misc.h>
22 #include <libtu/locale.h>
23 #include <libtu/output.h>
28 static int kill_sig=0;
30 static int wait_sig=0;
33 static int usr2_sig=0;
34 static bool had_tmr=FALSE;
36 WHook *mainloop_sigchld_hook=NULL;
37 WHook *mainloop_sigusr2_hook=NULL;
39 static sigset_t special_sigs;
45 static WTimer *queue=NULL;
48 int mainloop_gettime(struct timeval *val)
50 #if defined(_POSIX_MONOTONIC_CLOCK) && (_POSIX_MONOTONIC_CLOCK>=0)
56 ret=clock_gettime(CLOCK_MONOTONIC, &spec);
58 if(ret==-1 && errno==EINVAL && checked==0){
63 val->tv_sec=spec.tv_sec;
64 val->tv_usec=spec.tv_nsec/1000;
70 #warning "Monotonic clock unavailable; please fix your operating system."
72 return gettimeofday(val, NULL);
76 #define TIMEVAL_LATER(a, b) \
77 ((a.tv_sec > b.tv_sec) || \
78 ((a.tv_sec == b.tv_sec) && \
79 (a.tv_usec > b.tv_usec)))
81 #define USECS_IN_SEC 1000000
84 bool libmainloop_get_timeout(struct timeval *tv)
89 /* Subtract queue time from current time, don't go below zero */
91 if(TIMEVAL_LATER((queue)->when, (*tv))){
92 if(queue->when.tv_usec<tv->tv_usec){
93 queue->when.tv_usec+=USECS_IN_SEC;
96 tv->tv_usec=queue->when.tv_usec-tv->tv_usec;
97 tv->tv_sec=queue->when.tv_sec-tv->tv_sec;
100 /* POSIX and some kernels have been designed by absolute morons and
101 * contain idiotic artificial restrictions on the value of tv_usec,
102 * that will only cause more code being run and clock cycles being
103 * spent to do the same thing, as the kernel will in any case convert
104 * the seconds to some other units.
106 tv->tv_sec+=tv->tv_usec/USECS_IN_SEC;
107 tv->tv_usec%=USECS_IN_SEC;
117 static void do_timer_set()
119 struct itimerval val={{0, 0}, {0, 0}};
121 if(libmainloop_get_timeout(&val.it_value)){
122 val.it_interval.tv_usec=0;
123 val.it_interval.tv_sec=0;
125 if((setitimer(ITIMER_REAL, &val, NULL)))
128 setitimer(ITIMER_REAL, &val, NULL);
139 static bool mrsh_chld(void (*fn)(pid_t, int), ChldParams *p)
146 static bool mrsh_chld_extl(ExtlFn fn, ChldParams *p)
148 ExtlTab t=extl_create_table();
151 extl_table_sets_i(t, "pid", (int)p->pid);
153 if(WIFEXITED(p->code)){
154 extl_table_sets_b(t, "exited", TRUE);
155 extl_table_sets_i(t, "exitstatus", WEXITSTATUS(p->code));
157 if(WIFSIGNALED(p->code)){
158 extl_table_sets_b(t, "signaled", TRUE);
159 extl_table_sets_i(t, "termsig", WTERMSIG(p->code));
161 extl_table_sets_i(t, "coredump", WCOREDUMP(p->code));
164 if(WIFSTOPPED(p->code)){
165 extl_table_sets_b(t, "stopped", TRUE);
166 extl_table_sets_i(t, "stopsig", WSTOPSIG(p->code));
168 /*if(WIFCONTINUED(p->code)){
169 extl_table_sets_b(t, "continued", TRUE);
172 ret=extl_call(fn, "t", NULL, t);
179 static bool mrsh_usr2(void (*fn)(void), void *p)
185 static bool mrsh_usr2_extl(ExtlFn fn, void *p)
188 ExtlTab t=extl_create_table();
189 ret=extl_call(fn, "t", NULL, t);
195 bool mainloop_check_signals()
197 struct timeval current_time;
203 if(mainloop_sigusr2_hook!=NULL){
204 hook_call(mainloop_sigusr2_hook, NULL,
205 (WHookMarshall*)mrsh_usr2,
206 (WHookMarshallExtl*)mrsh_usr2_extl);
214 while((p.pid=waitpid(-1, &p.code, WNOHANG|WUNTRACED))>0){
215 if(mainloop_sigchld_hook!=NULL &&
216 (WIFEXITED(p.code) || WIFSIGNALED(p.code))){
217 hook_call(mainloop_sigchld_hook, &p,
218 (WHookMarshall*)mrsh_chld,
219 (WHookMarshallExtl*)mrsh_chld_extl);
228 /* Check for timer events in the queue */
229 while(had_tmr && queue!=NULL){
231 mainloop_gettime(¤t_time);
233 if(TIMEVAL_LATER(current_time, queue->when)){
237 if(q->handler!=NULL){
238 WTimerHandler *handler=q->handler;
239 Obj *obj=q->objwatch.obj;
241 watch_reset(&(q->objwatch));
243 }else if(q->extl_handler!=extl_fn_none()){
244 ExtlFn fn=q->extl_handler;
245 Obj *obj=q->objwatch.obj;
246 watch_reset(&(q->objwatch));
247 q->extl_handler=extl_fn_none();
248 extl_call(fn, "o", NULL, obj);
262 void mainloop_block_signals(sigset_t *oldmask)
264 sigprocmask(SIG_BLOCK, &special_sigs, oldmask);
268 bool mainloop_unhandled_signals()
270 return (usr2_sig || wait_sig || kill_sig || had_tmr);
274 static void add_to_current_time(struct timeval *when, uint msecs)
278 mainloop_gettime(when);
279 tmp_usec=when->tv_usec + (msecs * 1000);
280 when->tv_usec=tmp_usec % 1000000;
281 when->tv_sec+=tmp_usec / 1000000;
289 bool timer_is_set(WTimer *timer)
292 for(tmr=queue; tmr!=NULL; tmr=tmr->next){
300 void timer_do_set(WTimer *timer, uint msecs, WTimerHandler *handler,
308 /* Initialize the new queue timer event */
309 add_to_current_time(&(timer->when), msecs);
311 timer->handler=handler;
312 timer->extl_handler=fn;
314 watch_setup(&(timer->objwatch), obj, NULL);
316 watch_reset(&(timer->objwatch));
318 /* Add timerevent in place to queue */
323 if(TIMEVAL_LATER(q->when, timer->when))
336 void timer_set(WTimer *timer, uint msecs, WTimerHandler *handler,
339 timer_do_set(timer, msecs, handler, obj, extl_fn_none());
344 * Set \var{timer} to call \var{fn} in \var{msecs} milliseconds.
346 EXTL_EXPORT_AS(WTimer, set)
347 void timer_set_extl(WTimer *timer, uint msecs, ExtlFn fn)
349 timer_do_set(timer, msecs, NULL, NULL, extl_ref_fn(fn));
357 void timer_reset(WTimer *timer)
359 WTimer *q=queue, **qptr=&queue;
373 extl_unref_fn(timer->extl_handler);
374 timer->extl_handler=extl_fn_none();
375 watch_reset(&(timer->objwatch));
379 bool timer_init(WTimer *timer)
381 timer->when.tv_sec=0;
382 timer->when.tv_usec=0;
385 timer->extl_handler=extl_fn_none();
386 watch_init(&(timer->objwatch));
390 void timer_deinit(WTimer *timer)
396 WTimer *create_timer()
398 CREATEOBJ_IMPL(WTimer, timer, (p));
402 * Create a new timer.
404 EXTL_EXPORT_AS(mainloop, create_timer)
405 WTimer *create_timer_extl_owned()
407 WTimer *timer=create_timer();
409 ((Obj*)timer)->flags|=OBJ_EXTL_OWNED;
415 IMPLCLASS(WTimer, Obj, timer_deinit, NULL);
421 /*{{{ Signal handling */
424 static void fatal_signal_handler(int signal_num)
426 set_warn_handler(NULL);
427 warn(TR("Caught fatal signal %d. Dying without deinit."), signal_num);
428 signal(signal_num, SIG_DFL);
429 kill(getpid(), signal_num);
433 static void deadly_signal_handler(int signal_num)
435 set_warn_handler(NULL);
436 warn(TR("Caught signal %d. Dying."), signal_num);
437 signal(signal_num, SIG_DFL);
438 /*if(ioncore_g.opmode==IONCORE_OPMODE_INIT)
439 kill(getpid(), signal_num);
445 static void chld_handler(int signal_num)
450 while((pid=waitpid(-1, NULL, WNOHANG|WUNTRACED))>0){
458 static void usr2_handler(int signal_num)
464 static void exit_handler(int signal_num)
467 warn(TR("Got signal %d while %d is still to be handled."),
468 signal_num, kill_sig);
474 static void timer_handler(int signal_num)
480 static void ignore_handler(int signal_num)
487 /* glibc is broken (?) and does not define SA_RESTART with
488 * '-ansi -D_XOPEN_SOURCE -D_XOPEN_SOURCE_EXTENDED', so just try to live
494 #define IFTRAP(X) if(sigismember(which, X))
495 #define DEADLY(X) IFTRAP(X) signal(X, deadly_signal_handler);
496 #define FATAL(X) IFTRAP(X) signal(X, fatal_signal_handler);
497 #define IGNORE(X) IFTRAP(X) signal(X, SIG_IGN)
500 void mainloop_trap_signals(const sigset_t *which)
503 sigset_t set, oldset;
511 sigemptyset(&special_sigs);
513 sigemptyset(&oldset);
514 sigprocmask(SIG_SETMASK, &set, &oldset);
527 /*IGNORE(SIGWINCH);*/
529 sigemptyset(&(sa.sa_mask));
532 sa.sa_handler=timer_handler;
533 sa.sa_flags=SA_RESTART;
534 sigaction(SIGALRM, &sa, NULL);
535 sigaddset(&special_sigs, SIGALRM);
539 sa.sa_handler=chld_handler;
540 sa.sa_flags=SA_NOCLDSTOP|SA_RESTART;
541 sigaction(SIGCHLD, &sa, NULL);
542 sigaddset(&special_sigs, SIGCHLD);
546 sa.sa_handler=usr2_handler;
547 sa.sa_flags=SA_RESTART;
548 sigaction(SIGUSR2, &sa, NULL);
549 sigaddset(&special_sigs, SIGUSR2);
553 sa.sa_handler=exit_handler;
554 sa.sa_flags=SA_RESTART;
555 sigaction(SIGTERM, &sa, NULL);
556 sigaddset(&special_sigs, SIGTERM);
560 sa.sa_handler=exit_handler;
561 sa.sa_flags=SA_RESTART;
562 sigaction(SIGUSR1, &sa, NULL);
565 /* SIG_IGN is preserved over execve and since the the default action
566 * for SIGPIPE is not to ignore it, some programs may get upset if
567 * the behaviour is not the default.
570 sa.sa_handler=ignore_handler;
571 sigaction(SIGPIPE, &sa, NULL);