91 static TaskExecuteNode *PopTaskExecutor(ThreadManager *mgr)  in PopTaskExecutor()
106 static int AddExecutor(ThreadManager *mgr, const TaskNode *task)  in AddExecutor()
127 static void RunExecutor(ThreadManager *mgr, ThreadNode *threadNode, uint32_t maxCount)  in RunExecutor()
152 static TaskNode *GetTask(ThreadManager *mgr, ListNode *queue, uint32_t taskId)  in GetTask()
177 static TaskNode *PopTask(ThreadManager *mgr, ListNode *queue)  in PopTask()
191 static void PushTask(ThreadManager *mgr, TaskNode *task, ListNode *queue)  in PushTask()
199 static void SafeRemoveTask(ThreadManager *mgr, TaskNode *task)  in SafeRemoveTask()
224 static void ExecuteTask(ThreadManager *mgr)  in ExecuteTask()
237 static void CheckTaskComplete(ThreadManager *mgr)  in CheckTaskComplete()
272 …ThreadManager *mgr = (ThreadManager *)malloc(sizeof(ThreadManager) + maxThreadCount * sizeof(Threa…  in CreateThreadMgr()  local
307     ThreadManager *mgr = (ThreadManager *)instance;  in DestroyThreadMgr()  local
340     ThreadManager *mgr = (ThreadManager *)instance;  in ThreadMgrAddTask()  local
367     ThreadManager *mgr = (ThreadManager *)instance;  in ThreadMgrAddExecutor()  local
386     ThreadManager *mgr = (ThreadManager *)instance;  in ThreadMgrCancelTask()  local
411     ThreadManager *mgr = (ThreadManager *)instance;  in TaskSyncExecute()  local
440     ThreadManager *mgr = (ThreadManager *)instance;  in TaskExecute()  local
457 static void CheckAndCreateNewThread(ThreadManager *mgr)  in CheckAndCreateNewThread()
491     ThreadManager *mgr = g_threadManager;  in ManagerThreadProc()  local
528     ThreadManager *mgr = g_threadManager;  in ThreadExecute()  local