17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include <iprt/req.h>

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include "internal/iprt.h"

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include <iprt/assert.h>

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include <iprt/asm.h>

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync#include <iprt/critsect.h>

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync#include <iprt/list.h>

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync#include <iprt/log.h>

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync#include <iprt/mem.h>

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include <iprt/string.h>

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include <iprt/time.h>

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include <iprt/semaphore.h>

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include <iprt/thread.h>

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include "internal/req.h"

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync#include "internal/magics.h"

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync

17ef1920962b3df57bf6d2704ced1586396d96f0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync#define RTREQPOOL_MAX_THREADS UINT32_C(16384)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync#define RTREQPOOL_PUSH_BACK_MAX_MS RT_MS_1MIN

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync#define RTREQPOOL_MAX_FREE_REQUESTS (RTREQPOOL_MAX_THREADS * 2U)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsynctypedef struct RTREQPOOLTHREAD

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync{

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Node in the RTREQPOOLINT::IdleThreads list. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync RTLISTNODE IdleNode;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Node in the RTREQPOOLINT::WorkerThreads list. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync RTLISTNODE ListNode;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** The submit timestamp of the pending request. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint64_t uPendingNanoTs;

8867771015571c5542d39e393d7fe6304421a928vboxsync /** The submit timestamp of the request processing. */

8867771015571c5542d39e393d7fe6304421a928vboxsync uint64_t uProcessingNanoTs;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** When this CPU went idle the last time. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint64_t uIdleNanoTs;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** The number of requests processed by this thread. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint64_t cReqProcessed;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Total time the requests processed by this thread took to process. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint64_t cNsTotalReqProcessing;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Total time the requests processed by this thread had to wait in

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint64_t cNsTotalReqQueued;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** The CPU this was scheduled last time we checked. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync RTCPUID idLastCpu;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** The submitter will put an incoming request here when scheduling an idle

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync PRTREQINT volatile pTodoReq;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** The request the thread is currently processing. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync PRTREQINT volatile pPendingReq;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /** The thread handle. */

8867771015571c5542d39e393d7fe6304421a928vboxsync RTTHREAD hThread;

8867771015571c5542d39e393d7fe6304421a928vboxsync /** Nano seconds timestamp representing the birth time of the thread. */

8867771015571c5542d39e393d7fe6304421a928vboxsync uint64_t uBirthNanoTs;

8867771015571c5542d39e393d7fe6304421a928vboxsync /** Pointer to the request thread pool instance the thread is associated

8867771015571c5542d39e393d7fe6304421a928vboxsync struct RTREQPOOLINT *pPool;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync} RTREQPOOLTHREAD;

8867771015571c5542d39e393d7fe6304421a928vboxsynctypedef RTREQPOOLTHREAD *PRTREQPOOLTHREAD;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsynctypedef struct RTREQPOOLINT

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync{

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Magic value (RTREQPOOL_MAGIC). */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint32_t u32Magic;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync /** The request pool name. */

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync char szName[12];

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** @name Config

8867771015571c5542d39e393d7fe6304421a928vboxsync /** The worker thread type. */

8867771015571c5542d39e393d7fe6304421a928vboxsync RTTHREADTYPE enmThreadType;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** The maximum number of worker threads. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint32_t cMaxThreads;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** The minimum number of worker threads. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint32_t cMinThreads;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** The number of milliseconds a thread needs to be idle before it is

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint32_t cMsMinIdle;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /** cMsMinIdle in nano seconds. */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync uint64_t cNsMinIdle;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /** The idle thread sleep interval in milliseconds. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTMSINTERVAL cMsIdleSleep;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /** The number of threads which should be spawned before throttling kicks

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint32_t cThreadsPushBackThreshold;

8867771015571c5542d39e393d7fe6304421a928vboxsync /** The max number of milliseconds to push back a submitter before creating

8867771015571c5542d39e393d7fe6304421a928vboxsync uint32_t cMsMaxPushBack;

8867771015571c5542d39e393d7fe6304421a928vboxsync /** The minimum number of milliseconds to push back a submitter before

8867771015571c5542d39e393d7fe6304421a928vboxsync uint32_t cMsMinPushBack;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** The max number of free requests in the recycle LIFO. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync uint32_t cMaxFreeRequests;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** @} */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** Signaled by terminating worker threads. */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTSEMEVENTMULTI hThreadTermEvt;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** Destruction indicator. The worker threads checks in their loop. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync bool volatile fDestructing;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /** The current submitter push back in milliseconds.

8867771015571c5542d39e393d7fe6304421a928vboxsync uint32_t cMsCurPushBack;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** The current number of worker threads. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync uint32_t cCurThreads;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Statistics: The total number of threads created. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint32_t cThreadsCreated;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Statistics: The timestamp when the last thread was created. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint64_t uLastThreadCreateNanoTs;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Linked list of worker threads. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync RTLISTANCHOR WorkerThreads;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /** The number of requests processed and counted in the time totals. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint64_t cReqProcessed;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /** Total time the requests processed by this thread took to process. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint64_t cNsTotalReqProcessing;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /** Total time the requests processed by this thread had to wait in

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint64_t cNsTotalReqQueued;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Reference counter. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync uint32_t volatile cRefs;

8867771015571c5542d39e393d7fe6304421a928vboxsync /** The number of idle thread or threads in the process of becoming

8867771015571c5542d39e393d7fe6304421a928vboxsync uint32_t volatile cIdleThreads;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync /** Linked list of idle threads. */

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync RTLISTANCHOR IdleThreads;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /** Head of the request FIFO. */

8867771015571c5542d39e393d7fe6304421a928vboxsync PRTREQINT pPendingRequests;

8867771015571c5542d39e393d7fe6304421a928vboxsync /** Where to insert the next request. */

8867771015571c5542d39e393d7fe6304421a928vboxsync PRTREQINT *ppPendingRequests;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /** The number of requests currently pending. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint32_t cCurPendingRequests;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /** The number of requests currently being executed. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint32_t volatile cCurActiveRequests;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /** The number of requests submitted. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint64_t cReqSubmitted;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** Head of the request recycling LIFO. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync PRTREQINT pFreeRequests;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** The number of requests in the recycling LIFO. This is read without

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync uint32_t volatile cCurFreeRequests;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** Critical section serializing access to members of this structure. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCRITSECT CritSect;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync} RTREQPOOLINT;

fe14fe6d46ce87a9b25cbdacb3a20b1f87bf34c7vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsyncstatic void rtReqPoolCancelReq(PRTREQINT pReq)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync{

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync pReq->uOwner.hPool = NIL_RTREQPOOL; /* force free */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync pReq->enmState = RTREQSTATE_COMPLETED;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync ASMAtomicWriteS32(&pReq->iStatusX, VERR_CANCELLED);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (pReq->hPushBackEvt != NIL_RTSEMEVENTMULTI)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTSemEventMultiSignal(pReq->hPushBackEvt);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTSemEventSignal(pReq->EventSem);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTReqRelease(pReq);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync}

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsyncstatic void rtReqPoolRecalcPushBack(PRTREQPOOLINT pPool)

