Changeset 47572 in vbox for trunk/src/VBox/Runtime/testcase/tstR0ThreadPreemption.cpp

Timestamp:

Aug 7, 2013 9:51:45 AM (12 years ago)

Author:

vboxsync

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

87772

Message:

Runtime/threadctxhooks: RTThreadCtxHooksAreRegistered().

File:

• trunk/src/VBox/Runtime/testcase/tstR0ThreadPreemption.cpp (modified) (6 diffs)

trunk/src/VBox/Runtime/testcase/tstR0ThreadPreemption.cpp

@@ -299 +299 @@
             }
 
+            bool fRegistered = RTThreadCtxHooksAreRegistered(NIL_RTTHREADCTX);
+            if (fRegistered)
+            {
+                RTStrPrintf(pszErr, cchErr, "!RTThreadCtxHooksAreRegistered returns true before creating any hooks");
+                break;
+            }
+
             RTTHREADCTX hThreadCtx;
             int rc = RTThreadCtxHooksCreate(&hThreadCtx);
@@ -307 +314 @@
                 else
                     RTStrPrintf(pszErr, cchErr, "!RTThreadCtxHooksCreate returns %Rrc", rc);
+                break;
+            }
+
+            fRegistered = RTThreadCtxHooksAreRegistered(hThreadCtx);
+            if (fRegistered)
+            {
+                RTStrPrintf(pszErr, cchErr, "!RTThreadCtxHooksAreRegistered returns true before registering any hooks");
+                RTThreadCtxHooksRelease(hThreadCtx);
                 break;
             }
@@ -330 +345 @@
             if (RT_FAILURE(rc))
             {
+                RTThreadPreemptRestore(&PreemptState);
                 RTMemFree(pCtxData);
                 RTStrPrintf(pszErr, cchErr, "!RTThreadCtxHooksRegister returns %Rrc", rc);
@@ -335 +351 @@
             }
 
+            fRegistered = RTThreadCtxHooksAreRegistered(hThreadCtx);
+            if (!fRegistered)
+            {
+                RTThreadPreemptRestore(&PreemptState);
+                RTMemFree(pCtxData);
+                RTStrPrintf(pszErr, cchErr, "!RTThreadCtxHooksAreRegistered return false when hooks are supposedly registered");
+                break;
+            }
+
             RTThreadPreemptRestore(&PreemptState);
 
             /* Check if the preempting callback has/will been invoked. */
-            const uint32_t  cMsTimeout           = 8000;
+            const uint32_t  cMsTimeout           = 10000;
             const uint32_t  cMsSleepGranularity  = 50;
             uint32_t        cMsSlept             = 0;
+            RTCPUID         uCurrentCpuId        = NIL_RTCPUID;
             for (;;)
             {
                 RTThreadPreemptDisable(&PreemptState);
-                const RTCPUID uCurrentCpuId = RTMpCpuId();
+                uCurrentCpuId = RTMpCpuId();
                 RTThreadPreemptRestore(&PreemptState);
 
@@ -359 +385 @@
             if (!ASMAtomicReadBool(&pCtxData->fPreemptingInvoked))
             {
-                RTStrPrintf(pszErr, cchErr, "!tstR0ThreadCtxHooks[RTTHREADCTXEVENT_PREEMPTING] not invoked after ca. %u ms",
-                            cMsSlept);
+                if (pCtxData->uSourceCpuId != uCurrentCpuId)
+                {
+                    RTStrPrintf(pszErr, cchErr,
+                                "!tstR0ThreadCtxHooks[RTTHREADCTXEVENT_PREEMPTING] not invoked before migrating from CPU %RU32 to %RU32",
+                                pCtxData->uSourceCpuId, uCurrentCpuId);
+                }
+                else
+                {
+                    RTStrPrintf(pszErr, cchErr, "!tstR0ThreadCtxHooks[RTTHREADCTXEVENT_PREEMPTING] not invoked after ca. %u ms",
+                                cMsSlept);
+                }
             }
             else if (!pCtxData->fPreemptingSuccess)
@@ -391 +426 @@
             RTThreadCtxHooksDeregister(hThreadCtx);
 
+            fRegistered = RTThreadCtxHooksAreRegistered(hThreadCtx);
+            if (fRegistered)
+            {
+                RTMemFree(pCtxData);
+                RTStrPrintf(pszErr, cchErr, "!RTThreadCtxHooksAreRegistered return true when hooks are deregistered");
+                break;
+            }
+
             Assert(RTThreadPreemptIsEnabled(NIL_RTTHREAD));
             uint32_t cRefs = RTThreadCtxHooksRelease(hThreadCtx);