Searched refs:inFrameBuffer (Results 1 – 2 of 2) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_aggregator.cpp | 664 …catorAggregator::OnAppLayerFrameReceive(const std::string &srcTarget, SerialBuffer *&inFrameBuffer, in OnAppLayerFrameReceive() argument
670 … int errCode = TryDeliverAppLayerFrameToCommunicatorNoMutex(srcTarget, inFrameBuffer, toLabel); in OnAppLayerFrameReceive()
688 …int errCodeAgain = TryDeliverAppLayerFrameToCommunicatorNoMutex(srcTarget, inFrameBuffer, toLabel); in OnAppLayerFrameReceive()
695 TryToFeedbackWhenCommunicatorNotFound(srcTarget, toLabel, inFrameBuffer); in OnAppLayerFrameReceive()
696 delete inFrameBuffer; in OnAppLayerFrameReceive()
697 inFrameBuffer = nullptr; in OnAppLayerFrameReceive()
701 retainer_.RetainFrame(FrameInfo{inFrameBuffer, srcTarget, toLabel, inResult.GetFrameId()}); in OnAppLayerFrameReceive()
702 inFrameBuffer = nullptr; in OnAppLayerFrameReceive()
707 SerialBuffer *&inFrameBuffer, const LabelType &toLabel) in TryDeliverAppLayerFrameToCommunicatorNoMutex() argument
711 commMap_.at(toLabel).first->OnBufferReceive(srcTarget, inFrameBuffer); in TryDeliverAppLayerFrameToCommunicatorNoMutex()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | communicator_aggregator.h | 116 int OnAppLayerFrameReceive(const std::string &srcTarget, SerialBuffer *&inFrameBuffer,
120 …liverAppLayerFrameToCommunicatorNoMutex(const std::string &srcTarget, SerialBuffer *&inFrameBuffer,
|