Lines Matching refs:callbackInfo
909 void TaskManager::RegisterCallback(napi_env env, uint64_t taskId, std::shared_ptr<CallbackInfo> callbackInfo)
912 callbackTable_[taskId] = callbackInfo;
975 auto callbackInfo = iter->second;
976 callbackInfo->refCount++;
977 callbackInfo->worker = worker;
983 auto onCallbackTask = [callbackInfo]() {
984 TaskPool::ExecuteCallbackTask(callbackInfo.get());
988 callbackInfo->onCallbackSignal->data = callbackInfo.get();
989 uv_async_send(callbackInfo->onCallbackSignal);
992 callbackInfo->onCallbackSignal->data = callbackInfo.get();
993 uv_async_send(callbackInfo->onCallbackSignal);
1012 MsgQueue* TaskManager::GetMessageQueueFromCallbackInfo(CallbackInfo* callbackInfo)
1015 if (callbackInfo == nullptr || callbackInfo->worker == nullptr) {
1016 HILOG_ERROR("taskpool:: callbackInfo or worker is nullptr");
1019 auto worker = callbackInfo->worker;
1021 worker->Dequeue(callbackInfo->hostEnv, queue);