102 …RITE_LOG(LOG_DEBUG, "BeginRemoveTask taskType:%d channelId:%u", hTask->taskType, hTask->channelId);  in BeginRemoveTask()
105 …(LOG_INFO, "RemoveInstanceTask false taskType:%d channelId:%u", hTask->taskType, hTask->channelId);  in BeginRemoveTask()
113 …      hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId);  in BeginRemoveTask()
120         WRITE_LOG(LOG_DEBUG, "TaskDelay task remove finish, channelId:%u", hTask->channelId);  in BeginRemoveTask()
144         uint32_t channelId = iter->first;  in ClearOwnTasks()  local
147             if (channelIDInput != channelId) {  in ClearOwnTasks()
694                   idx++, ti->channelId, ti->taskType, ti->closeRetryCount);  in DumpTasksInfo()
699 HTaskInfo HdcSessionBase::AdminTask(const uint8_t op, HSession hSession, const uint32_t channelId, …  in AdminTask()  argument
716             hRet = mapTask[channelId];  in AdminTask()
720             mapTask[channelId] = hInput;  in AdminTask()
724                       hSession->sessionId, channelId, mapTask.size());  in AdminTask()
728             mapTask.erase(channelId);  in AdminTask()
730                       hSession->sessionId, channelId, mapTask.size());  in AdminTask()
733             if (mapTask.count(channelId)) {  in AdminTask()
734                 hRet = mapTask[channelId];  in AdminTask()
796 int HdcSessionBase::Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t command…  in Send()  argument
805     protectBuf.channelId = channelId;  in Send()
870     if (!FetchCommand(hSession, protectBuf.channelId, protectBuf.commandFlag, data, dataSize)) {  in DecryptPayload()
872                   protectBuf.channelId, protectBuf.commandFlag);  in DecryptPayload()
1066 vector<uint8_t> HdcSessionBase::BuildCtrlString(InnerCtrlCommand command, uint32_t channelId, uint8…  in BuildCtrlString()  argument
1076         ctrl.channelId = channelId;  in BuildCtrlString()
1091     uint32_t channelId = ctrl->channelId;  // if send not set, it is zero  in DispatchMainThreadCommand()  local
1123             AttachChannel(hSession, channelId);  in DispatchMainThreadCommand()
1130             DeatchChannel(hSession, channelId);  in DispatchMainThreadCommand()
1163                       hSession->sessionId, ctrl->channelId, ctrl->command);  in ReadCtrlFromMain()
1190                       hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->channelId, hTask->sessionId);  in ReChildLoopForSessionClear()
1194                 thisClass->AdminTask(OP_VOTE_RESET, hSession, hTask->channelId, nullptr);  in ReChildLoopForSessionClear()
1239 void HdcSessionBase::LogMsg(const uint32_t sessionId, const uint32_t channelId,  in LogMsg()  argument
1250     ServerCommand(sessionId, channelId, CMD_KERNEL_ECHO, buf.data(), buf.size());  in LogMsg()
1291 bool HdcSessionBase::DispatchTaskData(HSession hSession, const uint32_t channelId, const uint16_t c…  in DispatchTaskData()  argument
1300             WRITE_LOG(LOG_DEBUG, "New HTaskInfo channelId:%u command:%u", channelId, command);  in DispatchTaskData()
1306             hTaskInfo->channelId = channelId;  in DispatchTaskData()
1316                 if (AdminTask(OP_ADD, hSession, channelId, hTaskInfo)) {  in DispatchTaskData()
1325 …LogMsg(hTaskInfo->sessionId, hTaskInfo->channelId, MSG_FAIL, "hdc thread pool busy, may cause rese…  in DispatchTaskData()
1333             hTaskInfo = AdminTask(OP_QUERY, hSession, channelId, nullptr);  in DispatchTaskData()
1336 …         WRITE_LOG(LOG_ALL, "Dead HTaskInfo, ignore, channelId:%u command:%u", channelId, command);  in DispatchTaskData()
1339         ret = RedirectToTask(hTaskInfo, hSession, channelId, command, payload, payloadSize);  in DispatchTaskData()