Home
last modified time | relevance | path

Searched refs:workerIndex (Results 1 – 7 of 7) sorted by relevance

/TaskScheduler/Scheduler/Include/
H A DMTProfilerEventListener.h47 virtual void OnThreadCreated(uint32 workerIndex) = 0;
50 virtual void OnThreadStarted(uint32 workerIndex) = 0;
53 virtual void OnThreadStoped(uint32 workerIndex) = 0;
56 virtual void OnThreadIdleStarted(uint32 workerIndex) = 0;
59 virtual void OnThreadIdleFinished(uint32 workerIndex) = 0;
H A DMTThreadContext.h105 uint32 workerIndex; member
/TaskScheduler/SchedulerTests/Profiler/
H A DProfiler.cpp75 virtual void OnThreadCreated(uint32 workerIndex) override in OnThreadCreated() argument
78 MT_UNUSED(workerIndex); in OnThreadCreated()
81 virtual void OnThreadStarted(uint32 workerIndex) override in OnThreadStarted() argument
83 MT_UNUSED(workerIndex); in OnThreadStarted()
86 virtual void OnThreadStoped(uint32 workerIndex) override in OnThreadStoped() argument
88 MT_UNUSED(workerIndex); in OnThreadStoped()
92 virtual void OnThreadIdleStarted(uint32 workerIndex) override in OnThreadIdleStarted() argument
94 MT_UNUSED(workerIndex); in OnThreadIdleStarted()
97 virtual void OnThreadIdleFinished(uint32 workerIndex) override in OnThreadIdleFinished() argument
99 MT_UNUSED(workerIndex); in OnThreadIdleFinished()
/TaskScheduler/SchedulerTests/Tests/
H A DPriorityTests.cpp77 uint32 workerIndex = ctx.GetThreadContext()->workerIndex; in SUITE() local
78 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerState), "Invalid worker index"); in SUITE()
79 ThreadState& state = workerState[workerIndex]; in SUITE()
106 uint32 workerIndex = ctx.GetThreadContext()->workerIndex; in SUITE() local
107 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerState), "Invalid worker index"); in SUITE()
108 ThreadState& state = workerState[workerIndex]; in SUITE()
140 uint32 workerIndex = ctx.GetThreadContext()->workerIndex; in SUITE() local
141 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerState), "Invalid worker index"); in SUITE()
142 ThreadState& state = workerState[workerIndex]; in SUITE()
H A DSimpleTests.cpp140 volatile WorkerThreadState* GetWorkerState( volatile uint32 workerIndex) volatile in SUITE()
142 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerStates), "Invalid worker index"); in SUITE()
143 volatile WorkerThreadState& state = workerStates[workerIndex]; in SUITE()
149 volatile WorkerThreadState* state0 = GetWorkerState( context.GetThreadContext()->workerIndex ); in SUITE()
157 volatile WorkerThreadState* state1 = GetWorkerState( context.GetThreadContext()->workerIndex ); in SUITE()
/TaskScheduler/Scheduler/Source/
H A DMTThreadContext.cpp48 , workerIndex(0) in ThreadContext()
59 , workerIndex(0) in ThreadContext()
81 workerIndex = threadIndex; in SetThreadIndex()
H A DMTScheduler.cpp350 if (index == threadContext.workerIndex) in TryStealTask()
376 if (context.workerIndex < MT_ARRAY_SIZE(threadNames)) in WorkerThreadMain()
378 Thread::SetThreadName(threadNames[context.workerIndex]); in WorkerThreadMain()
448 context.NotifyThreadCreated(context.workerIndex); in SchedulerFiberMain()
470 context.NotifyThreadStarted(context.workerIndex); in SchedulerFiberMain()
480 context.NotifyThreadIdleStarted(context.workerIndex); in SchedulerFiberMain()
500 context.NotifyThreadIdleFinished(context.workerIndex); in SchedulerFiberMain()
510 context.NotifyThreadIdleFinished(context.workerIndex); in SchedulerFiberMain()
525 context.NotifyThreadIdleFinished(context.workerIndex); in SchedulerFiberMain()
536 context.NotifyThreadStoped(context.workerIndex); in SchedulerFiberMain()