Lines Matching refs:sessionId
116 … hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
175 FreeSession(hSession->sessionId); in ClearSessions()
315 void HdcSessionBase::PushAsyncMessage(const uint32_t sessionId, const uint8_t method, const void *d… in PushAsyncMessage() argument
322 param->sid = sessionId; in PushAsyncMessage()
403 uint32_t sessionId) in MallocSession() argument
416 hSession->sessionId = ((sessionId == 0) ? GetSessionPseudoUid() : sessionId); in MallocSession()
437 hSession->sessionId, hSession->connType); in MallocSession()
469 AdminSession(OP_ADD, hSession->sessionId, hSession); in MallocSession()
539 thisClass->AdminSession(OP_REMOVE, hSession->sessionId, nullptr); in FreeSessionFinally()
540 WRITE_LOG(LOG_DEBUG, "!!!FreeSessionFinally sessionId:%u finish", hSession->sessionId); in FreeSessionFinally()
596 …E_LOG(LOG_DEBUG, "FreeSessionOpeate, send workthread for free. sessionId:%u", hSession->sessionId); in FreeSessionOpeate()
613 void HdcSessionBase::FreeSession(const uint32_t sessionId) in FreeSession() argument
617 PushAsyncMessage(sessionId, ASYNC_FREE_SESSION, nullptr, 0); in FreeSession()
620 HSession hSession = AdminSession(OP_QUERY, sessionId, nullptr); in FreeSession()
621 WRITE_LOG(LOG_DEBUG, "Begin to free session, sessionid:%u", sessionId); in FreeSession()
629 …WRITE_LOG(LOG_DEBUG, "FreeSession sessionId:%u ref:%u", hSession->sessionId, uint32_t(hSession->re… in FreeSession()
633 HSession HdcSessionBase::AdminSession(const uint8_t op, const uint32_t sessionId, HSession hInput) in AdminSession() argument
639 mapSession[sessionId] = hInput; in AdminSession()
644 mapSession.erase(sessionId); in AdminSession()
649 if (mapSession.count(sessionId)) { in AdminSession()
650 hRet = mapSession[sessionId]; in AdminSession()
656 if (mapSession.count(sessionId)) { in AdminSession()
657 hRet = mapSession[sessionId]; in AdminSession()
665 mapSession.erase(sessionId); in AdminSession()
666 mapSession[hInput->sessionId] = hInput; in AdminSession()
670 if (mapSession.count(sessionId) == 0) { in AdminSession()
676 hRet = mapSession[sessionId]; in AdminSession()
680 if (sessionId == kv.first) { in AdminSession()
684 sessionId, kv.first, kv.second->voteReset ? "YES" : "NO"); in AdminSession()
694 WRITE_LOG(LOG_FATAL, "!! session:%u vote reset, passed unanimously !!", sessionId); in AdminSession()
734 hSession->sessionId, channelId, mapTask.size()); in AdminTask()
740 hSession->sessionId, channelId, mapTask.size()); in AdminTask()
748 AdminSession(op, hSession->sessionId, nullptr); in AdminTask()
798 int HdcSessionBase::Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t command… in Send() argument
802 HSession hSession = AdminSession(OP_QUERY, sessionId, nullptr); in Send()
804 WRITE_LOG(LOG_DEBUG, "Send to offline device, drop it, sessionId:%u", sessionId); in Send()
971 WRITE_LOG(LOG_DEBUG, "FinishWriteSessionTCP freesession :%u", hSession->sessionId); in FinishWriteSessionTCP()
972 thisClass->FreeSession(hSession->sessionId); in FinishWriteSessionTCP()
1062 handshake.sessionId = hSession->sessionId; in WorkThreadStartSession()
1072 hSession->sessionId, handshake.authType, hs.c_str()); in WorkThreadStartSession()
1074 Send(hSession->sessionId, 0, CMD_KERNEL_HANDSHAKE, in WorkThreadStartSession()
1109 hSession->sessionId, hSession->serverOrDaemon ? "server" : "daemon"); in DispatchMainThreadCommand()
1114 … WRITE_LOG(LOG_DEBUG, "Dispatch MainThreadCommand STOP_SESSION sessionId:%u", hSession->sessionId); in DispatchMainThreadCommand()
1183 hSession->sessionId, ctrl->channelId, ctrl->command); in ReadCtrlFromMain()
1198 WRITE_LOG(LOG_INFO, "ReChildLoopForSessionClear sessionId:%u", hSession->sessionId); in ReChildLoopForSessionClear()
1210 hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->channelId, hTask->sessionId); in ReChildLoopForSessionClear()
1213 hSession = thisClass->AdminSession(OP_QUERY, hTask->sessionId, nullptr); in ReChildLoopForSessionClear()
1239 WRITE_LOG(LOG_DEBUG, "!!!Workthread run begin, sessionId:%u instance:%s", hSession->sessionId, in SessionWorkThread()
1242 WRITE_LOG(LOG_DEBUG, "!!!Workthread run again, sessionId:%u", hSession->sessionId); in SessionWorkThread()
1246 WRITE_LOG(LOG_DEBUG, "!!!Workthread run finish, sessionId:%u", hSession->sessionId); in SessionWorkThread()
1250 void HdcSessionBase::LogMsg(const uint32_t sessionId, const uint32_t channelId, in LogMsg() argument
1261 ServerCommand(sessionId, channelId, CMD_KERNEL_ECHO, buf.data(), buf.size()); in LogMsg()
1320 hTaskInfo->sessionId = hSession->sessionId; in DispatchTaskData()
1338 …LogMsg(hTaskInfo->sessionId, hTaskInfo->channelId, MSG_FAIL, "hdc thread pool busy, may cause rese… in DispatchTaskData()