Valve/Proton
1
0
Fork 0
mirror of https://github.com/ValveSoftware/Proton.git synced 2025-03-15 15:00:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

fixup! lsteamclient: Execute SteamNetworkingSocketsDebugOutput callback from a Wine thread.

Browse Source
This commit is contained in:
Paul Gofman 2022-05-25 14:30:03 -05:00 committed by Paul Gofman
parent e25a701aba
commit 7421ad04b8
1 changed files with 30 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
lsteamclient/steamclient_main.c
View File

@ -32,7 +32,15 @@ static CRITICAL_SECTION steamclient_cs = { NULL, -1, 0, 0, 0, 0 };
static HANDLE steam_overlay_event; static HANDLE steam_overlay_event;
static HANDLE callback_thread_handle; static HANDLE callback_thread_handle;
static void callback_queue_finish(void); #define MAX_CALLBACK_QUEUE_SIZE 4
struct callback_data *callback_queue[MAX_CALLBACK_QUEUE_SIZE];
static unsigned int callback_queue_size;
static BOOL callback_queue_done;
static UINT64 callback_queue_current_seq_number;
static pthread_mutex_t callback_queue_mutex;
static pthread_cond_t callback_queue_callback_event;
static pthread_cond_t callback_queue_ready_event;
static pthread_cond_t callback_queue_complete_event;
BOOL WINAPI DllMain(HINSTANCE instance, DWORD reason, void *reserved) BOOL WINAPI DllMain(HINSTANCE instance, DWORD reason, void *reserved)
{ {
@ -45,11 +53,22 @@ BOOL WINAPI DllMain(HINSTANCE instance, DWORD reason, void *reserved)
steam_overlay_event = CreateEventA(NULL, TRUE, FALSE, "__wine_steamclient_GameOverlayActivated"); steam_overlay_event = CreateEventA(NULL, TRUE, FALSE, "__wine_steamclient_GameOverlayActivated");
break; break;
case DLL_PROCESS_DETACH: case DLL_PROCESS_DETACH:
callback_queue_finish(); if (callback_thread_handle)
TRACE("Waiting for callback thread.\n"); {
WaitForSingleObject(callback_thread_handle, INFINITE); /* Unfortunately we don't have a clear place to shutdown the thread so just kill it. */
TRACE("Queue thread finished.\n"); /* An explicit sync events and handle cleanup is to protect from unloading and loading
CloseHandle(callback_thread_handle); * .so again which may end up not actually reloading anyting and leaving the values of our static
* variables. */
TerminateThread(callback_thread_handle, -1);
WaitForSingleObject(callback_thread_handle, INFINITE);
pthread_mutex_destroy(&callback_queue_mutex);
pthread_cond_destroy(&callback_queue_callback_event);
pthread_cond_destroy(&callback_queue_ready_event);
pthread_cond_destroy(&callback_queue_complete_event);
CloseHandle(callback_thread_handle);
callback_thread_handle = NULL;
TRACE("Terminated callback thread.\n");
}
CloseHandle(steam_overlay_event); CloseHandle(steam_overlay_event);
break; break;
} }
@ -583,16 +602,6 @@ done:
return ret; return ret;
} }
#define MAX_CALLBACK_QUEUE_SIZE 4
struct callback_data *callback_queue[MAX_CALLBACK_QUEUE_SIZE];
static unsigned int callback_queue_size;
static BOOL callback_queue_done;
static UINT64 callback_queue_current_seq_number;
static pthread_mutex_t callback_queue_mutex = PTHREAD_MUTEX_INITIALIZER;
static pthread_cond_t callback_queue_callback_event = PTHREAD_COND_INITIALIZER;
static pthread_cond_t callback_queue_ready_event = PTHREAD_COND_INITIALIZER;
static pthread_cond_t callback_queue_complete_event = PTHREAD_COND_INITIALIZER;
void execute_callback(struct callback_data *cb_data) void execute_callback(struct callback_data *cb_data)
{ {
/* No TRACEs or other Wine calls here, this is executed from Unix native thread /* No TRACEs or other Wine calls here, this is executed from Unix native thread
@ -643,16 +652,6 @@ static void callback_complete(UINT64 cookie)
pthread_mutex_unlock(&callback_queue_mutex); pthread_mutex_unlock(&callback_queue_mutex);
} }
static void callback_queue_finish(void)
{
pthread_mutex_lock(&callback_queue_mutex);
callback_queue_done = TRUE;
pthread_cond_broadcast(&callback_queue_callback_event);
pthread_cond_broadcast(&callback_queue_ready_event);
pthread_cond_broadcast(&callback_queue_complete_event);
pthread_mutex_unlock(&callback_queue_mutex);
}
typedef void (WINAPI *win_FSteamNetworkingSocketsDebugOutput)(ESteamNetworkingSocketsDebugOutputType nType, typedef void (WINAPI *win_FSteamNetworkingSocketsDebugOutput)(ESteamNetworkingSocketsDebugOutputType nType,
const char *pszMsg); const char *pszMsg);
@ -752,6 +751,11 @@ static int load_steamclient(void)
return 0; return 0;
} }
pthread_mutex_init(&callback_queue_mutex, NULL);
pthread_cond_init(&callback_queue_callback_event, NULL);
pthread_cond_init(&callback_queue_ready_event, NULL);
pthread_cond_init(&callback_queue_complete_event, NULL);
callback_thread_handle = CreateThread(NULL, 0, callback_thread, NULL, 0, &callback_thread_id); callback_thread_handle = CreateThread(NULL, 0, callback_thread, NULL, 0, &callback_thread_id);
TRACE("Created callback thread 0x%04x.\n", callback_thread_id); TRACE("Created callback thread 0x%04x.\n", callback_thread_id);