8867771015571c5542d39e393d7fe6304421a928vboxsync{

8867771015571c5542d39e393d7fe6304421a928vboxsync uint32_t const cMsRange = pPool->cMsMaxPushBack - pPool->cMsMinPushBack;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint32_t const cSteps = pPool->cMaxThreads - pPool->cThreadsPushBackThreshold;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint32_t const iStep = pPool->cCurThreads - pPool->cThreadsPushBackThreshold;

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync uint32_t cMsCurPushBack;

8867771015571c5542d39e393d7fe6304421a928vboxsync if ((cMsRange >> 2) >= cSteps)

8867771015571c5542d39e393d7fe6304421a928vboxsync cMsCurPushBack = cMsRange / cSteps * iStep;

8867771015571c5542d39e393d7fe6304421a928vboxsync else

8867771015571c5542d39e393d7fe6304421a928vboxsync cMsCurPushBack = (uint32_t)( (uint64_t)cMsRange * RT_NS_1MS / cSteps * iStep / RT_NS_1MS );

8867771015571c5542d39e393d7fe6304421a928vboxsync cMsCurPushBack += pPool->cMsMinPushBack;

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync pPool->cMsCurPushBack = cMsCurPushBack;

8867771015571c5542d39e393d7fe6304421a928vboxsync}

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsyncstatic int rtReqPoolThreadExit(PRTREQPOOLINT pPool, PRTREQPOOLTHREAD pThread, bool fLocked)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync{

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (!fLocked)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTCritSectEnter(&pPool->CritSect);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /* Get out of the idle list. */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (!RTListIsEmpty(&pThread->IdleNode))

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync {

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTListNodeRemove(&pThread->IdleNode);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync Assert(pPool->cIdleThreads > 0);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync ASMAtomicDecU32(&pPool->cIdleThreads);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync }

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /* Get out of the thread list. */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTListNodeRemove(&pThread->ListNode);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync Assert(pPool->cCurThreads > 0);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync pPool->cCurThreads--;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync rtReqPoolRecalcPushBack(pPool);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /* This shouldn't happen... */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync PRTREQINT pReq = pThread->pTodoReq;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (pReq)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync {

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync AssertFailed();

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync pThread->pTodoReq = NULL;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync rtReqPoolCancelReq(pReq);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync }

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /* If we're the last thread terminating, ping the destruction thread before

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if ( RTListIsEmpty(&pPool->WorkerThreads)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync && pPool->hThreadTermEvt != NIL_RTSEMEVENT)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTSemEventMultiSignal(pPool->hThreadTermEvt);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTCritSectLeave(&pPool->CritSect);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync return VINF_SUCCESS;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync}

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsyncstatic void rtReqPoolThreadProcessRequest(PRTREQPOOLINT pPool, PRTREQPOOLTHREAD pThread, PRTREQINT pReq)

8867771015571c5542d39e393d7fe6304421a928vboxsync{

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

8867771015571c5542d39e393d7fe6304421a928vboxsync pThread->uProcessingNanoTs = RTTimeNanoTS();

8867771015571c5542d39e393d7fe6304421a928vboxsync pThread->uPendingNanoTs = pReq->uSubmitNanoTs;

8867771015571c5542d39e393d7fe6304421a928vboxsync pThread->pPendingReq = pReq;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync ASMAtomicIncU32(&pPool->cCurActiveRequests);

8867771015571c5542d39e393d7fe6304421a928vboxsync Assert(pReq->u32Magic == RTREQ_MAGIC);

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqProcessOne(pReq);

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync ASMAtomicDecU32(&pPool->cCurActiveRequests);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pThread->pPendingReq = NULL;

8867771015571c5542d39e393d7fe6304421a928vboxsync uint64_t const uNsTsEnd = RTTimeNanoTS();

8867771015571c5542d39e393d7fe6304421a928vboxsync pThread->cNsTotalReqProcessing += uNsTsEnd - pThread->uProcessingNanoTs;

dbf778dbca739883cb93737abe3e5095011dbe6avboxsync pThread->cNsTotalReqQueued += pThread->uProcessingNanoTs - pThread->uPendingNanoTs;

8867771015571c5542d39e393d7fe6304421a928vboxsync pThread->cReqProcessed++;

8867771015571c5542d39e393d7fe6304421a928vboxsync}

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsyncstatic DECLCALLBACK(int) rtReqPoolThreadProc(RTTHREAD hThreadSelf, void *pvArg)

8867771015571c5542d39e393d7fe6304421a928vboxsync{

8867771015571c5542d39e393d7fe6304421a928vboxsync PRTREQPOOLTHREAD pThread = (PRTREQPOOLTHREAD)pvArg;

8867771015571c5542d39e393d7fe6304421a928vboxsync PRTREQPOOLINT pPool = pThread->pPool;

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint64_t cReqPrevProcessedIdle = UINT64_MAX;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint64_t cReqPrevProcessedStat = 0;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint64_t cNsPrevTotalReqProcessing = 0;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync uint64_t cNsPrevTotalReqQueued = 0;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync while (!pPool->fDestructing)

8867771015571c5542d39e393d7fe6304421a928vboxsync {

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /* Check if anything is scheduled directly to us. */

8867771015571c5542d39e393d7fe6304421a928vboxsync PRTREQINT pReq = ASMAtomicXchgPtrT(&pThread->pTodoReq, NULL, PRTREQINT);

8867771015571c5542d39e393d7fe6304421a928vboxsync if (pReq)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync {

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync Assert(RTListIsEmpty(&pThread->IdleNode)); /* Must not be in the idle list. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqPoolThreadProcessRequest(pPool, pThread, pReq);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync continue;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync }

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync ASMAtomicIncU32(&pPool->cIdleThreads);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTCritSectEnter(&pPool->CritSect);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /* Update the global statistics. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (cReqPrevProcessedStat != pThread->cReqProcessed)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

224132d5ac9f727f499ec4507bc1da2a06080c03vboxsync pPool->cReqProcessed += pThread->cReqProcessed - cReqPrevProcessedStat;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync cReqPrevProcessedStat = pThread->cReqProcessed;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cNsTotalReqProcessing += pThread->cNsTotalReqProcessing - cNsPrevTotalReqProcessing;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync cNsPrevTotalReqProcessing = pThread->cNsTotalReqProcessing;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cNsTotalReqQueued += pThread->cNsTotalReqQueued - cNsPrevTotalReqQueued;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync cNsPrevTotalReqQueued = pThread->cNsTotalReqQueued;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /* Recheck the todo request pointer after entering the critsect. */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync pReq = ASMAtomicXchgPtrT(&pThread->pTodoReq, NULL, PRTREQINT);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (pReq)

8867771015571c5542d39e393d7fe6304421a928vboxsync {

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync Assert(RTListIsEmpty(&pThread->IdleNode)); /* Must not be in the idle list. */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTCritSectLeave(&pPool->CritSect);

8867771015571c5542d39e393d7fe6304421a928vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqPoolThreadProcessRequest(pPool, pThread, pReq);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync continue;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync }

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /* Any pending requests in the queue? */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync pReq = pPool->pPendingRequests;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (pReq)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync {

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync pPool->pPendingRequests = pReq->pNext;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (pReq->pNext == NULL)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync pPool->ppPendingRequests = &pPool->pPendingRequests;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync Assert(pPool->cCurPendingRequests > 0);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cCurPendingRequests--;

8867771015571c5542d39e393d7fe6304421a928vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /* Un-idle ourselves and process the request. */

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (!RTListIsEmpty(&pThread->IdleNode))

8867771015571c5542d39e393d7fe6304421a928vboxsync {

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTListNodeRemove(&pThread->IdleNode);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTListInit(&pThread->IdleNode);

8867771015571c5542d39e393d7fe6304421a928vboxsync ASMAtomicDecU32(&pPool->cIdleThreads);

8867771015571c5542d39e393d7fe6304421a928vboxsync }

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync ASMAtomicDecU32(&pPool->cIdleThreads);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTCritSectLeave(&pPool->CritSect);

8867771015571c5542d39e393d7fe6304421a928vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqPoolThreadProcessRequest(pPool, pThread, pReq);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync continue;

8867771015571c5542d39e393d7fe6304421a928vboxsync }

8867771015571c5542d39e393d7fe6304421a928vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync /*

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (cReqPrevProcessedIdle != pThread->cReqProcessed)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync cReqPrevProcessedIdle = pThread->cReqProcessed;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pThread->uIdleNanoTs = RTTimeNanoTS();

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync }

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync else if (pPool->cCurThreads > pPool->cMinThreads)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync {

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync uint64_t cNsIdle = RTTimeNanoTS() - pThread->uIdleNanoTs;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (cNsIdle >= pPool->cNsMinIdle)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync return rtReqPoolThreadExit(pPool, pThread, true /*fLocked*/);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync }

