Lines Matching refs:pTask
134 WELS_THREAD_ERROR_CODE CWelsThreadPool::OnTaskStart (CWelsTaskThread* pThread, IWelsTask* pTask) { in OnTaskStart() argument
140 WELS_THREAD_ERROR_CODE CWelsThreadPool::OnTaskStop (CWelsTaskThread* pThread, IWelsTask* pTask) { in OnTaskStop() argument
146 if (pTask && pTask->GetSink()) { in OnTaskStop()
148 pTask->GetSink()->OnTaskExecuted(); in OnTaskStop()
232 IWelsTask* pTask = NULL; in ExecuteTask() local
241 pTask = GetWaitedTask(); in ExecuteTask()
243 if (pTask) { in ExecuteTask()
244 pThread->SetTask (pTask); in ExecuteTask()
251 WELS_THREAD_ERROR_CODE CWelsThreadPool::QueueTask (IWelsTask* pTask) { in QueueTask() argument
260 pThread->SetTask (pTask); in QueueTask()
266 if (false == AddTaskToWaitedList (pTask)) { in QueueTask()
319 bool CWelsThreadPool::AddTaskToWaitedList (IWelsTask* pTask) { in AddTaskToWaitedList() argument
322 return m_cWaitedTasks->push_back (pTask); in AddTaskToWaitedList()
358 IWelsTask* pTask = m_cWaitedTasks->begin(); in GetWaitedTask() local
362 return pTask; in GetWaitedTask()
370 IWelsTask* pTask = NULL; in ClearWaitedTasks() local
372 pTask = m_cWaitedTasks->begin(); in ClearWaitedTasks()
373 if (pTask->GetSink()) { in ClearWaitedTasks()
374 pTask->GetSink()->OnTaskCancelled(); in ClearWaitedTasks()