[PATCH 1/7] winepulse: Move synchroinzatin functions to unix lib.
Andrew Eikum
aeikum at codeweavers.com
Wed May 12 11:36:06 CDT 2021
Signed-off-by: Andrew Eikum <aeikum at codeweavers.com>
---
Would be nice to fix typo in Subject when merging.
On Tue, May 11, 2021 at 06:29:38PM +0200, Jacek Caban wrote:
> Signed-off-by: Jacek Caban <jacek at codeweavers.com>
> ---
> dlls/winepulse.drv/Makefile.in | 3 +-
> dlls/winepulse.drv/mmdevdrv.c | 199 ++++++++++++++++-----------------
> dlls/winepulse.drv/pulse.c | 83 ++++++++++++++
> dlls/winepulse.drv/unixlib.h | 25 +++++
> 4 files changed, 207 insertions(+), 103 deletions(-)
> create mode 100644 dlls/winepulse.drv/pulse.c
> create mode 100644 dlls/winepulse.drv/unixlib.h
>
>
> diff --git a/dlls/winepulse.drv/Makefile.in b/dlls/winepulse.drv/Makefile.in
> index d6600632360..920366f07af 100644
> --- a/dlls/winepulse.drv/Makefile.in
> +++ b/dlls/winepulse.drv/Makefile.in
> @@ -4,4 +4,5 @@ EXTRALIBS = $(PULSE_LIBS) $(PTHREAD_LIBS)
> EXTRAINCL = $(PULSE_CFLAGS)
>
> C_SRCS = \
> - mmdevdrv.c
> + mmdevdrv.c \
> + pulse.c
> diff --git a/dlls/winepulse.drv/mmdevdrv.c b/dlls/winepulse.drv/mmdevdrv.c
> index ea739affb2f..9eb056ab506 100644
> --- a/dlls/winepulse.drv/mmdevdrv.c
> +++ b/dlls/winepulse.drv/mmdevdrv.c
> @@ -24,7 +24,6 @@
>
> #include "config.h"
> #include <poll.h>
> -#include <pthread.h>
>
> #include <stdarg.h>
> #include <unistd.h>
> @@ -57,8 +56,12 @@
> #include "endpointvolume.h"
> #include "audiopolicy.h"
>
> +#include "unixlib.h"
> +
> WINE_DEFAULT_DEBUG_CHANNEL(pulse);
>
> +static const struct unix_funcs *pulse;
> +
> #define NULL_PTR_ERR MAKE_HRESULT(SEVERITY_ERROR, FACILITY_WIN32, RPC_X_NULL_REF_POINTER)
>
> /* From <dlls/mmdevapi/mmdevapi.h> */
> @@ -76,8 +79,6 @@ static pa_context *pulse_ctx;
> static pa_mainloop *pulse_ml;
>
> static HANDLE pulse_thread;
> -static pthread_mutex_t pulse_lock;
> -static pthread_cond_t pulse_cond = PTHREAD_COND_INITIALIZER;
> static struct list g_sessions = LIST_INIT(g_sessions);
>
> static UINT g_phys_speakers_mask = 0;
> @@ -97,15 +98,9 @@ static UINT8 mult_ulaw_sample(UINT8, float);
> BOOL WINAPI DllMain(HINSTANCE dll, DWORD reason, void *reserved)
> {
> if (reason == DLL_PROCESS_ATTACH) {
> - pthread_mutexattr_t attr;
> -
> DisableThreadLibraryCalls(dll);
> -
> - pthread_mutexattr_init(&attr);
> - pthread_mutexattr_setprotocol(&attr, PTHREAD_PRIO_INHERIT);
> -
> - if (pthread_mutex_init(&pulse_lock, &attr) != 0)
> - pthread_mutex_init(&pulse_lock, NULL);
> + if (__wine_init_unix_lib(dll, reason, NULL, &pulse))
> + return FALSE;
> } else if (reason == DLL_PROCESS_DETACH) {
> if (pulse_thread)
> SetThreadPriority(pulse_thread, 0);
> @@ -273,9 +268,9 @@ static inline ACImpl *impl_from_IAudioStreamVolume(IAudioStreamVolume *iface)
>
> static int pulse_poll_func(struct pollfd *ufds, unsigned long nfds, int timeout, void *userdata) {
> int r;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> r = poll(ufds, nfds, timeout);
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> return r;
> }
>
> @@ -283,10 +278,10 @@ static DWORD CALLBACK pulse_mainloop_thread(void *tmp) {
> int ret;
> pulse_ml = pa_mainloop_new();
> pa_mainloop_set_poll_func(pulse_ml, pulse_poll_func, NULL);
> - pthread_mutex_lock(&pulse_lock);
> - pthread_cond_broadcast(&pulse_cond);
> + pulse->lock();
> + pulse->broadcast();
> pa_mainloop_run(pulse_ml, &ret);
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> pa_mainloop_free(pulse_ml);
> return ret;
> }
> @@ -314,14 +309,14 @@ static void pulse_contextcallback(pa_context *c, void *userdata)
> WARN("Context failed: %s\n", pa_strerror(pa_context_errno(c)));
> break;
> }
> - pthread_cond_broadcast(&pulse_cond);
> + pulse->broadcast();
> }
>
> static void pulse_stream_state(pa_stream *s, void *user)
> {
> pa_stream_state_t state = pa_stream_get_state(s);
> TRACE("Stream state changed to %i\n", state);
> - pthread_cond_broadcast(&pulse_cond);
> + pulse->broadcast();
> }
>
> static const enum pa_channel_position pulse_pos_from_wfx[] = {
> @@ -553,7 +548,7 @@ static HRESULT pulse_connect(void)
> return E_FAIL;
> }
> SetThreadPriority(pulse_thread, THREAD_PRIORITY_TIME_CRITICAL);
> - pthread_cond_wait(&pulse_cond, &pulse_lock);
> + pulse->cond_wait();
> }
>
> if (pulse_ctx && PA_CONTEXT_IS_GOOD(pa_context_get_state(pulse_ctx)))
> @@ -585,7 +580,7 @@ static HRESULT pulse_connect(void)
> goto fail;
>
> /* Wait for connection */
> - while (pthread_cond_wait(&pulse_cond, &pulse_lock)) {
> + while (pulse->cond_wait()) {
> pa_context_state_t state = pa_context_get_state(pulse_ctx);
>
> if (state == PA_CONTEXT_FAILED || state == PA_CONTEXT_TERMINATED)
> @@ -862,7 +857,7 @@ static void dump_attr(const pa_buffer_attr *attr) {
> static void pulse_op_cb(pa_stream *s, int success, void *user) {
> TRACE("Success: %i\n", success);
> *(int*)user = success;
> - pthread_cond_broadcast(&pulse_cond);
> + pulse->broadcast();
> }
>
> static void pulse_attr_update(pa_stream *s, void *user) {
> @@ -1028,10 +1023,10 @@ static DWORD WINAPI pulse_timer_cb(void *user)
> int success;
> pa_operation *o;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> delay.QuadPart = -This->mmdev_period_usec * 10;
> pa_stream_get_time(This->stream, &This->last_time);
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> while(!This->please_quit){
> pa_usec_t now, adv_usec = 0;
> @@ -1039,7 +1034,7 @@ static DWORD WINAPI pulse_timer_cb(void *user)
>
> NtDelayExecution(FALSE, &delay);
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
>
> delay.QuadPart = -This->mmdev_period_usec * 10;
>
> @@ -1047,7 +1042,7 @@ static DWORD WINAPI pulse_timer_cb(void *user)
> if (o)
> {
> while (pa_operation_get_state(o) == PA_OPERATION_RUNNING)
> - pthread_cond_wait(&pulse_cond, &pulse_lock);
> + pulse->cond_wait();
> pa_operation_unref(o);
> }
> err = pa_stream_get_time(This->stream, &now);
> @@ -1106,7 +1101,7 @@ static DWORD WINAPI pulse_timer_cb(void *user)
> This, (int)adv_usec,
> (int)(This->held_bytes/ pa_frame_size(&This->ss)), (unsigned int)(-delay.QuadPart / 10));
>
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> }
>
> return 0;
> @@ -1120,7 +1115,7 @@ static HRESULT pulse_stream_connect(ACImpl *This, UINT32 period_bytes) {
> if (This->stream) {
> pa_stream_disconnect(This->stream);
> while (pa_stream_get_state(This->stream) == PA_STREAM_READY)
> - pthread_cond_wait(&pulse_cond, &pulse_lock);
> + pulse->cond_wait();
> pa_stream_unref(This->stream);
> }
> ret = InterlockedIncrement(&number);
> @@ -1153,7 +1148,7 @@ static HRESULT pulse_stream_connect(ACImpl *This, UINT32 period_bytes) {
> return AUDCLNT_E_ENDPOINT_CREATE_FAILED;
> }
> while (pa_stream_get_state(This->stream) == PA_STREAM_CREATING)
> - pthread_cond_wait(&pulse_cond, &pulse_lock);
> + pulse->cond_wait();
> if (pa_stream_get_state(This->stream) != PA_STREAM_READY)
> return AUDCLNT_E_ENDPOINT_CREATE_FAILED;
>
> @@ -1202,9 +1197,9 @@ HRESULT WINAPI AUDDRV_GetEndpointIDs(EDataFlow flow, const WCHAR ***ids, GUID **
> int WINAPI AUDDRV_GetPriority(void)
> {
> HRESULT hr;
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_test_connect();
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return SUCCEEDED(hr) ? Priority_Preferred : Priority_Unavailable;
> }
>
> @@ -1303,16 +1298,16 @@ static ULONG WINAPI AudioClient_Release(IAudioClient3 *iface)
> WaitForSingleObject(This->timer, INFINITE);
> CloseHandle(This->timer);
> }
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> if (PA_STREAM_IS_GOOD(pa_stream_get_state(This->stream))) {
> pa_stream_disconnect(This->stream);
> while (PA_STREAM_IS_GOOD(pa_stream_get_state(This->stream)))
> - pthread_cond_wait(&pulse_cond, &pulse_lock);
> + pulse->cond_wait();
> }
> pa_stream_unref(This->stream);
> This->stream = NULL;
> list_remove(&This->entry);
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> }
> IUnknown_Release(This->marshal);
> IMMDevice_Release(This->parent);
> @@ -1625,16 +1620,16 @@ static HRESULT WINAPI AudioClient_Initialize(IAudioClient3 *iface,
> return E_INVALIDARG;
> }
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
>
> hr = pulse_connect();
> if (FAILED(hr)) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> if (This->stream) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_ALREADY_INITIALIZED;
> }
>
> @@ -1711,7 +1706,7 @@ exit:
> This->stream = NULL;
> }
> }
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -1726,11 +1721,11 @@ static HRESULT WINAPI AudioClient_GetBufferSize(IAudioClient3 *iface,
> if (!out)
> return E_POINTER;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (SUCCEEDED(hr))
> *out = This->bufsize_frames;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> return hr;
> }
> @@ -1748,10 +1743,10 @@ static HRESULT WINAPI AudioClient_GetStreamLatency(IAudioClient3 *iface,
> if (!latency)
> return E_POINTER;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr)) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
> attr = pa_stream_get_buffer_attr(This->stream);
> @@ -1763,7 +1758,7 @@ static HRESULT WINAPI AudioClient_GetStreamLatency(IAudioClient3 *iface,
> *latency *= lat;
> *latency /= This->ss.rate;
> *latency += pulse_def_period[0];
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> TRACE("Latency: %u ms\n", (DWORD)(*latency / 10000));
> return S_OK;
> }
> @@ -1796,10 +1791,10 @@ static HRESULT WINAPI AudioClient_GetCurrentPadding(IAudioClient3 *iface,
> if (!out)
> return E_POINTER;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr)) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -1807,7 +1802,7 @@ static HRESULT WINAPI AudioClient_GetCurrentPadding(IAudioClient3 *iface,
> ACImpl_GetRenderPad(This, out);
> else
> ACImpl_GetCapturePad(This, out);
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> TRACE("%p Pad: %u ms (%u)\n", This, MulDiv(*out, 1000, This->ss.rate), *out);
> return S_OK;
> @@ -2011,20 +2006,20 @@ static HRESULT WINAPI AudioClient_Start(IAudioClient3 *iface)
>
> TRACE("(%p)\n", This);
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr)) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> if ((This->flags & AUDCLNT_STREAMFLAGS_EVENTCALLBACK) && !This->event) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_EVENTHANDLE_NOT_SET;
> }
>
> if (This->started) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_NOT_STOPPED;
> }
>
> @@ -2034,7 +2029,7 @@ static HRESULT WINAPI AudioClient_Start(IAudioClient3 *iface)
> o = pa_stream_cork(This->stream, 0, pulse_op_cb, &success);
> if (o) {
> while(pa_operation_get_state(o) == PA_OPERATION_RUNNING)
> - pthread_cond_wait(&pulse_cond, &pulse_lock);
> + pulse->cond_wait();
> pa_operation_unref(o);
> } else
> success = 0;
> @@ -2051,7 +2046,7 @@ static HRESULT WINAPI AudioClient_Start(IAudioClient3 *iface)
> SetThreadPriority(This->timer, THREAD_PRIORITY_TIME_CRITICAL);
> }
> }
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -2064,15 +2059,15 @@ static HRESULT WINAPI AudioClient_Stop(IAudioClient3 *iface)
>
> TRACE("(%p)\n", This);
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr)) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> if (!This->started) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return S_FALSE;
> }
>
> @@ -2080,7 +2075,7 @@ static HRESULT WINAPI AudioClient_Stop(IAudioClient3 *iface)
> o = pa_stream_cork(This->stream, 1, pulse_op_cb, &success);
> if (o) {
> while(pa_operation_get_state(o) == PA_OPERATION_RUNNING)
> - pthread_cond_wait(&pulse_cond, &pulse_lock);
> + pulse->cond_wait();
> pa_operation_unref(o);
> } else
> success = 0;
> @@ -2090,7 +2085,7 @@ static HRESULT WINAPI AudioClient_Stop(IAudioClient3 *iface)
> if (SUCCEEDED(hr)) {
> This->started = FALSE;
> }
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -2101,20 +2096,20 @@ static HRESULT WINAPI AudioClient_Reset(IAudioClient3 *iface)
>
> TRACE("(%p)\n", This);
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr)) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> if (This->started) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_NOT_STOPPED;
> }
>
> if (This->locked) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_BUFFER_OPERATION_PENDING;
> }
>
> @@ -2125,7 +2120,7 @@ static HRESULT WINAPI AudioClient_Reset(IAudioClient3 *iface)
> pa_operation *o = pa_stream_flush(This->stream, pulse_op_cb, &success);
> if (o) {
> while(pa_operation_get_state(o) == PA_OPERATION_RUNNING)
> - pthread_cond_wait(&pulse_cond, &pulse_lock);
> + pulse->cond_wait();
> pa_operation_unref(o);
> }
> }
> @@ -2144,7 +2139,7 @@ static HRESULT WINAPI AudioClient_Reset(IAudioClient3 *iface)
> }
> list_move_tail(&This->packet_free_head, &This->packet_filled_head);
> }
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> return hr;
> }
> @@ -2160,10 +2155,10 @@ static HRESULT WINAPI AudioClient_SetEventHandle(IAudioClient3 *iface,
> if (!event)
> return E_INVALIDARG;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr)) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -2173,7 +2168,7 @@ static HRESULT WINAPI AudioClient_SetEventHandle(IAudioClient3 *iface,
> hr = HRESULT_FROM_WIN32(ERROR_INVALID_NAME);
> else
> This->event = event;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -2189,9 +2184,9 @@ static HRESULT WINAPI AudioClient_GetService(IAudioClient3 *iface, REFIID riid,
> return E_POINTER;
> *ppv = NULL;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> if (FAILED(hr))
> return hr;
>
> @@ -2409,19 +2404,19 @@ static HRESULT WINAPI AudioRenderClient_GetBuffer(IAudioRenderClient *iface,
> return E_POINTER;
> *data = NULL;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr) || This->locked) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return FAILED(hr) ? hr : AUDCLNT_E_OUT_OF_ORDER;
> }
> if (!frames) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return S_OK;
> }
>
> if(This->held_bytes / pa_frame_size(&This->ss) + frames > This->bufsize_frames){
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_BUFFER_TOO_LARGE;
> }
>
> @@ -2437,7 +2432,7 @@ static HRESULT WINAPI AudioRenderClient_GetBuffer(IAudioRenderClient *iface,
>
> silence_buffer(This->ss.format, *data, bytes);
>
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> return hr;
> }
> @@ -2465,15 +2460,15 @@ static HRESULT WINAPI AudioRenderClient_ReleaseBuffer(
>
> TRACE("(%p)->(%u, %x)\n", This, written_frames, flags);
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> if (!This->locked || !written_frames) {
> This->locked = 0;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return written_frames ? AUDCLNT_E_OUT_OF_ORDER : S_OK;
> }
>
> if(written_frames * pa_frame_size(&This->ss) > (This->locked >= 0 ? This->locked : -This->locked)){
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_INVALID_SIZE;
> }
>
> @@ -2500,7 +2495,7 @@ static HRESULT WINAPI AudioRenderClient_ReleaseBuffer(
>
> TRACE("Released %u, held %zu\n", written_frames, This->held_bytes / pa_frame_size(&This->ss));
>
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> return S_OK;
> }
> @@ -2569,10 +2564,10 @@ static HRESULT WINAPI AudioCaptureClient_GetBuffer(IAudioCaptureClient *iface,
> if (!frames || !flags)
> return E_POINTER;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr) || This->locked) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return FAILED(hr) ? hr : AUDCLNT_E_OUT_OF_ORDER;
> }
>
> @@ -2595,7 +2590,7 @@ static HRESULT WINAPI AudioCaptureClient_GetBuffer(IAudioCaptureClient *iface,
> else
> *frames = 0;
> This->locked = *frames;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return *frames ? S_OK : AUDCLNT_S_BUFFER_EMPTY;
> }
>
> @@ -2606,13 +2601,13 @@ static HRESULT WINAPI AudioCaptureClient_ReleaseBuffer(
>
> TRACE("(%p)->(%u)\n", This, done);
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> if (!This->locked && done) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_OUT_OF_ORDER;
> }
> if (done && This->locked != done) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return AUDCLNT_E_INVALID_SIZE;
> }
> if (done) {
> @@ -2626,7 +2621,7 @@ static HRESULT WINAPI AudioCaptureClient_ReleaseBuffer(
> list_add_tail(&This->packet_free_head, &packet->entry);
> }
> This->locked = 0;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return S_OK;
> }
>
> @@ -2639,13 +2634,13 @@ static HRESULT WINAPI AudioCaptureClient_GetNextPacketSize(
> if (!frames)
> return E_POINTER;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> ACImpl_GetCapturePad(This, NULL);
> if (This->locked_ptr)
> *frames = This->period_bytes / pa_frame_size(&This->ss);
> else
> *frames = 0;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return S_OK;
> }
>
> @@ -2705,14 +2700,14 @@ static HRESULT WINAPI AudioClock_GetFrequency(IAudioClock *iface, UINT64 *freq)
>
> TRACE("(%p)->(%p)\n", This, freq);
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (SUCCEEDED(hr)) {
> *freq = This->ss.rate;
> if (This->share == AUDCLNT_SHAREMODE_SHARED)
> *freq *= pa_frame_size(&This->ss);
> }
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -2727,10 +2722,10 @@ static HRESULT WINAPI AudioClock_GetPosition(IAudioClock *iface, UINT64 *pos,
> if (!pos)
> return E_POINTER;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr)) {
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -2744,7 +2739,7 @@ static HRESULT WINAPI AudioClock_GetPosition(IAudioClock *iface, UINT64 *pos,
> *pos = This->clock_lastpos;
> else
> This->clock_lastpos = *pos;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> TRACE("%p Position: %u\n", This, (unsigned)*pos);
>
> @@ -2893,7 +2888,7 @@ static HRESULT WINAPI AudioStreamVolume_SetAllVolumes(
> if (count != This->ss.channels)
> return E_INVALIDARG;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr))
> goto out;
> @@ -2902,7 +2897,7 @@ static HRESULT WINAPI AudioStreamVolume_SetAllVolumes(
> This->vol[i] = levels[i];
>
> out:
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -2921,7 +2916,7 @@ static HRESULT WINAPI AudioStreamVolume_GetAllVolumes(
> if (count != This->ss.channels)
> return E_INVALIDARG;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> hr = pulse_stream_valid(This);
> if (FAILED(hr))
> goto out;
> @@ -2930,7 +2925,7 @@ static HRESULT WINAPI AudioStreamVolume_GetAllVolumes(
> levels[i] = This->vol[i];
>
> out:
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return hr;
> }
>
> @@ -3071,7 +3066,7 @@ static HRESULT WINAPI AudioSessionControl_GetState(IAudioSessionControl2 *iface,
> if (!state)
> return NULL_PTR_ERR;
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> if (list_empty(&This->session->clients)) {
> *state = AudioSessionStateExpired;
> goto out;
> @@ -3085,7 +3080,7 @@ static HRESULT WINAPI AudioSessionControl_GetState(IAudioSessionControl2 *iface,
> *state = AudioSessionStateInactive;
>
> out:
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return S_OK;
> }
>
> @@ -3460,9 +3455,9 @@ static HRESULT WINAPI SimpleAudioVolume_SetMasterVolume(
>
> TRACE("PulseAudio does not support session volume control\n");
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> session->master_vol = level;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> return S_OK;
> }
> @@ -3596,9 +3591,9 @@ static HRESULT WINAPI ChannelAudioVolume_SetChannelVolume(
>
> TRACE("PulseAudio does not support session volume control\n");
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> session->channel_vols[index] = level;
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
>
> return S_OK;
> }
> @@ -3644,10 +3639,10 @@ static HRESULT WINAPI ChannelAudioVolume_SetAllVolumes(
>
> TRACE("PulseAudio does not support session volume control\n");
>
> - pthread_mutex_lock(&pulse_lock);
> + pulse->lock();
> for(i = 0; i < count; ++i)
> session->channel_vols[i] = levels[i];
> - pthread_mutex_unlock(&pulse_lock);
> + pulse->unlock();
> return S_OK;
> }
>
> diff --git a/dlls/winepulse.drv/pulse.c b/dlls/winepulse.drv/pulse.c
> new file mode 100644
> index 00000000000..f6f2a45264e
> --- /dev/null
> +++ b/dlls/winepulse.drv/pulse.c
> @@ -0,0 +1,83 @@
> +/*
> + * Copyright 2011-2012 Maarten Lankhorst
> + * Copyright 2010-2011 Maarten Lankhorst for CodeWeavers
> + * Copyright 2011 Andrew Eikum for CodeWeavers
> + *
> + * This library is free software; you can redistribute it and/or
> + * modify it under the terms of the GNU Lesser General Public
> + * License as published by the Free Software Foundation; either
> + * version 2.1 of the License, or (at your option) any later version.
> + *
> + * This library is distributed in the hope that it will be useful,
> + * but WITHOUT ANY WARRANTY; without even the implied warranty of
> + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
> + * Lesser General Public License for more details.
> + *
> + * You should have received a copy of the GNU Lesser General Public
> + * License along with this library; if not, write to the Free Software
> + * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
> + */
> +
> +#if 0
> +#pragma makedep unix
> +#endif
> +
> +#include <stdarg.h>
> +#include <pthread.h>
> +
> +#include "ntstatus.h"
> +#define WIN32_NO_STATUS
> +#include "winternl.h"
> +
> +#include "unixlib.h"
> +
> +static pthread_mutex_t pulse_mutex;
> +static pthread_cond_t pulse_cond = PTHREAD_COND_INITIALIZER;
> +
> +static void WINAPI pulse_lock(void)
> +{
> + pthread_mutex_lock(&pulse_mutex);
> +}
> +
> +static void WINAPI pulse_unlock(void)
> +{
> + pthread_mutex_unlock(&pulse_mutex);
> +}
> +
> +static int WINAPI pulse_cond_wait(void)
> +{
> + return pthread_cond_wait(&pulse_cond, &pulse_mutex);
> +}
> +
> +static void WINAPI pulse_broadcast(void)
> +{
> + pthread_cond_broadcast(&pulse_cond);
> +}
> +
> +static const struct unix_funcs unix_funcs =
> +{
> + pulse_lock,
> + pulse_unlock,
> + pulse_cond_wait,
> + pulse_broadcast,
> +};
> +
> +NTSTATUS CDECL __wine_init_unix_lib(HMODULE module, DWORD reason, const void *ptr_in, void *ptr_out)
> +{
> + pthread_mutexattr_t attr;
> +
> + switch (reason)
> + {
> + case DLL_PROCESS_ATTACH:
> + pthread_mutexattr_init(&attr);
> + pthread_mutexattr_setprotocol(&attr, PTHREAD_PRIO_INHERIT);
> +
> + if (pthread_mutex_init(&pulse_mutex, &attr) != 0)
> + pthread_mutex_init(&pulse_mutex, NULL);
> +
> + *(const struct unix_funcs **)ptr_out = &unix_funcs;
> + break;
> + }
> +
> + return STATUS_SUCCESS;
> +}
> diff --git a/dlls/winepulse.drv/unixlib.h b/dlls/winepulse.drv/unixlib.h
> new file mode 100644
> index 00000000000..97595ed3cee
> --- /dev/null
> +++ b/dlls/winepulse.drv/unixlib.h
> @@ -0,0 +1,25 @@
> +/*
> + * Copyright 2021 Jacek Caban for CodeWeavers
> + *
> + * This library is free software; you can redistribute it and/or
> + * modify it under the terms of the GNU Lesser General Public
> + * License as published by the Free Software Foundation; either
> + * version 2.1 of the License, or (at your option) any later version.
> + *
> + * This library is distributed in the hope that it will be useful,
> + * but WITHOUT ANY WARRANTY; without even the implied warranty of
> + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
> + * Lesser General Public License for more details.
> + *
> + * You should have received a copy of the GNU Lesser General Public
> + * License along with this library; if not, write to the Free Software
> + * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
> + */
> +
> +struct unix_funcs
> +{
> + void (WINAPI *lock)(void);
> + void (WINAPI *unlock)(void);
> + int (WINAPI *cond_wait)(void);
> + void (WINAPI *broadcast)(void);
> +};
>
More information about the wine-devel
mailing list