Changeset 19895 in vbox for trunk/src/VBox/HostDrivers/Support

Timestamp:

May 21, 2009 3:58:48 PM (16 years ago)

Author:

vboxsync

svn:sync-xref-src-repo-rev:

47590

Message:

tstSupSem.cpp: Extended it to cover interruptibility.

File:

• trunk/src/VBox/HostDrivers/Support/testcase/tstSupSem.cpp (modified) (6 diffs)

trunk/src/VBox/HostDrivers/Support/testcase/tstSupSem.cpp

@@ -36 +36 @@
 
 #include <VBox/param.h>
+#include <iprt/err.h>
 #include <iprt/initterm.h>
+#include <iprt/stream.h>
 #include <iprt/test.h>
-#include <iprt/stream.h>
-#include <iprt/string.h>
+#include <iprt/thread.h>
+
+
+/*******************************************************************************
+*   Structures and Typedefs                                                    *
+*******************************************************************************/
+static PSUPDRVSESSION   g_pSession;
+static RTTEST           g_hTest;
+
+
+
+static DECLCALLBACK(int) tstSupSemInterruptibleSRE(RTTHREAD hSelf, void *pvUser)
+{
+    SUPSEMEVENT hEvent = (SUPSEMEVENT)pvUser;
+    RTThreadUserSignal(hSelf);
+    return SUPSemEventWaitNoResume(g_pSession, hEvent, RT_INDEFINITE_WAIT);
+}
+
+
+static DECLCALLBACK(int) tstSupSemInterruptibleMRE(RTTHREAD hSelf, void *pvUser)
+{
+    SUPSEMEVENTMULTI hEventMulti = (SUPSEMEVENTMULTI)pvUser;
+    RTThreadUserSignal(hSelf);
+    return SUPSemEventMultiWaitNoResume(g_pSession, hEventMulti, RT_INDEFINITE_WAIT);
+}
 
 
@@ -53 +78 @@
         return 1;
     }
+
     RTTEST hTest;
     rc = RTTestCreate("tstSupSem", &hTest);
@@ -60 +86 @@
         return 1;
     }
+    g_hTest = hTest;
+
     PSUPDRVSESSION pSession;
     rc = SUPR3Init(&pSession);
@@ -67 +95 @@
         return RTTestSummaryAndDestroy(hTest);
     }
+    g_pSession = pSession;
 
     /*
      * Basic API checks.
      */
-    RTTestSub(hTest, "Single Release Event API");
+    RTTestSub(hTest, "Single Release Event (SRE) API");
     SUPSEMEVENT hEvent = NIL_SUPSEMEVENT;
     RTTESTI_CHECK_RC(SUPSemEventCreate(pSession, &hEvent),          VINF_SUCCESS);
@@ -89 +118 @@
     RTTESTI_CHECK_RC(SUPSemEventClose(pSession, NIL_SUPSEMEVENT),   VINF_SUCCESS);
 
-    RTTestSub(hTest, "Multiple Release Event API");
+    RTTestSub(hTest, "Multiple Release Event (MRE) API");
     SUPSEMEVENTMULTI hEventMulti = NIL_SUPSEMEVENT;
     RTTESTI_CHECK_RC(SUPSemEventMultiCreate(pSession, &hEventMulti),            VINF_SUCCESS);
@@ -110 +139 @@
     RTTESTI_CHECK_RC(SUPSemEventMultiClose(pSession, NIL_SUPSEMEVENTMULTI),     VINF_SUCCESS);
 
+#if !defined(RT_OS_OS2) && !defined(RT_OS_WINDOWS)
+    RTTestSub(hTest, "SRE Interruptibility");
+    RTTESTI_CHECK_RC(SUPSemEventCreate(pSession, &hEvent), VINF_SUCCESS);
+    RTTHREAD hThread = NIL_RTTHREAD;
+    RTTESTI_CHECK_RC(RTThreadCreate(&hThread, tstSupSemInterruptibleSRE, (void *)hEvent, 0, RTTHREADTYPE_TIMER, RTTHREADFLAGS_WAITABLE, "IntSRE"), VINF_SUCCESS);
+    RTTESTI_CHECK_RC(RTThreadUserWait(hThread, 60*1000), VINF_SUCCESS);
+    RTThreadSleep(120);
+    RTThreadPoke(hThread);
+    int rcThread = VINF_SUCCESS;
+    RTTESTI_CHECK_RC(RTThreadWait(hThread, 60*1000, &rcThread), VINF_SUCCESS);
+    RTTESTI_CHECK_RC(rcThread, VERR_INTERRUPTED);
+    RTTESTI_CHECK_RC(SUPSemEventClose(pSession, hEvent), VINF_OBJECT_DESTROYED);
+
+    RTTestSub(hTest, "MRE Interruptibility");
+    RTTESTI_CHECK_RC(SUPSemEventMultiCreate(pSession, &hEventMulti), VINF_SUCCESS);
+    hThread = NIL_RTTHREAD;
+    RTTESTI_CHECK_RC(RTThreadCreate(&hThread, tstSupSemInterruptibleMRE, (void *)hEventMulti, 0, RTTHREADTYPE_TIMER, RTTHREADFLAGS_WAITABLE, "IntMRE"), VINF_SUCCESS);
+    RTTESTI_CHECK_RC(RTThreadUserWait(hThread, 60*1000), VINF_SUCCESS);
+    RTThreadSleep(120);
+    RTThreadPoke(hThread);
+    rcThread = VINF_SUCCESS;
+    RTTESTI_CHECK_RC(RTThreadWait(hThread, 60*1000, &rcThread), VINF_SUCCESS);
+    RTTESTI_CHECK_RC(rcThread, VERR_INTERRUPTED);
+    RTTESTI_CHECK_RC(SUPSemEventMultiClose(pSession, hEventMulti), VINF_OBJECT_DESTROYED);
+
+#endif
+
     /*
      * Done.