Searched refs:TaskResultInfo (Results 1 - 8 of 8) sorted by relevance
/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
H A D | worker.h | 41 using MsgQueue = MessageQueue<TaskResultInfo*>;
62 void Enqueue(napi_env env, TaskResultInfo* resultInfo)
in Enqueue() 220 MessageQueue<TaskResultInfo*> hostMessageQueue_ {};
|
H A D | task.h | 239 struct TaskResultInfo { struct 240 TaskResultInfo(napi_env env, napi_env curEnv, uint64_t id, void* args) : hostEnv(env), workerEnv(curEnv), in TaskResultInfo() function 242 ~TaskResultInfo() = default;
|
H A D | task_manager.h | 105 napi_value NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task);
|
H A D | task.cpp | 470 TaskResultInfo* resultInfo = new TaskResultInfo(task->env_, env, task->taskId_, serializationArgs); in SendData()
|
H A D | taskpool.cpp | 134 ObjectScope<TaskResultInfo> resultInfoScope(resultInfo, false);
in ExecuteCallbackInner()
|
H A D | task_manager.cpp | 962 napi_value TaskManager::NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task) in NotifyCallbackExecute()
|
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
H A D | test_taskpool.cpp | 2048 TaskResultInfo* resultInfo = new TaskResultInfo(env, env, taskId, args); in HWTEST_F() 2050 TaskResultInfo* resultInfo2 = nullptr; in HWTEST_F() 2076 TaskResultInfo* resultInfo = new TaskResultInfo(env, env, taskId, args); in HWTEST_F() 2120 TaskResultInfo* resultInfo = new TaskResultInfo(env, env, taskId, serializationArgs); in HWTEST_F() 2154 TaskResultInfo* resultInfo = new TaskResultInfo(env, env, taskId, args); in HWTEST_F() 4532 TaskResultInfo* resultInf in HWTEST_F() [all...] |
H A D | test.cpp | 889 TaskResultInfo* resultInfo = new TaskResultInfo(env, workerEnv, task->taskId_, nullptr);
in HandleFunctionException()
|
Completed in 20 milliseconds