Suspending never fails.
}
/* Called from IO context */
-static int suspend(struct userdata *u) {
+static void suspend(struct userdata *u) {
pa_assert(u);
pa_assert(u->pcm_handle);
pa_sink_set_max_request_within_thread(u->sink, 0);
pa_log_info("Device suspended...");
-
- return 0;
}
/* Called from IO context */
switch ((pa_sink_state_t) PA_PTR_TO_UINT(data)) {
case PA_SINK_SUSPENDED: {
- int r;
-
pa_assert(PA_SINK_IS_OPENED(u->sink->thread_info.state));
- if ((r = suspend(u)) < 0)
- return r;
+ suspend(u);
break;
}
}
/* Called from IO context */
-static int suspend(struct userdata *u) {
+static void suspend(struct userdata *u) {
pa_assert(u);
pa_assert(u->pcm_handle);
}
pa_log_info("Device suspended...");
-
- return 0;
}
/* Called from IO context */
switch ((pa_source_state_t) PA_PTR_TO_UINT(data)) {
case PA_SOURCE_SUSPENDED: {
- int r;
-
pa_assert(PA_SOURCE_IS_OPENED(u->source->thread_info.state));
- if ((r = suspend(u)) < 0)
- return r;
+ suspend(u);
break;
}
return u->fd;
}
-static int suspend(struct userdata *u) {
+static void suspend(struct userdata *u) {
pa_assert(u);
pa_assert(u->fd >= 0);
}
pa_log_info("Device suspended.");
-
- return 0;
}
static int unsuspend(struct userdata *u) {
pa_smoother_pause(u->smoother, pa_rtclock_now());
- if (!u->source || u->source_suspended) {
- if (suspend(u) < 0)
- return -1;
- }
+ if (!u->source || u->source_suspended)
+ suspend(u);
+
u->sink_suspended = true;
break;
pa_assert(PA_SOURCE_IS_OPENED(u->source->thread_info.state));
- if (!u->sink || u->sink_suspended) {
- if (suspend(u) < 0)
- return -1;
- }
+ if (!u->sink || u->sink_suspended)
+ suspend(u);
+
u->source_suspended = true;
break;
}
/* Called from IO context */
-static int suspend(struct userdata *u) {
+static void suspend(struct userdata *u) {
pa_assert(u);
pa_assert(u->fd >= 0);
}
pa_log_info("Device suspended...");
-
- return 0;
}
/* Called from IO context */
case PA_SINK_SUSPENDED:
pa_assert(PA_SINK_IS_OPENED(u->sink->thread_info.state));
- if (!u->source || u->source_suspended) {
- if (suspend(u) < 0)
- return -1;
- }
+ if (!u->source || u->source_suspended)
+ suspend(u);
do_trigger = true;
case PA_SOURCE_SUSPENDED:
pa_assert(PA_SOURCE_IS_OPENED(u->source->thread_info.state));
- if (!u->sink || u->sink_suspended) {
- if (suspend(u) < 0)
- return -1;
- }
+ if (!u->sink || u->sink_suspended)
+ suspend(u);
do_trigger = true;