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>
36 #include <pulse/util.h>
37 #include <pulse/xmalloc.h>
39 #include <pulsecore/i18n.h>
40 #include <pulsecore/poll.h>
41 #include <pulsecore/macro.h>
42 #include <pulsecore/core-util.h>
43 #include <pulsecore/log.h>
44 #include <pulsecore/pid.h>
46 static void help(const char *argv0) {
47 printf("%s %s\n", argv0, "exit");
48 printf("%s %s\n", argv0, "help");
49 printf("%s %s\n", argv0, "list-(modules|sinks|sources|clients|cards|samples)");
50 printf("%s %s\n", argv0, "list-(sink-inputs|source-outputs)");
51 printf("%s %s\n", argv0, "stat");
52 printf("%s %s\n", argv0, "info");
53 printf("%s %s %s\n", argv0, "load-module", _("NAME [ARGS ...]"));
54 printf("%s %s %s\n", argv0, "unload-module", _("#N"));
55 printf("%s %s %s\n", argv0, "describe-module", _("NAME"));
56 printf("%s %s %s\n", argv0, "set-(sink|source)-volume", _("NAME|#N VOLUME"));
57 printf("%s %s %s\n", argv0, "set-(sink-input|source-output)-volume", _("#N VOLUME"));
58 printf("%s %s %s\n", argv0, "set-(sink|source)-mute", _("NAME|#N 1|0"));
59 printf("%s %s %s\n", argv0, "set-(sink-input|source-output)-mute", _("#N 1|0"));
60 printf("%s %s %s\n", argv0, "update-(sink|source)-proplist", _("NAME|#N KEY=VALUE"));
61 printf("%s %s %s\n", argv0, "update-(sink-input|source-output)-proplist", _("#N KEY=VALUE"));
62 printf("%s %s %s\n", argv0, "set-default(sink|source)", _("NAME|#N"));
63 printf("%s %s %s\n", argv0, "kill-(client|sink-input|source-output)", _("#N"));
64 printf("%s %s %s\n", argv0, "play-sample", _("NAME SINK|#N"));
65 printf("%s %s %s\n", argv0, "remove-sample", _("NAME"));
66 printf("%s %s %s\n", argv0, "load-sample", _("NAME FILENAME"));
67 printf("%s %s %s\n", argv0, "load-sample-lazy", _("NAME FILENAME"));
68 printf("%s %s %s\n", argv0, "load-sample-dir-lazy", _("PATHNAME"));
69 printf("%s %s %s\n", argv0, "play-file", _("FILENAME SINK|#N"));
70 printf("%s %s\n", argv0, "dump");
71 printf("%s %s %s\n", argv0, "move-(sink-input|source-output)", _("#N SINK|SOURCE"));
72 printf("%s %s %s\n", argv0, "suspend-(sink|source)", _("NAME|#N 1|0"));
73 printf("%s %s %s\n", argv0, "suspend", _("1|0"));
74 printf("%s %s %s\n", argv0, "set-card-profile", _("CARD PROFILE"));
75 printf("%s %s %s\n", argv0, "set-(sink|source)-port", _("NAME|#N PORT"));
76 printf("%s %s %s\n", argv0, "set-log-level", _("NUMERIC LEVEL"));
77 printf("%s %s %s\n", argv0, "set-log-meta", _("1|0"));
78 printf("%s %s %s\n", argv0, "set-log-time", _("1|0"));
79 printf("%s %s %s\n", argv0, "set-log-backtrace", _("FRAMES"));
82 " -h, --help Show this help\n"
83 " --version Show version\n"
84 "When no command is given pacdm starts in the interactive mode\n" ));
91 int main(int argc, char*argv[]) {
95 struct sockaddr_un sa;
98 size_t buf_size, ibuf_size, ibuf_index, ibuf_length, obuf_size, obuf_index, obuf_length;
100 pa_bool_t ibuf_eof, obuf_eof, ibuf_closed, obuf_closed;
101 struct pollfd pollfd[3];
102 struct pollfd *watch_socket, *watch_stdin, *watch_stdout;
104 int stdin_type = 0, stdout_type = 0, fd_type = 0;
109 static const struct option long_options[] = {
110 {"version", 0, NULL, ARG_VERSION},
111 {"help", 0, NULL, 'h'},
115 setlocale(LC_ALL, "");
117 bindtextdomain(GETTEXT_PACKAGE, PULSE_LOCALEDIR);
120 bn = pa_path_get_filename(argv[0]);
122 while ((c = getopt_long(argc, argv, "h", long_options, NULL)) != -1) {
129 printf(_("pacmd %s\n"
130 "Compiled with libpulse %s\n"
131 "Linked with libpulse %s\n"),
133 pa_get_headers_version(),
134 pa_get_library_version());
142 if (pa_pid_file_check_running(&pid, "pulseaudio") < 0) {
143 pa_log(_("No PulseAudio daemon running, or not running as session daemon."));
147 if ((fd = pa_socket_cloexec(PF_UNIX, SOCK_STREAM, 0)) < 0) {
148 pa_log(_("socket(PF_UNIX, SOCK_STREAM, 0): %s"), strerror(errno));
153 sa.sun_family = AF_UNIX;
155 if (!(cli = pa_runtime_path("cli")))
158 pa_strlcpy(sa.sun_path, cli, sizeof(sa.sun_path));
161 for (i = 0; i < 5; i++) {
164 if ((r = connect(fd, (struct sockaddr*) &sa, sizeof(sa))) < 0 && (errno != ECONNREFUSED && errno != ENOENT)) {
165 pa_log(_("connect(): %s"), strerror(errno));
173 if (pa_pid_file_kill(SIGUSR2, NULL, "pulseaudio") < 0) {
174 pa_log(_("Failed to kill PulseAudio daemon."));
182 pa_log(_("Daemon not responding."));
186 buf_size = pa_pipe_buf(fd);
187 ibuf_size = PA_MIN(buf_size, pa_pipe_buf(STDIN_FILENO));
188 ibuf = pa_xmalloc(ibuf_size);
189 obuf_size = PA_MIN(buf_size, pa_pipe_buf(STDOUT_FILENO));
190 obuf = pa_xmalloc(obuf_size);
191 ibuf_index = ibuf_length = obuf_index = obuf_length = 0;
192 ibuf_eof = obuf_eof = ibuf_closed = obuf_closed = FALSE;
195 for (i = 1; i < argc; i++) {
198 k = PA_MIN(ibuf_size - ibuf_length, strlen(argv[i]));
199 memcpy(ibuf + ibuf_length, argv[i], k);
202 if (ibuf_length < ibuf_size) {
203 ibuf[ibuf_length] = i < argc-1 ? ' ' : '\n';
220 if (ibuf_length <= 0 && ibuf_eof && !ibuf_closed) {
221 shutdown(fd, SHUT_WR);
225 if (obuf_length <= 0 && obuf_eof && !obuf_closed) {
226 shutdown(fd, SHUT_RD);
234 if (ibuf_length > 0 || (!obuf_eof && obuf_length <= 0)) {
236 watch_socket->fd = fd;
237 watch_socket->events =
238 (ibuf_length > 0 ? POLLOUT : 0) |
239 (!obuf_eof && obuf_length <= 0 ? POLLIN : 0);
243 if (!ibuf_eof && ibuf_length <= 0) {
245 watch_stdin->fd = STDIN_FILENO;
246 watch_stdin->events = POLLIN;
250 if (obuf_length > 0) {
252 watch_stdout->fd = STDOUT_FILENO;
253 watch_stdout->events = POLLOUT;
257 if (pa_poll(pollfd, p-pollfd, -1) < 0) {
262 pa_log(_("poll(): %s"), strerror(errno));
267 if (watch_stdin->revents & POLLIN) {
269 pa_assert(ibuf_length <= 0);
271 if ((r = pa_read(STDIN_FILENO, ibuf, ibuf_size, &stdin_type)) <= 0) {
273 pa_log(_("read(): %s"), strerror(errno));
279 ibuf_length = (size_t) r;
282 } else if (watch_stdin->revents & POLLHUP)
287 if (watch_socket->revents & POLLIN) {
289 pa_assert(obuf_length <= 0);
291 if ((r = pa_read(fd, obuf, obuf_size, &fd_type)) <= 0) {
293 pa_log(_("read(): %s"), strerror(errno));
299 obuf_length = (size_t) r;
302 } else if (watch_socket->revents & POLLHUP)
307 if (watch_stdout->revents & POLLHUP) {
310 } else if (watch_stdout->revents & POLLOUT) {
312 pa_assert(obuf_length > 0);
314 if ((r = pa_write(STDOUT_FILENO, obuf + obuf_index, obuf_length, &stdout_type)) < 0) {
315 pa_log(_("write(): %s"), strerror(errno));
319 obuf_length -= (size_t) r;
320 obuf_index += obuf_index;
325 if (watch_socket->revents & POLLHUP) {
328 } if (watch_socket->revents & POLLOUT) {
330 pa_assert(ibuf_length > 0);
332 if ((r = pa_write(fd, ibuf + ibuf_index, ibuf_length, &fd_type)) < 0) {
333 pa_log(_("write(): %s"), strerror(errno));
337 ibuf_length -= (size_t) r;
338 ibuf_index += obuf_index;