Changeset 88810 in vbox

Timestamp:

May 1, 2021 1:05:17 AM (4 years ago)

Author:

vboxsync

Message:

IPRT/RTReqPool: Added RTREQPOOLCFGVAR_THREAD_FLAGS so we can supply RTTHREADFLAGS_COM_MTA or similar to RTThreadCreate for the pool. bugref:9890

Location:

trunk

Files:

• include/iprt/req.h (modified) (1 diff)
• src/VBox/Runtime/common/misc/reqpool.cpp (modified) (5 diffs)

trunk/include/iprt/req.h

@@ -332 +332 @@
     /** The desired RTTHREADTYPE of the worker threads. */
     RTREQPOOLCFGVAR_THREAD_TYPE,
+    /** The RTTHREADFLAGS mask for the worker threads (not waitable). */
+    RTREQPOOLCFGVAR_THREAD_FLAGS,
     /** The minimum number of threads to keep handy once spawned. */
     RTREQPOOLCFGVAR_MIN_THREADS,

trunk/src/VBox/Runtime/common/misc/reqpool.cpp

@@ -116 +116 @@
     /** The worker thread type. */
     RTTHREADTYPE            enmThreadType;
+    /** The work thread flags (RTTHREADFLAGS). */
+    uint32_t                fThreadFlags;
     /** The maximum number of worker threads. */
     uint32_t                cMaxThreads;
@@ -463 +465 @@
 
     int rc = RTThreadCreateF(&pThread->hThread, rtReqPoolThreadProc, pThread, 0 /*default stack size*/,
-                             pPool->enmThreadType, 0 /*fFlags*/, "%s%02u", pPool->szName, pPool->cThreadsCreated);
+                             pPool->enmThreadType, pPool->fThreadFlags, "%s%02u", pPool->szName, pPool->cThreadsCreated);
     if (RT_SUCCESS(rc))
         pPool->uLastThreadCreateNanoTs = pThread->uBirthNanoTs;
@@ -658 +660 @@
         return VERR_NO_MEMORY;
 
-    pPool->u32Magic         = RTREQPOOL_MAGIC;
+    pPool->u32Magic             = RTREQPOOL_MAGIC;
     RTStrCopy(pPool->szName, sizeof(pPool->szName), pszName);
 
     pPool->enmThreadType        = RTTHREADTYPE_DEFAULT;
+    pPool->fThreadFlags         = 0;
     pPool->cMaxThreads          = cMaxThreads;
     pPool->cMinThreads          = cMinThreads;
@@ -731 +734 @@
             break;
 
+        case RTREQPOOLCFGVAR_THREAD_FLAGS:
+            AssertMsgBreakStmt(!(uValue & ~(uint64_t)RTTHREADFLAGS_MASK) && !(uValue & RTTHREADFLAGS_WAITABLE),
+                               ("%#llx\n",  uValue), rc = VERR_INVALID_FLAGS);
+
+            pPool->fThreadFlags = (uint32_t)uValue;
+            break;
+
         case RTREQPOOLCFGVAR_MIN_THREADS:
             AssertMsgBreakStmt(uValue <= RTREQPOOL_MAX_THREADS,  ("%llu\n",  uValue), rc = VERR_OUT_OF_RANGE);
@@ -881 +891 @@
             break;
 
+        case RTREQPOOLCFGVAR_THREAD_FLAGS:
+            u64 = pPool->fThreadFlags;
+            break;
+
         case RTREQPOOLCFGVAR_MIN_THREADS:
             u64 = pPool->cMinThreads;