Home
last modified time | relevance | path

Searched refs:MT (Results 1 – 25 of 61) sorted by relevance

123

/TaskScheduler/SchedulerTests/Tests/
H A DSubtasksTests.cpp46 …MT_DECLARE_TASK(DeepSubtaskQueue<N>, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT… in SUITE()
67 …MT_DECLARE_TASK(DeepSubtaskQueue<0>, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT… in SUITE()
70 void Do(MT::FiberContext&) in SUITE()
80 …MT_DECLARE_TASK(DeepSubtaskQueue<1>, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT… in SUITE()
109 …MT_DECLARE_TASK(GroupSubtask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color… in SUITE()
119 …MT_DECLARE_TASK(GroupTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::B… in SUITE()
130 …MT_DECLARE_TASK(TaskWithManySubtasks, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, M… in SUITE()
207 …MT_DECLARE_TASK(TaskSubtaskCombo_Sum1, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, … in SUITE()
219 …MT_DECLARE_TASK(TaskSubtaskCombo_Sum4, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, … in SUITE()
237 …MT_DECLARE_TASK(TaskSubtaskCombo_Sum16, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL,… in SUITE()
[all …]
H A DWaitTests.cpp35 MT::TaskGroup testGroup; in SUITE()
39 …MT_DECLARE_TASK(Subtask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::Blu… in SUITE()
41 void Do(MT::FiberContext&) in SUITE()
51 MT_DECLARE_TASK(Task, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::Blue); in SUITE()
70 MT::TaskScheduler scheduler; in SUITE()
90 …MT_DECLARE_TASK(LongTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::Bl… in SUITE()
92 void Do(MT::FiberContext&) in SUITE()
94 MT::Thread::Sleep(1); in SUITE()
140 …MT_DECLARE_TASK(SecondaryTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Colo… in SUITE()
142 void Do(MT::FiberContext&) in SUITE()
[all …]
H A DFireAndForget.cpp38 …MT_DECLARE_TASK(SimpleTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::… in SUITE()
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()
76 void Do(MT::FiberContext& context) in SUITE()
152 …MT_DECLARE_TASK(ThreadTest, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::… in SUITE()
156 void Do(MT::FiberContext&) in SUITE()
177 MT::TaskScheduler scheduler; in SUITE()
195 MT::Atomic32<int32> doCounter(0); in SUITE()
198 MT::TaskScheduler scheduler; in SUITE()
[all …]
H A DSimpleTests.cpp33 …MT_DECLARE_TASK(SimpleTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::… in SUITE()
40 void Do(MT::FiberContext&) in SUITE()
54 MT::TaskScheduler scheduler; in SUITE()
67 …MT_DECLARE_TASK(ALotOfTasks, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color:… in SUITE()
69 MT::Atomic32<int32>* counter; in SUITE()
71 void Do(MT::FiberContext&) in SUITE()
81 MT::TaskScheduler scheduler; in SUITE()
83 MT::Atomic32<int32> counter; in SUITE()
132 …MT_DECLARE_TASK(YieldTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::B… in SUITE()
175 MT::TaskScheduler scheduler(0, nullptr, nullptr, MT::TaskStealingMode::DISABLED); in SUITE()
[all …]
H A DStackSizeTests.cpp32 …MT_DECLARE_TASK(StandartStackSizeTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, … in SUITE()
34 void Do(MT::FiberContext&) in SUITE()
50 …MT_DECLARE_TASK(ExtendedStackSizeTask, MT::StackRequirements::EXTENDED, MT::TaskPriority::NORMAL, … in SUITE()
52 void Do(MT::FiberContext&) in SUITE()
67 MT::TaskScheduler scheduler; in SUITE()
77 MT::TaskScheduler scheduler; in SUITE()
87 MT::TaskScheduler scheduler; in SUITE()
89 MT::TaskPool<ExtendedStackSizeTask, 64> extendedTaskPool; in SUITE()
90 MT::TaskPool<StandartStackSizeTask, 64> standardTaskPool; in SUITE()
92 MT::TaskHandle taskHandles[100]; in SUITE()
[all …]
H A DScopesTests.cpp47 static MT::PersistentScopeDescriptorStorage<MT::ScopeDesc, 128>* globalScopesStorage = nullptr; in SUITE()
54 int32 descId = MT::invalidStackId; in SUITE()
90 globalScopesStorage = new MT::PersistentScopeDescriptorStorage<MT::ScopeDesc, 128>(); in SUITE()
108 MT::WeakScopeStack<MT::ScopeStackEntry, 64> weakStack; in SUITE()
114 MT::ScopeStackEntry* pInstance = weakStack.Push(parentId, MT::invalidStorageId); in SUITE()
150 MT::StrongScopeStack<MT::ScopeStackEntry, 64> strongStack; in SUITE()
156 MT::ScopeStackEntry* pInstance = strongStack.Push(parentId, MT::invalidStorageId); in SUITE()
200 MT::ScopeStackEntry* pInstance3 = strongStack.Push(parentId, MT::invalidStorageId); in SUITE()
212 MT::PersistentScopeDescriptorStorage<MT::ScopeDesc, 128> persistentStorage; in SUITE()
220 CHECK(id1 != MT::invalidStorageId); in SUITE()
[all …]
H A DPlatformTests.cpp47 MT::Thread thread; in SUITE()
66 MT::Event event1; in SUITE()
70 MT::Event event2; in SUITE()
74 MT::Thread thread; in SUITE()
100 MT::AtomicPtrBase<MT::Event> pStressEvent = { nullptr }; in SUITE()
151 MT::Event stressEvent; in SUITE()
153 MT::Thread waitThreads[3]; in SUITE()
186 MT::Thread::Sleep(150); in SUITE()
232 MT::Thread::Sleep(150); in SUITE()
249 MT::Thread::Sleep(100); in SUITE()
[all …]
H A DGroupTests.cpp33 MT::Atomic32<int32> subtaskCount(0); in SUITE()
34 MT::Atomic32<int32> animTaskCount(0); in SUITE()
35 MT::Atomic32<int32> physTaskCount(0); in SUITE()
40 …MT_DECLARE_TASK(DummySubTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color… in SUITE()
44 void Do(MT::FiberContext& ) in SUITE()
58 …MT_DECLARE_TASK(DummyAnimTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Colo… in SUITE()
62 void Do(MT::FiberContext& ctx) in SUITE()
79 …MT_DECLARE_TASK(DummyPhysicTask, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Co… in SUITE()
83 void Do(MT::FiberContext& ctx) in SUITE()
107 MT::TaskScheduler scheduler; in SUITE()
[all …]
H A DDxtTests.cpp78 …MT_DECLARE_TASK(CompressDxtBlock, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::C… in SUITE()
80 MT::ArrayView<uint8> srcPixels; in SUITE()
81 MT::ArrayView<uint8> dstBlocks; in SUITE()
121 void Do(MT::FiberContext&) in SUITE()
157 …MT_DECLARE_TASK(CompressDxt, MT::StackRequirements::EXTENDED, MT::TaskPriority::NORMAL, MT::Color:… in SUITE()
168 MT::ArrayView<uint8> srcPixels; in SUITE()
232 …MT_DECLARE_TASK(DecompressDxtBlock, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT:… in SUITE()
276 void Do(MT::FiberContext&) in SUITE()
309 …MT_DECLARE_TASK(DecompressDxt, MT::StackRequirements::EXTENDED, MT::TaskPriority::NORMAL, MT::Colo… in SUITE()
326 decompressedImage = MT::ArrayView<uint8>( MT::Memory::Alloc(bytesCount), bytesCount); in SUITE()
[all …]
H A DFiberTests.cpp39 MT::Atomic32<int32> counter(0); in SUITE()
40 MT::Fiber* fiberMain = nullptr; in SUITE()
47 MT::Fiber* currentFiber = (MT::Fiber*)userData; in SUITE()
58 endTime = MT::GetTimeMicroSeconds(); in SUITE()
64 MT::Fiber fiber1; in SUITE()
68 MT::Fiber::SwitchTo(*fiberMain, fiber1); in SUITE()
87 MT::Fiber fiber1; in SUITE()
90 startTime = MT::GetTimeMicroSeconds(); in SUITE()
96 startTime = MT::GetTimeMicroSeconds(); in SUITE()
100 MT::Fiber fiber2; in SUITE()
[all …]
H A DCleanupTests.cpp34 …MT_DECLARE_TASK(NotFinishedTaskDestroy, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL,… in SUITE()
36 void Do(MT::FiberContext&) in SUITE()
38 MT::SpinSleepMilliSeconds(4); in SUITE()
45 MT::TaskScheduler scheduler; in SUITE()
49 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
H A DPriorityTests.cpp36 MT::Atomic32<int32> switchCountToNormal; in SUITE()
37 MT::Atomic32<int32> switchCountToLow; in SUITE()
66 …MT_DECLARE_TASK(TaskHigh, MT::StackRequirements::STANDARD, MT::TaskPriority::HIGH, MT::Color::Blue… in SUITE()
75 void Do(MT::FiberContext& ctx) in SUITE()
95 …MT_DECLARE_TASK(TaskNormal, MT::StackRequirements::STANDARD, MT::TaskPriority::NORMAL, MT::Color::… in SUITE()
104 void Do(MT::FiberContext& ctx) in SUITE()
128 MT_DECLARE_TASK(TaskLow, MT::StackRequirements::STANDARD, MT::TaskPriority::LOW, MT::Color::Blue); in SUITE()
138 void Do(MT::FiberContext& ctx) in SUITE()
169 MT::TaskScheduler scheduler(0, nullptr, nullptr, MT::TaskStealingMode::DISABLED); in SUITE()
171 MT::TaskScheduler scheduler(0, nullptr, MT::TaskStealingMode::DISABLED); in SUITE()
[all …]
H A DAtomicTests.cpp64 MT::Atomic32<int32> test_relaxed; in SUITE()
68 MT::Atomic32<int32> test; in SUITE()
85 MT::Atomic32<int32> test2(VALUE); in SUITE()
112 MT::AtomicPtr<char> atomicPtrRelaxed; in SUITE()
116 MT::AtomicPtr<char> atomicPtr; in SUITE()
136 MT::Atomic32<uint32> isReady; in SUITE()
137 MT::Atomic32<uint32> a; in SUITE()
138 MT::Atomic32<uint32> b; in SUITE()
142 MT::Atomic32<uint32> simpleLock; in SUITE()
148 MT::SpinWait spinWait; in SUITE()
[all …]
H A DFoundationTests.cpp38 MT::ConcurrentRingBuffer<int, 32> ringBuffer; in SUITE()
71 MT::StaticVector<int, elementsCount> stackArray; in SUITE()
98 MT::LockFreeQueueMPMC<int, 32> queue; in SUITE()
162 MT::ArrayView<int> emptyArrayView(nullptr, 0); in SUITE()
166 void* rawMemory = MT::Memory::Alloc(sizeof(int) * elementsCount); in SUITE()
168 MT::ArrayView<int> arrayView(rawMemory, elementsCount); in SUITE()
182 MT::Memory::Free(rawMemory); in SUITE()
/TaskScheduler/Scheduler/Include/
H A DMTTaskDesc.h32 namespace MT
56 MT::StackRequirements::Type stackRequirements;
59 MT::TaskPriority::Type priority;
63 MT::Color::Type debugColor;
70 , stackRequirements(MT::StackRequirements::INVALID) in TaskDesc()
71 , priority(MT::TaskPriority::INVALID) in TaskDesc()
75 debugColor = MT::Color::Blue; in TaskDesc()
79 …(TTaskEntryPoint _taskFunc, const void* _userData, MT::StackRequirements::Type _stackRequirements,… in TaskDesc()
88 debugColor = MT::Color::Blue; in TaskDesc()
97 , priority(MT::TaskPriority::INVALID) in TaskDesc()
[all …]
H A DMTScheduler.h45 namespace MT
80 …MT::CheckType< typename std::remove_pointer< decltype(MT::TypeChecker::QueryThisType(this)) >::typ…
91 typedef decltype(MT::TypeChecker::QueryThisType(this)) THIS_PTR_TYPE; \
97 MT::CheckType< CPP_TYPE, MACRO_TYPE > compileTypeTypesCheck; \
125 MT::CallDtor( task ); \
127 …MT::PoolElementHeader * poolHeader = (MT::PoolElementHeader *)((char*)userData - sizeof(MT::PoolEl…
129 poolHeader->id.Store(MT::TaskID::UNUSED); \
132 static MT::StackRequirements::Type GetStackRequirements() \
136 static MT::TaskPriority::Type GetTaskPriority() \
152 static MT::Color::Type GetDebugColor() \
[all …]
H A DMTPlatform.h32 namespace MT
57 namespace MT
64 MT::Mutex & mutex;
71 ScopedGuard(MT::Mutex & _mutex) : mutex(_mutex) in ScopedGuard()
H A DMTTools.h27 namespace MT
53 Timer() : startMicroSeconds(MT::GetTimeMicroSeconds()) in Timer()
59 return (uint32)(MT::GetTimeMicroSeconds() - startMicroSeconds); in GetPastMicroSeconds()
64 return (uint32)((MT::GetTimeMicroSeconds() - startMicroSeconds) / 1000); in GetPastMilliSeconds()
H A DMTConcurrentRingBuffer.h29 namespace MT
45 MT::Mutex mutex;
98 MT::ScopedGuard guard(mutex); in Push()
116 MT::ScopedGuard guard(mutex); in PopAll()
119 elementsCount = MT::Min(elementsCount, dstBufferSize); in PopAll()
H A DMTThreadContext.h34 #define MT_SYSTEM_TASK_COLOR (MT::Color::Yellow)
42 namespace MT
127 …void NotifyTaskExecuteStateChanged(MT::Color::Type debugColor, const mt_char* debugID, TaskExecute…
H A DMTProfilerEventListener.h29 namespace MT
74 …virtual void OnTaskExecuteStateChanged(MT::Color::Type debugColor, const mt_char* debugID, TaskExe…
/TaskScheduler/Scheduler/Include/Platform/Common/
H A DMTSpinWait.h26 namespace MT
65 MT::YieldProcessor(); in SpinOnce()
72 MT::YieldProcessor(); in SpinOnce()
78 MT::YieldThread(); in SpinOnce()
83 MT::Thread::Sleep(0); in SpinOnce()
86 MT::Thread::Sleep(1); in SpinOnce()
/TaskScheduler/SchedulerTests/Profiler/
H A DProfiler.cpp14 class ProfilerEventListener : public MT::IProfilerEventListener
16 …Brofiler::EventStorage* fiberEventStorages[MT::MT_MAX_STANDART_FIBERS_COUNT + MT::MT_MAX_EXTENDED_…
110 …virtual void OnTaskExecuteStateChanged(MT::Color::Type debugColor, const mt_char* debugID, MT::Tas… in OnTaskExecuteStateChanged()
135 case MT::TaskExecuteState::START: in OnTaskExecuteStateChanged()
136 case MT::TaskExecuteState::RESUME: in OnTaskExecuteStateChanged()
152 Brofiler::FiberSyncData::AttachToThread(currentFiberStorage, MT::ThreadId::Self().AsUInt64()); in OnTaskExecuteStateChanged()
156 case MT::TaskExecuteState::STOP: in OnTaskExecuteStateChanged()
157 case MT::TaskExecuteState::SUSPEND: in OnTaskExecuteStateChanged()
193 MT::IProfilerEventListener* GetProfiler() in GetProfiler()
H A DProfiler.h23 namespace MT
29 MT::IProfilerEventListener* GetProfiler();
/TaskScheduler/Scheduler/Include/Platform/Windows/
H A DMTMutex.h28 namespace MT
53 friend class MT::ScopedGuard;

123