]> pd.if.org Git - pdclib.old/blobdiff - platform/win32/functions/threads/mtx_lock.c
win32: Fix warnings relating to definition of LONG and use of InterlockedCompareExchange
[pdclib.old] / platform / win32 / functions / threads / mtx_lock.c
index 70af8ae35bd7cd65c7785527544d7cf7778e2776..d16a487b70d26622cb6f6b6eb2dec2340d04e891 100644 (file)
@@ -6,26 +6,20 @@ int mtx_lock(mtx_t *mtx)
 {\r
     DWORD myId = GetCurrentThreadId();\r
 \r
-    if(mtx->_ThreadId == myId) {\r
+    if(mtx->_ThreadId == (long) myId) {\r
         mtx->_NestCount++;\r
         return thrd_success;\r
     }\r
 \r
-    DWORD res = InterlockedIncrement(&mtx->_State);\r
-    if(res == 0) {\r
-        mtx->_ThreadId = myId;\r
-        return thrd_success;\r
-    }\r
+    for(;;) {\r
+        LONG prev = InterlockedCompareExchange(&mtx->_ThreadId, myId, 0);\r
+        if(prev == 0)\r
+            return thrd_success;\r
 \r
-    // If that increment didn't leave the state == 0, then we have contention\r
-    //  -> block on the wait event handle\r
-    DWORD rv = WaitForSingleObject(mtx->_WaitEvHandle, INFINITE);\r
-    if(rv != WAIT_OBJECT_0) \r
-        return thrd_error;\r
-\r
-    // We now own the mutex - so set it up for our use\r
-    mtx->_ThreadId = myId;\r
-    return thrd_success;\r
+        DWORD rv = WaitForSingleObject(mtx->_WaitEvHandle, INFINITE);\r
+        if(rv != WAIT_OBJECT_0)\r
+            return thrd_error;\r
+    }\r
 }\r
 #endif\r
 \r