• Home
  • Raw
  • Download

Lines Matching refs:sessionId

457         uint32_t sessionId = 0;  in PackageProcess()  local
460 if (ValidateUartPacket(data, sessionId, packageIndex, packetSize) != RET_SUCCESS) { in PackageProcess()
475 hSession = GetSession(sessionId); in PackageProcess()
478 hSession = GetSession(sessionId, true); in PackageProcess()
482 … WRITE_LOG(LOG_WARN, "%s have not found session (%u). skip it", __FUNCTION__, sessionId); in PackageProcess()
502 ResponseUartTrans(hSession->sessionId, ++hSession->hUART->packageIndex, in PackageProcess()
542 hSession = GetSession(uartHeader->sessionId); in SendUARTRaw()
545 WRITE_LOG(LOG_WARN, "%s hSession not found:%zu", __FUNCTION__, uartHeader->sessionId); in SendUARTRaw()
585 if (head->sessionId != hSession->sessionId) { in UartSendToHdcStream()
588 head->sessionId); in UartSendToHdcStream()
589 SendUartSoftReset(hSession, head->sessionId); in UartSendToHdcStream()
665 slots.Wait(head->sessionId); in RequestSendPackage()
675 outPkgs.emplace_back(pkgId, head->sessionId, data, length, response, in RequestSendPackage()
697 slots.Free(it->sessionId); in ProcessResponsePackage()
731 if (!it->response and hasWaitPkg.find(it->sessionId) != hasWaitPkg.end()) { in SendPkgInUARTOutMap()
755 hasWaitPkg.emplace(it->sessionId); in SendPkgInUARTOutMap()
778 it->sessionId); in SendPkgInUARTOutMap()
779 OnTransferError(GetSession(it->sessionId)); in SendPkgInUARTOutMap()
786 hasWaitPkg.emplace(it->sessionId); in SendPkgInUARTOutMap()
793 void HdcUARTBase::ClearUARTOutMap(uint32_t sessionId) in ClearUARTOutMap() argument
795 WRITE_LOG(LOG_DEBUG, "%s UartPackageManager clean for sessionId %u", __FUNCTION__, sessionId); in ClearUARTOutMap()
800 if (it->sessionId == sessionId) { in ClearUARTOutMap()
802 slots.Free(it->sessionId); in ClearUARTOutMap()
825 RetErrCode HdcUARTBase::ValidateUartPacket(vector<uint8_t> &data, uint32_t &sessionId, in ValidateUartPacket() argument
843 sessionId = head->sessionId; in ValidateUartPacket()
855 __FUNCTION__, head->sessionId); in ValidateUartPacket()
856 ResetOldSession(head->sessionId); in ValidateUartPacket()
864 head->sessionId); in ValidateUartPacket()
865 Restartession(GetSession(head->sessionId)); in ValidateUartPacket()
880 ResponseUartTrans(head->sessionId, head->packageIndex, PKG_OPTION_ACK); in ValidateUartPacket()
887 void HdcUARTBase::ResponseUartTrans(uint32_t sessionId, uint32_t packageIndex, in ResponseUartTrans() argument
890 UartHead uartHeader(sessionId, option, 0, packageIndex); in ResponseUartTrans()
898 WRITE_LOG(LOG_DEBUG, "SendUARTData hSession:%u, total length:%d", hSession->sessionId, length); in SendUARTData()
914 head->sessionId = hSession->sessionId; in SendUARTData()
958 hSession->sessionId, nread, buffer, in ReadDataFromUARTStream()
969 hUARTBase->ResponseUartTrans(hSession->sessionId, ++hSession->hUART->packageIndex, in ReadDataFromUARTStream()
973 hSessionBase->FreeSession(hSession->sessionId); in ReadDataFromUARTStream()
976 WRITE_LOG(LOG_DEBUG, "%s sessionId:%u, nread:%d", __FUNCTION__, hSession->sessionId, nread); in ReadDataFromUARTStream()
1002 ClearUARTOutMap(session->sessionId); in Restartession()
1003 sessionBase.FreeSession(session->sessionId); in Restartession()
1011 ClearUARTOutMap(hSession->sessionId); in StopSession()