aboutsummaryrefslogtreecommitdiffstats
path: root/Alc
diff options
context:
space:
mode:
Diffstat (limited to 'Alc')
-rw-r--r--Alc/pulseaudio.c263
1 files changed, 188 insertions, 75 deletions
diff --git a/Alc/pulseaudio.c b/Alc/pulseaudio.c
index 6ba0255a..83c7c84b 100644
--- a/Alc/pulseaudio.c
+++ b/Alc/pulseaudio.c
@@ -21,6 +21,9 @@
#include "config.h"
#include "alMain.h"
+#ifdef HAVE_DLFCN_H
+#include <dlfcn.h>
+#endif
#include <pulse/pulseaudio.h>
@@ -41,6 +44,45 @@ static inline int PA_CONTEXT_IS_GOOD(pa_context_state_t x)
#error Invalid PulseAudio API version
#endif
+static void *pa_handle;
+#define MAKE_FUNC(x) static typeof(x) * p##x
+MAKE_FUNC(pa_context_unref);
+MAKE_FUNC(pa_sample_spec_valid);
+MAKE_FUNC(pa_stream_drop);
+MAKE_FUNC(pa_strerror);
+MAKE_FUNC(pa_context_get_state);
+MAKE_FUNC(pa_stream_get_state);
+MAKE_FUNC(pa_threaded_mainloop_signal);
+MAKE_FUNC(pa_stream_peek);
+MAKE_FUNC(pa_threaded_mainloop_wait);
+MAKE_FUNC(pa_threaded_mainloop_unlock);
+MAKE_FUNC(pa_context_new);
+MAKE_FUNC(pa_threaded_mainloop_stop);
+MAKE_FUNC(pa_context_disconnect);
+MAKE_FUNC(pa_threaded_mainloop_start);
+MAKE_FUNC(pa_threaded_mainloop_get_api);
+MAKE_FUNC(pa_context_set_state_callback);
+MAKE_FUNC(pa_stream_write);
+MAKE_FUNC(pa_xfree);
+MAKE_FUNC(pa_stream_connect_record);
+MAKE_FUNC(pa_stream_connect_playback);
+MAKE_FUNC(pa_path_get_filename);
+MAKE_FUNC(pa_get_binary_name);
+MAKE_FUNC(pa_threaded_mainloop_free);
+MAKE_FUNC(pa_context_errno);
+MAKE_FUNC(pa_xmalloc0);
+MAKE_FUNC(pa_stream_unref);
+MAKE_FUNC(pa_threaded_mainloop_accept);
+MAKE_FUNC(pa_stream_set_write_callback);
+MAKE_FUNC(pa_threaded_mainloop_new);
+MAKE_FUNC(pa_context_connect);
+MAKE_FUNC(pa_stream_set_read_callback);
+MAKE_FUNC(pa_stream_set_state_callback);
+MAKE_FUNC(pa_stream_new);
+MAKE_FUNC(pa_stream_disconnect);
+MAKE_FUNC(pa_threaded_mainloop_lock);
+#undef MAKE_FUNC
+
typedef struct {
ALCdevice *device;
@@ -72,7 +114,7 @@ static void stream_state_callback(pa_stream *stream, void *pdata) //{{{
{
pulse_data *data = pdata;
- switch(pa_stream_get_state(stream))
+ switch(ppa_stream_get_state(stream))
{
case PA_STREAM_READY:
AL_PRINT("%s: %s ready!\n", data->context_name, data->stream_name);
@@ -80,7 +122,7 @@ static void stream_state_callback(pa_stream *stream, void *pdata) //{{{
case PA_STREAM_FAILED:
AL_PRINT("%s: %s: Connection failed: %s\n", data->context_name,
- data->stream_name, pa_strerror(pa_context_errno(data->context)));
+ data->stream_name, ppa_strerror(ppa_context_errno(data->context)));
break;
case PA_STREAM_TERMINATED:
@@ -91,14 +133,14 @@ static void stream_state_callback(pa_stream *stream, void *pdata) //{{{
break;
}
- pa_threaded_mainloop_signal(data->loop, 1);
+ ppa_threaded_mainloop_signal(data->loop, 1);
} //}}}
static void context_state_callback(pa_context *context, void *pdata) //{{{
{
pulse_data *data = pdata;
- switch(pa_context_get_state(context))
+ switch(ppa_context_get_state(context))
{
case PA_CONTEXT_READY:
AL_PRINT("%s ready!\n", data->context_name);
@@ -106,7 +148,7 @@ static void context_state_callback(pa_context *context, void *pdata) //{{{
case PA_CONTEXT_FAILED:
AL_PRINT("%s: Connection failed: %s\n", data->context_name,
- pa_strerror(pa_context_errno(context)));
+ ppa_strerror(ppa_context_errno(context)));
break;
case PA_CONTEXT_TERMINATED:
@@ -117,7 +159,7 @@ static void context_state_callback(pa_context *context, void *pdata) //{{{
break;
}
- pa_threaded_mainloop_signal(data->loop, 1);
+ ppa_threaded_mainloop_signal(data->loop, 1);
} //}}}
//}}}
@@ -125,13 +167,13 @@ static void context_state_callback(pa_context *context, void *pdata) //{{{
static void stream_write_callback(pa_stream *stream, size_t len, void *pdata) //{{{
{
ALCdevice *Device = pdata;
- void *buf = pa_xmalloc0(len);
+ void *buf = ppa_xmalloc0(len);
SuspendContext(NULL);
aluMixData(Device->Context, buf, len, Device->Format);
ProcessContext(NULL);
- pa_stream_write(stream, buf, len, pa_xfree, 0, PA_SEEK_RELATIVE);
+ ppa_stream_write(stream, buf, len, ppa_xfree, 0, PA_SEEK_RELATIVE);
} //}}}
static void stream_read_callback(pa_stream *stream, size_t length, void *pdata) //{{{
@@ -140,10 +182,10 @@ static void stream_read_callback(pa_stream *stream, size_t length, void *pdata)
pulse_data *data = Device->ExtraData;
const void *buf;
- if(pa_stream_peek(stream, &buf, &length) < 0)
+ if(ppa_stream_peek(stream, &buf, &length) < 0)
{
AL_PRINT("pa_stream_peek() failed: %s\n",
- pa_strerror(pa_context_errno(data->context)));
+ ppa_strerror(ppa_context_errno(data->context)));
return;
}
@@ -157,13 +199,13 @@ static void stream_read_callback(pa_stream *stream, size_t length, void *pdata)
WriteRingBuffer(data->ring, buf, (length<data->samples) ? length : data->samples);
- pa_stream_drop(stream);
+ ppa_stream_drop(stream);
} //}}}
//}}}
static ALCboolean pulse_open(ALCdevice *device, ALCchar *device_name, ALCenum format, ALCuint samples, ALCuint frequency) //{{{
{
- pulse_data *data = pa_xmalloc0(sizeof(pulse_data));
+ pulse_data *data = ppa_xmalloc0(sizeof(pulse_data));
data->device = device;
data->format = format;
@@ -171,14 +213,14 @@ static ALCboolean pulse_open(ALCdevice *device, ALCchar *device_name, ALCenum fo
data->frequency = frequency;
data->frame_size = aluBytesFromFormat(format) * aluChannelsFromFormat(format);
- if(pa_get_binary_name(data->path_name, sizeof(data->path_name)))
- data->context_name = pa_path_get_filename(data->path_name);
+ if(ppa_get_binary_name(data->path_name, sizeof(data->path_name)))
+ data->context_name = ppa_path_get_filename(data->path_name);
else
data->context_name = "OpenAL Soft";
if(!(data->ring = CreateRingBuffer(data->frame_size, data->samples)))
{
- pa_xfree(data);
+ ppa_xfree(data);
return ALC_FALSE;
}
@@ -218,86 +260,86 @@ static ALCboolean pulse_open(ALCdevice *device, ALCchar *device_name, ALCenum fo
goto out2;
}
- if(pa_sample_spec_valid(&data->spec) == 0)
+ if(ppa_sample_spec_valid(&data->spec) == 0)
{
AL_PRINT("Invalid sample format\n");
goto out2;
}
- if(!(data->loop = pa_threaded_mainloop_new()))
+ if(!(data->loop = ppa_threaded_mainloop_new()))
{
AL_PRINT("pa_threaded_mainloop_new() failed!\n");
goto out2;
}
- if(pa_threaded_mainloop_start(data->loop) < 0)
+ if(ppa_threaded_mainloop_start(data->loop) < 0)
{
AL_PRINT("pa_threaded_mainloop_start() failed\n");
goto out3;
}
- pa_threaded_mainloop_lock(data->loop);
+ ppa_threaded_mainloop_lock(data->loop);
- data->context = pa_context_new(pa_threaded_mainloop_get_api(data->loop), data->context_name);
+ data->context = ppa_context_new(ppa_threaded_mainloop_get_api(data->loop), data->context_name);
if(!data->context)
{
AL_PRINT("pa_context_new() failed: %s\n",
- pa_strerror(pa_context_errno(data->context)));
+ ppa_strerror(ppa_context_errno(data->context)));
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_threaded_mainloop_unlock(data->loop);
goto out3;
}
- pa_context_set_state_callback(data->context, context_state_callback, data);
+ ppa_context_set_state_callback(data->context, context_state_callback, data);
- if(pa_context_connect(data->context, NULL, PA_CONTEXT_NOAUTOSPAWN, NULL) < 0)
+ if(ppa_context_connect(data->context, NULL, PA_CONTEXT_NOAUTOSPAWN, NULL) < 0)
{
AL_PRINT("Context did not connect: %s\n",
- pa_strerror(pa_context_errno(data->context)));
+ ppa_strerror(ppa_context_errno(data->context)));
- pa_context_unref(data->context);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_context_unref(data->context);
+ ppa_threaded_mainloop_unlock(data->loop);
data->context = NULL;
goto out3;
}
- while(pa_context_get_state(data->context) != PA_CONTEXT_READY)
+ while(ppa_context_get_state(data->context) != PA_CONTEXT_READY)
{
- if(!PA_CONTEXT_IS_GOOD(pa_context_get_state(data->context)))
+ if(!PA_CONTEXT_IS_GOOD(ppa_context_get_state(data->context)))
{
- pa_context_unref(data->context);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_context_unref(data->context);
+ ppa_threaded_mainloop_unlock(data->loop);
data->context = NULL;
goto out3;
}
- pa_threaded_mainloop_wait(data->loop);
- pa_threaded_mainloop_accept(data->loop);
+ ppa_threaded_mainloop_wait(data->loop);
+ ppa_threaded_mainloop_accept(data->loop);
}
- data->stream = pa_stream_new(data->context, data->stream_name, &data->spec, NULL);
+ data->stream = ppa_stream_new(data->context, data->stream_name, &data->spec, NULL);
if(!data->stream)
{
AL_PRINT("pa_stream_new() failed: %s\n",
- pa_strerror(pa_context_errno(data->context)));
+ ppa_strerror(ppa_context_errno(data->context)));
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_threaded_mainloop_unlock(data->loop);
goto out4;
}
- pa_stream_set_state_callback(data->stream, stream_state_callback, data);
+ ppa_stream_set_state_callback(data->stream, stream_state_callback, data);
if(device->IsCaptureDevice)
{
- if(pa_stream_connect_record(data->stream, NULL, &data->attr, PA_STREAM_ADJUST_LATENCY) < 0)
+ if(ppa_stream_connect_record(data->stream, NULL, &data->attr, PA_STREAM_ADJUST_LATENCY) < 0)
{
AL_PRINT("Stream did not connect: %s\n",
- pa_strerror(pa_context_errno(data->context)));
+ ppa_strerror(ppa_context_errno(data->context)));
- pa_stream_unref(data->stream);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_stream_unref(data->stream);
+ ppa_threaded_mainloop_unlock(data->loop);
data->stream = NULL;
goto out4;
@@ -305,57 +347,57 @@ static ALCboolean pulse_open(ALCdevice *device, ALCchar *device_name, ALCenum fo
}
else
{
- pa_stream_set_write_callback(data->stream, stream_write_callback, device);
+ ppa_stream_set_write_callback(data->stream, stream_write_callback, device);
- if(pa_stream_connect_playback(data->stream, NULL, &data->attr, PA_STREAM_ADJUST_LATENCY, NULL, NULL) < 0)
+ if(ppa_stream_connect_playback(data->stream, NULL, &data->attr, PA_STREAM_ADJUST_LATENCY, NULL, NULL) < 0)
{
AL_PRINT("Stream did not connect: %s\n",
- pa_strerror(pa_context_errno(data->context)));
+ ppa_strerror(ppa_context_errno(data->context)));
- pa_stream_unref(data->stream);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_stream_unref(data->stream);
+ ppa_threaded_mainloop_unlock(data->loop);
data->stream = NULL;
goto out4;
}
}
- while(pa_stream_get_state(data->stream) != PA_STREAM_READY)
+ while(ppa_stream_get_state(data->stream) != PA_STREAM_READY)
{
- if(!PA_STREAM_IS_GOOD(pa_stream_get_state(data->stream)))
+ if(!PA_STREAM_IS_GOOD(ppa_stream_get_state(data->stream)))
{
- pa_stream_unref(data->stream);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_stream_unref(data->stream);
+ ppa_threaded_mainloop_unlock(data->loop);
data->stream = NULL;
goto out4;
}
- pa_threaded_mainloop_wait(data->loop);
- pa_threaded_mainloop_accept(data->loop);
+ ppa_threaded_mainloop_wait(data->loop);
+ ppa_threaded_mainloop_accept(data->loop);
}
device->UpdateSize /= 4;
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_threaded_mainloop_unlock(data->loop);
return ALC_TRUE;
out4:
- pa_threaded_mainloop_lock(data->loop);
+ ppa_threaded_mainloop_lock(data->loop);
- pa_context_disconnect(data->context);
- pa_context_unref(data->context);
+ ppa_context_disconnect(data->context);
+ ppa_context_unref(data->context);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_threaded_mainloop_unlock(data->loop);
out3:
- pa_threaded_mainloop_stop(data->loop);
- pa_threaded_mainloop_free(data->loop);
+ ppa_threaded_mainloop_stop(data->loop);
+ ppa_threaded_mainloop_free(data->loop);
out2:
device->ExtraData = NULL;
device->szDeviceName = NULL;
DestroyRingBuffer(data->ring);
- pa_xfree(data);
+ ppa_xfree(data);
return ALC_FALSE;
} //}}}
@@ -363,24 +405,24 @@ static void pulse_close(ALCdevice *device) //{{{
{
pulse_data *data = device->ExtraData;
- pa_threaded_mainloop_lock(data->loop);
+ ppa_threaded_mainloop_lock(data->loop);
- pa_stream_disconnect(data->stream);
- pa_stream_unref(data->stream);
+ ppa_stream_disconnect(data->stream);
+ ppa_stream_unref(data->stream);
- pa_context_disconnect(data->context);
- pa_context_unref(data->context);
+ ppa_context_disconnect(data->context);
+ ppa_context_unref(data->context);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_threaded_mainloop_unlock(data->loop);
- pa_threaded_mainloop_stop(data->loop);
- pa_threaded_mainloop_free(data->loop);
+ ppa_threaded_mainloop_stop(data->loop);
+ ppa_threaded_mainloop_free(data->loop);
device->ExtraData = NULL;
device->szDeviceName = NULL;
DestroyRingBuffer(data->ring);
- pa_xfree(data);
+ ppa_xfree(data);
} //}}}
//}}}
@@ -421,18 +463,18 @@ static void pulse_start_capture(ALCdevice *device) //{{{
{
pulse_data *data = device->ExtraData;
- pa_threaded_mainloop_lock(data->loop);
- pa_stream_set_read_callback(data->stream, stream_read_callback, device);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_threaded_mainloop_lock(data->loop);
+ ppa_stream_set_read_callback(data->stream, stream_read_callback, device);
+ ppa_threaded_mainloop_unlock(data->loop);
} //}}}
static void pulse_stop_capture(ALCdevice *device) //{{{
{
pulse_data *data = device->ExtraData;
- pa_threaded_mainloop_lock(data->loop);
- pa_stream_set_read_callback(data->stream, NULL, NULL);
- pa_threaded_mainloop_unlock(data->loop);
+ ppa_threaded_mainloop_lock(data->loop);
+ ppa_stream_set_read_callback(data->stream, NULL, NULL);
+ ppa_threaded_mainloop_unlock(data->loop);
} //}}}
static void pulse_capture_samples(ALCdevice *device, ALCvoid *buffer, ALCuint samples) //{{{
@@ -467,6 +509,77 @@ void alc_pulse_init(BackendFuncs *func_list) //{{{
{
*func_list = pulse_funcs;
+#ifdef _WIN32
+ pa_handle = LoadLibrary("libpulse-0.dll");
+#define LOAD_FUNC(x) do { \
+ p##x = GetProcAddress(pa_handle, #x); \
+ if(!(p##x)) { \
+ FreeLibrary(pa_handle); \
+ pa_handle = NULL; \
+ return; \
+ } \
+} while(0)
+
+#elif defined (HAVE_DLFCN_H)
+
+#if defined(__APPLE__) && defined(__MACH__)
+ pa_handle = dlopen("libpulse.0.dylib", RTLD_NOW);
+#else
+ pa_handle = dlopen("libpulse.so.0", RTLD_NOW);
+#endif
+#define LOAD_FUNC(x) do { \
+ p##x = dlsym(pa_handle, #x); \
+ if(!(p##x)) { \
+ dlclose(pa_handle); \
+ pa_handle = NULL; \
+ return; \
+ } \
+} while(0)
+
+#else
+
+#define LOAD_FUNC(x) p##x = (x)
+
+#endif
+
+LOAD_FUNC(pa_context_unref);
+LOAD_FUNC(pa_sample_spec_valid);
+LOAD_FUNC(pa_stream_drop);
+LOAD_FUNC(pa_strerror);
+LOAD_FUNC(pa_context_get_state);
+LOAD_FUNC(pa_stream_get_state);
+LOAD_FUNC(pa_threaded_mainloop_signal);
+LOAD_FUNC(pa_stream_peek);
+LOAD_FUNC(pa_threaded_mainloop_wait);
+LOAD_FUNC(pa_threaded_mainloop_unlock);
+LOAD_FUNC(pa_context_new);
+LOAD_FUNC(pa_threaded_mainloop_stop);
+LOAD_FUNC(pa_context_disconnect);
+LOAD_FUNC(pa_threaded_mainloop_start);
+LOAD_FUNC(pa_threaded_mainloop_get_api);
+LOAD_FUNC(pa_context_set_state_callback);
+LOAD_FUNC(pa_stream_write);
+LOAD_FUNC(pa_xfree);
+LOAD_FUNC(pa_stream_connect_record);
+LOAD_FUNC(pa_stream_connect_playback);
+LOAD_FUNC(pa_path_get_filename);
+LOAD_FUNC(pa_get_binary_name);
+LOAD_FUNC(pa_threaded_mainloop_free);
+LOAD_FUNC(pa_context_errno);
+LOAD_FUNC(pa_xmalloc0);
+LOAD_FUNC(pa_stream_unref);
+LOAD_FUNC(pa_threaded_mainloop_accept);
+LOAD_FUNC(pa_stream_set_write_callback);
+LOAD_FUNC(pa_threaded_mainloop_new);
+LOAD_FUNC(pa_context_connect);
+LOAD_FUNC(pa_stream_set_read_callback);
+LOAD_FUNC(pa_stream_set_state_callback);
+LOAD_FUNC(pa_stream_new);
+LOAD_FUNC(pa_stream_disconnect);
+LOAD_FUNC(pa_threaded_mainloop_lock);
+
+#undef LOAD_FUNC
+
pulse_device = AppendDeviceList("PulseAudio Software");
AppendAllDeviceList(pulse_device);
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-14 19:08:13 +0000