Lines Matching refs:TaskNode
56 } TaskNode; typedef
61 TaskNode *task;
106 static int AddExecutor(ThreadManager *mgr, const TaskNode *task) in AddExecutor()
148 TaskNode *task = ListEntry(node, TaskNode, node); in TaskCompareTaskId()
152 static TaskNode *GetTask(ThreadManager *mgr, ListNode *queue, uint32_t taskId) in GetTask()
161 return ListEntry(node, TaskNode, node); in GetTask()
164 static void DeleteTask(TaskNode *task) in DeleteTask()
177 static TaskNode *PopTask(ThreadManager *mgr, ListNode *queue) in PopTask()
179 TaskNode *task = NULL; in PopTask()
185 task = ListEntry(node, TaskNode, node); in PopTask()
191 static void PushTask(ThreadManager *mgr, TaskNode *task, ListNode *queue) in PushTask()
199 static void SafeRemoveTask(ThreadManager *mgr, TaskNode *task) in SafeRemoveTask()
226 TaskNode *task = PopTask(mgr, &mgr->waitingTaskQueue); in ExecuteTask()
239 TaskNode *task = PopTask(mgr, &mgr->executingTaskQueue); in CheckTaskComplete()
261 TaskNode *task = ListEntry(node, TaskNode, node); in TaskQueueDestroyProc()
342 TaskNode *task = (TaskNode *)malloc(sizeof(TaskNode)); in ThreadMgrAddTask()
369 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); in ThreadMgrAddExecutor()
388 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); in ThreadMgrCancelTask()
413 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); in TaskSyncExecute()
442 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); in TaskExecute()