| /commonlibrary/ets_utils/js_sys_module/timer/ |
| H A D | timer.cpp | 101 TimerCallbackInfo* callbackInfo = iter->second; in ClearTimer() local
102 if (callbackInfo->env_ != env) { in ClearTimer()
106 Helper::CloseHelp::DeletePointer(callbackInfo, false); in ClearTimer()
115 TimerCallbackInfo* callbackInfo = static_cast<TimerCallbackInfo*>(handle->data); in TimerCallback() local
116 if (callbackInfo == nullptr) { in TimerCallback()
119 // Save the following parameters to ensure that they can still obtained if callback clears the callbackInfo. in TimerCallback()
120 bool repeat = callbackInfo->repeat_; in TimerCallback()
121 uint32_t tId = callbackInfo->tId_; in TimerCallback()
122 napi_env env = callbackInfo->env_; in TimerCallback()
124 ContainerScope containerScope(callbackInfo in TimerCallback()
200 TimerCallbackInfo* callbackInfo = nullptr; SetTimeoutInnerCore() local
256 TimerCallbackInfo* callbackInfo = iter->second; ClearEnvironmentTimer() local
275 DeleteTimer(uint32_t tId, TimerCallbackInfo* callbackInfo) DeleteTimer() argument
[all...] |
| H A D | timer.h | 81 static void DeleteTimer(uint32_t tId, TimerCallbackInfo* callbackInfo);
|
| /commonlibrary/ets_utils/js_sys_module/timer/test/ |
| H A D | test_timer.h | 30 static void DeleteTimer(uint32_t tId, TimerCallbackInfo* callbackInfo);
51 void TimerTest::DeleteTimer(uint32_t tId, TimerCallbackInfo* callbackInfo) in DeleteTimer() argument
53 return Timer::DeleteTimer(tId, callbackInfo); in DeleteTimer()
|
| H A D | test_timer.cpp | 340 TimerCallbackInfo* callbackInfo = new TimerCallbackInfo(env, tId, timeout, callback, repeat, argc, argv); in HWTEST_F() local
341 table[tId] = callbackInfo; in HWTEST_F()
342 TimerTest::DeleteTimer(tId, callbackInfo); in HWTEST_F()
441 TimerCallbackInfo* callbackInfo = static_cast<TimerCallbackInfo*>(handle->data); in HWTEST_F() local
442 callbackInfo->env_ = env2; in HWTEST_F()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | task_manager.cpp | 909 void TaskManager::RegisterCallback(napi_env env, uint64_t taskId, std::shared_ptr<CallbackInfo> callbackInfo) in RegisterCallback() argument
912 callbackTable_[taskId] = callbackInfo; in RegisterCallback()
975 auto callbackInfo = iter->second; in NotifyCallbackExecute() local
976 callbackInfo->refCount++; in NotifyCallbackExecute()
977 callbackInfo->worker = worker; in NotifyCallbackExecute()
983 auto onCallbackTask = [callbackInfo]() { in NotifyCallbackExecute()
984 TaskPool::ExecuteCallbackTask(callbackInfo.get()); in NotifyCallbackExecute()
988 callbackInfo->onCallbackSignal->data = callbackInfo.get(); in NotifyCallbackExecute()
989 uv_async_send(callbackInfo in NotifyCallbackExecute()
1012 GetMessageQueueFromCallbackInfo(CallbackInfo* callbackInfo) GetMessageQueueFromCallbackInfo() argument
[all...] |
| H A D | taskpool.h | 38 static void ExecuteCallbackTask(CallbackInfo* callbackInfo);
|
| H A D | taskpool.cpp | 116 void TaskPool::ExecuteCallbackTask(CallbackInfo* callbackInfo)
in ExecuteCallbackTask() argument
118 auto* msgQueue = TaskManager::GetInstance().GetMessageQueueFromCallbackInfo(callbackInfo);
in ExecuteCallbackTask()
142 auto callbackInfo = TaskManager::GetInstance().GetCallbackInfo(resultInfo->taskId);
in ExecuteCallbackInner() local
143 if (callbackInfo == nullptr) {
in ExecuteCallbackInner()
148 auto func = NapiHelper::GetReferenceValue(env, callbackInfo->callbackRef);
in ExecuteCallbackInner()
|
| H A D | task_manager.h | 102 void RegisterCallback(napi_env env, uint64_t taskId, std::shared_ptr<CallbackInfo> callbackInfo);
107 MsgQueue* GetMessageQueueFromCallbackInfo(CallbackInfo* callbackInfo);
|
| H A D | task.cpp | 410 // store callbackInfo in OnReceiveData()
415 std::shared_ptr<CallbackInfo> callbackInfo = std::make_shared<CallbackInfo>(env, 1, callbackRef, task); in OnReceiveData() local
419 ConcurrentHelper::UvHandleInit(loop, callbackInfo->onCallbackSignal, TaskPool::ExecuteCallback); in OnReceiveData()
423 ConcurrentHelper::UvHandleInit(loop, callbackInfo->onCallbackSignal, TaskPool::ExecuteCallback); in OnReceiveData()
425 TaskManager::GetInstance().RegisterCallback(env, taskId, callbackInfo); in OnReceiveData()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test_taskpool.cpp | 2087 std::shared_ptr<CallbackInfo> callbackInfo = std::make_shared<CallbackInfo>(env, 1, callbackRef, task); in HWTEST_F() local
2088 taskManager.RegisterCallback(env, taskId, callbackInfo); in HWTEST_F()
2131 std::shared_ptr<CallbackInfo> callbackInfo = std::make_shared<CallbackInfo>(env, 1, callbackRef, task); in HWTEST_F() local
2132 taskManager.RegisterCallback(env, taskId, callbackInfo); in HWTEST_F()
|