Home
last modified time | relevance | path

Searched refs:TaskInfo (Results 1 – 8 of 8) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
Dtask_manager.h53 TaskInfo* GetTaskInfo(uint32_t executeId);
54 TaskInfo* PopTaskInfo(uint32_t executeId);
64 …TaskInfo* GenerateTaskInfo(napi_env env, napi_value func, napi_value args, uint32_t taskId, uint32…
66 TaskInfo* GenerateTaskInfoFromTask(napi_env env, napi_value task, uint32_t executeId);
67 void ReleaseTaskContent(TaskInfo* taskInfo);
102 void StoreTaskInfo(uint32_t executeId, TaskInfo* taskInfo);
120 std::unordered_map<uint32_t, TaskInfo*> taskInfos_ {};
Dtaskpool.h44 …static void ExecuteFunction(napi_env env, TaskInfo* taskInfo, Priority priority = Priority::DEFAUL…
47 …static void UpdateGroupInfoByResult(napi_env env, TaskInfo* taskInfo, napi_value res, bool success…
Dtaskpool.cpp113 … TaskInfo* taskInfo = TaskManager::GetInstance().GenerateTaskInfoFromTask(env, args[0], executeId); in Execute()
135 …TaskInfo* taskInfo = TaskManager::GetInstance().GenerateTaskInfo(env, args[0], argsArray, 0, execu… in Execute()
159 … TaskInfo* taskInfo = TaskManager::GetInstance().GenerateTaskInfoFromTask(env, task, executeId); in ExecuteGroup()
173 auto taskInfo = static_cast<TaskInfo*>(req->data); in HandleTaskResult()
214 void TaskPool::UpdateGroupInfoByResult(napi_env env, TaskInfo* taskInfo, napi_value res, bool succe… in UpdateGroupInfoByResult()
247 void TaskPool::ExecuteFunction(napi_env env, TaskInfo* taskInfo, Priority priority) in ExecuteFunction()
Dtask_manager.cpp374 void TaskManager::StoreTaskInfo(uint32_t executeId, TaskInfo* taskInfo) in StoreTaskInfo()
392 TaskInfo* TaskManager::PopTaskInfo(uint32_t executeId) in PopTaskInfo()
400 TaskInfo* taskInfo = iter->second; in PopTaskInfo()
406 TaskInfo* TaskManager::GetTaskInfo(uint32_t executeId) in GetTaskInfo()
499 TaskInfo* taskInfo = nullptr; in CancelExecution()
527 TaskInfo* TaskManager::GenerateTaskInfo(napi_env env, napi_value func, napi_value args, in GenerateTaskInfo()
547 TaskInfo* taskInfo = new TaskInfo(); in GenerateTaskInfo()
563 TaskInfo* TaskManager::GenerateTaskInfoFromTask(napi_env env, napi_value task, uint32_t executeId) in GenerateTaskInfoFromTask()
574 TaskInfo* taskInfo = GenerateTaskInfo(env, function, arguments, id, executeId, transferList); in GenerateTaskInfoFromTask()
578 void TaskManager::ReleaseTaskContent(TaskInfo* taskInfo) in ReleaseTaskContent()
[all …]
Dworker.cpp261 TaskInfo* taskInfo = TaskManager::GetInstance().GetTaskInfo(executeIdAndPriority.first); in PerformTask()
348 void Worker::NotifyTaskResult(napi_env env, TaskInfo* taskInfo, napi_value result) in NotifyTaskResult()
390 TaskInfo* taskInfo = static_cast<TaskInfo*>(data); in TaskResultCallback()
Dtask.h45 struct TaskInfo { struct
Dworker.h138 static void NotifyTaskResult(napi_env env, TaskInfo* taskInfo, napi_value result);
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
Dtest_taskpool.cpp84 TaskInfo* taskInfo = taskManager.GetTaskInfo(executeId);
92 TaskInfo *result = taskManager.PopTaskInfo(executeId);
238 TaskInfo* taskInfo = taskManger.GenerateTaskInfoFromTask(env, task, executeId);
286 TaskInfo* taskInfo = taskManger.GenerateTaskInfo(env, function, args, taskId, executeId);
290 TaskInfo* taskInfo1 = taskManger.GetTaskInfo(executeId);
292 TaskInfo* taskInfo2 = taskManger.PopTaskInfo(executeId);