suspend-on-idle: Allow disabling suspending for specific devices

Sometimes it would be nice to disable module-suspend-on-idle for
specific devices. For me the use case is to keep a HDMI sink running
all the time to avoid loss of audio when starting to play a stream to
the device (the HDMI receiver eats a bit from the beginning of the
stream when the device is opened). This is arguably a hacky solution
to the problem, but on the other hand, I think it's very sensible to
interpret negative timeout in the module-suspend-on-idle.timeout
property as disabling the suspending altogher. This is also how the
exit-idle-time configuration option behaves (negative value disables
automatic exiting).

I moved the property parsing from the timer restart function to the
function that creates the device_info objects, because if the timeout
is negative, we don't need to create the device_info object at all.
This commit is contained in:
Tanu Kaskinen 2013-08-29 17:36:53 +03:00
parent 8a2ea2834c
commit 943275d2fd

View file

@ -78,6 +78,7 @@ struct device_info {
pa_source *source; pa_source *source;
pa_usec_t last_use; pa_usec_t last_use;
pa_time_event *time_event; pa_time_event *time_event;
pa_usec_t timeout;
}; };
static void timeout_cb(pa_mainloop_api*a, pa_time_event* e, const struct timeval *t, void *userdata) { static void timeout_cb(pa_mainloop_api*a, pa_time_event* e, const struct timeval *t, void *userdata) {
@ -102,24 +103,17 @@ static void timeout_cb(pa_mainloop_api*a, pa_time_event* e, const struct timeval
static void restart(struct device_info *d) { static void restart(struct device_info *d) {
pa_usec_t now; pa_usec_t now;
const char *s;
uint32_t timeout;
pa_assert(d); pa_assert(d);
pa_assert(d->sink || d->source); pa_assert(d->sink || d->source);
d->last_use = now = pa_rtclock_now(); d->last_use = now = pa_rtclock_now();
pa_core_rttime_restart(d->userdata->core, d->time_event, now + d->timeout);
s = pa_proplist_gets(d->sink ? d->sink->proplist : d->source->proplist, "module-suspend-on-idle.timeout");
if (!s || pa_atou(s, &timeout) < 0)
timeout = d->userdata->timeout;
pa_core_rttime_restart(d->userdata->core, d->time_event, now + timeout * PA_USEC_PER_SEC);
if (d->sink) if (d->sink)
pa_log_debug("Sink %s becomes idle, timeout in %u seconds.", d->sink->name, timeout); pa_log_debug("Sink %s becomes idle, timeout in %" PRIu64 " seconds.", d->sink->name, d->timeout / PA_USEC_PER_SEC);
if (d->source) if (d->source)
pa_log_debug("Source %s becomes idle, timeout in %u seconds.", d->source->name, timeout); pa_log_debug("Source %s becomes idle, timeout in %" PRIu64 " seconds.", d->source->name, d->timeout / PA_USEC_PER_SEC);
} }
static void resume(struct device_info *d) { static void resume(struct device_info *d) {
@ -328,6 +322,9 @@ static pa_hook_result_t device_new_hook_cb(pa_core *c, pa_object *o, struct user
struct device_info *d; struct device_info *d;
pa_source *source; pa_source *source;
pa_sink *sink; pa_sink *sink;
const char *timeout_str;
int32_t timeout;
bool timeout_valid;
pa_assert(c); pa_assert(c);
pa_object_assert_ref(o); pa_object_assert_ref(o);
@ -342,11 +339,26 @@ static pa_hook_result_t device_new_hook_cb(pa_core *c, pa_object *o, struct user
pa_assert(source || sink); pa_assert(source || sink);
timeout_str = pa_proplist_gets(sink ? sink->proplist : source->proplist, "module-suspend-on-idle.timeout");
if (timeout_str && pa_atoi(timeout_str, &timeout) >= 0)
timeout_valid = true;
else
timeout_valid = false;
if (timeout_valid && timeout < 0)
return PA_HOOK_OK;
d = pa_xnew(struct device_info, 1); d = pa_xnew(struct device_info, 1);
d->userdata = u; d->userdata = u;
d->source = source ? pa_source_ref(source) : NULL; d->source = source ? pa_source_ref(source) : NULL;
d->sink = sink ? pa_sink_ref(sink) : NULL; d->sink = sink ? pa_sink_ref(sink) : NULL;
d->time_event = pa_core_rttime_new(c, PA_USEC_INVALID, timeout_cb, d); d->time_event = pa_core_rttime_new(c, PA_USEC_INVALID, timeout_cb, d);
if (timeout_valid)
d->timeout = timeout * PA_USEC_PER_SEC;
else
d->timeout = d->userdata->timeout;
pa_hashmap_put(u->device_infos, o, d); pa_hashmap_put(u->device_infos, o, d);
if ((d->sink && pa_sink_check_suspend(d->sink) <= 0) || if ((d->sink && pa_sink_check_suspend(d->sink) <= 0) ||
@ -434,7 +446,7 @@ int pa__init(pa_module*m) {
m->userdata = u = pa_xnew(struct userdata, 1); m->userdata = u = pa_xnew(struct userdata, 1);
u->core = m->core; u->core = m->core;
u->timeout = timeout; u->timeout = timeout * PA_USEC_PER_SEC;
u->device_infos = pa_hashmap_new(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func); u->device_infos = pa_hashmap_new(pa_idxset_trivial_hash_func, pa_idxset_trivial_compare_func);
PA_IDXSET_FOREACH(sink, m->core->sinks, idx) PA_IDXSET_FOREACH(sink, m->core->sinks, idx)