8867771015571c5542d39e393d7fe6304421a928vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync if (RTListIsEmpty(&pThread->IdleNode))

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTListPrepend(&pPool->IdleThreads, &pThread->IdleNode);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync else

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync ASMAtomicDecU32(&pPool->cIdleThreads);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTThreadUserReset(hThreadSelf);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync uint32_t const cMsSleep = pPool->cMsIdleSleep;

8867771015571c5542d39e393d7fe6304421a928vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTCritSectLeave(&pPool->CritSect);

8867771015571c5542d39e393d7fe6304421a928vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTThreadUserWait(hThreadSelf, cMsSleep);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync }

8867771015571c5542d39e393d7fe6304421a928vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync return rtReqPoolThreadExit(pPool, pThread, false /*fLocked*/);

8867771015571c5542d39e393d7fe6304421a928vboxsync}

8867771015571c5542d39e393d7fe6304421a928vboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

c999f225d03074008a0c21cdd5d3594da476e243vboxsyncstatic void rtReqPoolCreateNewWorker(RTREQPOOL pPool)

c999f225d03074008a0c21cdd5d3594da476e243vboxsync{

c999f225d03074008a0c21cdd5d3594da476e243vboxsync PRTREQPOOLTHREAD pThread = (PRTREQPOOLTHREAD)RTMemAllocZ(sizeof(RTREQPOOLTHREAD));

c999f225d03074008a0c21cdd5d3594da476e243vboxsync if (!pThread)

c999f225d03074008a0c21cdd5d3594da476e243vboxsync return;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync

c999f225d03074008a0c21cdd5d3594da476e243vboxsync pThread->uBirthNanoTs = RTTimeNanoTS();

c999f225d03074008a0c21cdd5d3594da476e243vboxsync pThread->pPool = pPool;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync pThread->idLastCpu = NIL_RTCPUID;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync pThread->hThread = NIL_RTTHREAD;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync RTListInit(&pThread->IdleNode);

c999f225d03074008a0c21cdd5d3594da476e243vboxsync RTListAppend(&pPool->WorkerThreads, &pThread->ListNode);

c999f225d03074008a0c21cdd5d3594da476e243vboxsync pPool->cCurThreads++;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync pPool->cThreadsCreated++;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync

c999f225d03074008a0c21cdd5d3594da476e243vboxsync int rc = RTThreadCreateF(&pThread->hThread, rtReqPoolThreadProc, pThread, 0 /*default stack size*/,

88f85f14bc6b8d928002d328b2c8c05a8f42179evboxsync pPool->enmThreadType, 0 /*fFlags*/, "%s%02u", pPool->szName, pPool->cThreadsCreated);

c999f225d03074008a0c21cdd5d3594da476e243vboxsync if (RT_SUCCESS(rc))

c999f225d03074008a0c21cdd5d3594da476e243vboxsync pPool->uLastThreadCreateNanoTs = pThread->uBirthNanoTs;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync else

c999f225d03074008a0c21cdd5d3594da476e243vboxsync {

c999f225d03074008a0c21cdd5d3594da476e243vboxsync pPool->cCurThreads--;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync RTListNodeRemove(&pThread->ListNode);

c999f225d03074008a0c21cdd5d3594da476e243vboxsync RTMemFree(pThread);

c999f225d03074008a0c21cdd5d3594da476e243vboxsync }

c999f225d03074008a0c21cdd5d3594da476e243vboxsync}

