| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | task_queue.cpp | 19 void ExecuteQueue::EnqueueTaskId(uint32_t taskId) in EnqueueTaskId()
24 bool ExecuteQueue::EraseWaitingTaskId(uint32_t taskId) in EraseWaitingTaskId()
37 uint32_t taskId = tasks_.front(); in DequeueTaskId() local
|
| D | task_manager.cpp | 180 napi_value taskId = nullptr; in GetThreadInfos() local
222 napi_value taskId = NapiHelper::CreateUint32(env, info->taskId); in GetTaskInfos() local
651 void TaskManager::CancelTask(napi_env env, uint32_t taskId) in CancelTask()
823 void TaskManager::EnqueueTaskId(uint32_t taskId, Priority priority) in EnqueueTaskId()
849 bool TaskManager::EraseWaitingTaskId(uint32_t taskId, Priority priority) in EraseWaitingTaskId()
905 uint32_t taskId = taskQueue->DequeueTaskId(); in GetTaskByPriority() local
1013 void TaskManager::RegisterCallback(napi_env env, uint32_t taskId, std::shared_ptr<CallbackInfo> cal… in RegisterCallback()
1025 void TaskManager::IncreaseSendDataRefCount(uint32_t taskId) in IncreaseSendDataRefCount()
1038 void TaskManager::DecreaseSendDataRefCount(napi_env env, uint32_t taskId, Task* task) in DecreaseSendDataRefCount()
1098 void TaskManager::NotifyDependencyTaskInfo(uint32_t taskId) in NotifyDependencyTaskInfo()
[all …]
|
| D | task_group_manager.cpp | 27 void TaskGroupManager::AddTask(uint64_t groupId, napi_ref taskRef, uint32_t taskId) in AddTask()
60 for (uint32_t taskId : group->taskIds_) { in ReleaseTaskGroupData() local
104 for (uint32_t taskId : taskGroup->taskIds_) { in CancelGroup() local
123 void TaskGroupManager::CancelGroupTask(napi_env env, uint32_t taskId, TaskGroup* group) in CancelGroupTask()
|
| D | task.h | 92 uint32_t taskId; member
101 uint32_t taskId; member
290 uint32_t taskId; member
|
| D | task_group.cpp | 171 uint32_t TaskGroup::GetTaskIndex(uint32_t taskId) in GetTaskIndex()
241 void TaskGroup::CancelGroupTask(napi_env env, uint32_t taskId) in CancelGroupTask()
|
| D | taskpool.cpp | 170 uint32_t taskId = NapiHelper::GetUint32Value(env, napiTaskId); in TerminateTask() local
516 for (uint32_t taskId : taskGroup->taskIds_) { in UpdateGroupInfoByResult() local
574 uint32_t taskId = NapiHelper::GetUint32Value(env, args[0]); in Cancel() local
590 uint32_t taskId = NapiHelper::GetUint32Value(env, napiTaskId); in Cancel() local
|
| D | worker.cpp | 605 void Worker::StoreTaskId(uint32_t taskId) in StoreTaskId()
645 void Worker::TerminateTask(uint32_t taskId) in TerminateTask()
720 void Worker::EraseRunningTaskId(uint32_t taskId) in EraseRunningTaskId()
|
| D | task.cpp | 203 napi_value taskId = NapiHelper::CreateUint32(env, task->taskId_); in GenerateTask() local
431 uint32_t taskId = NapiHelper::GetUint32Value(env, id); in OnReceiveData() local
448 uint32_t taskId = NapiHelper::GetUint32Value(env, napiTaskId); in OnReceiveData() local
728 void Task::ExecuteListenerCallback(ListenerCallBackInfo* listenerCallBackInfo, uint32_t taskId) in ExecuteListenerCallback()
1478 auto taskId = task->GetTaskId(); in VerifyAndPostResult() local
1537 uint32_t taskId = taskId_; in CheckStartExecution() local
1621 void Task::SetTaskId(uint32_t taskId) in SetTaskId()
|
| D | sequence_runner.cpp | 162 void SequenceRunner::ExecuteTaskImmediately(uint32_t taskId, Priority priority) in ExecuteTaskImmediately()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test_taskpool.cpp | 170 uint32_t taskId = 10; variable
301 uint32_t taskId = TaskManager::GetInstance().CalculateTaskId(reinterpret_cast<uint64_t>(task)); variable
312 uint32_t taskId = TaskManager::GetInstance().CalculateTaskId(reinterpret_cast<uint64_t>(task)); variable
323 uint32_t taskId = TaskManager::GetInstance().CalculateTaskId(reinterpret_cast<uint64_t>(task)); variable
396 uint32_t taskId = TaskManager::GetInstance().CalculateTaskId(reinterpret_cast<uint64_t>(task)); variable
481 uint32_t taskId = 10; variable
492 uint32_t taskId = 11; variable
502 uint32_t taskId = 12; variable
520 uint32_t taskId = 14; variable
533 auto taskId = TaskManager::GetInstance().CalculateTaskId(reinterpret_cast<uint64_t>(task)); variable
[all …]
|
| D | test.cpp | 434 void NativeEngineTest::StoreDependentId(uint32_t taskId, uint32_t dependentId) in StoreDependentId()
441 void NativeEngineTest::StoreDependentTaskId(uint32_t taskId, uint32_t dependentId) in StoreDependentTaskId()
448 void NativeEngineTest::StoreTaskDuration(uint32_t taskId) in StoreTaskDuration()
515 std::set<uint32_t> taskId{ id1, id2 }; in StoreTaskDependency() local
973 void NativeEngineTest::StoreTaskId(Worker* worker, uint32_t taskId) in StoreTaskId()
979 void NativeEngineTest::RemoveTaskId(Worker* worker, uint32_t taskId) in RemoveTaskId()
988 bool NativeEngineTest::FindTaskId(Worker* worker, uint32_t taskId) in FindTaskId()
|