Piotr Caban : msvcr100: Add reader_writer_lock tests.

[Alexandre Julliard]

Module: wine
Branch: master
Commit: 00475e1dfd56caa47e5f2b5670e77301f07d89aa
URL:    http://source.winehq.org/git/wine.git/?a=commit;h=00475e1dfd56caa47e5f2b5670e77301f07d89aa

Author: Piotr Caban <piotr at codeweavers.com>
Date:   Thu Jan 26 17:30:45 2017 +0100

msvcr100: Add reader_writer_lock tests.

Signed-off-by: Piotr Caban <piotr at codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard at winehq.org>

---

 dlls/msvcr100/tests/msvcr100.c | 84 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 84 insertions(+)

diff --git a/dlls/msvcr100/tests/msvcr100.c b/dlls/msvcr100/tests/msvcr100.c
index 4c66ed5..045d698 100644
--- a/dlls/msvcr100/tests/msvcr100.c
+++ b/dlls/msvcr100/tests/msvcr100.c
@@ -155,6 +155,14 @@ static void (__thiscall *pSpinWait__SetSpinCount)(SpinWait*, unsigned int);
 static MSVCRT_bool (__thiscall *pSpinWait__ShouldSpinAgain)(SpinWait*);
 static MSVCRT_bool (__thiscall *pSpinWait__SpinOnce)(SpinWait*);
 
+static void* (__thiscall *preader_writer_lock_ctor)(void*);
+static void (__thiscall *preader_writer_lock_dtor)(void*);
+static void (__thiscall *preader_writer_lock_lock)(void*);
+static void (__thiscall *preader_writer_lock_lock_read)(void*);
+static void (__thiscall *preader_writer_lock_unlock)(void*);
+static MSVCRT_bool (__thiscall *preader_writer_lock_try_lock)(void*);
+static MSVCRT_bool (__thiscall *preader_writer_lock_try_lock_read)(void*);
+
 /* make sure we use the correct errno */
 #undef errno
 #define errno (*p_errno())
@@ -195,6 +203,14 @@ static BOOL init(void)
         SET(pSpinWait__SetSpinCount, "?_SetSpinCount@?$_SpinWait@$00 at details@Concurrency@@QEAAXI at Z");
         SET(pSpinWait__ShouldSpinAgain, "?_ShouldSpinAgain@?$_SpinWait@$00 at details@Concurrency@@IEAA_NXZ");
         SET(pSpinWait__SpinOnce, "?_SpinOnce@?$_SpinWait@$00 at details@Concurrency@@QEAA_NXZ");
+
+        SET(preader_writer_lock_ctor, "??0reader_writer_lock at Concurrency@@QEAA at XZ");
+        SET(preader_writer_lock_dtor, "??1reader_writer_lock at Concurrency@@QEAA at XZ");
+        SET(preader_writer_lock_lock, "?lock at reader_writer_lock@Concurrency@@QEAAXXZ");
+        SET(preader_writer_lock_lock_read, "?lock_read at reader_writer_lock@Concurrency@@QEAAXXZ");
+        SET(preader_writer_lock_unlock, "?unlock at reader_writer_lock@Concurrency@@QEAAXXZ");
+        SET(preader_writer_lock_try_lock, "?try_lock at reader_writer_lock@Concurrency@@QEAA_NXZ");
+        SET(preader_writer_lock_try_lock_read, "?try_lock_read at reader_writer_lock@Concurrency@@QEAA_NXZ");
     } else {
         SET(pSpinWait_ctor_yield, "??0?$_SpinWait@$00 at details@Concurrency@@QAE at P6AXXZ@Z");
         SET(pSpinWait_dtor, "??_F?$_SpinWait@$00 at details@Concurrency@@QAEXXZ");
@@ -203,6 +219,14 @@ static BOOL init(void)
         SET(pSpinWait__SetSpinCount, "?_SetSpinCount@?$_SpinWait@$00 at details@Concurrency@@QAEXI at Z");
         SET(pSpinWait__ShouldSpinAgain, "?_ShouldSpinAgain@?$_SpinWait@$00 at details@Concurrency@@IAE_NXZ");
         SET(pSpinWait__SpinOnce, "?_SpinOnce@?$_SpinWait@$00 at details@Concurrency@@QAE_NXZ");
+
+        SET(preader_writer_lock_ctor, "??0reader_writer_lock at Concurrency@@QAE at XZ");
+        SET(preader_writer_lock_dtor, "??1reader_writer_lock at Concurrency@@QAE at XZ");
+        SET(preader_writer_lock_lock, "?lock at reader_writer_lock@Concurrency@@QAEXXZ");
+        SET(preader_writer_lock_lock_read, "?lock_read at reader_writer_lock@Concurrency@@QAEXXZ");
+        SET(preader_writer_lock_unlock, "?unlock at reader_writer_lock@Concurrency@@QAEXXZ");
+        SET(preader_writer_lock_try_lock, "?try_lock at reader_writer_lock@Concurrency@@QAE_NXZ");
+        SET(preader_writer_lock_try_lock_read, "?try_lock_read at reader_writer_lock@Concurrency@@QAE_NXZ");
     }
 
     init_thiscall_thunk();
