2 This file is part of PulseAudio.
4 Copyright 2004-2008 Lennart Poettering
5 Copyright 2006 Pierre Ossman <ossman@cendio.se> for Cendio AB
7 PulseAudio is free software; you can redistribute it and/or modify
8 it under the terms of the GNU Lesser General Public License as published
9 by the Free Software Foundation; either version 2 of the License,
10 or (at your option) any later version.
12 PulseAudio is distributed in the hope that it will be useful, but
13 WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 General Public License for more details.
17 You should have received a copy of the GNU Lesser General Public License
18 along with PulseAudio; if not, write to the Free Software
19 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
39 #include <pulse/xmalloc.h>
40 #include <pulse/gccmacro.h>
41 #include <pulse/i18n.h>
43 #include <pulsecore/core-error.h>
44 #include <pulsecore/core-util.h>
45 #include <pulsecore/log.h>
46 #include <pulsecore/macro.h>
48 #include "mainloop-signal.h"
50 struct pa_signal_event
{
53 struct sigaction saved_sigaction
;
55 void (*saved_handler
)(int sig
);
58 pa_signal_cb_t callback
;
59 pa_signal_destroy_cb_t destroy_callback
;
60 pa_signal_event
*previous
, *next
;
63 static pa_mainloop_api
*api
= NULL
;
64 static int signal_pipe
[2] = { -1, -1 };
65 static pa_io_event
* io_event
= NULL
;
66 static pa_signal_event
*signals
= NULL
;
68 static void signal_handler(int sig
) {
73 #ifndef HAVE_SIGACTION
74 signal(sig
, signal_handler
);
77 pa_write(signal_pipe
[1], &sig
, sizeof(sig
), NULL
);
82 static void dispatch(pa_mainloop_api
*a
, int sig
) {
85 for (s
= signals
; s
; s
= s
->next
)
87 pa_assert(s
->callback
);
88 s
->callback(a
, s
, sig
, s
->userdata
);
93 static void callback(pa_mainloop_api
*a
, pa_io_event
*e
, int fd
, pa_io_event_flags_t f
, void *userdata
) {
99 pa_assert(f
== PA_IO_EVENT_INPUT
);
100 pa_assert(e
== io_event
);
101 pa_assert(fd
== signal_pipe
[0]);
103 if ((r
= pa_read(signal_pipe
[0], &sig
, sizeof(sig
), NULL
)) < 0) {
107 pa_log("read(): %s", pa_cstrerror(errno
));
111 if (r
!= sizeof(sig
)) {
112 pa_log("short read()");
119 int pa_signal_init(pa_mainloop_api
*a
) {
123 pa_assert(signal_pipe
[0] == -1);
124 pa_assert(signal_pipe
[1] == -1);
125 pa_assert(!io_event
);
127 if (pipe(signal_pipe
) < 0) {
128 pa_log("pipe(): %s", pa_cstrerror(errno
));
132 pa_make_fd_nonblock(signal_pipe
[0]);
133 pa_make_fd_nonblock(signal_pipe
[1]);
134 pa_make_fd_cloexec(signal_pipe
[0]);
135 pa_make_fd_cloexec(signal_pipe
[1]);
139 pa_assert_se(io_event
= api
->io_new(api
, signal_pipe
[0], PA_IO_EVENT_INPUT
, callback
, NULL
));
144 void pa_signal_done(void) {
146 pa_signal_free(signals
);
150 api
->io_free(io_event
);
154 pa_close_pipe(signal_pipe
);
159 pa_signal_event
* pa_signal_new(int sig
, pa_signal_cb_t _callback
, void *userdata
) {
160 pa_signal_event
*e
= NULL
;
162 #ifdef HAVE_SIGACTION
167 pa_assert(_callback
);
171 for (e
= signals
; e
; e
= e
->next
)
175 e
= pa_xnew(pa_signal_event
, 1);
177 e
->callback
= _callback
;
178 e
->userdata
= userdata
;
179 e
->destroy_callback
= NULL
;
181 #ifdef HAVE_SIGACTION
182 memset(&sa
, 0, sizeof(sa
));
183 sa
.sa_handler
= signal_handler
;
184 sigemptyset(&sa
.sa_mask
);
185 sa
.sa_flags
= SA_RESTART
;
187 if (sigaction(sig
, &sa
, &e
->saved_sigaction
) < 0)
189 if ((e
->saved_handler
= signal(sig
, signal_handler
)) == SIG_ERR
)
204 void pa_signal_free(pa_signal_event
*e
) {
208 e
->next
->previous
= e
->previous
;
210 e
->previous
->next
= e
->next
;
214 #ifdef HAVE_SIGACTION
215 pa_assert_se(sigaction(e
->sig
, &e
->saved_sigaction
, NULL
) == 0);
217 pa_assert_se(signal(e
->sig
, e
->saved_handler
) == signal_handler
);
220 if (e
->destroy_callback
)
221 e
->destroy_callback(api
, e
, e
->userdata
);
226 void pa_signal_set_destroy(pa_signal_event
*e
, pa_signal_destroy_cb_t _callback
) {
229 e
->destroy_callback
= _callback
;