Lines Matching refs:sessionId
119 hTask->taskType, hTask->channelId, hTask->sessionId);
123 hTask->taskType, hTask->channelId, hTask->sessionId);
129 WRITE_LOG(LOG_DEBUG, "TaskDelay task remove retry count %d/%d, taskType:%d channelId:%u, sessionId:%u",
130 hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId);
171 WRITE_LOG(LOG_WARN, "ClearOwnTasks OP_CLEAR finish, sessionId:%u channelIDInput:%u",
172 hSession->sessionId, channelIDInput);
190 FreeSession(hSession->sessionId);
330 void HdcSessionBase::PushAsyncMessage(const uint32_t sessionId, const uint8_t method, const void *data,
337 param->sid = sessionId;
418 uint32_t sessionId)
435 hSession->sessionId = ((sessionId == 0) ? GetSessionPseudoUid() : sessionId);
455 WRITE_LOG(LOG_INFO, "HdcSessionBase NewSession, sessionId:%u, connType:%d.",
456 hSession->sessionId, hSession->connType);
492 AdminSession(OP_ADD, hSession->sessionId, hSession);
557 WRITE_LOG(LOG_INFO, "FreeSessionFinally uvHandleRef:%d sessionId:%u",
558 hSession->uvHandleRef, hSession->sessionId);
564 thisClass->AdminSession(OP_REMOVE, hSession->sessionId, nullptr);
565 WRITE_LOG(LOG_INFO, "!!!FreeSessionFinally sessionId:%u finish", hSession->sessionId);
617 WRITE_LOG(LOG_WARN, "FreeSessionOpeate sid:%u ref:%u > 0", hSession->sessionId, uint32_t(hSession->ref));
620 WRITE_LOG(LOG_INFO, "FreeSessionOpeate sid:%u ref:%u", hSession->sessionId, uint32_t(hSession->ref));
625 WRITE_LOG(LOG_INFO, "FreeSessionOpeate, send workthread for free. sessionId:%u", hSession->sessionId);
630 WRITE_LOG(LOG_INFO, "FreeSessionOpeate childCleared:%d sessionId:%u",
631 hSession->childCleared, hSession->sessionId);
644 void HdcSessionBase::FreeSession(const uint32_t sessionId)
647 Base::AddDeletedSessionId(sessionId);
649 PushAsyncMessage(sessionId, ASYNC_FREE_SESSION, nullptr, 0);
652 HSession hSession = AdminSession(OP_QUERY, sessionId, nullptr);
653 WRITE_LOG(LOG_INFO, "Begin to free session, sessionid:%u", sessionId);
656 WRITE_LOG(LOG_WARN, "FreeSession hSession nullptr or isDead sessionId:%u", sessionId);
665 WRITE_LOG(LOG_INFO, "FreeSession sessionId:%u ref:%u", hSession->sessionId, uint32_t(hSession->ref));
669 HSession HdcSessionBase::AdminSession(const uint8_t op, const uint32_t sessionId, HSession hInput)
675 mapSession[sessionId] = hInput;
680 mapSession.erase(sessionId);
685 if (mapSession.count(sessionId)) {
686 hRet = mapSession[sessionId];
692 if (mapSession.count(sessionId)) {
693 hRet = mapSession[sessionId];
701 mapSession.erase(sessionId);
702 mapSession[hInput->sessionId] = hInput;
706 if (mapSession.count(sessionId) == 0) {
712 hRet = mapSession[sessionId];
716 if (sessionId == kv.first) {
720 sessionId, kv.first, kv.second->voteReset ? "YES" : "NO");
730 WRITE_LOG(LOG_FATAL, "!! session:%u vote reset, passed unanimously !!", sessionId);
766 hSession->sessionId, channelId, mapTask.size());
772 hSession->sessionId, channelId, mapTask.size());
780 AdminSession(op, hSession->sessionId, nullptr);
831 int HdcSessionBase::Send(const uint32_t sessionId, const uint32_t channelId, const uint16_t commandFlag,
835 HSession hSession = AdminSession(OP_QUERY, sessionId, nullptr);
837 WRITE_LOG(LOG_WARN, "Send to offline device, drop it, sessionId:%u", sessionId);
971 WRITE_LOG(LOG_FATAL, "FetchIOBuf error childRet:%d sessionId:%u", childRet, hSession->sessionId);
1004 WRITE_LOG(LOG_WARN, "FinishWriteSessionTCP status:%d sessionId:%u isDead:%d ref:%u",
1005 status, hSession->sessionId, hSession->isDead, uint32_t(hSession->ref));
1008 WRITE_LOG(LOG_DEBUG, "FinishWriteSessionTCP freesession :%u", hSession->sessionId);
1009 thisClass->FreeSession(hSession->sessionId);
1066 handshake.sessionId = hSession->sessionId;
1117 hSession->sessionId, handshake.authType, hs.c_str());
1119 Send(hSession->sessionId, 0, CMD_KERNEL_HANDSHAKE,
1154 WRITE_LOG(LOG_WARN, "Dispatch MainThreadCommand START_SESSION sessionId:%u instance:%s",
1155 hSession->sessionId, hSession->serverOrDaemon ? "server" : "daemon");
1160 WRITE_LOG(LOG_WARN, "Dispatch MainThreadCommand STOP_SESSION sessionId:%u", hSession->sessionId);
1229 WRITE_LOG(LOG_FATAL, "ReadCtrlFromMain failed sessionId:%u channelId:%u command:%u",
1230 hSession->sessionId, ctrl->channelId, ctrl->command);
1245 WRITE_LOG(LOG_INFO, "ReChildLoopForSessionClear sessionId:%u", hSession->sessionId);
1256 WRITE_LOG(level, "wait task free retry %d/%d, channelId:%u, sessionId:%u",
1257 hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->channelId, hTask->sessionId);
1260 hSession = thisClass->AdminSession(OP_QUERY, hTask->sessionId, nullptr);
1287 WRITE_LOG(LOG_DEBUG, "!!!Workthread run begin, sessionId:%u instance:%s", hSession->sessionId,
1290 WRITE_LOG(LOG_DEBUG, "!!!Workthread run again, sessionId:%u", hSession->sessionId);
1294 WRITE_LOG(LOG_WARN, "!!!Workthread run finish, sessionId:%u", hSession->sessionId);
1298 void HdcSessionBase::LogMsg(const uint32_t sessionId, const uint32_t channelId,
1309 ServerCommand(sessionId, channelId, CMD_KERNEL_ECHO, buf.data(), buf.size());
1368 hTaskInfo->sessionId = hSession->sessionId;
1387 LogMsg(hTaskInfo->sessionId, hTaskInfo->channelId,