c999f225d03074008a0c21cdd5d3594da476e243vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncstatic int rtReqPoolPushBack(PRTREQPOOLINT pPool, PRTREQINT pReq)

8867771015571c5542d39e393d7fe6304421a928vboxsync{

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync int rc;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTSEMEVENTMULTI hEvt = pReq->hPushBackEvt;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (hEvt == NIL_RTSEMEVENTMULTI)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync rc = RTSemEventMultiCreate(&hEvt);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (RT_FAILURE(rc))

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return rc;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pReq->hPushBackEvt = hEvt;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /*

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync uint32_t const cMsTimeout = pPool->cMsCurPushBack;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pReq->fSignalPushBack = true;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTReqRetain(pReq);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTSemEventMultiReset(hEvt);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectLeave(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /*

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync rc = RTSemEventMultiWait(hEvt, cMsTimeout);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (RT_FAILURE(rc))

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync AssertMsg(rc == VERR_TIMEOUT, ("%Rrc\n", rc));

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectEnter(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTReqRelease(pReq);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return rc;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync}

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncDECLHIDDEN(void) rtReqPoolSubmit(PRTREQPOOLINT pPool, PRTREQINT pReq)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync{

8867771015571c5542d39e393d7fe6304421a928vboxsync RTCritSectEnter(&pPool->CritSect);

8867771015571c5542d39e393d7fe6304421a928vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cReqSubmitted++;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

8867771015571c5542d39e393d7fe6304421a928vboxsync PRTREQPOOLTHREAD pThread = RTListGetFirst(&pPool->IdleThreads, RTREQPOOLTHREAD, IdleNode);

8867771015571c5542d39e393d7fe6304421a928vboxsync if (pThread)

8867771015571c5542d39e393d7fe6304421a928vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /** @todo CPU affinity??? */

8867771015571c5542d39e393d7fe6304421a928vboxsync ASMAtomicWritePtr(&pThread->pTodoReq, pReq);

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync RTListNodeRemove(&pThread->IdleNode);

8867771015571c5542d39e393d7fe6304421a928vboxsync RTListInit(&pThread->IdleNode);

8867771015571c5542d39e393d7fe6304421a928vboxsync ASMAtomicDecU32(&pPool->cIdleThreads);

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync RTThreadUserSignal(pThread->hThread);

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync RTCritSectLeave(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return;

8867771015571c5542d39e393d7fe6304421a928vboxsync }

8867771015571c5542d39e393d7fe6304421a928vboxsync Assert(RTListIsEmpty(&pPool->IdleThreads));

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

8867771015571c5542d39e393d7fe6304421a928vboxsync pReq->pNext = NULL;

8867771015571c5542d39e393d7fe6304421a928vboxsync *pPool->ppPendingRequests = pReq;

8867771015571c5542d39e393d7fe6304421a928vboxsync pPool->ppPendingRequests = (PRTREQINT*)&pReq->pNext;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cCurPendingRequests++;

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

8867771015571c5542d39e393d7fe6304421a928vboxsync if ( pPool->cIdleThreads > 0

8867771015571c5542d39e393d7fe6304421a928vboxsync || pPool->cCurThreads >= pPool->cMaxThreads)

8867771015571c5542d39e393d7fe6304421a928vboxsync {

8867771015571c5542d39e393d7fe6304421a928vboxsync RTCritSectLeave(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return;

8867771015571c5542d39e393d7fe6304421a928vboxsync }

8867771015571c5542d39e393d7fe6304421a928vboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if ( pPool->cCurThreads > pPool->cThreadsPushBackThreshold

8867771015571c5542d39e393d7fe6304421a928vboxsync && (RTTimeNanoTS() - pReq->uSubmitNanoTs) / RT_NS_1MS >= pPool->cMsCurPushBack )

8867771015571c5542d39e393d7fe6304421a928vboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync int rc = rtReqPoolPushBack(pPool, pReq);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (RT_SUCCESS(rc))

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /*

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync rtReqPoolCreateNewWorker(pPool);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectLeave(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync}

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncDECLHIDDEN(bool) rtReqPoolRecycle(PRTREQPOOLINT pPool, PRTREQINT pReq)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync{

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if ( pPool

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync && ASMAtomicReadU32(&pPool->cCurFreeRequests) < pPool->cMaxFreeRequests)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectEnter(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (pPool->cCurFreeRequests < pPool->cMaxFreeRequests)

c999f225d03074008a0c21cdd5d3594da476e243vboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pReq->pNext = pPool->pFreeRequests;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pPool->pFreeRequests = pReq;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync ASMAtomicIncU32(&pPool->cCurFreeRequests);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectLeave(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return true;

c999f225d03074008a0c21cdd5d3594da476e243vboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectLeave(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return false;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync}

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

159b42c2e42dbee770ce06fcf174697a9ae96e06vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRTDECL(int) RTReqPoolCreate(uint32_t cMaxThreads, RTMSINTERVAL cMsMinIdle,

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync uint32_t cThreadsPushBackThreshold, uint32_t cMsMaxPushBack,

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync const char *pszName, PRTREQPOOL phPool)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync{

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync /*

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (cMaxThreads == UINT32_MAX)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync cMaxThreads = RTREQPOOL_MAX_THREADS;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertMsgReturn(cMaxThreads > 0 && cMaxThreads <= RTREQPOOL_MAX_THREADS, ("%u\n", cMaxThreads), VERR_OUT_OF_RANGE);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync uint32_t const cMinThreads = cMaxThreads > 2 ? 2 : cMaxThreads - 1;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (cThreadsPushBackThreshold == 0)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync cThreadsPushBackThreshold = cMinThreads;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync else if (cThreadsPushBackThreshold == UINT32_MAX)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync cThreadsPushBackThreshold = cMaxThreads;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertMsgReturn(cThreadsPushBackThreshold <= cMaxThreads, ("%u/%u\n", cThreadsPushBackThreshold, cMaxThreads), VERR_OUT_OF_RANGE);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (cMsMaxPushBack == UINT32_MAX)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync cMsMaxPushBack = RTREQPOOL_PUSH_BACK_MAX_MS;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertMsgReturn(cMsMaxPushBack <= RTREQPOOL_PUSH_BACK_MAX_MS, ("%llu\n", cMsMaxPushBack), VERR_OUT_OF_RANGE);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync uint32_t const cMsMinPushBack = cMsMaxPushBack >= 200 ? 100 : cMsMaxPushBack / 2;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertPtrReturn(pszName, VERR_INVALID_POINTER);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync size_t cchName = strlen(pszName);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertReturn(cchName > 0, VERR_INVALID_PARAMETER);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync Assert(cchName <= 10);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertPtrReturn(phPool, VERR_INVALID_POINTER);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync /*

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync PRTREQPOOLINT pPool = (PRTREQPOOLINT)RTMemAlloc(sizeof(*pPool));

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (!pPool)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return VERR_NO_MEMORY;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->u32Magic = RTREQPOOL_MAGIC;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTStrCopy(pPool->szName, sizeof(pPool->szName), pszName);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->enmThreadType = RTTHREADTYPE_DEFAULT;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cMaxThreads = cMaxThreads;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cMinThreads = cMinThreads;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cMsMinIdle = cMsMinIdle == RT_INDEFINITE_WAIT || cMsMinIdle >= UINT32_MAX ? UINT32_MAX : cMsMinIdle;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cNsMinIdle = pPool->cMsMinIdle == UINT32_MAX ? UINT64_MAX : cMsMinIdle * RT_NS_1MS_64;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cMsIdleSleep = pPool->cMsMinIdle == UINT32_MAX ? RT_INDEFINITE_WAIT : RT_MAX(RT_MS_1SEC, pPool->cMsMinIdle);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cThreadsPushBackThreshold = cThreadsPushBackThreshold;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cMsMaxPushBack = cMsMaxPushBack;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cMsMinPushBack = cMsMinPushBack;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cMaxFreeRequests = cMaxThreads * 2;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->hThreadTermEvt = NIL_RTSEMEVENTMULTI;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->fDestructing = false;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cMsCurPushBack = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cCurThreads = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cThreadsCreated = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->uLastThreadCreateNanoTs = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTListInit(&pPool->WorkerThreads);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cReqProcessed = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cNsTotalReqProcessing= 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cNsTotalReqQueued = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cRefs = 1;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cIdleThreads = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTListInit(&pPool->IdleThreads);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->pPendingRequests = NULL;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->ppPendingRequests = &pPool->pPendingRequests;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cCurPendingRequests = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cCurActiveRequests = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->cReqSubmitted = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->pFreeRequests = NULL;

d6f77e47c11df743d9273a39dacb925684b69bd4vboxsync pPool->cCurFreeRequests = 0;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync int rc = RTSemEventMultiCreate(&pPool->hThreadTermEvt);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (RT_SUCCESS(rc))

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync {

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync rc = RTCritSectInit(&pPool->CritSect);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (RT_SUCCESS(rc))

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync {

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync *phPool = pPool;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return VINF_SUCCESS;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync }

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTSemEventMultiDestroy(pPool->hThreadTermEvt);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync }

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pPool->u32Magic = RTREQPOOL_MAGIC_DEAD;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTMemFree(pPool);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return rc;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync}

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsyncRTDECL(int) RTReqPoolSetCfgVar(RTREQPOOL hPool, RTREQPOOLCFGVAR enmVar, uint64_t uValue)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync{

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync PRTREQPOOLINT pPool = hPool;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertPtrReturn(pPool, VERR_INVALID_HANDLE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertReturn(pPool->u32Magic == RTREQPOOL_MAGIC, VERR_INVALID_HANDLE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertReturn(enmVar > RTREQPOOLCFGVAR_INVALID && enmVar < RTREQPOOLCFGVAR_END, VERR_INVALID_PARAMETER);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTCritSectEnter(&pPool->CritSect);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync bool fWakeUpIdleThreads = false;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync int rc = VINF_SUCCESS;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync switch (enmVar)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_THREAD_TYPE:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertMsgBreakStmt(uValue > (uint64_t)RTTHREADTYPE_INVALID && uValue < (uint64_t)RTTHREADTYPE_END,

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->enmThreadType = (RTTHREADTYPE)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MIN_THREADS:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertMsgBreakStmt(uValue <= RTREQPOOL_MAX_THREADS, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync fWakeUpIdleThreads = pPool->cMinThreads > (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMinThreads = (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (pPool->cMinThreads > pPool->cMaxThreads)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMaxThreads = pPool->cMinThreads;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if ( pPool->cThreadsPushBackThreshold < pPool->cMinThreads

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync || pPool->cThreadsPushBackThreshold > pPool->cMaxThreads)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cThreadsPushBackThreshold = pPool->cMinThreads + (pPool->cMaxThreads - pPool->cMinThreads) / 2;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqPoolRecalcPushBack(pPool);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MAX_THREADS:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertMsgBreakStmt(uValue <= RTREQPOOL_MAX_THREADS && uValue >= 1, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMaxThreads = (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (pPool->cMaxThreads < pPool->cMinThreads)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMinThreads = pPool->cMaxThreads;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync fWakeUpIdleThreads = true;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (pPool->cMaxThreads < pPool->cThreadsPushBackThreshold)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cThreadsPushBackThreshold = pPool->cMinThreads + (pPool->cMaxThreads - pPool->cMinThreads) / 2;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqPoolRecalcPushBack(pPool);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MS_MIN_IDLE:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertMsgBreakStmt(uValue < UINT32_MAX || uValue == RT_INDEFINITE_WAIT, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (uValue < UINT32_MAX && uValue != RT_INDEFINITE_WAIT)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync fWakeUpIdleThreads = pPool->cMsMinIdle != (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsMinIdle = (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cNsMinIdle = pPool->cMsMinIdle * RT_NS_1MS_64;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (pPool->cMsIdleSleep > pPool->cMsMinIdle)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsIdleSleep = RT_MAX(RT_MS_1SEC, pPool->cMsMinIdle);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync else

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsMinIdle = UINT32_MAX;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cNsMinIdle = UINT64_MAX;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsIdleSleep = RT_INDEFINITE_WAIT;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MS_IDLE_SLEEP:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertMsgBreakStmt(uValue <= RT_INDEFINITE_WAIT, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync fWakeUpIdleThreads = pPool->cMsMinIdle > (RTMSINTERVAL)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsIdleSleep = (RTMSINTERVAL)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (pPool->cMsIdleSleep == RT_INDEFINITE_WAIT)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsMinIdle = UINT32_MAX;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cNsMinIdle = UINT64_MAX;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_PUSH_BACK_THRESHOLD:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (uValue == UINT64_MAX)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cThreadsPushBackThreshold = pPool->cMaxThreads;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync else if (uValue == 0)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cThreadsPushBackThreshold = pPool->cMinThreads;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync else

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertMsgBreakStmt(uValue <= pPool->cMaxThreads, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertMsgBreakStmt(uValue >= pPool->cMinThreads, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cThreadsPushBackThreshold = (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_PUSH_BACK_MIN_MS:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (uValue == UINT32_MAX || uValue == UINT64_MAX)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync uValue = RTREQPOOL_PUSH_BACK_MAX_MS;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync else

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertMsgBreakStmt(uValue <= RTREQPOOL_PUSH_BACK_MAX_MS, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsMinPushBack = (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (pPool->cMsMaxPushBack < pPool->cMsMinPushBack)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsMaxPushBack = pPool->cMsMinPushBack;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqPoolRecalcPushBack(pPool);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_PUSH_BACK_MAX_MS:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (uValue == UINT32_MAX || uValue == UINT64_MAX)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync uValue = RTREQPOOL_PUSH_BACK_MAX_MS;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync else

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertMsgBreakStmt(uValue <= RTREQPOOL_PUSH_BACK_MAX_MS, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsMaxPushBack = (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (pPool->cMsMinPushBack < pPool->cMsMaxPushBack)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMsMinPushBack = pPool->cMsMaxPushBack;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqPoolRecalcPushBack(pPool);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MAX_FREE_REQUESTS:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (uValue == UINT64_MAX)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMaxFreeRequests = pPool->cMaxThreads * 2;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (pPool->cMaxFreeRequests < 16)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMaxFreeRequests = 16;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync else

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertMsgBreakStmt(uValue <= RTREQPOOL_MAX_FREE_REQUESTS, ("%llu\n", uValue), rc = VERR_OUT_OF_RANGE);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cMaxFreeRequests = (uint32_t)uValue;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync while (pPool->cCurFreeRequests > pPool->cMaxFreeRequests)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync PRTREQINT pReq = pPool->pFreeRequests;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->pFreeRequests = pReq->pNext;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync ASMAtomicDecU32(&pPool->cCurFreeRequests);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rtReqFreeIt(pReq);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync default:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertFailed();

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync rc = VERR_IPE_NOT_REACHED_DEFAULT_CASE;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync /* Wake up all idle threads if required. */

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync if (fWakeUpIdleThreads)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync Assert(rc == VINF_SUCCESS);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync PRTREQPOOLTHREAD pThread;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTListForEach(&pPool->WorkerThreads, pThread, RTREQPOOLTHREAD, ListNode)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTThreadUserSignal(pThread->hThread);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTCritSectLeave(&pPool->CritSect);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync return rc;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync}

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsyncRT_EXPORT_SYMBOL(RTReqPoolSetCfgVar);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRTDECL(uint64_t) RTReqPoolGetCfgVar(RTREQPOOL hPool, RTREQPOOLCFGVAR enmVar)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync{

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync PRTREQPOOLINT pPool = hPool;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertPtrReturn(pPool, UINT64_MAX);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertReturn(pPool->u32Magic == RTREQPOOL_MAGIC, UINT64_MAX);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertReturn(enmVar > RTREQPOOLCFGVAR_INVALID && enmVar < RTREQPOOLCFGVAR_END, UINT64_MAX);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTCritSectEnter(&pPool->CritSect);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync uint64_t u64;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync switch (enmVar)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_THREAD_TYPE:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->enmThreadType;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MIN_THREADS:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->cMinThreads;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MAX_THREADS:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->cMaxThreads;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MS_MIN_IDLE:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->cMsMinIdle;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MS_IDLE_SLEEP:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->cMsIdleSleep;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_PUSH_BACK_THRESHOLD:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->cThreadsPushBackThreshold;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_PUSH_BACK_MIN_MS:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->cMsMinPushBack;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_PUSH_BACK_MAX_MS:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->cMsMaxPushBack;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLCFGVAR_MAX_FREE_REQUESTS:

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = pPool->cMaxFreeRequests;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync default:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertFailed();

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync u64 = UINT64_MAX;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTCritSectLeave(&pPool->CritSect);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return u64;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync}

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRT_EXPORT_SYMBOL(RTReqGetQueryCfgVar);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsyncRTDECL(uint64_t) RTReqPoolGetStat(RTREQPOOL hPool, RTREQPOOLSTAT enmStat)

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync{

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync PRTREQPOOLINT pPool = hPool;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertPtrReturn(pPool, UINT64_MAX);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertReturn(pPool->u32Magic == RTREQPOOL_MAGIC, UINT64_MAX);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertReturn(enmStat > RTREQPOOLSTAT_INVALID && enmStat < RTREQPOOLSTAT_END, UINT64_MAX);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTCritSectEnter(&pPool->CritSect);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

62d83880d1187f78f0b42681645906aabce8b33fvboxsync uint64_t u64;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync switch (enmStat)

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync {

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_THREADS: u64 = pPool->cCurThreads; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_THREADS_CREATED: u64 = pPool->cThreadsCreated; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_REQUESTS_PROCESSED: u64 = pPool->cReqProcessed; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_REQUESTS_SUBMITTED: u64 = pPool->cReqSubmitted; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_REQUESTS_PENDING: u64 = pPool->cCurPendingRequests; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_REQUESTS_ACTIVE: u64 = pPool->cCurActiveRequests; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_REQUESTS_FREE: u64 = pPool->cCurFreeRequests; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_NS_TOTAL_REQ_PROCESSING: u64 = pPool->cNsTotalReqProcessing; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_NS_TOTAL_REQ_QUEUED: u64 = pPool->cNsTotalReqQueued; break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_NS_AVERAGE_REQ_PROCESSING: u64 = pPool->cNsTotalReqProcessing / RT_MAX(pPool->cReqProcessed, 1); break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync case RTREQPOOLSTAT_NS_AVERAGE_REQ_QUEUED: u64 = pPool->cNsTotalReqQueued / RT_MAX(pPool->cReqProcessed, 1); break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync default:

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync AssertFailed();

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync u64 = UINT64_MAX;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync break;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync }

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync RTCritSectLeave(&pPool->CritSect);

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync return u64;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync}

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsyncRT_EXPORT_SYMBOL(RTReqPoolGetStat);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncRTDECL(uint32_t) RTReqPoolRetain(RTREQPOOL hPool)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync{

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync PRTREQPOOLINT pPool = hPool;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync AssertPtrReturn(pPool, UINT32_MAX);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync AssertReturn(pPool->u32Magic == RTREQPOOL_MAGIC, UINT32_MAX);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return ASMAtomicIncU32(&pPool->cRefs);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync}

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncRT_EXPORT_SYMBOL(RTReqPoolRetain);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncRTDECL(uint32_t) RTReqPoolRelease(RTREQPOOL hPool)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync{

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /*

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (!hPool)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return 0;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync PRTREQPOOLINT pPool = hPool;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync AssertPtrReturn(pPool, UINT32_MAX);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync AssertReturn(pPool->u32Magic == RTREQPOOL_MAGIC, UINT32_MAX);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /*

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync uint32_t cRefs = ASMAtomicDecU32(&pPool->cRefs);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (cRefs == 0)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync AssertReturn(ASMAtomicCmpXchgU32(&pPool->u32Magic, RTREQPOOL_MAGIC_DEAD, RTREQPOOL_MAGIC), UINT32_MAX);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectEnter(&pPool->CritSect);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync#ifdef RT_STRICT

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTTHREAD const hSelf = RTThreadSelf();

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync#endif

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /* Indicate to the worker threads that we're shutting down. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync ASMAtomicWriteBool(&pPool->fDestructing, true);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync PRTREQPOOLTHREAD pThread;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTListForEach(&pPool->WorkerThreads, pThread, RTREQPOOLTHREAD, ListNode)

c999f225d03074008a0c21cdd5d3594da476e243vboxsync {

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync Assert(pThread->hThread != hSelf);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTThreadUserSignal(pThread->hThread);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /* Cancel pending requests. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync Assert(!pPool->pPendingRequests);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync while (pPool->pPendingRequests)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync PRTREQINT pReq = pPool->pPendingRequests;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pPool->pPendingRequests = pReq->pNext;

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync rtReqPoolCancelReq(pReq);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pPool->ppPendingRequests = NULL;

c1b4529a269091edd0274bd98d35b75663fd66c0vboxsync pPool->cCurPendingRequests = 0;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /* Wait for the workers to shut down. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync while (!RTListIsEmpty(&pPool->WorkerThreads))

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectLeave(&pPool->CritSect);

4c464a0800535c29782d7ab5bcd7820bc7115cd7vboxsync RTSemEventMultiWait(pPool->hThreadTermEvt, RT_MS_1MIN);

c999f225d03074008a0c21cdd5d3594da476e243vboxsync RTCritSectEnter(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /** @todo should we wait forever here? */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /* Free recycled requests. */

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync for (;;)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync PRTREQINT pReq = pPool->pFreeRequests;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (!pReq)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync break;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pPool->pFreeRequests = pReq->pNext;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pPool->cCurFreeRequests--;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync rtReqFreeIt(pReq);

c999f225d03074008a0c21cdd5d3594da476e243vboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync /* Finally, free the critical section and pool instance. */

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTCritSectLeave(&pPool->CritSect);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTCritSectDelete(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTMemFree(pPool);

8867771015571c5542d39e393d7fe6304421a928vboxsync }

8867771015571c5542d39e393d7fe6304421a928vboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return cRefs;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync}

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncRT_EXPORT_SYMBOL(RTReqPoolRelease);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncRTDECL(int) RTReqPoolAlloc(RTREQPOOL hPool, RTREQTYPE enmType, PRTREQ *phReq)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync{

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync PRTREQPOOLINT pPool = hPool;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync AssertPtrReturn(pPool, VERR_INVALID_HANDLE);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync AssertReturn(pPool->u32Magic == RTREQPOOL_MAGIC, VERR_INVALID_HANDLE);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

8867771015571c5542d39e393d7fe6304421a928vboxsync /*

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (ASMAtomicReadU32(&pPool->cCurFreeRequests) > 0)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectEnter(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync PRTREQINT pReq = pPool->pFreeRequests;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (pReq)

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync ASMAtomicDecU32(&pPool->cCurFreeRequests);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync pPool->pFreeRequests = pReq->pNext;

8867771015571c5542d39e393d7fe6304421a928vboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectLeave(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync Assert(pReq->fPoolOrQueue);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync Assert(pReq->uOwner.hPool == pPool);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync int rc = rtReqReInit(pReq, enmType);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync if (RT_SUCCESS(rc))

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync {

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync *phReq = pReq;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync LogFlow(("RTReqPoolAlloc: returns VINF_SUCCESS *phReq=%p recycled\n", pReq));

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync return rc;

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync else

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync RTCritSectLeave(&pPool->CritSect);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync }

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync /*

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync int rc = rtReqAlloc(enmType, true /*fPoolOrQueue*/, pPool, phReq);

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsync LogFlow(("RTReqPoolAlloc: returns %Rrc *phReq=%p\n", rc, *phReq));

7b5ad951086f9e0e8ec18d8c7388b9dd619a5b12vboxsync return rc;

8867771015571c5542d39e393d7fe6304421a928vboxsync}

