* (c) 2014 Martin Mares <mj@ucw.cz>
*/
-#define LOCAL_DEBUG
+#undef LOCAL_DEBUG
#include <ucw/lib.h>
#include <ucw/clists.h>
#include "ursaryd.h"
+enum pulse_state {
+ PS_OFFLINE,
+ PS_SUBSCRIBE,
+ PS_GET_CLIENTS,
+ PS_GET_SINKS,
+ PS_GET_SINK_INPUTS,
+ PS_GET_SERVER,
+ PS_ONLINE,
+};
+
enum pulse_state pulse_state;
#define PULSE_STATE(s) do { pulse_state = s; DBG("Pulse: " #s); } while (0)
msg(L_DEBUG, "## Client #%d: %s host=%s", c->idx, c->name, c->host);
CLIST_FOR_EACH(struct pulse_sink *, s, pulse_sink_list)
- msg(L_DEBUG, "## Sink #%d: %s channels=%u volume=%u base_vol=%u mute=%u",
- s->idx, s->name, s->channels, s->volume, s->base_volume, s->mute);
+ msg(L_DEBUG, "## Sink #%d: %s channels=%u volume=%u base_vol=%u mute=%u suspended=%u",
+ s->idx, s->name, s->channels, s->volume, s->base_volume, s->mute, s->suspended);
CLIST_FOR_EACH(struct pulse_sink_input *, s, pulse_sink_input_list)
msg(L_DEBUG, "## Sink input #%d: %s client=%d sink=%d channels=%u volume=%u mute=%u",
#define HASH_PREFIX(x) pulse_sink_input_##x
#define HASH_KEY_ATOMIC idx
#define HASH_WANT_CLEANUP
+#define HASH_WANT_FIND
#define HASH_WANT_LOOKUP
#define HASH_WANT_REMOVE
#define HASH_ZERO_FILL
static void pulse_sink_input_gone(int idx)
{
DBG("Pulse: REMOVE SINK INPUT #%d", idx);
- struct pulse_sink_input *s = pulse_sink_input_lookup(idx);
- clist_remove(&s->n);
- pulse_sink_input_remove(s);
+ struct pulse_sink_input *s = pulse_sink_input_find(idx);
+ if (s)
+ {
+ clist_remove(&s->n);
+ pulse_sink_input_remove(s);
+ }
+ else
+ DBG("Pulse: Removing sink which does not exist");
schedule_update();
}
s->volume = pa_cvolume_avg(&i->volume);
s->base_volume = i->base_volume;
s->mute = i->mute;
+ s->suspended = (i->state == PA_SINK_SUSPENDED);
schedule_update();
}
#define HASH_PREFIX(x) pulse_client_##x
#define HASH_KEY_ATOMIC idx
#define HASH_WANT_CLEANUP
+#define HASH_WANT_FIND
#define HASH_WANT_LOOKUP
#define HASH_WANT_REMOVE
#define HASH_ZERO_FILL
static void pulse_client_gone(int idx)
{
DBG("Pulse: REMOVE CLIENT #%d", idx);
- struct pulse_client *c = pulse_client_lookup(idx);
- clist_remove(&c->n);
- pulse_client_remove(c);
- schedule_update();
+ struct pulse_client *c = pulse_client_find(idx);
+ if (c)
+ {
+ clist_remove(&c->n);
+ pulse_client_remove(c);
+ schedule_update();
+ }
}
struct pulse_client *pulse_client_by_idx(int idx)
{
- return pulse_client_lookup(idx);
+ return pulse_client_find(idx);
}
/*** Events ***/
pa_context_connect(pulse_ctx, NULL, PA_CONTEXT_NOAUTOSPAWN, NULL);
}
+bool pulse_is_ready(void)
+{
+ return (pulse_state == PS_ONLINE);
+}
+
void pulse_init(void)
{
pmain_init();