[pulseaudio-commits] r1669 - in /branches/lennart/src: ./ Makefile.am utils/pasuspender.c
svnmailer-noreply at 0pointer.de
svnmailer-noreply at 0pointer.de
Wed Aug 15 13:50:17 PDT 2007
Author: lennart
Date: Wed Aug 15 22:50:15 2007
New Revision: 1669
URL: http://0pointer.de/cgi-bin/viewcvs.cgi?rev=3D1669&root=3Dpulseaudio&vi=
ew=3Drev
Log:
add new tool pasuspender which temporarily suspends all sinks and resumes t=
hem later again
Added:
branches/lennart/src/utils/pasuspender.c (with props)
Modified:
branches/lennart/src/ (props changed)
branches/lennart/src/Makefile.am
Propchange: branches/lennart/src/
---------------------------------------------------------------------------=
---
--- svn:ignore (original)
+++ svn:ignore Wed Aug 15 22:50:15 2007
@@ -1,3 +1,4 @@
+pasuspender
queue-test
asyncmsgq-test
asyncq-test
Modified: branches/lennart/src/Makefile.am
URL: http://0pointer.de/cgi-bin/viewcvs.cgi/branches/lennart/src/Makefile.a=
m?rev=3D1669&root=3Dpulseaudio&r1=3D1668&r2=3D1669&view=3Ddiff
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/lennart/src/Makefile.am (original)
+++ branches/lennart/src/Makefile.am Wed Aug 15 22:50:15 2007
@@ -161,7 +161,8 @@
bin_PROGRAMS +=3D \
pacat \
pactl \
- paplay
+ paplay \
+ pasuspender
=
if HAVE_AF_UNIX
bin_PROGRAMS +=3D pacmd
@@ -191,6 +192,11 @@
pactl_LDADD =3D $(AM_LDADD) libpulse.la $(LIBSNDFILE_LIBS)
pactl_CFLAGS =3D $(AM_CFLAGS) $(LIBSNDFILE_CFLAGS)
pactl_LDFLAGS =3D $(AM_LDFLAGS) $(BINLDFLAGS)
+
+pasuspender_SOURCES =3D utils/pasuspender.c
+pasuspender_LDADD =3D $(AM_LDADD) libpulse.la $(LIBSNDFILE_LIBS)
+pasuspender_CFLAGS =3D $(AM_CFLAGS) $(LIBSNDFILE_CFLAGS)
+pasuspender_LDFLAGS =3D $(AM_LDFLAGS) $(BINLDFLAGS)
=
pacmd_SOURCES =3D utils/pacmd.c pulsecore/pid.c pulsecore/pid.h
pacmd_CFLAGS =3D $(AM_CFLAGS)
Added: branches/lennart/src/utils/pasuspender.c
URL: http://0pointer.de/cgi-bin/viewcvs.cgi/branches/lennart/src/utils/pasu=
spender.c?rev=3D1669&root=3Dpulseaudio&view=3Dauto
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/lennart/src/utils/pasuspender.c (added)
+++ branches/lennart/src/utils/pasuspender.c Wed Aug 15 22:50:15 2007
@@ -1,0 +1,286 @@
+/* $Id$ */
+
+/***
+ This file is part of PulseAudio.
+
+ Copyright 2004-2006 Lennart Poettering
+
+ PulseAudio is free software; you can redistribute it and/or modify
+ it under the terms of the GNU Lesser General Public License as published
+ by the Free Software Foundation; either version 2 of the License,
+ or (at your option) any later version.
+
+ PulseAudio is distributed in the hope that it will be useful, but
+ WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ General Public License for more details.
+
+ You should have received a copy of the GNU Lesser General Public License
+ along with PulseAudio; if not, write to the Free Software
+ Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
+ USA.
+***/
+
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include <sys/prctl.h>
+#include <sys/types.h>
+#include <sys/wait.h>
+
+#include <signal.h>
+#include <string.h>
+#include <errno.h>
+#include <unistd.h>
+#include <assert.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <limits.h>
+#include <getopt.h>
+
+#include <sndfile.h>
+
+#include <pulse/pulseaudio.h>
+#include <pulsecore/macro.h>
+
+#if PA_API_VERSION < 10
+#error Invalid PulseAudio API version
+#endif
+
+#define BUFSIZE 1024
+
+static pa_context *context =3D NULL;
+static pa_mainloop_api *mainloop_api =3D NULL;
+static char **child_argv =3D NULL;
+static int child_argc =3D 0;
+static pid_t child_pid =3D (pid_t) -1;
+static int child_ret =3D 0;
+static int dead =3D 1;
+
+static void quit(int ret) {
+ pa_assert(mainloop_api);
+ mainloop_api->quit(mainloop_api, ret);
+}
+
+
+static void context_drain_complete(pa_context *c, void *userdata) {
+ pa_context_disconnect(c);
+}
+
+static void drain(void) {
+ pa_operation *o;
+
+ if (!(o =3D pa_context_drain(context, context_drain_complete, NULL)))
+ pa_context_disconnect(context);
+ else
+ pa_operation_unref(o);
+}
+
+static void suspend_complete(pa_context *c, int success, void *userdata) {
+ static int n =3D 0;
+
+ n++;
+ =
+ if (!success) {
+ fprintf(stderr, "Failure to suspend: %s\n", pa_strerror(pa_context=
_errno(c)));
+ quit(1);
+ }
+
+ if (n >=3D 2) {
+ =
+ if ((child_pid =3D fork()) < 0) {
+
+ fprintf(stderr, "fork(): %s\n", strerror(errno));
+ quit(1);
+ =
+ } else if (child_pid =3D=3D 0) {
+ /* Child */
+
+#ifdef __linux__
+ prctl(PR_SET_PDEATHSIG, SIGTERM, 0, 0, 0);
+#endif
+ =
+ if (execvp(child_argv[0], child_argv) < 0)
+ fprintf(stderr, "execvp(): %s\n", strerror(errno));
+
+ _exit(1);
+
+ } else {
+
+ /* parent */
+ dead =3D 0;
+ }
+ }
+}
+
+static void resume_complete(pa_context *c, int success, void *userdata) {
+ static int n =3D 0;
+
+ n++;
+
+ if (!success) {
+ fprintf(stderr, "Failure to resume: %s\n", pa_strerror(pa_context_=
errno(c)));
+ quit(1);
+ return;
+ }
+
+ if (n >=3D 2)
+ drain(); /* drain and quit */
+}
+
+static void context_state_callback(pa_context *c, void *userdata) {
+ pa_assert(c);
+ =
+ switch (pa_context_get_state(c)) {
+ case PA_CONTEXT_CONNECTING:
+ case PA_CONTEXT_AUTHORIZING:
+ case PA_CONTEXT_SETTING_NAME:
+ break;
+
+ case PA_CONTEXT_READY:
+ pa_operation_unref(pa_context_suspend_sink_by_index(c, PA_INVA=
LID_INDEX, 1, suspend_complete, NULL));
+ pa_operation_unref(pa_context_suspend_source_by_index(c, PA_IN=
VALID_INDEX, 1, suspend_complete, NULL));
+ break;
+ =
+ case PA_CONTEXT_TERMINATED:
+ quit(0);
+ break;
+
+ case PA_CONTEXT_FAILED:
+ default:
+ fprintf(stderr, "Connection failure: %s\n", pa_strerror(pa_con=
text_errno(c)));
+ quit(1);
+ }
+}
+
+static void sigint_callback(pa_mainloop_api *m, pa_signal_event *e, int si=
g, void *userdata) {
+ fprintf(stderr, "Got SIGINT, exiting.\n");
+ quit(0);
+}
+
+static void sigchld_callback(pa_mainloop_api *m, pa_signal_event *e, int s=
ig, void *userdata) {
+ int status =3D 0;
+ pid_t p;
+ =
+ p =3D waitpid(-1, &status, WNOHANG);
+
+ if (p !=3D child_pid)
+ return;
+
+ dead =3D 1;
+ =
+ if (WIFEXITED(status))
+ child_ret =3D WEXITSTATUS(status);
+ else if (WIFSIGNALED(status)) {
+ fprintf(stderr, "WARNING: Child process terminated by signal %u\n"=
, WTERMSIG(status));
+ child_ret =3D 1;
+ }
+
+ pa_operation_unref(pa_context_suspend_sink_by_index(context, PA_INVALI=
D_INDEX, 0, resume_complete, NULL));
+ pa_operation_unref(pa_context_suspend_source_by_index(context, PA_INVA=
LID_INDEX, 0, resume_complete, NULL));
+}
+
+static void help(const char *argv0) {
+
+ printf("%s [options] ... \n\n"
+ " -h, --help Show this help\n"
+ " --version Show version\n"
+ " -s, --server=3DSERVER The name of the serv=
er to connect to\n\n",
+ argv0);
+}
+
+enum {
+ ARG_VERSION =3D 256
+};
+
+int main(int argc, char *argv[]) {
+ pa_mainloop* m =3D NULL;
+ int c, ret =3D 1;
+ char *server =3D NULL, *bn;
+
+ static const struct option long_options[] =3D {
+ {"server", 1, NULL, 's'},
+ {"version", 0, NULL, ARG_VERSION},
+ {"help", 0, NULL, 'h'},
+ {NULL, 0, NULL, 0}
+ };
+
+ if (!(bn =3D strrchr(argv[0], '/')))
+ bn =3D argv[0];
+ else
+ bn++;
+
+ while ((c =3D getopt_long(argc, argv, "s:h", long_options, NULL)) !=3D=
-1) {
+ switch (c) {
+ case 'h' :
+ help(bn);
+ ret =3D 0;
+ goto quit;
+
+ case ARG_VERSION:
+ printf("pasuspender "PACKAGE_VERSION"\nCompiled with libpu=
lse %s\nLinked with libpulse %s\n", pa_get_headers_version(), pa_get_librar=
y_version());
+ ret =3D 0;
+ goto quit;
+
+ case 's':
+ pa_xfree(server);
+ server =3D pa_xstrdup(optarg);
+ break;
+
+ default:
+ goto quit;
+ }
+ }
+
+ child_argv =3D argv + optind;
+ child_argc =3D argc - optind;
+
+ if (child_argc <=3D 0) {
+ help(bn);
+ ret =3D 0;
+ goto quit;
+ }
+
+ if (!(m =3D pa_mainloop_new())) {
+ fprintf(stderr, "pa_mainloop_new() failed.\n");
+ goto quit;
+ }
+
+ pa_assert_se(mainloop_api =3D pa_mainloop_get_api(m));
+ pa_assert_se(pa_signal_init(mainloop_api) =3D=3D 0);
+ pa_signal_new(SIGINT, sigint_callback, NULL);
+ pa_signal_new(SIGCHLD, sigchld_callback, NULL);
+#ifdef SIGPIPE
+ signal(SIGPIPE, SIG_IGN);
+#endif
+
+ if (!(context =3D pa_context_new(mainloop_api, bn))) {
+ fprintf(stderr, "pa_context_new() failed.\n");
+ goto quit;
+ }
+
+ pa_context_set_state_callback(context, context_state_callback, NULL);
+ pa_context_connect(context, server, 0, NULL);
+
+ if (pa_mainloop_run(m, &ret) < 0) {
+ fprintf(stderr, "pa_mainloop_run() failed.\n");
+ goto quit;
+ }
+
+quit:
+ if (context)
+ pa_context_unref(context);
+
+ if (m) {
+ pa_signal_done();
+ pa_mainloop_free(m);
+ }
+
+ pa_xfree(server);
+
+ if (!dead)
+ kill(child_pid, SIGTERM);
+
+ return ret =3D=3D 0 ? child_ret : ret;
+}
Propchange: branches/lennart/src/utils/pasuspender.c
---------------------------------------------------------------------------=
---
svn:keywords =3D Id
More information about the pulseaudio-commits
mailing list