]>
code.delx.au - pulseaudio/blob - src/utils/pacmd.c
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
;