code.delx.au - pulseaudio/blob - src/utils/pacmd.c

   1 /***
   2   This file is part of PulseAudio.
   3
   4   Copyright 2004-2006 Lennart Poettering
   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, write to the Free Software
  18   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
  19   USA.
  20 ***/
  21
  22 #ifdef HAVE_CONFIG_H
  23 #include <config.h>
  24 #endif
  25
  26 #include <assert.h>
  27 #include <signal.h>
  28 #include <sys/socket.h>
  29 #include <unistd.h>
  30 #include <errno.h>
  31 #include <string.h>
  32 #include <sys/un.h>
  33 #include <getopt.h>
  34 #include <locale.h>
  35
  36 #include <pulse/util.h>
  37 #include <pulse/xmalloc.h>
  38
  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>
  45
  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", _("NAME|#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-port-latency-offset", _("CARD-NAME|CARD-#N PORT OFFSET"));
  77     printf("%s %s %s\n", argv0, "set-log-target", _("TARGET"));
  78     printf("%s %s %s\n", argv0, "set-log-level", _("NUMERIC LEVEL"));
  79     printf("%s %s %s\n", argv0, "set-log-meta", _("1|0"));
  80     printf("%s %s %s\n", argv0, "set-log-time", _("1|0"));
  81     printf("%s %s %s\n", argv0, "set-log-backtrace", _("FRAMES"));
  82
  83     printf(_("\n"
  84          "  -h, --help                            Show this help\n"
  85          "      --version                         Show version\n"
  86          "When no command is given pacmd starts in the interactive mode.\n" ));
  87 }
  88
  89 enum {
  90     ARG_VERSION = 256
  91 };
  92
  93 int main(int argc, char*argv[]) {
  94     pid_t pid;
  95     int fd = -1;
  96     int ret = 1, i;
  97     struct sockaddr_un sa;
  98     char *ibuf = NULL;
  99     char *obuf = NULL;
 100     size_t buf_size, ibuf_size, ibuf_index, ibuf_length, obuf_size, obuf_index, obuf_length;
 101     char *cli;
 102     bool ibuf_eof, obuf_eof, ibuf_closed, obuf_closed;
 103     struct pollfd pollfd[3];
 104     struct pollfd *watch_socket, *watch_stdin, *watch_stdout;
 105     int stdin_type = 0, stdout_type = 0, fd_type = 0;
 106
 107     char *bn = NULL;
 108     int c;
 109
 110     static const struct option long_options[] = {
 111         {"version",     0, NULL, ARG_VERSION},
 112         {"help",        0, NULL, 'h'},
 113         {NULL,          0, NULL, 0}
 114     };
 115
 116     setlocale(LC_ALL, "");
 117 #ifdef ENABLE_NLS
 118     bindtextdomain(GETTEXT_PACKAGE, PULSE_LOCALEDIR);
 119 #endif
 120
 121     bn = pa_path_get_filename(argv[0]);
 122
 123     while ((c = getopt_long(argc, argv, "h", long_options, NULL)) != -1) {
 124         switch (c) {
 125             case 'h' :
 126                 help(bn);
 127                 ret = 0;
 128                 goto quit;
 129             case ARG_VERSION:
 130                 printf(_("pacmd %s\n"
 131                          "Compiled with libpulse %s\n"
 132                          "Linked with libpulse %s\n"),
 133                        PACKAGE_VERSION,
 134                        pa_get_headers_version(),
 135                        pa_get_library_version());
 136                 ret = 0;
 137                 goto quit;
 138             default:
 139                 goto quit;
 140         }
 141     }
 142
 143     if (pa_pid_file_check_running(&pid, "pulseaudio") < 0) {
 144         pa_log(_("No PulseAudio daemon running, or not running as session daemon."));
 145         goto quit;
 146     }
 147
 148     if ((fd = pa_socket_cloexec(PF_UNIX, SOCK_STREAM, 0)) < 0) {
 149         pa_log(_("socket(PF_UNIX, SOCK_STREAM, 0): %s"), strerror(errno));
 150         goto quit;
 151     }
 152
 153     pa_zero(sa);
 154     sa.sun_family = AF_UNIX;
 155
 156     if (!(cli = pa_runtime_path("cli")))
 157         goto quit;
 158
 159     pa_strlcpy(sa.sun_path, cli, sizeof(sa.sun_path));
 160     pa_xfree(cli);
 161
 162     for (i = 0; i < 5; i++) {
 163         int r;
 164
 165         if ((r = connect(fd, (struct sockaddr*) &sa, sizeof(sa))) < 0 && (errno != ECONNREFUSED && errno != ENOENT)) {
 166             pa_log(_("connect(): %s"), strerror(errno));
 167             goto quit;
 168         }
 169
 170         if (r >= 0)
 171             break;
 172
 173         if (pa_pid_file_kill(SIGUSR2, NULL, "pulseaudio") < 0) {
 174             pa_log(_("Failed to kill PulseAudio daemon."));
 175             goto quit;
 176         }
 177
 178         pa_msleep(300);
 179     }
 180
 181     if (i >= 5) {
 182         pa_log(_("Daemon not responding."));
 183         goto quit;
 184     }
 185
 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;
 193
 194     if (argc > 1) {
 195         for (i = 1; i < argc; i++) {
 196             size_t k;
 197
 198             k = PA_MIN(ibuf_size - ibuf_length, strlen(argv[i]));
 199             memcpy(ibuf + ibuf_length, argv[i], k);
 200             ibuf_length += k;
 201
 202             if (ibuf_length < ibuf_size) {
 203                 ibuf[ibuf_length] = i < argc-1 ? ' ' : '\n';
 204                 ibuf_length++;
 205             }
 206         }
 207
 208         ibuf_eof = true;
 209     }
 210
 211     if (!ibuf_eof && isatty(STDIN_FILENO)) {
 212         /* send hello to enable interactive mode (welcome message, prompt) */
 213         if (pa_write(fd, "hello\n", 6, &fd_type) < 0) {
 214             pa_log(_("write(): %s"), strerror(errno));
 215             goto quit;
 216         }
 217     }
 218
 219     for (;;) {
 220         struct pollfd *p;
 221
 222         if (ibuf_eof &&
 223             obuf_eof &&
 224             ibuf_length <= 0 &&
 225             obuf_length <= 0)
 226             break;
 227
 228         if (ibuf_length <= 0 && ibuf_eof && !ibuf_closed) {
 229             shutdown(fd, SHUT_WR);
 230             ibuf_closed = true;
 231         }
 232
 233         if (obuf_length <= 0 && obuf_eof && !obuf_closed) {
 234             shutdown(fd, SHUT_RD);
 235             obuf_closed = true;
 236         }
 237
 238         pa_zero(pollfd);
 239
 240         p = pollfd;
 241
 242         if (ibuf_length > 0 || (!obuf_eof && obuf_length <= 0)) {
 243             watch_socket = p++;
 244             watch_socket->fd = fd;
 245             watch_socket->events =
 246                 (ibuf_length > 0 ? POLLOUT : 0) |
 247                 (!obuf_eof && obuf_length <= 0 ? POLLIN : 0);
 248         } else
 249             watch_socket = NULL;
 250
 251         if (!ibuf_eof && ibuf_length <= 0) {
 252             watch_stdin = p++;
 253             watch_stdin->fd = STDIN_FILENO;
 254             watch_stdin->events = POLLIN;
 255         } else
 256             watch_stdin = NULL;
 257
 258         if (obuf_length > 0) {
 259             watch_stdout = p++;
 260             watch_stdout->fd = STDOUT_FILENO;
 261             watch_stdout->events = POLLOUT;
 262         } else
 263             watch_stdout = NULL;
 264
 265         if (pa_poll(pollfd, p-pollfd, -1) < 0) {
 266
 267             if (errno == EINTR)
 268                 continue;
 269
 270             pa_log(_("poll(): %s"), strerror(errno));
 271             goto quit;
 272         }
 273
 274         if (watch_stdin) {
 275             if (watch_stdin->revents & POLLIN) {
 276                 ssize_t r;
 277                 pa_assert(ibuf_length <= 0);
 278
 279                 if ((r = pa_read(STDIN_FILENO, ibuf, ibuf_size, &stdin_type)) <= 0) {
 280                     if (r < 0) {
 281                         pa_log(_("read(): %s"), strerror(errno));
 282                         goto quit;
 283                     }
 284
 285                     ibuf_eof = true;
 286                 } else {
 287                     ibuf_length = (size_t) r;
 288                     ibuf_index = 0;
 289                 }
 290             } else if (watch_stdin->revents & POLLHUP)
 291                 ibuf_eof = true;
 292         }
 293
 294         if (watch_socket) {
 295             if (watch_socket->revents & POLLIN) {
 296                 ssize_t r;
 297                 pa_assert(obuf_length <= 0);
 298
 299                 if ((r = pa_read(fd, obuf, obuf_size, &fd_type)) <= 0) {
 300                     if (r < 0) {
 301                         pa_log(_("read(): %s"), strerror(errno));
 302                         goto quit;
 303                     }
 304
 305                     obuf_eof = true;
 306                 } else {
 307                     obuf_length = (size_t) r;
 308                     obuf_index = 0;
 309                 }
 310             } else if (watch_socket->revents & POLLHUP)
 311                 obuf_eof = true;
 312         }
 313
 314         if (watch_stdout) {
 315             if (watch_stdout->revents & POLLHUP) {
 316                 obuf_eof = true;
 317                 obuf_length = 0;
 318             } else if (watch_stdout->revents & POLLOUT) {
 319                 ssize_t r;
 320                 pa_assert(obuf_length > 0);
 321
 322                 if ((r = pa_write(STDOUT_FILENO, obuf + obuf_index, obuf_length, &stdout_type)) < 0) {
 323                     pa_log(_("write(): %s"), strerror(errno));
 324                     goto quit;
 325                 }
 326
 327                 obuf_length -= (size_t) r;
 328                 obuf_index += obuf_index;
 329             }
 330         }
 331
 332         if (watch_socket) {
 333             if (watch_socket->revents & POLLHUP) {
 334                 ibuf_eof = true;
 335                 ibuf_length = 0;
 336             } if (watch_socket->revents & POLLOUT) {
 337                 ssize_t r;
 338                 pa_assert(ibuf_length > 0);
 339
 340                 if ((r = pa_write(fd, ibuf + ibuf_index, ibuf_length, &fd_type)) < 0) {
 341                     pa_log(_("write(): %s"), strerror(errno));
 342                     goto quit;
 343                 }
 344
 345                 ibuf_length -= (size_t) r;
 346                 ibuf_index += obuf_index;
 347             }
 348         }
 349     }
 350
 351     ret = 0;
 352
 353 quit:
 354     if (fd >= 0)
 355         pa_close(fd);
 356
 357     pa_xfree(obuf);
 358     pa_xfree(ibuf);
 359
 360     return ret;
 361 }