Changeset 39510 in vbox for trunk/src/VBox/Runtime/common/misc/reqpool.cpp

Timestamp:

Dec 2, 2011 10:58:29 AM (13 years ago)

Author:

vboxsync

Message:

laptop -> workstation.

File:

• trunk/src/VBox/Runtime/common/misc/reqpool.cpp (modified) (2 diffs)

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

@@ -34 +34 @@
 #include <iprt/assert.h>
 #include <iprt/asm.h>
+#include <iprt/critsect.h>
+#include <iprt/list.h>
+#include <iprt/log.h>
+#include <iprt/mem.h>
 #include <iprt/string.h>
 #include <iprt/time.h>
 #include <iprt/semaphore.h>
 #include <iprt/thread.h>
-#include <iprt/log.h>
-#include <iprt/mem.h>
 
 #include "internal/req.h"
@@ -45 +47 @@
 
 
+/*******************************************************************************
+*   Structures and Typedefs                                                    *
+*******************************************************************************/
+typedef struct RTREQPOOLTHREAD
+{
+    /** Node in the  RTREQPOOLINT::IdleThreads list. */
+    RTLISTNODE              IdleNode;
+    /** Node in the  RTREQPOOLINT::WorkerThreads list. */
+    RTLISTNODE              ListNode;
+
+    /** The submit timestamp of the pending request. */
+    uint64_t                uPendingNanoTs;
+    /** When this CPU went idle the last time. */
+    uint64_t                uIdleNanoTs;
+    /** The number of requests processed by this thread. */
+    uint64_t                cReqProcessed;
+    /** Total time the requests processed by this thread took to process. */
+    uint64_t                cNsTotalReqProcessing;
+    /** Total time the requests processed by this thread had to wait in
+     * the queue before being scheduled. */
+    uint64_t                cNsTotalReqQueued;
+    /** The CPU this was scheduled last time we checked. */
+    RTCPUID                 idLastCpu;
+
+    /** The thread handle. */
+    RTTHREAD                hThread;
+
+    /** The submitter will put an incoming request here when scheduling an idle
+     * thread.  */
+    PRTREQINT volatile      pTodoReq;
+    /** The request the thread is currently processing. */
+    PRTREQINT volatile      pPendingReq;
+
+} RTREQPOOLTHREAD;
+
+typedef struct RTREQPOOLINT
+{
+    /** Magic value (RTREQPOOL_MAGIC). */
+    uint32_t                u32Magic;
+
+    /** The current number of worker threads. */
+    uint32_t                cCurThreads;
+    /** The maximum number of worker threads. */
+    uint32_t                cMaxThreads;
+    /** The number of threads which should be spawned before throttling kicks
+     * in. */
+    uint32_t                cThreadsThreshold;
+    /** The minimum number of worker threads. */
+    uint32_t                cMinThreads;
+    /** The number of milliseconds a thread needs to be idle before it is
+     * considered for retirement. */
+    uint32_t                cMsMinIdle;
+
+    /** Statistics: The total number of threads created. */
+    uint32_t                cThreadsCreated;
+    /** Statistics: The timestamp when the last thread was created. */
+    uint64_t                uLastThreadCreateNanoTs;
+    /** Linked list of worker threads. */
+    RTLISTANCHOR            WorkerThreads;
+
+    /** Critical section serializing access to members of this structure.  */
+    RTCRITSECT              CritSect;
+
+    /** Reference counter. */
+    uint32_t volatile       cRefs;
+    /** Linked list of idle threads. */
+    RTLISTANCHOR            IdleThreads;
+
+
+} RTREQPOOLINT;
+/** Pointer to a request thread pool instance. */
+typedef RTREQPOOLINT *PRTREQPOOLINT;
+