src/pulsecore/pipe.c

   1 /***
   2   This file is part of PulseAudio.
   3
   4   Copyright 2006-2007 Pierre Ossman <ossman@cendio.se> for Cendio AB
   5
   6   PulseAudio is free software; you can redistribute it and/or modify
   7   it under the terms of the GNU Lesser General Public License as published
   8   by the Free Software Foundation; either version 2.1 of the License,
   9   or (at your option) any later version.
  10
  11   PulseAudio 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   General Public License for more details.
  15
  16   You should have received a copy of the GNU Lesser General Public License
  17   along with PulseAudio; if not, see <http://www.gnu.org/licenses/>.
  18 ***/
  19
  20 #ifdef HAVE_CONFIG_H
  21 #include <config.h>
  22 #endif
  23
  24 #include <errno.h>
  25 #include <unistd.h>
  26 #include <fcntl.h>
  27
  28 #include <sys/types.h>
  29
  30 #include <pulsecore/socket.h>
  31 #include <pulsecore/core-util.h>
  32
  33 #include "pipe.h"
  34
  35 #ifndef HAVE_PIPE
  36
  37 static int set_block(int fd, int blocking) {
  38 #ifdef O_NONBLOCK
  39
  40     int v;
  41
  42     pa_assert(fd >= 0);
  43
  44     if ((v = fcntl(fd, F_GETFL)) < 0)
  45         return -1;
  46
  47     if (blocking)
  48         v &= ~O_NONBLOCK;
  49     else
  50         v |= O_NONBLOCK;
  51
  52     if (fcntl(fd, F_SETFL, v) < 0)
  53         return -1;
  54
  55     return 0;
  56
  57 #elif defined(OS_IS_WIN32)
  58
  59     u_long arg;
  60
  61     arg = !blocking;
  62
  63     if (ioctlsocket(fd, FIONBIO, &arg) < 0)
  64         return -1;
  65
  66     return 0;
  67
  68 #else
  69
  70     return -1;
  71
  72 #endif
  73 }
  74
  75 int pipe(int filedes[2]) {
  76     int listener;
  77     struct sockaddr_in addr, peer;
  78     socklen_t len;
  79
  80     listener = -1;
  81     filedes[0] = -1;
  82     filedes[1] = -1;
  83
  84     listener = socket(PF_INET, SOCK_STREAM, 0);
  85     if (listener < 0)
  86         goto error;
  87
  88     filedes[0] = socket(PF_INET, SOCK_STREAM, 0);
  89     if (filedes[0] < 0)
  90         goto error;
  91
  92     filedes[1] = socket(PF_INET, SOCK_STREAM, 0);
  93     if (filedes[1] < 0)
  94         goto error;
  95
  96     /* Make non-blocking so that connect() won't block */
  97     if (set_block(filedes[0], 0) < 0)
  98         goto error;
  99
 100     addr.sin_family = AF_INET;
 101     addr.sin_port = 0;
 102     addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
 103
 104     if (bind(listener, (struct sockaddr*)&addr, sizeof(addr)) < 0)
 105         goto error;
 106
 107     if (listen(listener, 1) < 0)
 108         goto error;
 109
 110     len = sizeof(addr);
 111     if (getsockname(listener, (struct sockaddr*)&addr, &len) < 0)
 112         goto error;
 113
 114     if (connect(filedes[0], (struct sockaddr*)&addr, sizeof(addr)) < 0) {
 115 #ifdef OS_IS_WIN32
 116         if (WSAGetLastError() != EWOULDBLOCK)
 117 #else
 118         if (errno != EINPROGRESS)
 119 #endif
 120             goto error;
 121     }
 122
 123     len = sizeof(peer);
 124     filedes[1] = accept(listener, (struct sockaddr*)&peer, &len);
 125     if (filedes[1] < 0)
 126         goto error;
 127
 128     /* Restore blocking */
 129     if (set_block(filedes[0], 1) < 0)
 130         goto error;
 131
 132     len = sizeof(addr);
 133     if (getsockname(filedes[0], (struct sockaddr*)&addr, &len) < 0)
 134         goto error;
 135
 136     /* Check that someone else didn't steal the connection */
 137     if ((addr.sin_port != peer.sin_port) || (addr.sin_addr.s_addr != peer.sin_addr.s_addr))
 138         goto error;
 139
 140     pa_close(listener);
 141
 142     return 0;
 143
 144 error:
 145         if (listener >= 0)
 146                 pa_close(listener);
 147         if (filedes[0] >= 0)
 148                 pa_close(filedes[0]);
 149         if (filedes[1] >= 0)
 150                 pa_close(filedes[1]);
 151
 152         return -1;
 153 }
 154
 155 #endif /* HAVE_PIPE */