Lines Matching refs:channelId
83 WRITE_LOG(LOG_WARN, "TryRemoveTask channelId:%u", hTask->channelId); in TryRemoveTask()
103 hTask->channelId, hTask->taskStop, hTask->taskFree); in BeginRemoveTask()
107 …RITE_LOG(LOG_DEBUG, "BeginRemoveTask taskType:%d channelId:%u", hTask->taskType, hTask->channelId); in BeginRemoveTask()
110 …(LOG_INFO, "RemoveInstanceTask false taskType:%d channelId:%u", hTask->taskType, hTask->channelId); in BeginRemoveTask()
119 … hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
124 WRITE_LOG(LOG_WARN, "TaskDelay TryRemoveTask false channelId:%u", hTask->channelId); in BeginRemoveTask()
127 WRITE_LOG(LOG_DEBUG, "TaskDelay task remove finish, channelId:%u", hTask->channelId); in BeginRemoveTask()
152 uint32_t channelId = iter->first; in ClearOwnTasks() local
155 if (channelIDInput != channelId) { in ClearOwnTasks()
730 idx++, ti->channelId, ti->taskType, ti->closeRetryCount); in DumpTasksInfo()
735 HTaskInfo HdcSessionBase::AdminTask(const uint8_t op, HSession hSession, const uint32_t channelId, … in AdminTask() argument
742 hRet = mapTask[channelId]; in AdminTask()
746 mapTask[channelId] = hInput; in AdminTask()
750 hSession->sessionId, channelId, mapTask.size()); in AdminTask()
754 mapTask.erase(channelId); in AdminTask()
756 hSession->sessionId, channelId, mapTask.size()); in AdminTask()
759 if (mapTask.count(channelId)) { in AdminTask()
760 hRet = mapTask[channelId]; in AdminTask()
815 int HdcSessionBase::Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t command… in Send() argument
825 protectBuf.channelId = channelId; in Send()
891 if (!FetchCommand(hSession, protectBuf.channelId, protectBuf.commandFlag, data, dataSize)) { in DecryptPayload()
893 protectBuf.channelId, protectBuf.commandFlag); in DecryptPayload()
1101 vector<uint8_t> HdcSessionBase::BuildCtrlString(InnerCtrlCommand command, uint32_t channelId, uint8… in BuildCtrlString() argument
1112 ctrl.channelId = channelId; in BuildCtrlString()
1127 uint32_t channelId = ctrl->channelId; // if send not set, it is zero in DispatchMainThreadCommand() local
1163 AttachChannel(hSession, channelId); in DispatchMainThreadCommand()
1170 DeatchChannel(hSession, channelId); in DispatchMainThreadCommand()
1206 hSession->sessionId, ctrl->channelId, ctrl->command); in ReadCtrlFromMain()
1233 hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->channelId, hTask->sessionId); in ReChildLoopForSessionClear()
1237 thisClass->AdminTask(OP_VOTE_RESET, hSession, hTask->channelId, nullptr); in ReChildLoopForSessionClear()
1274 void HdcSessionBase::LogMsg(const uint32_t sessionId, const uint32_t channelId, in LogMsg() argument
1285 ServerCommand(sessionId, channelId, CMD_KERNEL_ECHO, buf.data(), buf.size()); in LogMsg()
1327 bool HdcSessionBase::DispatchTaskData(HSession hSession, const uint32_t channelId, const uint16_t c… in DispatchTaskData() argument
1337 WRITE_LOG(LOG_DEBUG, "New HTaskInfo channelId:%u command:%u", channelId, command); in DispatchTaskData()
1343 hTaskInfo->channelId = channelId; in DispatchTaskData()
1353 if (AdminTask(OP_ADD, hSession, channelId, hTaskInfo)) { in DispatchTaskData()
1362 LogMsg(hTaskInfo->sessionId, hTaskInfo->channelId, in DispatchTaskData()
1371 hTaskInfo = AdminTask(OP_QUERY, hSession, channelId, nullptr); in DispatchTaskData()
1374 … WRITE_LOG(LOG_ALL, "Dead HTaskInfo, ignore, channelId:%u command:%u", channelId, command); in DispatchTaskData()
1377 ret = RedirectToTask(hTaskInfo, hSession, channelId, command, payload, payloadSize); in DispatchTaskData()