Searched refs:resultInfo (Results 1 - 7 of 7) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | taskpool.cpp | 129 auto resultInfo = msgQueue.DeQueue();
in ExecuteCallbackInner() local
130 if (resultInfo == nullptr) {
in ExecuteCallbackInner()
131 HILOG_DEBUG("taskpool:: resultInfo is nullptr");
in ExecuteCallbackInner()
134 ObjectScope<TaskResultInfo> resultInfoScope(resultInfo, false);
in ExecuteCallbackInner()
136 CallbackScope callbackScope(resultInfo->hostEnv, resultInfo->workerEnv, resultInfo->taskId, status);
in ExecuteCallbackInner()
141 auto env = resultInfo->hostEnv;
in ExecuteCallbackInner()
142 auto callbackInfo = TaskManager::GetInstance().GetCallbackInfo(resultInfo->taskId);
in ExecuteCallbackInner()
151 status = napi_deserialize(env, resultInfo in ExecuteCallbackInner()
[all...] |
| H A D | worker.h | 62 void Enqueue(napi_env env, TaskResultInfo* resultInfo)
in Enqueue() argument
65 msgQueueMap_[env].EnQueue(resultInfo);
in Enqueue()
|
| H A D | task_manager.h | 105 napi_value NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task);
|
| H A D | task_manager.cpp | 962 napi_value TaskManager::NotifyCallbackExecute(napi_env env, TaskResultInfo* resultInfo, Task* task) in NotifyCallbackExecute() argument
970 delete resultInfo; in NotifyCallbackExecute()
974 worker->Enqueue(task->env_, resultInfo); in NotifyCallbackExecute()
|
| H A D | task.cpp | 470 TaskResultInfo* resultInfo = new TaskResultInfo(task->env_, env, task->taskId_, serializationArgs); in SendData() local
471 return TaskManager::GetInstance().NotifyCallbackExecute(env, resultInfo, task); in SendData()
|
| /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() local
2049 worker->Enqueue(env, resultInfo); in HWTEST_F()
2076 TaskResultInfo* resultInfo = new TaskResultInfo(env, env, taskId, args); in HWTEST_F() local
2077 worker->Enqueue(env, resultInfo); in HWTEST_F()
2120 TaskResultInfo* resultInfo = new TaskResultInfo(env, env, taskId, serializationArgs); in HWTEST_F() local
2121 worker->Enqueue(env, resultInfo); in HWTEST_F()
2154 TaskResultInfo* resultInfo = new TaskResultInfo(env, env, taskId, args); in HWTEST_F() local
2155 worker->Enqueue(env, resultInfo); in HWTEST_F()
4532 TaskResultInfo* resultInfo = new TaskResultInfo(nullptr, env, taskId, args); in HWTEST_F() local
4533 worker->Enqueue(env, resultInfo); in HWTEST_F()
[all...] |
| H A D | test.cpp | 889 TaskResultInfo* resultInfo = new TaskResultInfo(env, workerEnv, task->taskId_, nullptr);
in HandleFunctionException() local
890 TaskManager::GetInstance().NotifyCallbackExecute(env, resultInfo, task);
in HandleFunctionException()
|
Completed in 17 milliseconds