4 This file is part of polypaudio.
6 polypaudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU Lesser General Public License as
8 published by the Free Software Foundation; either version 2.1 of the
9 License, or (at your option) any later version.
11 polypaudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 Lesser General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public
17 License along with polypaudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
32 #ifdef HAVE_SYS_SOCKET_H
33 #include <sys/socket.h>
41 #include <polyp/xmalloc.h>
43 #include <polypcore/core-util.h>
44 #include <polypcore/socket-util.h>
45 #include <polypcore/log.h>
47 #include "iochannel.h"
51 pa_mainloop_api* mainloop;
53 pa_iochannel_cb_t callback;
62 pa_io_event* input_event, *output_event;
65 static void enable_mainloop_sources(pa_iochannel *io) {
68 if (io->input_event == io->output_event && io->input_event) {
69 pa_io_event_flags_t f = PA_IO_EVENT_NULL;
70 assert(io->input_event);
72 if (!pa_iochannel_is_readable(io))
73 f |= PA_IO_EVENT_INPUT;
74 if (!pa_iochannel_is_writable(io))
75 f |= PA_IO_EVENT_OUTPUT;
77 io->mainloop->io_enable(io->input_event, f);
80 io->mainloop->io_enable(io->input_event, pa_iochannel_is_readable(io) ? PA_IO_EVENT_NULL : PA_IO_EVENT_INPUT);
82 io->mainloop->io_enable(io->output_event, pa_iochannel_is_writable(io) ? PA_IO_EVENT_NULL : PA_IO_EVENT_OUTPUT);
86 static void callback(pa_mainloop_api* m, pa_io_event *e, int fd, pa_io_event_flags_t f, void *userdata) {
87 pa_iochannel *io = userdata;
95 if ((f & (PA_IO_EVENT_HANGUP|PA_IO_EVENT_ERROR)) && !io->hungup) {
100 if ((f & PA_IO_EVENT_INPUT) && !io->readable) {
103 assert(e == io->input_event);
106 if ((f & PA_IO_EVENT_OUTPUT) && !io->writable) {
109 assert(e == io->output_event);
113 enable_mainloop_sources(io);
116 io->callback(io, io->userdata);
120 pa_iochannel* pa_iochannel_new(pa_mainloop_api*m, int ifd, int ofd) {
124 assert(ifd >= 0 || ofd >= 0);
126 io = pa_xnew(pa_iochannel, 1);
138 io->input_event = io->output_event = NULL;
142 pa_make_nonblock_fd(io->ifd);
143 io->input_event = io->output_event = m->io_new(m, ifd, PA_IO_EVENT_INPUT|PA_IO_EVENT_OUTPUT, callback, io);
147 pa_make_nonblock_fd(io->ifd);
148 io->input_event = m->io_new(m, ifd, PA_IO_EVENT_INPUT, callback, io);
152 pa_make_nonblock_fd(io->ofd);
153 io->output_event = m->io_new(m, ofd, PA_IO_EVENT_OUTPUT, callback, io);
160 void pa_iochannel_free(pa_iochannel*io) {
164 io->mainloop->io_free(io->input_event);
166 if (io->output_event && (io->output_event != io->input_event))
167 io->mainloop->io_free(io->output_event);
173 if (io->ofd >= 0 && io->ofd != io->ifd)
180 int pa_iochannel_is_readable(pa_iochannel*io) {
183 return io->readable || io->hungup;
186 int pa_iochannel_is_writable(pa_iochannel*io) {
189 return io->writable && !io->hungup;
192 int pa_iochannel_is_hungup(pa_iochannel*io) {
198 ssize_t pa_iochannel_write(pa_iochannel*io, const void*data, size_t l) {
204 assert(io->ofd >= 0);
206 r = pa_write(io->ofd, data, l);
209 enable_mainloop_sources(io);
215 ssize_t pa_iochannel_read(pa_iochannel*io, void*data, size_t l) {
220 assert(io->ifd >= 0);
222 r = pa_read(io->ifd, data, l);
225 enable_mainloop_sources(io);
231 #ifdef SCM_CREDENTIALS
233 int pa_iochannel_creds_supported(pa_iochannel *io) {
234 struct sockaddr_un sa;
238 assert(io->ifd >= 0);
239 assert(io->ofd == io->ifd);
243 if (getsockname(io->ifd, (struct sockaddr*) &sa, &l) < 0)
246 return sa.sun_family == AF_UNIX;
249 int pa_iochannel_creds_enable(pa_iochannel *io) {
253 assert(io->ifd >= 0);
255 if (setsockopt(io->ifd, SOL_SOCKET, SO_PASSCRED, &t, sizeof(t)) < 0) {
256 pa_log_error("setsockopt(SOL_SOCKET, SO_PASSCRED): %s", strerror(errno));
263 ssize_t pa_iochannel_write_with_creds(pa_iochannel*io, const void*data, size_t l) {
267 uint8_t cmsg_data[CMSG_SPACE(sizeof(struct ucred))];
269 struct cmsghdr *cmsg;
274 assert(io->ofd >= 0);
276 memset(&iov, 0, sizeof(iov));
277 iov.iov_base = (void*) data;
280 memset(cmsg_data, 0, sizeof(cmsg_data));
281 cmsg = (struct cmsghdr*) cmsg_data;
282 cmsg->cmsg_len = CMSG_LEN(sizeof(struct ucred));
283 cmsg->cmsg_level = SOL_SOCKET;
284 cmsg->cmsg_type = SCM_CREDENTIALS;
286 ucred = (struct ucred*) CMSG_DATA(cmsg);
287 ucred->pid = getpid();
288 ucred->uid = getuid();
289 ucred->gid = getgid();
291 memset(&mh, 0, sizeof(mh));
296 mh.msg_control = cmsg_data;
297 mh.msg_controllen = sizeof(cmsg_data);
300 if ((r = sendmsg(io->ofd, &mh, MSG_NOSIGNAL)) >= 0) {
302 enable_mainloop_sources(io);
308 ssize_t pa_iochannel_read_with_creds(pa_iochannel*io, void*data, size_t l, struct ucred *ucred, int *creds_valid) {
312 uint8_t cmsg_data[CMSG_SPACE(sizeof(struct ucred))];
317 assert(io->ifd >= 0);
321 memset(&iov, 0, sizeof(iov));
325 memset(cmsg_data, 0, sizeof(cmsg_data));
327 memset(&mh, 0, sizeof(mh));
332 mh.msg_control = cmsg_data;
333 mh.msg_controllen = sizeof(cmsg_data);
336 if ((r = recvmsg(io->ifd, &mh, MSG_NOSIGNAL)) >= 0) {
337 struct cmsghdr *cmsg;
341 for (cmsg = CMSG_FIRSTHDR(&mh); cmsg; cmsg = CMSG_NXTHDR(&mh, cmsg)) {
343 if (cmsg->cmsg_level == SOL_SOCKET && cmsg->cmsg_type == SCM_CREDENTIALS) {
344 assert(cmsg->cmsg_len == CMSG_LEN(sizeof(struct ucred)));
345 memcpy(ucred, CMSG_DATA(cmsg), sizeof(struct ucred));
352 enable_mainloop_sources(io);
357 #else /* SCM_CREDENTIALS */
359 int pa_iochannel_creds_supported(pa_iochannel *io) {
363 int pa_iochannel_creds_enable(pa_iochannel *io) {
367 ssize_t pa_iochannel_write_with_creds(pa_iochannel*io, const void*data, size_t l) {
368 pa_log_error("pa_iochannel_write_with_creds() not supported.");
372 ssize_t pa_iochannel_read_with_creds(pa_iochannel*io, void*data, size_t l, struct ucred *ucred, int *creds_valid) {
373 pa_log_error("pa_iochannel_read_with_creds() not supported.");
377 #endif /* SCM_CREDENTIALS */
379 void pa_iochannel_set_callback(pa_iochannel*io, pa_iochannel_cb_t _callback, void *userdata) {
382 io->callback = _callback;
383 io->userdata = userdata;
386 void pa_iochannel_set_noclose(pa_iochannel*io, int b) {
392 void pa_iochannel_socket_peer_to_string(pa_iochannel*io, char*s, size_t l) {
397 pa_socket_peer_to_string(io->ifd, s, l);
400 int pa_iochannel_socket_set_rcvbuf(pa_iochannel *io, size_t l) {
403 return pa_socket_set_rcvbuf(io->ifd, l);
406 int pa_iochannel_socket_set_sndbuf(pa_iochannel *io, size_t l) {
409 return pa_socket_set_sndbuf(io->ofd, l);
412 pa_mainloop_api* pa_iochannel_get_mainloop_api(pa_iochannel *io) {