source: signal.c @ b711711

release-1.10release-1.8release-1.9
Last change on this file since b711711 was 1d21d9f, checked in by David Benjamin <davidben@mit.edu>, 13 years ago
Use sigwaitinfo instead of sigwait Eh, may as well give the signal handlers a little bit more rope.
  • Property mode set to 100644
File size: 1.6 KB
Line 
1#include <errno.h>
2#include <pthread.h>
3#include <signal.h>
4#include <stdio.h>
5#include <stdlib.h>
6
7static pthread_t signal_thread;
8static sigset_t signal_set;
9
10static void (*signal_cb)(const siginfo_t*, void*);
11static void *signal_cbdata;
12
13static void *signal_thread_func(void *data);
14
15/* Initializes the signal thread to listen for 'set' on a dedicated
16 * thread. 'callback' is called *on the signal thread* when a signal
17 * is received.
18 *
19 * This function /must/ be called before any other threads are
20 * created. (Otherwise the signals will not get blocked correctly.) */
21void owl_signal_init(const sigset_t *set, void (*callback)(const siginfo_t*, void*), void *data) {
22  int ret;
23
24  signal_set = *set;
25  signal_cb = callback;
26  signal_cbdata = data;
27  /* Block these signals in all threads, so we can get them. */
28  if ((ret = pthread_sigmask(SIG_BLOCK, set, NULL)) != 0) {
29    errno = ret;
30    perror("pthread_sigmask");
31  }
32  /* Spawn a dedicated thread to sigwait. */
33  if ((ret = pthread_create(&signal_thread, NULL,
34                            signal_thread_func, NULL)) != 0) {
35    errno = ret;
36    perror("pthread_create");
37    exit(1);
38  }
39}
40
41static void *signal_thread_func(void *data) {
42  while (1) {
43    siginfo_t siginfo;
44    int ret;
45
46    ret = sigwaitinfo(&signal_set, &siginfo);
47    /* TODO: Print an error? */
48    if (ret < 0)
49      continue;
50
51    signal_cb(&siginfo, signal_cbdata);
52    /* Die on SIGTERM. */
53    if (siginfo.si_signo == SIGTERM)
54      break;
55  }
56  return NULL;
57}
58
59void owl_signal_shutdown(void) {
60  pthread_kill(signal_thread, SIGTERM);
61  pthread_join(signal_thread, NULL);
62}
Note: See TracBrowser for help on using the repository browser.