aboutsummaryrefslogtreecommitdiffstats
path: root/src/output/PulseOutputPlugin.cxx
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/output/PulseOutputPlugin.cxx54
1 files changed, 3 insertions, 51 deletions
diff --git a/src/output/PulseOutputPlugin.cxx b/src/output/PulseOutputPlugin.cxx
index d035d10b7..5394edfac 100644
--- a/src/output/PulseOutputPlugin.cxx
+++ b/src/output/PulseOutputPlugin.cxx
@@ -38,13 +38,6 @@
#define MPD_PULSE_NAME "Music Player Daemon"
-#if !defined(PA_CHECK_VERSION)
-/**
- * This macro was implemented in libpulse 0.9.16.
- */
-#define PA_CHECK_VERSION(a,b,c) false
-#endif
-
struct PulseOutput {
struct audio_output base;
@@ -59,14 +52,6 @@ struct PulseOutput {
struct pa_stream *stream;
size_t writable;
-
-#if !PA_CHECK_VERSION(0,9,11)
- /**
- * We need this variable because pa_stream_is_corked() wasn't
- * added before 0.9.11.
- */
- bool pause;
-#endif
};
/**
@@ -278,9 +263,7 @@ pulse_output_delete_stream(PulseOutput *po)
assert(po != nullptr);
assert(po->stream != nullptr);
-#if PA_CHECK_VERSION(0,9,8)
pa_stream_set_suspended_callback(po->stream, nullptr, nullptr);
-#endif
pa_stream_set_state_callback(po->stream, nullptr, nullptr);
pa_stream_set_write_callback(po->stream, nullptr, nullptr);
@@ -482,8 +465,6 @@ pulse_output_wait_connection(PulseOutput *po, GError **error_r)
}
}
-#if PA_CHECK_VERSION(0,9,8)
-
static void
pulse_output_stream_suspended_cb(gcc_unused pa_stream *stream, void *userdata)
{
@@ -497,8 +478,6 @@ pulse_output_stream_suspended_cb(gcc_unused pa_stream *stream, void *userdata)
pa_threaded_mainloop_signal(po->mainloop, 0);
}
-#endif
-
static void
pulse_output_stream_state_cb(pa_stream *stream, void *userdata)
{
@@ -564,10 +543,8 @@ pulse_output_setup_stream(PulseOutput *po, const pa_sample_spec *ss,
return false;
}
-#if PA_CHECK_VERSION(0,9,8)
pa_stream_set_suspended_callback(po->stream,
pulse_output_stream_suspended_cb, po);
-#endif
pa_stream_set_state_callback(po->stream,
pulse_output_stream_state_cb, po);
@@ -645,10 +622,6 @@ pulse_output_open(struct audio_output *ao, AudioFormat &audio_format,
pa_threaded_mainloop_unlock(po->mainloop);
-#if !PA_CHECK_VERSION(0,9,11)
- po->pause = false;
-#endif
-
return true;
}
@@ -712,22 +685,6 @@ pulse_output_wait_stream(PulseOutput *po, GError **error_r)
}
/**
- * Determines whether the stream is paused. On libpulse older than
- * 0.9.11, it uses a custom pause flag.
- */
-static bool
-pulse_output_stream_is_paused(PulseOutput *po)
-{
- assert(po->stream != nullptr);
-
-#if !defined(PA_CHECK_VERSION) || !PA_CHECK_VERSION(0,9,11)
- return po->pause;
-#else
- return pa_stream_is_corked(po->stream);
-#endif
-}
-
-/**
* Sets cork mode on the stream.
*/
static bool
@@ -756,9 +713,6 @@ pulse_output_stream_pause(PulseOutput *po, bool pause,
return false;
}
-#if !PA_CHECK_VERSION(0,9,11)
- po->pause = pause;
-#endif
return true;
}
@@ -770,7 +724,7 @@ pulse_output_delay(struct audio_output *ao)
pa_threaded_mainloop_lock(po->mainloop);
- if (po->base.pause && pulse_output_stream_is_paused(po) &&
+ if (po->base.pause && pa_stream_is_corked(po->stream) &&
pa_stream_get_state(po->stream) == PA_STREAM_READY)
/* idle while paused */
result = 1000;
@@ -803,7 +757,7 @@ pulse_output_play(struct audio_output *ao, const void *chunk, size_t size,
/* unpause if previously paused */
- if (pulse_output_stream_is_paused(po) &&
+ if (pa_stream_is_corked(po->stream) &&
!pulse_output_stream_pause(po, false, error_r)) {
pa_threaded_mainloop_unlock(po->mainloop);
return 0;
@@ -812,14 +766,12 @@ pulse_output_play(struct audio_output *ao, const void *chunk, size_t size,
/* wait until the server allows us to write */
while (po->writable == 0) {
-#if PA_CHECK_VERSION(0,9,8)
if (pa_stream_is_suspended(po->stream)) {
pa_threaded_mainloop_unlock(po->mainloop);
g_set_error(error_r, pulse_output_quark(), 0,
"suspended");
return 0;
}
-#endif
pa_threaded_mainloop_wait(po->mainloop);
@@ -907,7 +859,7 @@ pulse_output_pause(struct audio_output *ao)
/* cork the stream */
- if (!pulse_output_stream_is_paused(po) &&
+ if (!pa_stream_is_corked(po->stream) &&
!pulse_output_stream_pause(po, true, &error)) {
pa_threaded_mainloop_unlock(po->mainloop);
g_warning("%s", error->message);