2 This file is part of PulseAudio.
4 Copyright 2004-2006 Lennart Poettering
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.
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.
16 You should have received a copy of the GNU Lesser General Public License
17 along with PulseAudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
28 #include <sys/socket.h>
35 #include <pulse/util.h>
36 #include <pulse/xmalloc.h>
38 #include <pulsecore/i18n.h>
39 #include <pulsecore/poll.h>
40 #include <pulsecore/macro.h>
41 #include <pulsecore/core-util.h>
42 #include <pulsecore/log.h>
43 #include <pulsecore/pid.h>
45 int main(int argc, char*argv[]) {
49 struct sockaddr_un sa;
50 char ibuf[PIPE_BUF], obuf[PIPE_BUF];
51 size_t ibuf_index, ibuf_length, obuf_index, obuf_length;
53 pa_bool_t ibuf_eof, obuf_eof, ibuf_closed, obuf_closed;
54 struct pollfd pollfd[3];
55 struct pollfd *watch_socket, *watch_stdin, *watch_stdout;
57 int stdin_type = 0, stdout_type = 0, fd_type = 0;
59 setlocale(LC_ALL, "");
61 bindtextdomain(GETTEXT_PACKAGE, PULSE_LOCALEDIR);
64 if (pa_pid_file_check_running(&pid, "pulseaudio") < 0) {
65 pa_log(_("No PulseAudio daemon running, or not running as session daemon."));
69 if ((fd = pa_socket_cloexec(PF_UNIX, SOCK_STREAM, 0)) < 0) {
70 pa_log(_("socket(PF_UNIX, SOCK_STREAM, 0): %s"), strerror(errno));
75 sa.sun_family = AF_UNIX;
77 if (!(cli = pa_runtime_path("cli")))
80 pa_strlcpy(sa.sun_path, cli, sizeof(sa.sun_path));
83 for (i = 0; i < 5; i++) {
86 if ((r = connect(fd, (struct sockaddr*) &sa, sizeof(sa))) < 0 && (errno != ECONNREFUSED && errno != ENOENT)) {
87 pa_log(_("connect(): %s"), strerror(errno));
94 if (pa_pid_file_kill(SIGUSR2, NULL, "pulseaudio") < 0) {
95 pa_log(_("Failed to kill PulseAudio daemon."));
103 pa_log(_("Daemon not responding."));
107 ibuf_index = ibuf_length = obuf_index = obuf_length = 0;
108 ibuf_eof = obuf_eof = ibuf_closed = obuf_closed = FALSE;
111 for (i = 1; i < argc; i++) {
114 k = PA_MIN(sizeof(ibuf) - ibuf_length, strlen(argv[i]));
115 memcpy(ibuf + ibuf_length, argv[i], k);
118 if (ibuf_length < sizeof(ibuf)) {
119 ibuf[ibuf_length] = i < argc-1 ? ' ' : '\n';
136 if (ibuf_length <= 0 && ibuf_eof && !ibuf_closed) {
137 shutdown(fd, SHUT_WR);
141 if (obuf_length <= 0 && obuf_eof && !obuf_closed) {
142 shutdown(fd, SHUT_RD);
150 if (ibuf_length > 0 || (!obuf_eof && obuf_length <= 0)) {
152 watch_socket->fd = fd;
153 watch_socket->events =
154 (ibuf_length > 0 ? POLLOUT : 0) |
155 (!obuf_eof && obuf_length <= 0 ? POLLIN : 0);
159 if (!ibuf_eof && ibuf_length <= 0) {
161 watch_stdin->fd = STDIN_FILENO;
162 watch_stdin->events = POLLIN;
166 if (obuf_length > 0) {
168 watch_stdout->fd = STDOUT_FILENO;
169 watch_stdout->events = POLLOUT;
173 if (pa_poll(pollfd, p-pollfd, -1) < 0) {
178 pa_log(_("poll(): %s"), strerror(errno));
183 if (watch_stdin->revents & POLLIN) {
185 pa_assert(ibuf_length <= 0);
187 if ((r = pa_read(STDIN_FILENO, ibuf, sizeof(ibuf), &stdin_type)) <= 0) {
189 pa_log(_("read(): %s"), strerror(errno));
195 ibuf_length = (size_t) r;
198 } else if (watch_stdin->revents & POLLHUP)
203 if (watch_socket->revents & POLLIN) {
205 pa_assert(obuf_length <= 0);
207 if ((r = pa_read(fd, obuf, sizeof(obuf), &fd_type)) <= 0) {
209 pa_log(_("read(): %s"), strerror(errno));
215 obuf_length = (size_t) r;
218 } else if (watch_socket->revents & POLLHUP)
223 if (watch_stdout->revents & POLLHUP) {
226 } else if (watch_stdout->revents & POLLOUT) {
228 pa_assert(obuf_length > 0);
230 if ((r = pa_write(STDOUT_FILENO, obuf + obuf_index, obuf_length, &stdout_type)) < 0) {
231 pa_log(_("write(): %s"), strerror(errno));
235 obuf_length -= (size_t) r;
236 obuf_index += obuf_index;
241 if (watch_socket->revents & POLLHUP) {
244 } if (watch_socket->revents & POLLOUT) {
246 pa_assert(ibuf_length > 0);
248 if ((r = pa_write(fd, ibuf + ibuf_index, ibuf_length, &fd_type)) < 0) {
249 pa_log(_("write(): %s"), strerror(errno));
253 ibuf_length -= (size_t) r;
254 ibuf_index += obuf_index;