Testing failed CI test for MacOS

Author: sadko4u

src/main/ipc/SharedMutex.cpp

@@ -496,7 +496,10 @@ namespace lsp
             // Check that we don't lock the mutex again
             const thread_id_t tid = Thread::current_thread_id();
             if (atomic_load(&nOwner) == tid)
+            {
+                lsp_warn("Already locked mutex");
                 return STATUS_LOCKED;
+            }
 
         #ifdef PLATFORM_WINDOWS
             DWORD res = WaitForSingleObject(hLock, delay);
@@ -536,7 +539,9 @@ namespace lsp
             {
                 case 0: break;
                 case EDEADLK: return STATUS_BAD_STATE;
-                case EBUSY: return STATUS_LOCKED;
+                case EBUSY:
+                    lsp_warn("got EBUSY error");
+                    return STATUS_LOCKED;
                 case ETIMEDOUT: return STATUS_TIMED_OUT;
                 case EOWNERDEAD:
                 {

src/test/utest/ipc/shmutex.cpp

@@ -42,7 +42,10 @@ UTEST_BEGIN("runtime.ipc", shmutex)
 
             data.append_ascii(event);
             data.append('=');
-            data.append_ascii((code == expected) ? "true" : "false");
+            if (code == expected)
+                data.append_ascii("true");
+            else
+                data.fmt_append_ascii("false(code=%d)", int(code));
             data.append(';');
         }
     } context_t;
@@ -55,9 +58,9 @@ UTEST_BEGIN("runtime.ipc", shmutex)
 
         ipc::Thread::sleep(500);
         ctx->log(mutex.open("test-lsp.lock"), "open1", STATUS_OK);
-        ctx->log(mutex.lock(), "SYNC1", STATUS_OK);
-        ipc::Thread::sleep(800);
-        ctx->log(mutex.unlock(), "SYNC2", STATUS_OK);
+        ctx->log(mutex.lock(), "SYNC1.lock", STATUS_OK);
+        ipc::Thread::sleep(1600);
+        ctx->log(mutex.unlock(), "SYNC2.unlock", STATUS_OK);
 
         return STATUS_OK;
     }
@@ -72,15 +75,15 @@ UTEST_BEGIN("runtime.ipc", shmutex)
 
         ipc::Thread::sleep(500);
 
-        ctx->log(mutex.unlock(), "SYNC1", STATUS_OK);
+        ctx->log(mutex.unlock(), "SYNC1.unlock", STATUS_OK);
 
         ipc::Thread::sleep(100);
 
         ctx->log(mutex.try_lock(), "trylock2", STATUS_RETRY);
-        ctx->log(mutex.lock(500), "timedlock2", STATUS_TIMED_OUT);
-        ctx->log(mutex.lock(500), "SYNC2", STATUS_OK);
+        ctx->log(mutex.lock(1000), "timedlock2", STATUS_TIMED_OUT);
+        ctx->log(mutex.lock(1000), "SYNC2.lock", STATUS_OK);
         ipc::Thread::sleep(200);
-        ctx->log(mutex.unlock(), "SYNC3", STATUS_OK);
+        ctx->log(mutex.unlock(), "SYNC3.unlock", STATUS_OK);
 
         return STATUS_OK;
     }
@@ -141,17 +144,17 @@ UTEST_BEGIN("runtime.ipc", shmutex)
         ctx.log(STATUS_OK, "unlock", STATUS_OK);
         UTEST_ASSERT(mutex.unlock() == STATUS_OK);
 
-        ipc::Thread::sleep(2000);
-        ctx.log(mutex.lock(), "SYNC3", STATUS_OK);
+        ipc::Thread::sleep(2800);
+        ctx.log(mutex.lock(), "SYNC3.lock", STATUS_OK);
         ctx.log(mutex.unlock(), "unlock", STATUS_OK);
 
         ctx.log(mutex.close(), "close", STATUS_OK);
 
         static const char *expected =
             "open=true;lock=true;start=true;sleep=true;open2=true;unlock=true;lock2=true;open1=true;"
-            "SYNC1=true;SYNC1=true;trylock2=true;timedlock2=true;"
-            "SYNC2=true;SYNC2=true;"
-            "SYNC3=true;SYNC3=true;unlock=true;close=true;";
+            "SYNC1.unlock=true;SYNC1.lock=true;trylock2=true;timedlock2=true;"
+            "SYNC2.unlock=true;SYNC2.lock=true;"
+            "SYNC3.unlock=true;SYNC3.lock=true;unlock=true;close=true;";
 
         printf("Result content:   %s\n", ctx.data.get_ascii());
         printf("Expected content: %s\n", expected);