| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_linker.h | 47 int TargetOnline(const std::string &inTarget, std::set<LabelType> &outRelatedLabels);
51 void TargetOffline(const std::string &inTarget, std::set<LabelType> &outRelatedLabels);
57 int IncreaseLocalLabel(const LabelType &inLabel, std::set<std::string> &outOnlineTarget);
61 int DecreaseLocalLabel(const LabelType &inLabel);
66 int ReceiveLabelExchange(const std::string &inTarget, const std::set<LabelType> &inLatestLabels,
67 … uint64_t inDistinctValue, uint64_t inSequenceId, std::map<LabelType, bool> &outChangeLabels);
77 void UpdateOnlineLabels(const std::string &device, const std::map<LabelType, bool> &labels);
120 std::set<LabelType> localOnlineLabels_;
124 std::map<std::string, std::set<LabelType>> targetMapOnlineLabels_;
|
| H A D | communicator_linker.cpp | 65 int CommunicatorLinker::TargetOnline(const std::string &inTarget, std::set<LabelType> &outRelatedLa… in TargetOnline()
82 void CommunicatorLinker::TargetOffline(const std::string &inTarget, std::set<LabelType> &outRelated… in TargetOffline()
104 int CommunicatorLinker::IncreaseLocalLabel(const LabelType &inLabel, std::set<std::string> &outOnli… in IncreaseLocalLabel()
123 int CommunicatorLinker::DecreaseLocalLabel(const LabelType &inLabel) in DecreaseLocalLabel()
135 int CommunicatorLinker::ReceiveLabelExchange(const std::string &inTarget, const std::set<LabelType>… in ReceiveLabelExchange()
136 uint64_t inDistinctValue, uint64_t inSequenceId, std::map<LabelType, bool> &outChangeLabels) in ReceiveLabelExchange() argument
287 std::set<LabelType> onlineLabels; in TriggerLabelExchangeEvent()
292 LabelType labelType(label.begin(), label.end()); in TriggerLabelExchangeEvent()
469 void CommunicatorLinker::UpdateOnlineLabels(const std::string &device, const std::map<LabelType, bo… in UpdateOnlineLabels() argument
|
| H A D | communicator.h | 33 Communicator(CommunicatorAggregator *inCommAggregator, const LabelType &inLabel);
68 LabelType GetCommunicatorLabel() const;
77 LabelType commLabel_;
|
| H A D | frame_retainer.cpp | 28 inline void LogRetainInfo(const std::string &logPrefix, const LabelType &label, const std::string &… in LogRetainInfo()
126 std::list<FrameInfo> FrameRetainer::FetchFramesForSpecificCommunicator(const LabelType &inCommLabel) in FetchFramesForSpecificCommunicator()
152 void FrameRetainer::DecreaseRemainTimeAndDiscard(const LabelType &label, in DecreaseRemainTimeAndDiscard()
196 std::map<uint64_t, std::pair<LabelType, std::string>> discardOrder; in DiscardObsoleteFramesIfNeed()
230 std::set<LabelType> emptyLabel; in ShrinkRetainWorkPool()
|
| H A D | communicator_aggregator.cpp | 177 LabelType commLabel = commPtr->GetCommunicatorLabel(); in ReleaseCommunicator()
534 std::set<LabelType> relatedLabels; in OnTargetChange()
615 std::map<LabelType, bool> changedLabels; in OnCommLayerFrameReceive()
667 LabelType toLabel = inResult.GetCommLabel(); in OnAppLayerFrameReceive()
707 SerialBuffer *&inFrameBuffer, const LabelType &toLabel) in TryDeliverAppLayerFrameToCommunicatorNoMutex()
812 const LabelType &dstLabel, const SerialBuffer *inOriFrame) in TryToFeedbackWhenCommunicatorNotFound()
830 const LabelType &dstLabel, Message* &oriMsg) in TriggerCommunicatorNotFoundFeedback()
879 std::map<LabelType, bool> changedLabels; in OnRemoteDBStatusChange()
882 LabelType labelType(label.begin(), label.end()); in OnRemoteDBStatusChange()
892 const std::map<LabelType, bool> &changedLabels) in NotifyConnectChange() argument
[all …]
|
| H A D | protocol_proto.h | 66 …static SerialBuffer *BuildFeedbackMessageFrame(const Message *inMsg, const LabelType &inLabel, int…
68 const std::set<LabelType> &inLabels, int &outErrorNo);
88 static int SetDivergeHeader(SerialBuffer *inBuff, const LabelType &inCommLabel);
|
| H A D | communicator.cpp | 22 Communicator::Communicator(CommunicatorAggregator *inCommAggregator, const LabelType &inLabel) in Communicator()
209 LabelType Communicator::GetCommunicatorLabel() const in GetCommunicatorLabel()
|
| H A D | protocol_proto.cpp | 200 SerialBuffer *ProtocolProto::BuildFeedbackMessageFrame(const Message *inMsg, const LabelType &inLab… in BuildFeedbackMessageFrame()
222 const std::set<LabelType> &inLabels, int &outErrorNo) in BuildLabelExchange()
403 int ProtocolProto::SetDivergeHeader(SerialBuffer *inBuff, const LabelType &inCommLabel) in SetDivergeHeader()
854 …inResult.SetCommLabel(LabelType(std::begin(divergeHeader.commLabel), std::end(divergeHeader.commLa… in ParseCommDivergeHeader()
911 std::set<LabelType> commLabels; in ParseLabelExchange()
915 LabelType commLabel(bytePtr + i * COMM_LABEL_LENGTH, bytePtr + (i + 1) * COMM_LABEL_LENGTH); in ParseLabelExchange()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | parse_result.h | 70 void SetCommLabel(const LabelType &inCommLabel) in SetCommLabel()
82 void SetLatestCommLabels(const std::set<LabelType> &inLatestCommLabels) in SetLatestCommLabels()
131 LabelType GetCommLabel() const in GetCommLabel()
143 const std::set<LabelType>& GetLatestCommLabels() const in GetLatestCommLabels()
174 LabelType commLabel_;
179 std::set<LabelType> latestCommLabels_; // For Only LabelExchange Frame
|
| H A D | frame_retainer.h | 32 LabelType commLabel;
58 std::list<FrameInfo> FetchFramesForSpecificCommunicator(const LabelType &inCommLabel);
61 void DecreaseRemainTimeAndDiscard(const LabelType &label,
80 std::map<LabelType, std::map<std::string, std::map<uint64_t, RetainWork>>> retainWorkPool_;
|
| H A D | communicator_aggregator.h | 63 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override;
84 void ActivateCommunicator(const LabelType &commLabel);
121 const LabelType &toLabel);
131 …void TryToFeedbackWhenCommunicatorNotFound(const std::string &dstTarget, const LabelType &dstLabel,
133 …void TriggerCommunicatorNotFoundFeedback(const std::string &dstTarget, const LabelType &dstLabel, …
140 …void NotifyConnectChange(const std::string &srcTarget, const std::map<LabelType, bool> &changedLab…
174 …std::map<LabelType, std::pair<Communicator *, bool>> commMap_; // bool true indicate communicator …
|
| H A D | icommunicator_aggregator.h | 28 using CommunicatorLackCallback = std::function<int(const LabelType &commLabel, const std::string &u…
46 virtual ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) = 0;
|
| H A D | communicator_type_define.h | 26 using LabelType = std::vector<uint8_t>; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_auto_launch_test.cpp | 375 LabelType label(g_identifierA.begin(), g_identifierA.end());
567 LabelType label(g_identifierA.begin(), g_identifierA.end()); in __anonaf6a41ef0c02()
683 LabelType label(g_identifierA.begin(), g_identifierA.end());
747 LabelType label(g_identifierA.begin(), g_identifierA.end());
783 LabelType label(g_identifierA.begin(), g_identifierA.end());
829 LabelType label(g_identifierA.begin(), g_identifierA.end());
889 LabelType label(g_identifierA.begin(), g_identifierA.end());
969 LabelType label(g_identifierA.begin(), g_identifierA.end());
1043 LabelType label(g_identifierA.begin(), g_identifierA.end());
1096 LabelType label(g_identifierA.begin(), g_identifierA.end()); in __anonaf6a41ef1b02()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator_aggregator.h | 37 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override;
43 void RunCommunicatorLackCallback(const LabelType &commLabel);
|
| H A D | virtual_communicator_aggregator.cpp | 46 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(const LabelType &commLabel, int &ou… in AllocCommunicator()
87 void VirtualCommunicatorAggregator::RunCommunicatorLackCallback(const LabelType &commLabel) in RunCommunicatorLackCallback()
|
| H A D | distributeddb_relational_ver_p2p_sync_test.cpp | 1220 LabelType labelType(g_id.begin(), g_id.end());
1268 LabelType labelType(g_id.begin(), g_id.end());
1310 LabelType labelType(g_id.begin(), g_id.end());
1380 LabelType labelType(g_id.begin(), g_id.end());
1666 LabelType labelType(g_id.begin(), g_id.end());
1899 LabelType labelType(g_id.begin(), g_id.end());
2017 LabelType labelType(g_id.begin(), g_id.end());
2806 LabelType labelType(g_id.begin(), g_id.end());
2888 LabelType labelType(g_id.begin(), g_id.end());
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_test.cpp | 523 LabelType ToLabelType(uint64_t commLabel) in ToLabelType()
547 std::vector<LabelType> lackLabels;
549 [&lackLabels](const LabelType &commLabel, const std::string &userId)->int { in __anonf82a9c550802()
642 std::vector<LabelType> lackLabels;
644 [&lackLabels](const LabelType &commLabel, const std::string &userId)->int { in __anonf82a9c550a02()
731 …int errCode = g_envDeviceB.commAggrHandle->RegCommunicatorLackCallback([](const LabelType &commLab…
805 …int errCode = g_envDeviceB.commAggrHandle->RegCommunicatorLackCallback([](const LabelType &commLab…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | auto_launch.h | 150 int ReceiveUnknownIdentifierCallBack(const LabelType &label, const std::string &originalUserId);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_auto_launch_test.cpp | 82 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override in AllocCommunicator()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | auto_launch.cpp | 68 [this](const LabelType &label, const std::string &originalUserId) { in SetCommunicatorAggregator()
693 int AutoLaunch::ReceiveUnknownIdentifierCallBack(const LabelType &label, const std::string &origina… in ReceiveUnknownIdentifierCallBack()
|