[PATCH v5 1/4] winepulse: Move main loop logic into mmdevapi.

[Davide Beatrici]

From: Davide Beatrici

---
 dlls/mmdevapi/client.c           | 40 ++++++++++++++++++++++++++++++++
 dlls/mmdevapi/main.c             |  2 ++
 dlls/mmdevapi/mmdevapi_private.h |  2 ++
 dlls/winepulse.drv/mmdevdrv.c    | 33 +++++---------------------
 4 files changed, 50 insertions(+), 27 deletions(-)

diff --git a/dlls/mmdevapi/client.c b/dlls/mmdevapi/client.c
index 03bfbabd536..01542f434a8 100644
--- a/dlls/mmdevapi/client.c
+++ b/dlls/mmdevapi/client.c
@@ -38,6 +38,16 @@ extern void sessions_unlock(void) DECLSPEC_HIDDEN;

extern struct audio_session_wrapper *session_wrapper_create(struct audio_client *client) DECLSPEC_HIDDEN;

+static HANDLE main_loop_thread;
+
+void main_loop_stop(void)
+{
+    if (main_loop_thread) {
+        WaitForSingleObject(main_loop_thread, INFINITE);
+        CloseHandle(main_loop_thread);
+    }
+}
+
 void set_stream_volumes(struct audio_client *This)
 {
     struct set_volumes_params params;
@@ -114,6 +124,36 @@ static void dump_fmt(const WAVEFORMATEX *fmt)
     }
 }

+static DWORD CALLBACK main_loop_func(void *event)
+{
+    struct main_loop_params params;
+
+    SetThreadDescription(GetCurrentThread(), L"audio_client_main");
+
+    params.event = event;
+
+    WINE_UNIX_CALL(main_loop, &params);
+
+    return 0;
+}
+
+HRESULT main_loop_start(void)
+{
+    if (!main_loop_thread) {
+        HANDLE event = CreateEventW(NULL, TRUE, FALSE, NULL);
+        if (!(main_loop_thread = CreateThread(NULL, 0, main_loop_func, event, 0, NULL))) {
+            CloseHandle(event);
+            return E_FAIL;
+        }
+
+        SetThreadPriority(main_loop_thread, THREAD_PRIORITY_TIME_CRITICAL);
+        WaitForSingleObject(event, INFINITE);
+        CloseHandle(event);
+    }
+
+    return S_OK;
+}
+
 static DWORD CALLBACK timer_loop_func(void *user)
 {
     struct timer_loop_params params;
diff --git a/dlls/mmdevapi/main.c b/dlls/mmdevapi/main.c
index d3d4ec6a905..676bc53d68d 100644
--- a/dlls/mmdevapi/main.c
+++ b/dlls/mmdevapi/main.c
@@ -196,6 +196,8 @@ BOOL WINAPI DllMain(HINSTANCE hinstDLL, DWORD fdwReason, LPVOID lpvReserved)
             DisableThreadLibraryCalls(hinstDLL);
             break;
         case DLL_PROCESS_DETACH:
+            main_loop_stop();
+
             if (drvs.module_unixlib) {
                 const NTSTATUS status = __wine_unix_call(drvs.module_unixlib, process_detach, NULL);
                 if (status)
diff --git a/dlls/mmdevapi/mmdevapi_private.h b/dlls/mmdevapi/mmdevapi_private.h
index 684d303eefb..5abde115951 100644
--- a/dlls/mmdevapi/mmdevapi_private.h
+++ b/dlls/mmdevapi/mmdevapi_private.h
@@ -80,4 +80,6 @@ extern HRESULT SpatialAudioClient_Create(IMMDevice *device, ISpatialAudioClient
 extern HRESULT load_devices_from_reg(void) DECLSPEC_HIDDEN;
 extern HRESULT load_driver_devices(EDataFlow flow) DECLSPEC_HIDDEN;

+extern void main_loop_stop(void) DECLSPEC_HIDDEN;
+
 extern const WCHAR drv_keyW[] DECLSPEC_HIDDEN;
diff --git a/dlls/winepulse.drv/mmdevdrv.c b/dlls/winepulse.drv/mmdevdrv.c
index 12e36fae827..60a660dcf8b 100644
--- a/dlls/winepulse.drv/mmdevdrv.c
+++ b/dlls/winepulse.drv/mmdevdrv.c
@@ -56,7 +56,6 @@ WINE_DEFAULT_DEBUG_CHANNEL(pulse);

#define NULL_PTR_ERR MAKE_HRESULT(SEVERITY_ERROR, FACILITY_WIN32, RPC_X_NULL_REF_POINTER)

-static HANDLE pulse_thread;
 static struct list g_sessions = LIST_INIT(g_sessions);
 static struct list g_devices_cache = LIST_INIT(g_devices_cache);

@@ -115,11 +114,6 @@ BOOL WINAPI DllMain(HINSTANCE dll, DWORD reason, void *reserved)

LIST_FOR_EACH_ENTRY_SAFE(device, device_next, &g_devices_cache, struct device_cache, entry)
             free(device);
-
-        if (pulse_thread) {
-            WaitForSingleObject(pulse_thread, INFINITE);
-            CloseHandle(pulse_thread);
-        }
     }
     return TRUE;
 }
@@ -134,6 +128,8 @@ extern const IAudioClockVtbl AudioClock_Vtbl;
 extern const IAudioClock2Vtbl AudioClock2_Vtbl;
 extern const IAudioStreamVolumeVtbl AudioStreamVolume_Vtbl;

+extern HRESULT main_loop_start(void) DECLSPEC_HIDDEN;
+
 extern struct audio_session_wrapper *session_wrapper_create(
     struct audio_client *client) DECLSPEC_HIDDEN;

@@ -157,15 +153,6 @@ static void pulse_release_stream(stream_handle stream, HANDLE timer)
     pulse_call(release_stream, &params);
 }

-static DWORD CALLBACK pulse_mainloop_thread(void *event)
-{
-    struct main_loop_params params;
-    params.event = event;
-    SetThreadDescription(GetCurrentThread(), L"winepulse_mainloop");
-    pulse_call(main_loop, &params);
-    return 0;
-}
-
 typedef struct tagLANGANDCODEPAGE
 {
     WORD wLanguage;
@@ -735,19 +722,11 @@ static HRESULT WINAPI AudioClient_Initialize(IAudioClient3 *iface,
         return AUDCLNT_E_ALREADY_INITIALIZED;
     }

-    if (!pulse_thread)
+    if (FAILED(hr = main_loop_start()))
     {
-        HANDLE event = CreateEventW(NULL, TRUE, FALSE, NULL);
-        if (!(pulse_thread = CreateThread(NULL, 0, pulse_mainloop_thread, event, 0, NULL)))
-        {
-            ERR("Failed to create mainloop thread.\n");
-            sessions_unlock();
-            CloseHandle(event);
-            return E_FAIL;
-        }
-        SetThreadPriority(pulse_thread, THREAD_PRIORITY_TIME_CRITICAL);
-        WaitForSingleObject(event, INFINITE);
-        CloseHandle(event);
+        ERR("Failed to create mainloop thread.\n");
+        sessions_unlock();
+        return hr;
     }

params.name = name = get_application_name(TRUE);