| /TaskScheduler/Scheduler/Include/Scopes/ |
| H A D | MTScopes.h | 51 int32 line;
92 ScopeStackEntry(int32 _parentIndex, int32 _descIndex) in ScopeStackEntry()
179 int32 id; in Alloc()
193 int32 id; in Alloc()
206 int32 id; in Alloc()
219 int32 id; in Alloc()
256 int32 top;
303 int32 Top() in Top()
376 int32 top;
430 int32 Top() in Top()
[all …]
|
| /TaskScheduler/Scheduler/Include/Platform/Common/ |
| H A D | MTSpinWait.h | 36 int32 iteration;
40 static const int32 YIELD_CPU_THRESHOLD = 10;
41 static const int32 YIELD_CPU_THRESHOLD2 = 20;
42 static const int32 YIELD_THREAD_THRESHOLD = 40;
43 static const int32 YIELD_SLEEP0_THRESHOLD = 200;
61 int32 SpinOnce() in SpinOnce()
70 for (int32 i = 0; i < 50; i++) in SpinOnce()
92 int32 retValue = iteration; in SpinOnce()
|
| /TaskScheduler/Scheduler/Include/ |
| H A D | MTQueueMPMC.h | 39 static const int32 ALIGNMENT = 16;
40 static const int32 ALIGNMENT_MASK = (ALIGNMENT-1);
101 int32 dif = (int32)seq - (int32)pos; in TryPush()
142 int32 dif = (int32)seq - (int32)(pos + 1); in TryPop()
|
| H A D | MTScheduler.h | 228 Atomic32<int32> inProgressTaskCount;
246 int32 GetTaskCount() const in GetTaskCount()
251 int32 Dec() in Dec()
256 int32 Inc() in Inc()
261 int32 Add(int sum) in Add()
266 Atomic32<int32>* GetWaitCounter() in GetWaitCounter()
287 Atomic32<int32>* waitCounter;
295 Atomic32<int32> roundRobinThreadIndex;
298 Atomic32<int32> startedThreadsCount;
304 Atomic32<int32> threadsCount;
[all …]
|
| H A D | MTThreadContext.h | 37 #define MT_SYSTEM_FIBER_INDEX (int32)(-1)
99 Atomic32<int32> state;
127 …MT::Color::Type debugColor, const mt_char* debugID, TaskExecuteState::Type type, int32 fiberIndex);
|
| H A D | MTTypes.h | 59 typedef int32_t int32; typedef
86 static_assert( sizeof(int32) == 4, "Invalid type size, int32" );
|
| H A D | MTStaticVector.h | 34 static const int32 ALIGNMENT = 16;
35 static const int32 ALIGNMENT_MASK = (ALIGNMENT-1);
41 inline T* IndexToObject(int32 index) in IndexToObject()
|
| H A D | MTTaskPool.h | 48 Atomic32<int32> id;
108 int32 check_id;
235 static const int32 ALIGNMENT = 16;
243 Atomic32<int32> idGenerator;
244 Atomic32<int32> index;
|
| H A D | MTProfilerEventListener.h | 74 …Color::Type debugColor, const mt_char* debugID, TaskExecuteState::Type type, int32 fiberIndex) = 0;
|
| H A D | MTFiberContext.h | 110 Atomic32<int32> childrenFibersCount;
|
| H A D | MTConcurrentRingBuffer.h | 43 static const int32 ALIGNMENT = 16;
|
| /TaskScheduler/SchedulerTests/Tests/ |
| H A D | SimpleTests.cpp | 69 MT::Atomic32<int32>* counter; in SUITE()
83 MT::Atomic32<int32> counter; in SUITE()
182 int32 workersCount = scheduler.GetWorkersCount(); in SUITE()
184 int32 taskCount = workersCount * TASK_COUNT_PER_WORKER; in SUITE()
189 for(int32 i = 0; i < taskCount; i++) in SUITE()
194 for(int32 i = 0; i < workersCount; i++) in SUITE()
205 for(int32 i = 0; i < workersCount; i++) in SUITE()
213 CHECK_EQUAL(taskCount, (int32)finishedTaskCount.Load()); in SUITE()
|
| H A D | ScopesTests.cpp | 36 AssetStackEntry(int32 parentIndex, int32 descIndex, const char* _assetName) in SUITE()
54 int32 descId = MT::invalidStackId; in SUITE()
64 int32 parentStackId = stackTop->GetParentId(); in SUITE()
68 int32 innerDescId = MT::invalidStackId; in SUITE()
126 int32 testStorageId = 3; in SUITE()
168 int32 testStorageId = 3; in SUITE()
215 int32 srcLine = __LINE__; in SUITE()
219 int32 id1 = persistentStorage.Alloc(srcFile, srcLine, scopeName1); in SUITE()
222 int32 id2 = persistentStorage.Alloc(srcFile, srcLine, scopeName2); in SUITE()
|
| H A D | WaitTests.cpp | 32 MT::Atomic32<int32> subTaskCount; in SUITE()
33 MT::Atomic32<int32> taskCount; in SUITE()
110 int32 waitTime = (int32)(endTime - startTime); in SUITE()
128 int32 waitTime = (int32)(endTime - startTime); in SUITE()
|
| H A D | FireAndForget.cpp | 40 MT::Atomic32<int32>* doCounter; in SUITE()
41 MT::Atomic32<int32>* dtorCounter; in SUITE()
51 …SimpleTask(MT::Atomic32<int32>* _doCounter, MT::Atomic32<int32>* _dtorCounter, TestPoolType * _tas… in SUITE()
195 MT::Atomic32<int32> doCounter(0); in SUITE()
196 MT::Atomic32<int32> dtorCounter(0); in SUITE()
|
| H A D | PriorityTests.cpp | 36 MT::Atomic32<int32> switchCountToNormal; in SUITE()
37 MT::Atomic32<int32> switchCountToLow; in SUITE()
207 int32 workersCount = scheduler.GetWorkersCount(); in SUITE()
216 for(int32 j = 0; j < workersCount; j++) in SUITE()
227 for(int32 j = 0; j < workersCount; j++) in SUITE()
|
| H A D | GroupTests.cpp | 33 MT::Atomic32<int32> subtaskCount(0); in SUITE()
34 MT::Atomic32<int32> animTaskCount(0); in SUITE()
35 MT::Atomic32<int32> physTaskCount(0); in SUITE()
|
| H A D | AtomicTests.cpp | 50 static MT::Atomic32Base<int32> test = { 0 }; in SUITE()
64 MT::Atomic32<int32> test_relaxed; in SUITE()
68 MT::Atomic32<int32> test; in SUITE()
85 MT::Atomic32<int32> test2(VALUE); in SUITE()
|
| H A D | SubtasksTests.cpp | 209 MT::Atomic32<int32>* data; in SUITE()
221 MT::Atomic32<int32>* data; in SUITE()
239 MT::Atomic32<int32>* data; in SUITE()
253 MT::Atomic32<int32> sum; in SUITE()
|
| H A D | FiberTests.cpp | 39 MT::Atomic32<int32> counter(0); in SUITE()
|
| /TaskScheduler/Scheduler/Source/ |
| H A D | MTScheduler.cpp | 103 int32 totalThreadsCount = GetWorkersCount(); in TaskScheduler()
109 for (int32 i = 0; i < totalThreadsCount; i++) in TaskScheduler()
130 int32 totalThreadsCount = GetWorkersCount(); in JoinWorkerThreads()
131 for (int32 i = 0; i < totalThreadsCount; i++) in JoinWorkerThreads()
137 for (int32 i = 0; i < totalThreadsCount; i++) in JoinWorkerThreads()
419 int32 groupTaskCount = waitContext.waitCounter->Load(); in SchedulerFiberWait()
742 int32 taskCount = groupDesc.GetTaskCount(); in WaitGroup()
777 int32 taskCount = allGroups.GetTaskCount(); in WaitAll()
818 int32 TaskScheduler::GetWorkersCount() const in GetWorkersCount()
826 int32 threadsCount = GetWorkersCount(); in IsWorkerThread()
[all …]
|
| H A D | MTFiberContext.cpp | 81 …hanged( currentTask.debugColor, currentTask.debugID, TaskExecuteState::SUSPEND, (int32)fiberIndex); in Yield()
91 …Changed( currentTask.debugColor, currentTask.debugID, TaskExecuteState::RESUME, (int32)fiberIndex); in Yield()
114 …hanged( currentTask.debugColor, currentTask.debugID, TaskExecuteState::SUSPEND, (int32)fiberIndex); in RunSubtasksAndYieldImpl()
124 …Changed( currentTask.debugColor, currentTask.debugID, TaskExecuteState::RESUME, (int32)fiberIndex); in RunSubtasksAndYieldImpl()
|
| /TaskScheduler/SchedulerTests/Profiler/ |
| H A D | Profiler.cpp | 110 …Type debugColor, const mt_char* debugID, MT::TaskExecuteState::Type type, int32 fiberIndex) overri… in OnTaskExecuteStateChanged()
116 MT_ASSERT(fiberIndex < (int32)totalFibersCount, "Sanity check failed"); in OnTaskExecuteStateChanged()
145 if (fiberIndex >= (int32)0) in OnTaskExecuteStateChanged()
163 if (fiberIndex >= (int32)0) in OnTaskExecuteStateChanged()
|
| /TaskScheduler/Scheduler/Include/Platform/Windows/ |
| H A D | MTAtomic.h | 36 static_assert(sizeof(T) == sizeof(int32), "Atomic32Base, type T must be equal size as int32"); \
37 static_assert(sizeof(int32) == sizeof(long), "Incompatible types, Interlocked* will fail.");
|
| H A D | MTEventUser.h | 44 volatile int32 value;
|