| /TaskScheduler/Scheduler/Include/Platform/Posix/ |
| H A D | MTMutex.h | 50 MT_USED_IN_ASSERT(res); in Mutex()
54 MT_USED_IN_ASSERT(res); in Mutex()
58 MT_USED_IN_ASSERT(res); in Mutex()
64 int res = pthread_mutex_destroy(&mutex); in ~Mutex() local
65 MT_USED_IN_ASSERT(res); in ~Mutex()
68 res = pthread_mutexattr_destroy(&mutexAttr); in ~Mutex()
69 MT_USED_IN_ASSERT(res); in ~Mutex()
79 int res = pthread_mutex_lock(&mutex); in Lock() local
80 MT_USED_IN_ASSERT(res); in Lock()
85 int res = pthread_mutex_unlock(&mutex); in Unlock() local
[all …]
|
| H A D | MTEvent.h | 87 MT_USED_IN_ASSERT(res); in ~Event()
91 MT_USED_IN_ASSERT(res); in ~Event()
103 MT_USED_IN_ASSERT(res); in Create()
107 MT_USED_IN_ASSERT(res); in Create()
120 MT_USED_IN_ASSERT(res); in Signal()
140 MT_USED_IN_ASSERT(res); in Signal()
150 MT_USED_IN_ASSERT(res); in Reset()
156 MT_USED_IN_ASSERT(res); in Reset()
166 MT_USED_IN_ASSERT(res); in Wait()
174 MT_USED_IN_ASSERT(res); in Wait()
[all …]
|
| H A D | MTFiber.h | 132 int res = getcontext(&fiberContext); in CreateFromCurrentThreadAndRun() local
133 MT_USED_IN_ASSERT(res); in CreateFromCurrentThreadAndRun()
134 MT_ASSERT(res == 0, "getcontext - failed"); in CreateFromCurrentThreadAndRun()
153 int res = getcontext(&fiberContext); in Create() local
154 MT_USED_IN_ASSERT(res); in Create()
155 MT_ASSERT(res == 0, "getcontext - failed"); in Create()
183 int res = swapcontext(&from.fiberContext, &to.fiberContext); in SwitchTo() local
184 MT_USED_IN_ASSERT(res); in SwitchTo()
185 MT_ASSERT(res == 0, "setcontext - failed"); in SwitchTo()
|
| /TaskScheduler/Scheduler/Source/ |
| H A D | MTDefaultAppInterop.cpp | 125 MT_USED_IN_ASSERT(res); in AllocStack()
126 MT_ASSERT(res != 0, "Can't protect memory"); in AllocStack()
150 int res = mprotect(desc.stackMemory, pageSize, PROT_NONE); in AllocStack() local
151 MT_USED_IN_ASSERT(res); in AllocStack()
152 MT_ASSERT(res == 0, "Can't protect memory"); in AllocStack()
164 int res = VirtualFree(desc.stackMemory, 0, MW_MEM_RELEASE); in FreeStack() local
165 MT_USED_IN_ASSERT(res); in FreeStack()
166 MT_ASSERT(res != 0, "Can't free memory"); in FreeStack()
170 int res = munmap(desc.stackMemory, desc.stackMemoryBytesCount); in FreeStack()
171 MT_USED_IN_ASSERT(res); in FreeStack()
[all …]
|
| H A D | MTScheduler.cpp | 67 MT_USED_IN_ASSERT(res); in TaskScheduler()
79 MT_USED_IN_ASSERT(res); in TaskScheduler()
93 MT_USED_IN_ASSERT(res); in TaskScheduler()
164 bool res = false; in RequestFiberContext() local
165 MT_USED_IN_ASSERT(res); in RequestFiberContext()
170 MT_USED_IN_ASSERT(res); in RequestFiberContext()
200 bool res = false; in ReleaseFiberContext() local
201 MT_USED_IN_ASSERT(res); in ReleaseFiberContext()
214 MT_USED_IN_ASSERT(res); in ReleaseFiberContext()
708 if (res == true) in RunTasksImpl()
[all …]
|
| /TaskScheduler/Scheduler/Include/Platform/Windows/ |
| H A D | MTThread.h | 167 MW_DWORD res = ::SetThreadIdealProcessor(thread, cpuCore);
168 MT_USED_IN_ASSERT(res);
169 MT_ASSERT(res != (MW_DWORD)-1, "SetThreadIdealProcessor failed!");
177 res = ::ResumeThread(thread);
178 MT_USED_IN_ASSERT(res);
179 MT_ASSERT(res != (MW_DWORD)-1, "ResumeThread failed!");
190 MW_BOOL res = CloseHandle(thread); in Join() local
191 MT_USED_IN_ASSERT(res); in Join()
192 MT_ASSERT(res != 0, "Can't close thread handle"); in Join()
236 MT_USED_IN_ASSERT(res);
[all …]
|
| H A D | MTFiberOptimized.h | 115 MW_BOOL res = GetThreadContext( GetCurrentThread(), &fiberContext ); in CreateFromCurrentThreadAndRun() local
116 MT_USED_IN_ASSERT(res); in CreateFromCurrentThreadAndRun()
117 MT_ASSERT(res != 0, "GetThreadContext - failed"); in CreateFromCurrentThreadAndRun()
141 MW_BOOL res = GetThreadContext( GetCurrentThread(), &fiberContext ); in Create() local
142 MT_USED_IN_ASSERT(res); in Create()
143 MT_ASSERT(res != 0, "GetThreadContext - failed"); in Create()
200 MW_BOOL res = GetThreadContext(thread, &from.fiberContext ); in SwitchTo() local
201 MT_ASSERT(res != 0, "GetThreadContext - failed"); in SwitchTo()
211 res = SetThreadContext(thread, &to.fiberContext ); in SwitchTo()
212 MT_ASSERT(res != 0, "SetThreadContext - failed"); in SwitchTo()
|
| H A D | MTEventKernel.h | 84 MW_DWORD res = WaitForSingleObject(eventHandle, milliseconds); in Wait() local
85 return (res == MW_WAIT_OBJECT_0); in Wait()
|
| /TaskScheduler/SchedulerTests/ |
| H A D | main.cpp | 103 int res = 0; in main() local
109 res = Tests::RunAll(); in main()
110 if (res != 0) in main()
113 return res; in main()
121 return res; in main()
|
| /TaskScheduler/SchedulerTests/Tests/ |
| H A D | FoundationTests.cpp | 102 bool res = queue.TryPush( std::move(77 + i) ); in SUITE() local
105 CHECK_EQUAL(true, res); in SUITE()
108 CHECK_EQUAL(false, res); in SUITE()
115 bool res = queue.TryPop(val); in SUITE() local
118 CHECK_EQUAL(true, res); in SUITE()
122 CHECK_EQUAL(false, res); in SUITE()
|
| H A D | PlatformTests.cpp | 132 bool res = pEvent->Wait(1000); in SUITE() local
134 CHECK(res == true); in SUITE()
214 bool res = stressEvent.Wait(1000); in SUITE() local
215 CHECK(res == true); in SUITE()
257 bool res = stressEvent.Wait(300); in SUITE() local
258 CHECK(res == true); in SUITE()
260 res = stressEvent.Wait(300); in SUITE()
261 CHECK(res == false); in SUITE()
|
| H A D | AtomicTests.cpp | 169 float res = 0.0f; in SUITE() local
174 res = 0.0f; in SUITE()
177 res += sin((float)i); in SUITE()
189 printf("%3.2f\n", res); in SUITE()
|
| /TaskScheduler/Scheduler/Include/ |
| H A D | MTTaskQueue.h | 261 bool res = queue.Add(itemArray[i]); in Add() local
262 MT_USED_IN_ASSERT(res); in Add()
263 MT_ASSERT(res == true, "Sanity check failed"); in Add()
|
| H A D | MTTaskPool.h | 322 TaskHandle res = TryAlloc(std::move(task)); in Alloc() local
323 MT_ASSERT(res.IsValid(), "Pool allocation failed"); in Alloc()
324 return res; in Alloc()
|