Lines Matching refs:msgQueue
108 auto* msgQueue = TaskManager::GetInstance().GetMessageQueue(req);
109 if (msgQueue == nullptr) {
110 HILOG_ERROR("taskpool:: msgQueue is nullptr");
113 ExecuteCallbackInner(*msgQueue);
118 auto* msgQueue = TaskManager::GetInstance().GetMessageQueueFromCallbackInfo(callbackInfo);
119 if (msgQueue == nullptr) {
120 HILOG_ERROR("taskpool:: msgQueue is nullptr");
123 ExecuteCallbackInner(*msgQueue);
126 void TaskPool::ExecuteCallbackInner(MsgQueue& msgQueue)
128 while (!msgQueue.IsEmpty()) {
129 auto resultInfo = msgQueue.DeQueue();