summaryrefslogtreecommitdiffstats
path: root/app/pac.c
diff options
context:
space:
mode:
authorMatt Porter <mporter@konsulko.com>2016-12-19 13:55:11 -0500
committerMatt Porter <mporter@konsulko.com>2016-12-21 08:24:39 -0500
commit392effc544e3d94b82f806378d4ac1d11a185422 (patch)
tree6467743066dd6153941529087fef244dc8639c24 /app/pac.c
AGL-style PulseAudio mixer app
Change-Id: I566050a1a8f241f140523df236de81ab951c1394 Signed-off-by: Matt Porter <mporter@konsulko.com>
Diffstat (limited to 'app/pac.c')
-rw-r--r--app/pac.c225
1 files changed, 225 insertions, 0 deletions
diff --git a/app/pac.c b/app/pac.c
new file mode 100644
index 0000000..83b4604
--- /dev/null
+++ b/app/pac.c
@@ -0,0 +1,225 @@
+/*
+ * Copyright (C) 2016 Konsulko Group
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <signal.h>
+#include <errno.h>
+#include <unistd.h>
+#include <limits.h>
+#include <assert.h>
+
+#include <pulse/pulseaudio.h>
+#include <sys/queue.h>
+
+#include "pacontrolmodel.h"
+#include "pac.h"
+
+/* FIXME: move these into a pac context */
+static pa_threaded_mainloop* m;
+TAILQ_HEAD(pac_cstateq, pac_cstate);
+static struct pac_cstateq cstateq;
+
+static void add_one_cstate(int type, int index, const pa_cvolume *cvolume)
+{
+ struct pac_cstate *cstate;
+ int i;
+
+ cstate = pa_xnew(struct pac_cstate, 1);
+ cstate->type = type;
+ cstate->index = index;
+ cstate->cvolume.channels = cvolume->channels;
+ for (i = 0; i < cvolume->channels; i++)
+ cstate->cvolume.values[i] = cvolume->values[i];
+
+ TAILQ_INSERT_TAIL(&cstateq, cstate, tailq);
+}
+
+static void get_source_list_cb(pa_context *c,
+ const pa_source_info *i,
+ int eol,
+ void *data)
+{
+ int chan;
+
+ if (eol < 0) {
+ fprintf(stderr, "get source list: %s\n",
+ pa_strerror(pa_context_errno(c)));
+
+ pa_threaded_mainloop_stop(m);
+ return;
+ }
+
+ if (!eol) {
+ assert(i);
+ add_one_cstate(C_SOURCE, i->index, &i->volume);
+ for (chan = 0; chan < i->channel_map.channels; chan++) {
+ add_one_control(data, i->index, i->description,
+ C_SOURCE, chan,
+ channel_position_string[i->channel_map.map[chan]],
+ i->volume.values[chan]);
+ }
+ }
+}
+
+static void get_sink_list_cb(pa_context *c,
+ const pa_sink_info *i,
+ int eol,
+ void *data)
+{
+ int chan;
+
+ if(eol < 0) {
+ fprintf(stderr, "get sink list: %s\n",
+ pa_strerror(pa_context_errno(c)));
+
+ pa_threaded_mainloop_stop(m);
+ return;
+ }
+
+ if(!eol) {
+ assert(i);
+ add_one_cstate(C_SINK, i->index, &i->volume);
+ for (chan = 0; chan < i->channel_map.channels; chan++) {
+ add_one_control(data, i->index, i->description,
+ C_SINK, chan,
+ channel_position_string[i->channel_map.map[chan]],
+ i->volume.values[chan]);
+ }
+ }
+}
+
+static void context_state_cb(pa_context *c, void *data) {
+ pa_operation *o;
+
+ 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:
+ /* Fetch the controls of interest */
+ if (!(o = pa_context_get_source_info_list(c, get_source_list_cb, data))) {
+ fprintf(stderr, "get source info list: %s\n",
+ pa_strerror(pa_context_errno(c)));
+ return;
+ }
+ pa_operation_unref(o);
+ if (!(o = pa_context_get_sink_info_list(c, get_sink_list_cb, data))) {
+ fprintf(stderr, "get sink info list: %s\n",
+ pa_strerror(pa_context_errno(c)));
+ return;
+ }
+ break;
+ case PA_CONTEXT_TERMINATED:
+ pa_threaded_mainloop_stop(m);
+ break;
+ case PA_CONTEXT_FAILED:
+ default:
+ fprintf(stderr, "PA connection failed: %s\n",
+ pa_strerror(pa_context_errno(c)));
+ pa_threaded_mainloop_stop(m);
+ }
+}
+
+static void pac_set_source_volume_cb(pa_context *c, int success, void *userdata __attribute__((unused))) {
+ assert(c);
+ if (!success)
+ fprintf(stderr, "Set source volume: %s\n",
+ pa_strerror(pa_context_errno(c)));
+}
+
+static void pac_set_sink_volume_cb(pa_context *c, int success, void *userdata __attribute__((unused))) {
+ assert(c);
+ if (!success)
+ fprintf(stderr, "Set source volume: %s\n",
+ pa_strerror(pa_context_errno(c)));
+}
+
+void pac_set_volume(pa_context *c, uint32_t type, uint32_t idx, uint32_t channel, uint32_t volume)
+{
+ pa_operation *o;
+ struct pac_cstate *cstate;
+
+ TAILQ_FOREACH(cstate, &cstateq, tailq)
+ if (cstate->index == idx)
+ break;
+ cstate->cvolume.values[channel] = volume;
+
+ if (type == C_SOURCE) {
+ if (!(o = pa_context_set_source_volume_by_index(c, idx, &cstate->cvolume, pac_set_source_volume_cb, NULL))) {
+ fprintf(stderr, "set source #%d channel #%d volume: %s\n",
+ idx, channel, pa_strerror(pa_context_errno(c)));
+ return;
+ }
+ pa_operation_unref(o);
+ } else if (type == C_SINK) {
+ if (!(o = pa_context_set_sink_volume_by_index(c, idx, &cstate->cvolume, pac_set_sink_volume_cb, NULL))) {
+ fprintf(stderr, "set sink #%d channel #%d volume: %s\n",
+ idx, channel, pa_strerror(pa_context_errno(c)));
+ return;
+ }
+ pa_operation_unref(o);
+ }
+}
+
+pa_context *pac_init(void *this, const char *name) {
+ pa_context *c;
+ pa_mainloop_api *mapi;
+ char *server = NULL;
+ char *client = pa_xstrdup(name);
+
+ TAILQ_INIT(&cstateq);
+
+ if (!(m = pa_threaded_mainloop_new())) {
+ fprintf(stderr, "pa_mainloop_new() failed.\n");
+ return NULL;
+ }
+
+ pa_threaded_mainloop_set_name(m, "pa_mainloop");
+ mapi = pa_threaded_mainloop_get_api(m);
+
+ if (!(c = pa_context_new(mapi, client))) {
+ fprintf(stderr, "pa_context_new() failed.\n");
+ goto exit;
+ }
+
+ pa_context_set_state_callback(c, context_state_cb, this);
+ if (pa_context_connect(c, server, 0, NULL) < 0) {
+ fprintf(stderr, "pa_context_connect(): %s", pa_strerror(pa_context_errno(c)));
+ goto exit;
+ }
+
+ if (pa_threaded_mainloop_start(m) < 0) {
+ fprintf(stderr, "pa_mainloop_run() failed.\n");
+ goto exit;
+ }
+
+ return c;
+
+exit:
+ if (c)
+ pa_context_unref(c);
+
+ if (m)
+ pa_threaded_mainloop_free(m);
+
+ pa_xfree(client);
+
+ return NULL;
+}