• Home
  • Raw
  • Download

Lines Matching refs:sessionId

455         uint32_t sessionId = 0;  in PackageProcess()  local
458 if (ValidateUartPacket(data, sessionId, packageIndex, packetSize) != RET_SUCCESS) { in PackageProcess()
473 hSession = GetSession(sessionId); in PackageProcess()
476 hSession = GetSession(sessionId, true); in PackageProcess()
480 … WRITE_LOG(LOG_WARN, "%s have not found session (%u). skip it", __FUNCTION__, sessionId); in PackageProcess()
500 ResponseUartTrans(hSession->sessionId, ++hSession->hUART->packageIndex, in PackageProcess()
540 hSession = GetSession(uartHeader->sessionId); in SendUARTRaw()
543 WRITE_LOG(LOG_WARN, "%s hSession not found:%zu", __FUNCTION__, uartHeader->sessionId); in SendUARTRaw()
583 if (head->sessionId != hSession->sessionId) { in UartSendToHdcStream()
586 head->sessionId); in UartSendToHdcStream()
587 SendUartSoftReset(hSession, head->sessionId); in UartSendToHdcStream()
663 slots.Wait(head->sessionId); in RequestSendPackage()
673 outPkgs.emplace_back(pkgId, head->sessionId, data, length, response, in RequestSendPackage()
695 slots.Free(it->sessionId); in ProcessResponsePackage()
729 if (!it->response and hasWaitPkg.find(it->sessionId) != hasWaitPkg.end()) { in SendPkgInUARTOutMap()
753 hasWaitPkg.emplace(it->sessionId); in SendPkgInUARTOutMap()
776 it->sessionId); in SendPkgInUARTOutMap()
777 OnTransferError(GetSession(it->sessionId)); in SendPkgInUARTOutMap()
784 hasWaitPkg.emplace(it->sessionId); in SendPkgInUARTOutMap()
791 void HdcUARTBase::ClearUARTOutMap(uint32_t sessionId) in ClearUARTOutMap() argument
793 WRITE_LOG(LOG_DEBUG, "%s UartPackageManager clean for sessionId %u", __FUNCTION__, sessionId); in ClearUARTOutMap()
798 if (it->sessionId == sessionId) { in ClearUARTOutMap()
800 slots.Free(it->sessionId); in ClearUARTOutMap()
823 RetErrCode HdcUARTBase::ValidateUartPacket(vector<uint8_t> &data, uint32_t &sessionId, in ValidateUartPacket() argument
841 sessionId = head->sessionId; in ValidateUartPacket()
853 __FUNCTION__, head->sessionId); in ValidateUartPacket()
854 ResetOldSession(head->sessionId); in ValidateUartPacket()
862 head->sessionId); in ValidateUartPacket()
863 Restartession(GetSession(head->sessionId)); in ValidateUartPacket()
878 ResponseUartTrans(head->sessionId, head->packageIndex, PKG_OPTION_ACK); in ValidateUartPacket()
885 void HdcUARTBase::ResponseUartTrans(uint32_t sessionId, uint32_t packageIndex, in ResponseUartTrans() argument
888 UartHead uartHeader(sessionId, option, 0, packageIndex); in ResponseUartTrans()
896 WRITE_LOG(LOG_DEBUG, "SendUARTData hSession:%u, total length:%d", hSession->sessionId, length); in SendUARTData()
912 head->sessionId = hSession->sessionId; in SendUARTData()
956 hSession->sessionId, nread, buffer, in ReadDataFromUARTStream()
967 hUARTBase->ResponseUartTrans(hSession->sessionId, ++hSession->hUART->packageIndex, in ReadDataFromUARTStream()
971 hSessionBase->FreeSession(hSession->sessionId); in ReadDataFromUARTStream()
974 WRITE_LOG(LOG_DEBUG, "%s sessionId:%u, nread:%d", __FUNCTION__, hSession->sessionId, nread); in ReadDataFromUARTStream()
1000 ClearUARTOutMap(session->sessionId); in Restartession()
1001 sessionBase.FreeSession(session->sessionId); in Restartession()
1009 ClearUARTOutMap(hSession->sessionId); in StopSession()