119 …      hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId);  in BeginRemoveTask()
161                 hSession->sessionId, channelIDInput);  in ClearOwnTasks()
179             FreeSession(hSession->sessionId);  in ClearSessions()
319 void HdcSessionBase::PushAsyncMessage(const uint32_t sessionId, const uint8_t method, const void *d…  in PushAsyncMessage()  argument
326     param->sid = sessionId;  in PushAsyncMessage()
407                                        uint32_t sessionId)  in MallocSession()  argument
424     hSession->sessionId = ((sessionId == 0) ? GetSessionPseudoUid() : sessionId);  in MallocSession()
445               hSession->sessionId, hSession->connType);  in MallocSession()
481         AdminSession(OP_ADD, hSession->sessionId, hSession);  in MallocSession()
547             hSession->uvHandleRef, hSession->sessionId);  in FreeSessionFinally()
553     thisClass->AdminSession(OP_REMOVE, hSession->sessionId, nullptr);  in FreeSessionFinally()
554     WRITE_LOG(LOG_DEBUG, "!!!FreeSessionFinally sessionId:%u finish", hSession->sessionId);  in FreeSessionFinally()
613 …E_LOG(LOG_DEBUG, "FreeSessionOpeate, send workthread for free. sessionId:%u", hSession->sessionId);  in FreeSessionOpeate()
619                     hSession->childCleared, hSession->sessionId);  in FreeSessionOpeate()
632 void HdcSessionBase::FreeSession(const uint32_t sessionId)  in FreeSession()  argument
636         PushAsyncMessage(sessionId, ASYNC_FREE_SESSION, nullptr, 0);  in FreeSession()
639     HSession hSession = AdminSession(OP_QUERY, sessionId, nullptr);  in FreeSession()
640     WRITE_LOG(LOG_DEBUG, "Begin to free session, sessionid:%u", sessionId);  in FreeSession()
643             WRITE_LOG(LOG_WARN, "FreeSession hSession nullptr or isDead sessionId:%u", sessionId);  in FreeSession()
649 …WRITE_LOG(LOG_DEBUG, "FreeSession sessionId:%u ref:%u", hSession->sessionId, uint32_t(hSession->re…  in FreeSession()
653 HSession HdcSessionBase::AdminSession(const uint8_t op, const uint32_t sessionId, HSession hInput)  in AdminSession()  argument
659             mapSession[sessionId] = hInput;  in AdminSession()
664             mapSession.erase(sessionId);  in AdminSession()
669             if (mapSession.count(sessionId)) {  in AdminSession()
670                 hRet = mapSession[sessionId];  in AdminSession()
676             if (mapSession.count(sessionId)) {  in AdminSession()
677                 hRet = mapSession[sessionId];  in AdminSession()
685             mapSession.erase(sessionId);  in AdminSession()
686             mapSession[hInput->sessionId] = hInput;  in AdminSession()
690             if (mapSession.count(sessionId) == 0) {  in AdminSession()
696                 hRet = mapSession[sessionId];  in AdminSession()
700                     if (sessionId == kv.first) {  in AdminSession()
704                               sessionId, kv.first, kv.second->voteReset ? "YES" : "NO");  in AdminSession()
714                 WRITE_LOG(LOG_FATAL, "!! session:%u vote reset, passed unanimously !!", sessionId);  in AdminSession()
750                       hSession->sessionId, channelId, mapTask.size());  in AdminTask()
756                       hSession->sessionId, channelId, mapTask.size());  in AdminTask()
764             AdminSession(op, hSession->sessionId, nullptr);  in AdminTask()
815 int HdcSessionBase::Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t command…  in Send()  argument
819     HSession hSession = AdminSession(OP_QUERY, sessionId, nullptr);  in Send()
821         WRITE_LOG(LOG_DEBUG, "Send to offline device, drop it, sessionId:%u", sessionId);  in Send()
954 …  WRITE_LOG(LOG_FATAL, "FetchIOBuf error childRet:%d sessionId:%u", childRet, hSession->sessionId);  in FetchIOBuf()
988             status, hSession->sessionId, hSession->isDead, uint32_t(hSession->ref));  in FinishWriteSessionTCP()
991             WRITE_LOG(LOG_DEBUG, "FinishWriteSessionTCP freesession :%u", hSession->sessionId);  in FinishWriteSessionTCP()
992             thisClass->FreeSession(hSession->sessionId);  in FinishWriteSessionTCP()
1083         handshake.sessionId = hSession->sessionId;  in WorkThreadStartSession()
1093                   hSession->sessionId, handshake.authType, hs.c_str());  in WorkThreadStartSession()
1095         Send(hSession->sessionId, 0, CMD_KERNEL_HANDSHAKE,  in WorkThreadStartSession()
1131                       hSession->sessionId, hSession->serverOrDaemon ? "server" : "daemon");  in DispatchMainThreadCommand()
1136 … WRITE_LOG(LOG_DEBUG, "Dispatch MainThreadCommand STOP_SESSION sessionId:%u", hSession->sessionId);  in DispatchMainThreadCommand()
1205                       hSession->sessionId, ctrl->channelId, ctrl->command);  in ReadCtrlFromMain()
1220     WRITE_LOG(LOG_INFO, "ReChildLoopForSessionClear sessionId:%u", hSession->sessionId);  in ReChildLoopForSessionClear()
1232                       hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->channelId, hTask->sessionId);  in ReChildLoopForSessionClear()
1235                 hSession = thisClass->AdminSession(OP_QUERY, hTask->sessionId, nullptr);  in ReChildLoopForSessionClear()
1261     WRITE_LOG(LOG_DEBUG, "!!!Workthread run begin, sessionId:%u instance:%s", hSession->sessionId,  in SessionWorkThread()
1264     WRITE_LOG(LOG_DEBUG, "!!!Workthread run again, sessionId:%u", hSession->sessionId);  in SessionWorkThread()
1268     WRITE_LOG(LOG_DEBUG, "!!!Workthread run finish, sessionId:%u", hSession->sessionId);  in SessionWorkThread()
1272 void HdcSessionBase::LogMsg(const uint32_t sessionId, const uint32_t channelId,  in LogMsg()  argument
1283     ServerCommand(sessionId, channelId, CMD_KERNEL_ECHO, buf.data(), buf.size());  in LogMsg()
1342             hTaskInfo->sessionId = hSession->sessionId;  in DispatchTaskData()
1360 …LogMsg(hTaskInfo->sessionId, hTaskInfo->channelId, MSG_FAIL, "hdc thread pool busy, may cause rese…  in DispatchTaskData()