2 This file is part of PulseAudio.
4 Copyright 2004-2006 Lennart Poettering
5 Copyright 2006-2007 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
9 published by the Free Software Foundation; either version 2.1 of the
10 License, 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 Lesser General Public License for more details.
17 You should have received a copy of the GNU Lesser General Public
18 License along with PulseAudio; if not, write to the Free Software
19 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
35 #include <pulse/xmalloc.h>
37 #include <pulsecore/core-error.h>
38 #include <pulsecore/core-util.h>
39 #include <pulsecore/socket.h>
40 #include <pulsecore/socket-util.h>
41 #include <pulsecore/log.h>
42 #include <pulsecore/macro.h>
44 #include "iochannel.h"
48 int ifd_type, ofd_type;
49 pa_mainloop_api* mainloop;
51 pa_iochannel_cb_t callback;
59 pa_io_event* input_event, *output_event;
62 static void callback(pa_mainloop_api* m, pa_io_event *e, int fd, pa_io_event_flags_t f, void *userdata);
64 static void delete_events(pa_iochannel *io) {
68 io->mainloop->io_free(io->input_event);
70 if (io->output_event && io->output_event != io->input_event)
71 io->mainloop->io_free(io->output_event);
73 io->input_event = io->output_event = NULL;
76 static void enable_events(pa_iochannel *io) {
84 if (io->ifd == io->ofd && io->ifd >= 0) {
85 pa_io_event_flags_t f = PA_IO_EVENT_NULL;
88 f |= PA_IO_EVENT_INPUT;
90 f |= PA_IO_EVENT_OUTPUT;
92 pa_assert(io->input_event == io->output_event);
94 if (f != PA_IO_EVENT_NULL) {
96 io->mainloop->io_enable(io->input_event, f);
98 io->input_event = io->output_event = io->mainloop->io_new(io->mainloop, io->ifd, f, callback, io);
107 io->mainloop->io_enable(io->input_event, PA_IO_EVENT_INPUT);
109 io->input_event = io->mainloop->io_new(io->mainloop, io->ifd, PA_IO_EVENT_INPUT, callback, io);
110 } else if (io->input_event) {
111 io->mainloop->io_free(io->input_event);
112 io->input_event = NULL;
118 if (io->output_event)
119 io->mainloop->io_enable(io->output_event, PA_IO_EVENT_OUTPUT);
121 io->output_event = io->mainloop->io_new(io->mainloop, io->ofd, PA_IO_EVENT_OUTPUT, callback, io);
122 } else if (io->input_event) {
123 io->mainloop->io_free(io->output_event);
124 io->output_event = NULL;
130 static void callback(pa_mainloop_api* m, pa_io_event *e, int fd, pa_io_event_flags_t f, void *userdata) {
131 pa_iochannel *io = userdata;
132 pa_bool_t changed = FALSE;
139 if ((f & (PA_IO_EVENT_HANGUP|PA_IO_EVENT_ERROR)) && !io->hungup) {
144 if ((f & PA_IO_EVENT_INPUT) && !io->readable) {
147 pa_assert(e == io->input_event);
150 if ((f & PA_IO_EVENT_OUTPUT) && !io->writable) {
153 pa_assert(e == io->output_event);
160 io->callback(io, io->userdata);
164 pa_iochannel* pa_iochannel_new(pa_mainloop_api*m, int ifd, int ofd) {
168 pa_assert(ifd >= 0 || ofd >= 0);
170 io = pa_xnew0(pa_iochannel, 1);
176 pa_make_fd_nonblock(io->ifd);
178 if (io->ofd >= 0 && io->ofd != io->ifd)
179 pa_make_fd_nonblock(io->ofd);
185 void pa_iochannel_free(pa_iochannel*io) {
193 if (io->ofd >= 0 && io->ofd != io->ifd)
200 pa_bool_t pa_iochannel_is_readable(pa_iochannel*io) {
203 return io->readable || io->hungup;
206 pa_bool_t pa_iochannel_is_writable(pa_iochannel*io) {
209 return io->writable && !io->hungup;
212 pa_bool_t pa_iochannel_is_hungup(pa_iochannel*io) {
218 ssize_t pa_iochannel_write(pa_iochannel*io, const void*data, size_t l) {
224 pa_assert(io->ofd >= 0);
226 if ((r = pa_write(io->ofd, data, l, &io->ofd_type)) >= 0) {
227 io->writable = io->hungup = FALSE;
234 ssize_t pa_iochannel_read(pa_iochannel*io, void*data, size_t l) {
239 pa_assert(io->ifd >= 0);
241 if ((r = pa_read(io->ifd, data, l, &io->ifd_type)) >= 0) {
243 /* We also reset the hangup flag here to ensure that another
244 * IO callback is triggered so that we will again call into
246 io->readable = io->hungup = FALSE;
255 pa_bool_t pa_iochannel_creds_supported(pa_iochannel *io) {
259 struct sockaddr_un un;
261 struct sockaddr_storage storage;
267 pa_assert(io->ifd >= 0);
268 pa_assert(io->ofd == io->ifd);
271 if (getsockname(io->ifd, &sa.sa, &l) < 0)
274 return sa.sa.sa_family == AF_UNIX;
277 int pa_iochannel_creds_enable(pa_iochannel *io) {
281 pa_assert(io->ifd >= 0);
283 if (setsockopt(io->ifd, SOL_SOCKET, SO_PASSCRED, &t, sizeof(t)) < 0) {
284 pa_log_error("setsockopt(SOL_SOCKET, SO_PASSCRED): %s", pa_cstrerror(errno));
291 ssize_t pa_iochannel_write_with_creds(pa_iochannel*io, const void*data, size_t l, const pa_creds *ucred) {
297 uint8_t data[CMSG_SPACE(sizeof(struct ucred))];
304 pa_assert(io->ofd >= 0);
307 iov.iov_base = (void*) data;
311 cmsg.hdr.cmsg_len = CMSG_LEN(sizeof(struct ucred));
312 cmsg.hdr.cmsg_level = SOL_SOCKET;
313 cmsg.hdr.cmsg_type = SCM_CREDENTIALS;
315 u = (struct ucred*) CMSG_DATA(&cmsg.hdr);
329 mh.msg_control = &cmsg;
330 mh.msg_controllen = sizeof(cmsg);
332 if ((r = sendmsg(io->ofd, &mh, MSG_NOSIGNAL)) >= 0) {
333 io->writable = io->hungup = FALSE;
340 ssize_t pa_iochannel_read_with_creds(pa_iochannel*io, void*data, size_t l, pa_creds *creds, pa_bool_t *creds_valid) {
346 uint8_t data[CMSG_SPACE(sizeof(struct ucred))];
352 pa_assert(io->ifd >= 0);
354 pa_assert(creds_valid);
364 mh.msg_control = &cmsg;
365 mh.msg_controllen = sizeof(cmsg);
367 if ((r = recvmsg(io->ifd, &mh, 0)) >= 0) {
370 *creds_valid = FALSE;
372 for (cmh = CMSG_FIRSTHDR(&mh); cmh; cmh = CMSG_NXTHDR(&mh, cmh)) {
374 if (cmh->cmsg_level == SOL_SOCKET && cmh->cmsg_type == SCM_CREDENTIALS) {
376 pa_assert(cmh->cmsg_len == CMSG_LEN(sizeof(struct ucred)));
377 memcpy(&u, CMSG_DATA(cmh), sizeof(struct ucred));
386 io->readable = io->hungup = FALSE;
393 #endif /* HAVE_CREDS */
395 void pa_iochannel_set_callback(pa_iochannel*io, pa_iochannel_cb_t _callback, void *userdata) {
398 io->callback = _callback;
399 io->userdata = userdata;
402 void pa_iochannel_set_noclose(pa_iochannel*io, pa_bool_t b) {
408 void pa_iochannel_socket_peer_to_string(pa_iochannel*io, char*s, size_t l) {
413 pa_socket_peer_to_string(io->ifd, s, l);
416 int pa_iochannel_socket_set_rcvbuf(pa_iochannel *io, size_t l) {
419 return pa_socket_set_rcvbuf(io->ifd, l);
422 int pa_iochannel_socket_set_sndbuf(pa_iochannel *io, size_t l) {
425 return pa_socket_set_sndbuf(io->ofd, l);
428 pa_mainloop_api* pa_iochannel_get_mainloop_api(pa_iochannel *io) {
434 int pa_iochannel_get_recv_fd(pa_iochannel *io) {
440 int pa_iochannel_get_send_fd(pa_iochannel *io) {
446 pa_bool_t pa_iochannel_socket_is_local(pa_iochannel *io) {
449 if (pa_socket_is_local(io->ifd))
452 if (io->ifd != io->ofd)
453 if (pa_socket_is_local(io->ofd))