Home
last modified time | relevance | path

Searched refs:MT_ARRAY_SIZE (Results 1 – 18 of 18) sorted by relevance

/TaskScheduler/SchedulerTests/Tests/
H A DStackSizeTests.cpp40 for (uint32 i = 0; i < MT_ARRAY_SIZE(stackData); i++) in SUITE()
55 for (uint32 i = 0; i < MT_ARRAY_SIZE(stackData); i++) in SUITE()
70 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
80 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
93 for (size_t i = 0; i < MT_ARRAY_SIZE(taskHandles); ++i) in SUITE()
107 scheduler.RunAsync(MT::TaskGroup::Default(), &taskHandles[0], MT_ARRAY_SIZE(taskHandles)); in SUITE()
H A DGroupTests.cpp46 for (size_t i = 0; i < MT_ARRAY_SIZE(tempData); i++) in SUITE()
64 for (size_t i = 0; i < MT_ARRAY_SIZE(tempData); i++) in SUITE()
70 ctx.RunSubtasksAndYield(MT::TaskGroup::Default(), &subtasks[0], MT_ARRAY_SIZE(subtasks)); in SUITE()
85 for (size_t i = 0; i < MT_ARRAY_SIZE(tempData); i++) in SUITE()
91 ctx.RunSubtasksAndYield(MT::TaskGroup::Default(), &subtasks[0], MT_ARRAY_SIZE(subtasks)); in SUITE()
117 scheduler.RunAsync(groupAnim, &dummyAnim[0], MT_ARRAY_SIZE(dummyAnim)); in SUITE()
121 scheduler.RunAsync(groupPhysic, &dummyPhysic[0], MT_ARRAY_SIZE(dummyPhysic)); in SUITE()
H A DWaitTests.cpp56 ctx.RunSubtasksAndYield(testGroup, &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
75 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
80 CHECK_EQUAL(MT_ARRAY_SIZE(tasks) * 2, (size_t)subTaskCountFinisehd); in SUITE()
83 CHECK_EQUAL(MT_ARRAY_SIZE(tasks), (size_t)taskCountFinished); in SUITE()
103 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
121 scheduler.RunAsync(myGroup, &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
164 ctx.RunAsync(secondaryGroup, &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
H A DPlatformTests.cpp164 for(uint32 i = 0; i < MT_ARRAY_SIZE(signalThreads); i++) in SUITE()
169 for(uint32 i = 0; i < MT_ARRAY_SIZE(waitThreads); i++) in SUITE()
174 printf("Signal threads num = %d\n", (uint32)MT_ARRAY_SIZE(signalThreads)); in SUITE()
175 printf("Wait threads num = %d\n", (uint32)MT_ARRAY_SIZE(waitThreads)); in SUITE()
244 for(uint32 i = 0; i < MT_ARRAY_SIZE(waitThreads); i++) in SUITE()
252 for(uint32 i = 0; i < MT_ARRAY_SIZE(signalThreads); i++) in SUITE()
H A DFireAndForget.cpp180 for (size_t i = 0; i < MT_ARRAY_SIZE(tasks); ++i) in SUITE()
185 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
209 for (size_t i = 0; i < MT_ARRAY_SIZE(taskHandles); ++i) in SUITE()
215 scheduler.RunAsync(MT::TaskGroup::Default(), &taskHandles[0], MT_ARRAY_SIZE(taskHandles)); in SUITE()
220 CHECK_EQUAL(MT_ARRAY_SIZE(taskHandles) * 2, (size_t)doCounter.Load()); in SUITE()
221 CHECK_EQUAL(MT_ARRAY_SIZE(taskHandles) * 2, (size_t)dtorCounter.Load()); in SUITE()
H A DPriorityTests.cpp78 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerState), "Invalid worker index"); in SUITE()
107 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerState), "Invalid worker index"); in SUITE()
141 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerState), "Invalid worker index"); in SUITE()
199 for(uint32 i = 0; i < MT_ARRAY_SIZE(workerState); i++) in SUITE()
204 scheduler.RunAsync(MT::TaskGroup::Default(), &taskHandles[0], MT_ARRAY_SIZE(taskHandles)); in SUITE()
H A DSubtasksTests.cpp230 context.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
231 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
248 context.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
249 context.RunSubtasksAndYield(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
H A DCleanupTests.cpp49 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
H A DSimpleTests.cpp89 for (size_t i = 0; i < MT_ARRAY_SIZE(tasks); ++i) in SUITE()
92 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks)); in SUITE()
142 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerStates), "Invalid worker index"); in SUITE()
H A DDxtTests.cpp136 …MT_ASSERT(index >= 0 && ((size_t)(index + 2) < MT_ARRAY_SIZE(EmbeddedImage::lenaColor)), "Invalid … in SUITE()
295 …MT_ASSERT(index >= 0 && ((size_t)(index + 2) < MT_ARRAY_SIZE(EmbeddedImage::lenaColor)), "Invalid … in SUITE()
474 static_assert(MT_ARRAY_SIZE(EmbeddedImage::lenaColor) == 49152, "Image size is invalid"); in SUITE()
478 …MT::ArrayView<uint8> srcImage((void*)&EmbeddedImage::lenaColor[0], MT_ARRAY_SIZE(EmbeddedImage::le… in SUITE()
519 …CompareImagesPSNR(&srcImage[0], &decompressTask.decompressedImage[0], MT_ARRAY_SIZE(EmbeddedImage:… in SUITE()
H A DFoundationTests.cpp44 size_t elementsCount = ringBuffer.PopAll(tempData, MT_ARRAY_SIZE(tempData)); in SUITE()
56 elementsCount = ringBuffer.PopAll(tempData, MT_ARRAY_SIZE(tempData)); in SUITE()
H A DAtomicTests.cpp213 uint32 threadsCount = MT_ARRAY_SIZE(threads); in SUITE()
/TaskScheduler/Scheduler/Include/
H A DMTTaskQueue.h222 for(uint32 i = 0; i < MT_ARRAY_SIZE(queues); i++) in TaskQueue()
243 for(size_t i = 0; i < MT_ARRAY_SIZE(queues); i++) in Add()
258 MT_ASSERT(queueIndex < MT_ARRAY_SIZE(queues), "Invalid task priority"); in Add()
H A DMTPlatform.h30 #define MT_ARRAY_SIZE( arr ) ( sizeof( arr ) / sizeof( (arr)[0] ) ) macro
/TaskScheduler/Scheduler/Source/
H A DMTThreadContext.cpp38 return primeNumbers[index % MT_ARRAY_SIZE(primeNumbers)]; in GetPrimeNumber()
H A DMTScheduler.cpp376 if (context.workerIndex < MT_ARRAY_SIZE(threadNames)) in WorkerThreadMain()
/TaskScheduler/SchedulerTests/Profiler/
H A DProfiler.cpp32 MT_ASSERT(fibersCount <= MT_ARRAY_SIZE(fiberEventStorages), "Too many fibers!"); in OnFibersCreated()
/TaskScheduler/
H A DREADME.md48 scheduler.RunAsync(MT::TaskGroup::Default(), &tasks[0], MT_ARRAY_SIZE(tasks));