moonlight-stream/moonlight-common-c
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-common-c.git synced 2026-06-17 06:11:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Track leaks of mutexes and events for debugging

Browse Source
This commit is contained in:
Cameron Gutman
2019-03-17 02:23:32 -07:00
parent 71a69204e9
commit c9745855fd
1 changed files with 18 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Platform.c
+18 -11
View File
@@ -14,7 +14,9 @@ struct thread_context {
#endif #endif
}; };
static int running_threads = 0; static int activeThreads = 0;
static int activeMutexes = 0;
static int activeEvents = 0;
#if defined(LC_WINDOWS) #if defined(LC_WINDOWS)
DWORD WINAPI ThreadProc(LPVOID lpParameter) { DWORD WINAPI ThreadProc(LPVOID lpParameter) {
@@ -59,19 +61,23 @@ int PltCreateMutex(PLT_MUTEX* mutex) {
if (!*mutex) { if (!*mutex) {
return -1; return -1;
} }
return 0;
#elif defined(__vita__) #elif defined(__vita__)
*mutex = sceKernelCreateMutex("", 0, 0, NULL); *mutex = sceKernelCreateMutex("", 0, 0, NULL);
if (*mutex < 0) { if (*mutex < 0) {
return -1; return -1;
} }
return 0;
#else #else
return pthread_mutex_init(mutex, NULL); int err = pthread_mutex_init(mutex, NULL);
if (err != 0) {
return err;
}
#endif #endif
activeMutexes++;
return 0;
} }
void PltDeleteMutex(PLT_MUTEX* mutex) { void PltDeleteMutex(PLT_MUTEX* mutex) {
activeMutexes--;
#if defined(LC_WINDOWS) #if defined(LC_WINDOWS)
CloseHandle(*mutex); CloseHandle(*mutex);
#elif defined(__vita__) #elif defined(__vita__)
@@ -121,7 +127,7 @@ void PltJoinThread(PLT_THREAD* thread) {
} }
void PltCloseThread(PLT_THREAD* thread) { void PltCloseThread(PLT_THREAD* thread) {
running_threads--; activeThreads--;
#if defined(LC_WINDOWS) #if defined(LC_WINDOWS)
CloseHandle(thread->handle); CloseHandle(thread->handle);
#elif defined(__vita__) #elif defined(__vita__)
@@ -180,7 +186,7 @@ int PltCreateThread(ThreadEntry entry, void* context, PLT_THREAD* thread) {
} }
#endif #endif
running_threads++; activeThreads++;
return 0; return 0;
} }
@@ -191,8 +197,6 @@ int PltCreateEvent(PLT_EVENT* event) {
if (!*event) { if (!*event) {
return -1; return -1;
} }
return 0;
#elif defined(__vita__) #elif defined(__vita__)
event->mutex = sceKernelCreateMutex("", 0, 0, NULL); event->mutex = sceKernelCreateMutex("", 0, 0, NULL);
if (event->mutex < 0) { if (event->mutex < 0) {
@@ -204,16 +208,17 @@ int PltCreateEvent(PLT_EVENT* event) {
return -1; return -1;
} }
event->signalled = 0; event->signalled = 0;
return 0;
#else #else
pthread_mutex_init(&event->mutex, NULL); pthread_mutex_init(&event->mutex, NULL);
pthread_cond_init(&event->cond, NULL); pthread_cond_init(&event->cond, NULL);
event->signalled = 0; event->signalled = 0;
return 0;
#endif #endif
activeEvents++;
return 0;
} }
void PltCloseEvent(PLT_EVENT* event) { void PltCloseEvent(PLT_EVENT* event) {
activeEvents--;
#if defined(LC_WINDOWS) #if defined(LC_WINDOWS)
CloseHandle(*event); CloseHandle(*event);
#elif defined(__vita__) #elif defined(__vita__)
@@ -319,5 +324,7 @@ void cleanupPlatform(void) {
enet_deinitialize(); enet_deinitialize();
LC_ASSERT(running_threads == 0); LC_ASSERT(activeThreads == 0);
LC_ASSERT(activeMutexes == 0);
LC_ASSERT(activeEvents == 0);
} }