Searched refs:packetResult (Results 1 – 1 of 1) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_aggregator.cpp | 483 ParseResult packetResult; in OnBytesReceive() local
484 int errCode = ProtocolProto::CheckAndParsePacket(srcTarget, bytes, length, packetResult); in OnBytesReceive()
494 SetRemoteCommunicatorVersion(srcTarget, packetResult.GetDbVersion()); in OnBytesReceive()
496 … dbStatusAdapter_->SetRemoteOptimizeCommunication(srcTarget, !packetResult.IsSendLabelExchange()); in OnBytesReceive()
498 … if (packetResult.GetFrameTypeInfo() == FrameType::EMPTY) { // Empty frame will never be fragmented in OnBytesReceive()
503 if (packetResult.IsFragment()) { in OnBytesReceive()
504 OnFragmentReceive(srcTarget, bytes, length, packetResult, userId); in OnBytesReceive()
505 } else if (packetResult.GetFrameTypeInfo() != FrameType::APPLICATION_MESSAGE) { in OnBytesReceive()
506 errCode = OnCommLayerFrameReceive(srcTarget, packetResult); in OnBytesReceive()
511 errCode = OnAppLayerFrameReceive(srcTarget, bytes, length, packetResult, userId); in OnBytesReceive()
|