nexmon – Blame information for rev 1

Subversion Repositories:
Rev:
Rev Author Line No. Line
1 office 1 /* source: xiosignal.c */
2 /* Copyright Gerhard Rieger */
3 /* Published under the GNU General Public License V.2, see file COPYING */
4  
5 /* this file contains code for handling signals (except SIGCHLD) */
6  
7 #include "config.h"
8 #include "xioconfig.h" /* what features are enabled */
9  
10 #include "sysincludes.h"
11  
12 #include "mytypes.h"
13 #include "compat.h"
14 #include "error.h"
15  
16 #include "sycls.h"
17  
18  
19 #define SOCAT_MAXPIDS 4
20  
21 struct socat_sig_desc {
22 int sig_use;
23 pid_t sig_pids[SOCAT_MAXPIDS];
24 } ;
25  
26 #if 0
27 size_t socat_sigint_use; /* how many pids are set in following array */
28 static pid_t socat_sigint_pids[SOCAT_MAXPIDS];
29 size_t socat_sigquit_use; /* how many pids are set in following array */
30 static pid_t socat_sigquit_pids[SOCAT_MAXPIDS];
31 #else
32 static struct socat_sig_desc socat_sighup;
33 static struct socat_sig_desc socat_sigint;
34 static struct socat_sig_desc socat_sigquit;
35 #endif
36  
37  
38 /* is async-signal-safe */
39 static struct socat_sig_desc *socat_get_sig_desc(int signum) {
40 struct socat_sig_desc *sigdesc;
41 switch (signum) {
42 case SIGHUP: sigdesc = &socat_sighup; break;
43 case SIGINT: sigdesc = &socat_sigint; break;
44 case SIGQUIT: sigdesc = &socat_sigquit; break;
45 default: sigdesc = NULL; break;
46 }
47 return sigdesc;
48 }
49  
50 /* a signal handler that possibly passes the signal to sub processes */
51 void socatsignalpass(int sig) {
52 int i;
53 struct socat_sig_desc *sigdesc;
54 int _errno;
55  
56 _errno = errno;
57 diag_in_handler = 1;
58 Notice1("socatsignalpass(%d)", sig);
59 if ((sigdesc = socat_get_sig_desc(sig)) == NULL) { /* is async-signal-safe */
60 diag_in_handler = 0;
61 errno = _errno;
62 return;
63 }
64  
65 for (i=0; i<sigdesc->sig_use; ++i) {
66 if (sigdesc->sig_pids[i]) {
67 if (Kill(sigdesc->sig_pids[i], sig) < 0) {
68 Warn2("kill("F_pid", %d): %m",
69 sigdesc->sig_pids[i], sig);
70 }
71 }
72 }
73 #if !HAVE_SIGACTION
74 Signal(sig, socatsignalpass);
75 #endif /* !HAVE_SIGACTION */
76 Debug("socatsignalpass() ->");
77 diag_in_handler = 0;
78 errno = _errno;
79 }
80  
81  
82 /* register the sub process pid for passing of signals of type signum.
83 Only for SIGHUP, SIGINT, and SIGQUIT!
84 returns 0 on success or <0 if an error occurred */
85 int xio_opt_signal(pid_t pid, int signum) {
86 struct socat_sig_desc *sigdesc;
87  
88 if ((sigdesc = socat_get_sig_desc(signum)) == NULL) {
89 Error("sub process registered for unsupported signal");
90 return -1;
91 }
92  
93 if (sigdesc->sig_use >= SOCAT_MAXPIDS) {
94 Error1("too many sub processes registered for signal %d", signum);
95 return -1;
96 }
97 if (sigdesc->sig_use == 0) {
98 /* the special signal handler has not been registered yet - do it now */
99 #if HAVE_SIGACTION
100 struct sigaction act;
101 memset(&act, 0, sizeof(struct sigaction));
102 act.sa_flags = 0/*SA_RESTART*/;
103 act.sa_handler = socatsignalpass;
104 sigfillset(&act.sa_mask);
105 if (Sigaction(signum, &act, NULL) < 0) {
106 /*! man does not say that errno is defined */
107 Warn3("sigaction(%d, %p, NULL): %s", signum, &act, strerror(errno));
108 }
109 #else
110 Signal(signum, socatsignalpass);
111 #endif /* !HAVE_SIGACTION */
112 }
113 sigdesc->sig_pids[sigdesc->sig_use++] = pid;
114 return 0;
115 }
116