Index: src/Makefile.am
===================================================================
--- src/Makefile.am (revision 28129)
+++ src/Makefile.am (working copy)
@@ -198,6 +198,12 @@
Sound += arch/Sound/RageSoundDriver_OSS.cpp arch/Sound/RageSoundDriver_OSS.h
endif
+if HAVE_PULSE
+Sound += arch/Sound/RageSoundDriver_Pulse.cpp arch/Sound/RageSoundDriver_Pulse.h
+AM_CXXFLAGS += $(PULSE_CFLAGS)
+AM_LDFLAGS += $(PULSE_LIBS)
+endif
+
if HAVE_ALSA
Sound += arch/Sound/ALSA9Dynamic.cpp arch/Sound/ALSA9Dynamic.h arch/Sound/ALSA9Functions.h \
arch/Sound/ALSA9Helpers.cpp arch/Sound/ALSA9Helpers.h \
Index: src/arch/arch_default.h
===================================================================
--- src/arch/arch_default.h (revision 28129)
+++ src/arch/arch_default.h (working copy)
@@ -49,7 +49,7 @@
#define DEFAULT_INPUT_DRIVER_LIST "X11"
#endif
#define DEFAULT_MOVIE_DRIVER_LIST "Theora,FFMpeg,Null"
-#define DEFAULT_SOUND_DRIVER_LIST "ALSA-sw,OSS,Null"
+#define DEFAULT_SOUND_DRIVER_LIST "pulse,ALSA-sw,OSS,Null"
#else
#error Which arch?
#endif
Index: src/arch/Sound/RageSoundDriver_Pulse.cpp
===================================================================
--- src/arch/Sound/RageSoundDriver_Pulse.cpp (revision 0)
+++ src/arch/Sound/RageSoundDriver_Pulse.cpp (revision 0)
@@ -0,0 +1,166 @@
+#include "global.h"
+#include "RageSoundDriver_Pulse.h"
+
+#include "RageLog.h"
+#include "RageSound.h"
+#include "RageSoundManager.h"
+#include "RageUtil.h"
+#include "PrefsManager.h"
+
+#include <errno.h>
+#include <string.h>
+#include <pulse/error.h>
+
+REGISTER_SOUND_DRIVER_CLASS( Pulse );
+
+/* samples */
+const int channels = 2;
+const int bytes_per_frame = channels*2; /* 16-bit */
+const int chunk_order = 12;
+const int num_chunks = 2; //4;
+const int buffersize = num_chunks * (1 << (chunk_order-1)); /* in bytes */
+const int buffersize_frames = buffersize/bytes_per_frame; /* in frames */
+
+int RageSoundDriver_Pulse::MixerThread_start(void *p)
+{
+ ((RageSoundDriver_Pulse *) p)->MixerThread();
+ return 0;
+}
+
+void RageSoundDriver_Pulse::MixerThread()
+{
+ /* We want to set a higher priority, but Unix only lets root renice
+ * < 0, which is silly. Give it a try, anyway. */
+ int status = nice( -10 );
+ if( status != -1 )
+ LOG->Trace( "Set MixerThread nice value to %d", status );
+
+ while( !shutdown )
+ {
+ GetData();
+
+ usleep( 10000 );
+ }
+}
+
+void RageSoundDriver_Pulse::SetupDecodingThread()
+{
+ int status = nice( -5 );
+ if( status != -1 )
+ LOG->Trace( "Set DecodingThread nice value to %d", status );
+}
+
+bool RageSoundDriver_Pulse::GetData()
+{
+ const int chunksize = buffersize;
+
+ static int16_t *buf = NULL;
+ if(!buf)
+ buf = new int16_t[chunksize / sizeof(int16_t)];
+
+ this->Mix( buf, chunksize/bytes_per_frame, last_cursor_pos, GetPosition() );
+
+ if (pa_simple_write( s, buf, chunksize, &err ) < 0)
+ return true; // need more data
+
+ /* Increment last_cursor_pos. */
+ last_cursor_pos += chunksize / bytes_per_frame;
+
+ return false; // have enough data
+}
+
+int64_t RageSoundDriver_Pulse::GetPosition() const
+{
+ return last_cursor_pos - (buffersize / bytes_per_frame);
+ //return last_cursor_pos;
+}
+
+RageSoundDriver_Pulse::RageSoundDriver_Pulse()
+{
+ s = NULL;
+ shutdown = false;
+ last_cursor_pos = 0;
+}
+
+RString RageSoundDriver_Pulse::Init()
+{
+ samplerate = PREFSMAN->m_iSoundPreferredSampleRate;
+ if( samplerate == 0 )
+ samplerate = 44100;
+
+ spec.format = PA_SAMPLE_S16LE;
+ spec.channels = channels;
+ spec.rate = samplerate;
+
+ //bufattr.maxlength = 4096;
+ bufattr.maxlength = buffersize * 2;
+
+ s = pa_simple_new(
+ NULL, // default server
+ "StepMania", // app name
+ PA_STREAM_PLAYBACK, // playback
+ NULL, // default device
+ "Audio", // stream description
+ &spec, // sample spec
+ NULL, // default channel map
+ &bufattr, // h4xed buffering
+ &err // error code
+ );
+ if (s == NULL)
+ return ssprintf( "RageSoundDriver_Pulse: Couldn't connect to Pulse server: %s", pa_strerror(err) );
+
+ StartDecodeThread();
+
+ MixingThread.SetName( "RageSoundDriver_Pulse" );
+ MixingThread.Create( MixerThread_start, this );
+
+ return "";
+}
+
+RageSoundDriver_Pulse::~RageSoundDriver_Pulse()
+{
+ if( MixingThread.IsCreated() )
+ {
+ /* Signal the mixing thread to quit. */
+ shutdown = true;
+ LOG->Trace("Shutting down mixer thread ...");
+ MixingThread.Wait();
+ LOG->Trace("Mixer thread shut down.");
+ }
+
+ if (s != NULL)
+ pa_simple_free(s);
+}
+
+float RageSoundDriver_Pulse::GetPlayLatency() const
+{
+ //return (1.0f / samplerate) * (buffersize_frames - chunksize_frames);
+ return pa_simple_get_latency(s, NULL) / 1000000.0f;
+ //return 0;
+}
+
+/*
+ * (c) 2002-2004 Glenn Maynard
+ * (c) 2009 Ondrej Hosek
+ * All rights reserved.
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the
+ * "Software"), to deal in the Software without restriction, including
+ * without limitation the rights to use, copy, modify, merge, publish,
+ * distribute, and/or sell copies of the Software, and to permit persons to
+ * whom the Software is furnished to do so, provided that the above
+ * copyright notice(s) and this permission notice appear in all copies of
+ * the Software and that both the above copyright notice(s) and this
+ * permission notice appear in supporting documentation.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+ * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+ * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF
+ * THIRD PARTY RIGHTS. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR HOLDERS
+ * INCLUDED IN THIS NOTICE BE LIABLE FOR ANY CLAIM, OR ANY SPECIAL INDIRECT
+ * OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
+ * OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+ * OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+ * PERFORMANCE OF THIS SOFTWARE.
+ */
Index: src/arch/Sound/RageSoundDriver_Pulse.h
===================================================================
--- src/arch/Sound/RageSoundDriver_Pulse.h (revision 0)
+++ src/arch/Sound/RageSoundDriver_Pulse.h (revision 0)
@@ -0,0 +1,66 @@
+#ifndef RAGE_SOUND_PULSE
+#define RAGE_SOUND_PULSE
+
+#include "RageSoundDriver.h"
+#include "RageThreads.h"
+#include "RageTimer.h"
+
+#include <pulse/simple.h>
+
+class RageSoundDriver_Pulse: public RageSoundDriver
+{
+ pa_simple *s;
+ pa_sample_spec spec;
+ pa_buffer_attr bufattr;
+
+ bool shutdown;
+ int last_cursor_pos;
+ int samplerate;
+
+ static int MixerThread_start(void *p);
+ void MixerThread();
+ RageThread MixingThread;
+
+ int err;
+
+public:
+ bool GetData();
+ int GetSampleRate() const { return samplerate; }
+
+ /* virtuals: */
+ int64_t GetPosition() const;
+ float GetPlayLatency() const;
+ void SetupDecodingThread();
+
+ RageSoundDriver_Pulse();
+ RString Init();
+ ~RageSoundDriver_Pulse();
+};
+
+#endif
+
+/*
+ * (c) 2002-2004 Glenn Maynard
+ * (c) 2009 Ondrej Hosek
+ * All rights reserved.
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the
+ * "Software"), to deal in the Software without restriction, including
+ * without limitation the rights to use, copy, modify, merge, publish,
+ * distribute, and/or sell copies of the Software, and to permit persons to
+ * whom the Software is furnished to do so, provided that the above
+ * copyright notice(s) and this permission notice appear in all copies of
+ * the Software and that both the above copyright notice(s) and this
+ * permission notice appear in supporting documentation.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+ * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+ * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF
+ * THIRD PARTY RIGHTS. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR HOLDERS
+ * INCLUDED IN THIS NOTICE BE LIABLE FOR ANY CLAIM, OR ANY SPECIAL INDIRECT
+ * OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
+ * OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+ * OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+ * PERFORMANCE OF THIS SOFTWARE.
+ */
Index: configure.ac
===================================================================
--- configure.ac (revision 28129)
+++ configure.ac (working copy)
@@ -208,6 +208,14 @@
AC_CHECK_HEADER(stdint.h, , [AC_DEFINE(MISSING_STDINT_H, 1, [stdint.h is missing])])
AC_CHECK_HEADERS([inttypes.h endian.h machine/endian.h alloca.h])
+have_pulse=no
+AC_CHECK_LIB(pulse, pa_stream_new, have_pulse=yes)
+if test x$have_pulse = xyes; then
+ AC_DEFINE(HAVE_PULSE, 1, [pulseaudio support available])
+ AC_SUBST(PULSE_LIBS)
+ AC_SUBST(PULSE_CFLAGS)
+fi
+
AC_MSG_CHECKING(if cstdlib breaks llabs)
AC_LANG_PUSH(C++)
AC_COMPILE_IFELSE([AC_LANG_PROGRAM([[#include <stdlib.h>
@@ -227,6 +234,7 @@
AM_CONDITIONAL(HAVE_ALSA, test x$alsa != xfalse )
AM_CONDITIONAL(HAVE_GTK, test "$enable_gtk2" != "no" )
AM_CONDITIONAL(HAVE_OSS, test x$ac_cv_header_sys_soundcard_h = xyes )
+AM_CONDITIONAL(HAVE_PULSE, test x$have_pulse = xyes)
AM_CONDITIONAL(USE_CRASH_HANDLER, test "$use_crash_handler" = "yes" )
if test x$force_oss = xyes && test x$ac_cv_header_sys_soundcard_h = xyes; then
Pastie << self Blog
