| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_aggregator.cpp | 139 uint64_t netOrderLabel = HostToNet(commLabel); in AllocCommunicator()
151 LOGI("[CommAggr][Alloc] Label=%.3s.", VEC_TO_STR(commLabel)); in AllocCommunicator()
152 if (commLabel.size() != COMM_LABEL_LENGTH) { in AllocCommunicator()
157 if (commMap_.count(commLabel) != 0) { in AllocCommunicator()
177 LabelType commLabel = commPtr->GetCommunicatorLabel(); in ReleaseCommunicator() local
178 LOGI("[CommAggr][Release] Label=%.3s.", VEC_TO_STR(commLabel)); in ReleaseCommunicator()
181 if (commMap_.count(commLabel) == 0) { in ReleaseCommunicator()
185 commMap_.erase(commLabel); in ReleaseCommunicator()
188 int errCode = commLinker_->DecreaseLocalLabel(commLabel); in ReleaseCommunicator()
250 if (commMap_.count(commLabel) == 0) { in ActivateCommunicator()
[all …]
|
| H A D | header_converter.cpp | 68 headerConverted.commLabel[i] = headerOriginal.commLabel[i]; in ConvertNetToHost()
|
| H A D | frame_header.h | 57 … uint8_t commLabel[COMM_LABEL_LENGTH] = {0}; // Indicate which communicator to hand out this frame
|
| H A D | protocol_proto.cpp | 420 divergeHeader.commLabel[i] = inCommLabel[i]; in SetDivergeHeader()
854 …esult.SetCommLabel(LabelType(std::begin(divergeHeader.commLabel), std::end(divergeHeader.commLabel… in ParseCommDivergeHeader()
915 LabelType commLabel(bytePtr + i * COMM_LABEL_LENGTH, bytePtr + (i + 1) * COMM_LABEL_LENGTH); in ParseLabelExchange() local
916 if (commLabels.count(commLabel) != 0) { in ParseLabelExchange()
917 … LOGW("[Proto][ParseLabel] Duplicate Label Detected, commLabel=%.3s.", VEC_TO_STR(commLabel)); in ParseLabelExchange()
919 commLabels.insert(commLabel); in ParseLabelExchange()
|
| H A D | frame_retainer.cpp | 104 …std::map<uint64_t, RetainWork> &perLabelPerTarget = retainWorkPool_[inFrame.commLabel][inFrame.src… in RetainFrame()
108 …LogRetainInfo("[Retainer][Retain] DISCARD", inFrame.commLabel, inFrame.srcTarget, iter->first, ite… in RetainFrame()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | icommunicator_aggregator.h | 28 using CommunicatorLackCallback = std::function<int(const LabelType &commLabel, const std::string &u…
45 virtual ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) = 0;
46 virtual ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) = 0;
|
| H A D | communicator_aggregator.h | 62 ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) override;
63 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override;
84 void ActivateCommunicator(const LabelType &commLabel);
|
| H A D | frame_retainer.h | 32 LabelType commLabel; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator_aggregator.cpp | 38 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(uint64_t commLabel, int &outErrorNo) in AllocCommunicator() argument
46 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(const LabelType &commLabel, int &ou… in AllocCommunicator() argument
48 LOGI("[VirtualCommunicatorAggregator][Alloc] Label=%.6s.", VEC_TO_STR(commLabel)); in AllocCommunicator()
49 if (commLabel.size() != COMM_LABEL_LENGTH) { in AllocCommunicator()
87 void VirtualCommunicatorAggregator::RunCommunicatorLackCallback(const LabelType &commLabel) in RunCommunicatorLackCallback() argument
90 onCommLack_(commLabel, userId_); in RunCommunicatorLackCallback()
|
| H A D | virtual_communicator_aggregator.h | 36 ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) override;
37 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override;
43 void RunCommunicatorLackCallback(const LabelType &commLabel);
|
| /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() argument
525 uint64_t netOrderLabel = HostToNet(commLabel); in ToLabelType()
549 [&lackLabels](const LabelType &commLabel, const std::string &userId)->int { in __anonf82a9c550802() argument
550 lackLabels.push_back(commLabel); in __anonf82a9c550802()
644 [&lackLabels](const LabelType &commLabel, const std::string &userId)->int { in __anonf82a9c550a02() argument
645 lackLabels.push_back(commLabel); in __anonf82a9c550a02()
731 …t errCode = g_envDeviceB.commAggrHandle->RegCommunicatorLackCallback([](const LabelType &commLabel,
805 …t errCode = g_envDeviceB.commAggrHandle->RegCommunicatorLackCallback([](const LabelType &commLabel,
883 std::vector<uint8_t> commLabel(label.begin(), label.end()); in InitCommunicator() local
885 comm = envDevice.commAggrHandle->AllocCommunicator(commLabel, errorNo); in InitCommunicator()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_auto_launch_test.cpp | 77 ICommunicator *AllocCommunicator(uint64_t commLabel, int &outErrorNo) override in AllocCommunicator() argument
82 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override in AllocCommunicator() argument
|