| /TaskScheduler/Scheduler/Include/Platform/Posix/ |
| H A D | MTEvent.h | 88 MT_ASSERT(res == 0, "pthread_cond_destroy - failed"); in ~Event() 104 MT_ASSERT(res == 0, "pthread_mutex_init - failed"); in Create() 108 MT_ASSERT(res == 0, "pthread_cond_init - failed"); in Create() 117 MT_ASSERT (isInitialized, "Event not initialized"); in Signal() 121 MT_ASSERT(res == 0, "pthread_mutex_lock - failed"); in Signal() 141 MT_ASSERT(res == 0, "pthread_mutex_unlock - failed"); in Signal() 146 MT_ASSERT (isInitialized, "Event not initialized"); in Reset() 151 MT_ASSERT(res == 0, "pthread_mutex_lock - failed"); in Reset() 157 MT_ASSERT(res == 0, "pthread_mutex_unlock - failed"); in Reset() 163 MT_ASSERT (isInitialized, "Event not initialized"); in Wait() [all …]
|
| H A D | MTFiber.h | 83 MT_ASSERT(pFiber != nullptr, "Invalid fiber"); in FiberFuncInternal() 86 MT_ASSERT(self->isInitialized == true, "Using non initialized fiber"); in FiberFuncInternal() 88 MT_ASSERT(self->func != nullptr, "Invalid fiber func"); in FiberFuncInternal() 126 MT_ASSERT(!isInitialized, "Already initialized"); in CreateFromCurrentThreadAndRun() 134 MT_ASSERT(res == 0, "getcontext - failed"); in CreateFromCurrentThreadAndRun() 147 MT_ASSERT(!isInitialized, "Already initialized"); in Create() 148 MT_ASSERT(stackSize >= PTHREAD_STACK_MIN, "Stack to small"); in Create() 155 MT_ASSERT(res == 0, "getcontext - failed"); in Create() 180 MT_ASSERT(from.isInitialized, "Invalid from fiber"); in SwitchTo() 181 MT_ASSERT(to.isInitialized, "Invalid to fiber"); in SwitchTo() [all …]
|
| H A D | MTMutex.h | 51 MT_ASSERT(res == 0, "pthread_mutexattr_init - failed"); in Mutex() 55 MT_ASSERT(res == 0, "pthread_mutexattr_settype - failed"); in Mutex() 59 MT_ASSERT(res == 0, "pthread_mutex_init - failed"); in Mutex() 66 MT_ASSERT(res == 0, "pthread_mutex_destroy - failed"); in ~Mutex() 70 MT_ASSERT(res == 0, "pthread_mutexattr_destroy - failed"); in ~Mutex() 81 MT_ASSERT(res == 0, "pthread_mutex_lock - failed"); in Lock() 87 MT_ASSERT(res == 0, "pthread_mutex_unlock - failed"); in Unlock()
|
| H A D | MTThread.h | 63 MT_ASSERT(err == 0, "pthread_yield - error"); in YieldThread() 219 MT_ASSERT(!isStarted, "Thread already stared"); 221 MT_ASSERT(func == nullptr, "Thread already started"); 233 MT_ASSERT(err == 0, "pthread_attr_init - error"); 237 MT_ASSERT(err == 0, "pthread_attr_setstack - error"); 270 MT_ASSERT(err == 0, "pthread_create - error"); 275 MT_ASSERT(isStarted, "Thread is not started"); in Join() 285 MT_ASSERT(err == 0, "pthread_join - error"); in Join() 289 MT_ASSERT(err == 0, "pthread_attr_destroy - error"); in Join() 335 MT_ASSERT(err == 0, "pthread_setschedprio - error"); [all …]
|
| /TaskScheduler/Scheduler/Include/Platform/Windows/ |
| H A D | MTFiberOptimized.h | 65 MT_ASSERT(pFiber != nullptr, "Invalid fiber"); in FiberFuncInternal() 68 MT_ASSERT(self->isInitialized == true, "Using non initialized fiber"); in FiberFuncInternal() 70 MT_ASSERT(self->func != nullptr, "Invalid fiber func"); in FiberFuncInternal() 112 MT_ASSERT(!isInitialized, "Already initialized"); in CreateFromCurrentThreadAndRun() 117 MT_ASSERT(res != 0, "GetThreadContext - failed"); in CreateFromCurrentThreadAndRun() 135 MT_ASSERT(!isInitialized, "Already initialized"); in Create() 143 MT_ASSERT(res != 0, "GetThreadContext - failed"); in Create() 194 MT_ASSERT(from.isInitialized, "Invalid from fiber"); in SwitchTo() 195 MT_ASSERT(to.isInitialized, "Invalid to fiber"); in SwitchTo() 201 MT_ASSERT(res != 0, "GetThreadContext - failed"); in SwitchTo() [all …]
|
| H A D | MTFiberDefault.h | 99 MT_ASSERT(fiber == nullptr, "Fiber already created"); in CreateFromCurrentThreadAndRun() 111 MT_ASSERT(fiber != nullptr, "Can't create fiber"); in CreateFromCurrentThreadAndRun() 122 MT_ASSERT(fiber == nullptr, "Fiber already created"); in Create() 127 MT_ASSERT(fiber != nullptr, "Can't create fiber"); in Create() 143 MT_ASSERT(from.fiber != nullptr, "Invalid from fiber"); in SwitchTo() 144 MT_ASSERT(to.fiber != nullptr, "Invalid to fiber"); in SwitchTo()
|
| H A D | MTEventUser.h | 87 MT_ASSERT (!isInitialized, "Event already initialized"); in Create() 100 MT_ASSERT (isInitialized, "Event not initialized"); in Signal() 118 MT_ASSERT (isInitialized, "Event not initialized"); in Reset() 119 MT_ASSERT(resetType == EventReset::MANUAL, "Can't reset, auto reset event"); in Reset() 128 MT_ASSERT (isInitialized, "Event not initialized"); in Wait() 150 MT_ASSERT(err == MW_ERROR_TIMEOUT, "Unexpected return value from SleepConditionVariable"); in Wait()
|
| H A D | MTThread.h | 150 MT_ASSERT(thread == nullptr, "Thread is not stopped!"); in ~Thread() 155 MT_ASSERT(thread == nullptr, "Thread already started"); 160 MT_ASSERT(thread != nullptr, "Can't create thread"); 169 MT_ASSERT(res != (MW_DWORD)-1, "SetThreadIdealProcessor failed!"); 175 MT_ASSERT(result != 0, "SetThreadPriority failed!"); 179 MT_ASSERT(res != (MW_DWORD)-1, "ResumeThread failed!"); 192 MT_ASSERT(res != 0, "Can't close thread handle"); in Join() 237 MT_ASSERT(res != (MW_DWORD)-1, "SetThreadIdealProcessor failed!"); 243 MT_ASSERT(result != 0, "SetThreadPriority failed!");
|
| /TaskScheduler/Scheduler/Source/ |
| H A D | MTFiberContext.cpp | 40 MT_ASSERT(threadContext, "Sanity check failed"); in SetStatus() 67 MT_ASSERT(childrenFibersCount.Load() == 0, "Can't release fiber with active children fibers"); in Reset() 97 MT_ASSERT(threadContext, "Sanity check failed!"); in RunSubtasksAndYieldImpl() 98 MT_ASSERT(threadContext->taskScheduler, "Sanity check failed!"); in RunSubtasksAndYieldImpl() 100 …MT_ASSERT(threadContext->threadId.IsEqual(ThreadId::Self()), "Thread context sanity check failed"); in RunSubtasksAndYieldImpl() 132 MT_ASSERT(taskHandleCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run."); in RunAsync() 133 MT_ASSERT(threadContext, "ThreadContext is nullptr"); in RunAsync() 134 MT_ASSERT(threadContext->taskScheduler, "Sanity check failed!"); in RunAsync() 151 MT_ASSERT(taskHandleCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run."); in RunSubtasksAndYield() 152 MT_ASSERT(threadContext, "ThreadContext is nullptr"); in RunSubtasksAndYield() [all …]
|
| H A D | MTScheduler.cpp | 68 MT_ASSERT(res == true, "Can't add fiber to storage"); in TaskScheduler() 80 MT_ASSERT(res == true, "Can't add fiber to storage"); in TaskScheduler() 94 MT_ASSERT(res == true, "Can't add group to storage"); in TaskScheduler() 171 MT_ASSERT(res, "Can't get more standard fibers!"); in RequestFiberContext() 176 MT_ASSERT(res, "Can't get more extended fibers!"); in RequestFiberContext() 215 MT_ASSERT(res != false, "Can't return fiber to storage"); in ReleaseFiberContext() 222 MT_ASSERT(fiberContext, "Invalid fiber context"); in ExecuteTask() 263 MT_ASSERT(groupTaskCount >= 0, "Sanity check failed!"); in ExecuteTask() 866 MT_ASSERT(group.IsValid(), "Invalid group ID"); in ReleaseGroup() 877 MT_ASSERT(res, "Can't return group to pool"); in ReleaseGroup() [all …]
|
| H A D | MTDefaultAppInterop.cpp | 82 MT_ASSERT(p, "Can't allocate memory"); in Alloc() 118 MT_ASSERT(desc.stackMemory != NULL, "Can't allocate memory"); in AllocStack() 126 MT_ASSERT(res != 0, "Can't protect memory"); in AllocStack() 145 MT_ASSERT((void *)desc.stackMemory != (void *)-1, "Can't allocate memory"); in AllocStack() 152 MT_ASSERT(res == 0, "Can't protect memory"); in AllocStack() 166 MT_ASSERT(res != 0, "Can't free memory"); in FreeStack() 172 MT_ASSERT(res == 0, "Can't free memory"); in FreeStack()
|
| /TaskScheduler/SchedulerTests/Profiler/ |
| H A D | Profiler.cpp | 32 MT_ASSERT(fibersCount <= MT_ARRAY_SIZE(fiberEventStorages), "Too many fibers!"); in OnFibersCreated() 47 MT_ASSERT(currentThreadStorageSlot, "Sanity check failed"); in OnTemporaryWorkerThreadLeave() 56 MT_ASSERT(IsFiberStorage(storage) == false, "Sanity check failed"); in OnTemporaryWorkerThreadLeave() 62 MT_ASSERT(currentThreadStorageSlot, "Sanity check failed"); in OnTemporaryWorkerThreadJoin() 71 MT_ASSERT(IsFiberStorage(storage) == false, "Sanity check failed"); in OnTemporaryWorkerThreadJoin() 116 MT_ASSERT(fiberIndex < (int32)totalFibersCount, "Sanity check failed"); in OnTaskExecuteStateChanged() 119 MT_ASSERT(currentThreadStorageSlot, "Sanity check failed"); in OnTaskExecuteStateChanged() 138 MT_ASSERT(originalThreadStorage == nullptr, "Sanity check failed"); in OnTaskExecuteStateChanged() 167 MT_ASSERT(checkFiberStorage == currentFiberStorage, "Sanity check failed"); in OnTaskExecuteStateChanged() 169 MT_ASSERT(activeThreadStorage == currentFiberStorage, "Sanity check failed"); in OnTaskExecuteStateChanged() [all …]
|
| /TaskScheduler/Scheduler/Include/ |
| H A D | MTDebug.h | 36 #ifndef MT_ASSERT 37 #define MT_ASSERT( condition, description ) { if ( !(condition) ) { MT_REPORT_ASSERT_IMPL( #conditi… macro 50 #ifndef MT_ASSERT 51 #define MT_ASSERT( condition, description ) macro
|
| H A D | MTArrayView.h | 50 MT_ASSERT(count == 0 || data, "Invalid data array"); in ArrayView() 61 MT_ASSERT( i < Size(), "bad index" ); 67 MT_ASSERT( i < Size(), "bad index" );
|
| H A D | MTStaticVector.h | 76 MT_ASSERT(count <= CAPACITY, "Too big size"); in count() 93 MT_ASSERT( i < Size(), "bad index" ); 99 MT_ASSERT( i < Size(), "bad index" ); 105 MT_ASSERT(count < CAPACITY, "Can't add element"); in PushBack()
|
| H A D | MTFiberContext.inl | 29 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run."); 30 MT_ASSERT(threadContext, "ThreadContext is nullptr"); 46 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run."); 48 MT_ASSERT(threadContext, "ThreadContext is nullptr"); 49 …MT_ASSERT(threadContext->taskScheduler->IsWorkerThread(), "Can't use RunAsync outside Task. Use Ta…
|
| H A D | MTScheduler.inl | 45 MT_ASSERT(group == TaskGroup::ASSIGN_FROM_CONTEXT, "Group must be assigned from context"); 47 …MT_ASSERT(fiberContext->currentTask.stackRequirements == fiberContext->stackRequirements, "Sanity … 57 MT_ASSERT(src->IsValid(), "Invalid task handle!"); 91 MT_ASSERT(index == descriptions.Size(), "Sanity check"); 104 MT_ASSERT(taskCount < (internal::TASK_BUFFER_CAPACITY - 1), "Too many tasks per one Run."); 105 …MT_ASSERT(!IsWorkerThread(), "Can't use RunAsync inside Task. Use FiberContext.RunAsync() instead.…
|
| H A D | MTTaskGroup.h | 88 MT_ASSERT(IsValid(), "Try to get invalid index"); in GetValidIndex()
|
| H A D | MTTaskQueue.h | 258 MT_ASSERT(queueIndex < MT_ARRAY_SIZE(queues), "Invalid task priority"); in Add() 263 MT_ASSERT(res == true, "Sanity check failed"); in Add()
|
| H A D | MTTaskPool.h | 192 MT_ASSERT(IsValid(), "Task handle is invalid"); in GetDesc() 323 MT_ASSERT(res.IsValid(), "Pool allocation failed"); in Alloc()
|
| /TaskScheduler/Scheduler/Include/Platform/Common/ |
| H A D | MTAtomic.h | 57 MT_ASSERT(IsPointerAligned(this, __alignof(T)), "Invalid atomic alignment"); in Atomic32() 65 MT_ASSERT(IsPointerAligned(this, __alignof(T)), "Invalid atomic alignment"); in Atomic32() 83 MT_ASSERT(IsPointerAligned(this, sizeof(T*)), "Invalid atomic ptr alignment"); in AtomicPtr() 91 MT_ASSERT(IsPointerAligned(this, sizeof(T*)), "Invalid atomic ptr alignment"); in AtomicPtr()
|
| /TaskScheduler/Scheduler/Include/Scopes/ |
| H A D | MTScopes.h | 313 MT_ASSERT(index >= 0, "Stack already empty. Invalid call."); in Pop() 444 MT_ASSERT(index >= 0, "Stack already empty. Invalid call."); in Pop() 526 MT_ASSERT( storagePointer != nullptr, "Scopes storage pointer was not initialized!"); \ 589 MT_ASSERT(stackPointer != nullptr, "Stack pointer is not initialized for current thread."); \ 591 MT_ASSERT(SCOPE_CONCAT(scope_stackParentId_, __LINE__) >= 0, "Invalid parent ID"); \ 597 MT_ASSERT(stackPointer != nullptr, "Stack pointer is not initialized for current thread."); \ 599 MT_ASSERT(SCOPE_CONCAT(scope_stackParentId_, __LINE__) >= 0, "Invalid parent ID"); \ 604 MT_ASSERT(stackPointer != nullptr, "Stack pointer is not initialized for current thread."); \ 606 MT_ASSERT(SCOPE_CONCAT(scope_stackParentId_, __LINE__) >= 0, "Invalid parent ID"); \ 612 MT_ASSERT(stackPointer != nullptr, "Stack pointer is not initialized for current thread."); \
|
| /TaskScheduler/SchedulerTests/Tests/ |
| H A D | PriorityTests.cpp | 78 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()
|
| H A D | DxtTests.cpp | 136 …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() 481 …MT_ASSERT ((compressTask.width & 3) == 0 && (compressTask.height & 3) == 0, "Image size must be a … in SUITE()
|
| H A D | SimpleTests.cpp | 142 MT_ASSERT(workerIndex < MT_ARRAY_SIZE(workerStates), "Invalid worker index"); in SUITE()
|