9de47c4ec7b0fc9a384e4b815153de399da7b8devboxsyncRT_EXPORT_SYMBOL(RTReqPoolAlloc);

8867771015571c5542d39e393d7fe6304421a928vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRTDECL(int) RTReqPoolCallEx( RTREQPOOL hPool, RTMSINTERVAL cMillies, PRTREQ *phReq, uint32_t fFlags, PFNRT pfnFunction, unsigned cArgs, ...)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync{

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_list va;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_start(va, cArgs);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync int rc = RTReqPoolCallExV(hPool, cMillies, phReq, fFlags, pfnFunction, cArgs, va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_end(va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return rc;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync}

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRT_EXPORT_SYMBOL(RTReqPoolCallEx);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRTDECL(int) RTReqPoolCallExV(RTREQPOOL hPool, RTMSINTERVAL cMillies, PRTREQ *phReq, uint32_t fFlags, PFNRT pfnFunction, unsigned cArgs, va_list va)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync{

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync /*

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertPtrReturn(pfnFunction, VERR_INVALID_POINTER);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertMsgReturn(!((uint32_t)fFlags & ~(uint32_t)(RTREQFLAGS_NO_WAIT | RTREQFLAGS_RETURN_MASK)), ("%#x\n", (uint32_t)fFlags), VERR_INVALID_PARAMETER);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (!(fFlags & RTREQFLAGS_NO_WAIT))

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync {

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertPtrReturn(phReq, VERR_INVALID_POINTER);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync *phReq = NIL_RTREQ;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync }

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync PRTREQINT pReq = NULL;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync AssertMsgReturn(cArgs * sizeof(uintptr_t) <= sizeof(pReq->u.Internal.aArgs), ("cArgs=%u\n", cArgs), VERR_TOO_MUCH_DATA);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync /*

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync int rc = RTReqPoolAlloc(hPool, RTREQTYPE_INTERNAL, &pReq);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (RT_FAILURE(rc))

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return rc;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pReq->fFlags = fFlags;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pReq->u.Internal.pfn = pfnFunction;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pReq->u.Internal.cArgs = cArgs;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync for (unsigned iArg = 0; iArg < cArgs; iArg++)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pReq->u.Internal.aArgs[iArg] = va_arg(va, uintptr_t);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync /*

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync rc = RTReqSubmit(pReq, cMillies);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if ( rc != VINF_SUCCESS

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync && rc != VERR_TIMEOUT)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync {

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync Assert(rc != VERR_INTERRUPTED);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTReqRelease(pReq);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pReq = NULL;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync }

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (!(fFlags & RTREQFLAGS_NO_WAIT))

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync {

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync *phReq = pReq;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync LogFlow(("RTReqPoolCallExV: returns %Rrc *phReq=%p\n", rc, pReq));

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync }

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync else

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync LogFlow(("RTReqPoolCallExV: returns %Rrc\n", rc));

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return rc;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync}

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRT_EXPORT_SYMBOL(RTReqPoolCallExV);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRTDECL(int) RTReqPoolCallWait(RTREQPOOL hPool, PFNRT pfnFunction, unsigned cArgs, ...)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync{

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync PRTREQINT pReq;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_list va;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_start(va, cArgs);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync int rc = RTReqPoolCallExV(hPool, RT_INDEFINITE_WAIT, &pReq, RTREQFLAGS_IPRT_STATUS,

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pfnFunction, cArgs, va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_end(va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (RT_SUCCESS(rc))

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync rc = pReq->iStatusX;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTReqRelease(pReq);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return rc;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync}

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRT_EXPORT_SYMBOL(RTReqPoolCallWait);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRTDECL(int) RTReqPoolCallNoWait(RTREQPOOL hPool, PFNRT pfnFunction, unsigned cArgs, ...)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync{

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_list va;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_start(va, cArgs);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync int rc = RTReqPoolCallExV(hPool, 0, NULL, RTREQFLAGS_IPRT_STATUS | RTREQFLAGS_NO_WAIT,

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pfnFunction, cArgs, va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_end(va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return rc;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync}

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRT_EXPORT_SYMBOL(RTReqPoolCallNoWait);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRTDECL(int) RTReqPoolCallVoidWait(RTREQPOOL hPool, PFNRT pfnFunction, unsigned cArgs, ...)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync{

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync PRTREQINT pReq;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_list va;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_start(va, cArgs);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync int rc = RTReqPoolCallExV(hPool, RT_INDEFINITE_WAIT, &pReq, RTREQFLAGS_VOID,

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pfnFunction, cArgs, va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_end(va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync if (RT_SUCCESS(rc))

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync rc = pReq->iStatusX;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync RTReqRelease(pReq);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return rc;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync}

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRT_EXPORT_SYMBOL(RTReqPoolCallVoidWait);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRTDECL(int) RTReqPoolCallVoidNoWait(RTREQPOOL hPool, PFNRT pfnFunction, unsigned cArgs, ...)

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync{

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_list va;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_start(va, cArgs);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync int rc = RTReqPoolCallExV(hPool, 0, NULL, RTREQFLAGS_VOID | RTREQFLAGS_NO_WAIT,

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync pfnFunction, cArgs, va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync va_end(va);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync return rc;

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync}

f5edc444546b57af847ae33f2bd1e10442496e47vboxsyncRT_EXPORT_SYMBOL(RTReqPoolCallVoidNoWait);

f5edc444546b57af847ae33f2bd1e10442496e47vboxsync