Piotr Caban : msvcr100: Use Context blocking functions in Concurrency::wait().

[Alexandre Julliard]

Module: wine
Branch: master
Commit: 01c3f4dc65338c265a82d1fe61f1feb462c28ef6
URL:    https://gitlab.winehq.org/wine/wine/-/commit/01c3f4dc65338c265a82d1fe61f1feb...

Author: Piotr Caban 
Date:   Mon Jun  5 21:07:14 2023 +0200

msvcr100: Use Context blocking functions in Concurrency::wait().

---

dlls/msvcrt/concurrency.c | 25 ++++++++++++++++++++++---
 1 file changed, 22 insertions(+), 3 deletions(-)

diff --git a/dlls/msvcrt/concurrency.c b/dlls/msvcrt/concurrency.c
index d30faf34681..66adef1fa6d 100644
--- a/dlls/msvcrt/concurrency.c
+++ b/dlls/msvcrt/concurrency.c
@@ -3459,14 +3459,33 @@ bool __thiscall _ReentrantBlockingLock__TryAcquire(_ReentrantBlockingLock *this)
     return TryEnterCriticalSection(&this->cs);
 }

+static void WINAPI wait_timeout(TP_CALLBACK_INSTANCE *instance, void *arg, TP_TIMER *timer)
+{
+    Context *ctx = arg;
+
+    call_Context_Unblock(ctx);
+}
+
 /* ?wait@Concurrency@@YAXI@Z */
 void __cdecl Concurrency_wait(unsigned int time)
 {
-    static int once;
+    Context *ctx = get_current_context();
+    TP_TIMER *tp_timer;
+    FILETIME ft;

-    if (!once++) FIXME("(%d) stub!\n", time);
+    TRACE("(%d)\n", time);

-    Sleep(time);
+    tp_timer = CreateThreadpoolTimer(wait_timeout, ctx, NULL);
+    if(!tp_timer) {
+        FIXME("throw exception?\n");
+        Sleep(time);
+        return;
+    }
+    set_timeout(&ft, time);
+    SetThreadpoolTimer(tp_timer, &ft, 0, 0);
+
+    call_Context_Block(ctx);
+    CloseThreadpoolTimer(tp_timer);
 }

#if _MSVCR_VER>=110