@@ -557,6 +581,65 @@ static void test__SpinWait(void)
     call_func1(pSpinWait_dtor, &sp);
 }
 
+static DWORD WINAPI lock_read_thread(void *rw_lock)
+{
+    return (MSVCRT_bool)call_func1(preader_writer_lock_try_lock_read, rw_lock);
+}
+
+static void test_reader_writer_lock(void)
+{
+    /* define reader_writer_lock data big enough to hold every version of structure */
+    char rw_lock[100];
+    MSVCRT_bool ret;
+    HANDLE thread;
+    DWORD d;
+
+    call_func1(preader_writer_lock_ctor, rw_lock);
+
+    ret = call_func1(preader_writer_lock_try_lock, rw_lock);
+    ok(ret, "reader_writer_lock:try_lock returned %x\n", ret);
+    ret = call_func1(preader_writer_lock_try_lock, rw_lock);
+    ok(!ret, "reader_writer_lock:try_lock returned %x\n", ret);
+    ret = call_func1(preader_writer_lock_try_lock_read, rw_lock);
+    ok(!ret, "reader_writer_lock:try_lock_read returned %x\n", ret);
+    call_func1(preader_writer_lock_unlock, rw_lock);
+
+    /* test lock for read on already locked section */
+    ret = call_func1(preader_writer_lock_try_lock_read, rw_lock);
+    ok(ret, "reader_writer_lock:try_lock_read returned %x\n", ret);
+    ret = call_func1(preader_writer_lock_try_lock_read, rw_lock);
+    ok(ret, "reader_writer_lock:try_lock_read returned %x\n", ret);
+    ret = call_func1(preader_writer_lock_try_lock, rw_lock);
+    ok(!ret, "reader_writer_lock:try_lock returned %x\n", ret);
+    call_func1(preader_writer_lock_unlock, rw_lock);
+    ret = call_func1(preader_writer_lock_try_lock, rw_lock);
+    ok(!ret, "reader_writer_lock:try_lock returned %x\n", ret);
+    call_func1(preader_writer_lock_unlock, rw_lock);
+    ret = call_func1(preader_writer_lock_try_lock, rw_lock);
+    ok(ret, "reader_writer_lock:try_lock returned %x\n", ret);
+    call_func1(preader_writer_lock_unlock, rw_lock);
+
+    call_func1(preader_writer_lock_lock, rw_lock);
+    thread = CreateThread(NULL, 0, lock_read_thread, rw_lock, 0, NULL);
+    ok(thread != NULL, "CreateThread failed: %d\n", GetLastError());
+    WaitForSingleObject(thread, INFINITE);
+    ok(GetExitCodeThread(thread, &d), "GetExitCodeThread failed\n");
+    ok(!d, "reader_writer_lock::try_lock_read succeeded on already locked object\n");
+    CloseHandle(thread);
+    call_func1(preader_writer_lock_unlock, rw_lock);
+
+    call_func1(preader_writer_lock_lock_read, rw_lock);
+    thread = CreateThread(NULL, 0, lock_read_thread, rw_lock, 0, NULL);
+    ok(thread != NULL, "CreateThread failed: %d\n", GetLastError());
+    WaitForSingleObject(thread, INFINITE);
+    ok(GetExitCodeThread(thread, &d), "GetExitCodeThread failed\n");
+    ok(d, "reader_writer_lock::try_lock_read failed on object locked for reading\n");
+    CloseHandle(thread);
+    call_func1(preader_writer_lock_unlock, rw_lock);
+
+    call_func1(preader_writer_lock_dtor, rw_lock);
+}
+
 START_TEST(msvcr100)
 {
     if (!init())
@@ -568,4 +651,5 @@ START_TEST(msvcr100)
     test__aligned_msize();
     test_atoi();
     test__SpinWait();
+    test_reader_writer_lock();
 }