| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_test.cpp | 113 ICommunicator *commA = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo);
122 ICommunicator *commB = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_B, errorNo);
131 ICommunicator *commC = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo);
148 ICommunicator *commD = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo);
180 ICommunicator *commAA = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo);
198 ICommunicator *commBB = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_B, errorNo);
218 ICommunicator *commBA = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_A, errorNo);
390 ICommunicator *commDD = envDeviceD.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in TestRemoteRestart()
398 ICommunicator *commEE = envDeviceE.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in TestRemoteRestart()
419 commEE = envDeviceE.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in TestRemoteRestart()
[all …]
|
| H A D | distributeddb_communicator_deep_test.cpp | 86 g_commAA = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in AllocAllCommunicator()
88 g_commAB = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_B, errorNo); in AllocAllCommunicator()
90 g_commBB = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_B, errorNo); in AllocAllCommunicator()
92 g_commBC = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_C, errorNo); in AllocAllCommunicator()
94 g_commCC = g_envDeviceC.commAggrHandle->AllocCommunicator(LABEL_C, errorNo); in AllocAllCommunicator()
96 g_commCA = g_envDeviceC.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in AllocAllCommunicator()
|
| H A D | distributeddb_communicator_send_receive_test.cpp | 82 g_commAA = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in SetUp()
87 g_commBA = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in SetUp()
92 g_commBB = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_B, errorNo); in SetUp()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | icommunicator_aggregator.h | 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;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| 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;
58 ICommunicator *AllocCommunicator(const std::string &deviceId, int &outErrorNo);
|
| H A D | virtual_communicator_aggregator.cpp | 38 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(uint64_t commLabel, int &outErrorNo) in AllocCommunicator() function in DistributedDB::VirtualCommunicatorAggregator
41 return AllocCommunicator(remoteDeviceId_, outErrorNo); in AllocCommunicator()
46 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(const LabelType &commLabel, int &ou… in AllocCommunicator() function in DistributedDB::VirtualCommunicatorAggregator
55 return AllocCommunicator(remoteDeviceId_, outErrorNo); in AllocCommunicator()
142 ICommunicator *VirtualCommunicatorAggregator::AllocCommunicator(const std::string &deviceId, int &o… in AllocCommunicator() function in DistributedDB::VirtualCommunicatorAggregator
|
| H A D | distributeddb_syncer_device_manager_test.cpp | 62 …ator = static_cast<VirtualCommunicator *>(g_communicatorAggregator->AllocCommunicator(0, errCode)); in SetUpTestCase()
|
| H A D | distributeddb_ability_sync_test.cpp | 80 g_communicatorA = g_communicatorAggregator->AllocCommunicator(DEVICE_A, errCode); in SetUp()
82 g_communicatorB = g_communicatorAggregator->AllocCommunicator(DEVICE_B, errCode); in SetUp()
|
| H A D | generic_virtual_device.cpp | 84 communicateHandle_ = communicatorAggregator_->AllocCommunicator(deviceId_, errCode); in Initialize()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_engine.cpp | 289 communicator_ = communicatorAggregator->AllocCommunicator(dualTuplelabel, errCode); in InitComunicator()
291 communicator_ = communicatorAggregator->AllocCommunicator(label, errCode); in InitComunicator()
760 communicator = AllocCommunicator(identifier, errCode); in SetEqualIdentifier()
887 ICommunicator *SyncEngine::AllocCommunicator(const std::string &identifier, int &errCode) in AllocCommunicator() function in DistributedDB::SyncEngine
896 auto communicator = communicatorAggregator->AllocCommunicator(identifierVect, errCode); in AllocCommunicator()
|
| H A D | sync_engine.h | 195 ICommunicator *AllocCommunicator(const std::string &identifier, int &errCode);
|
| /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() function in __anon8101092d0110::StoreCommunicatorAggregator
82 ICommunicator *AllocCommunicator(const LabelType &commLabel, int &outErrorNo) override in AllocCommunicator() function in __anon8101092d0110::StoreCommunicatorAggregator
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_aggregator.cpp | 137 ICommunicator *CommunicatorAggregator::AllocCommunicator(uint64_t commLabel, int &outErrorNo) in AllocCommunicator() function in DistributedDB::CommunicatorAggregator
145 return AllocCommunicator(realLabel, outErrorNo); in AllocCommunicator()
148 ICommunicator *CommunicatorAggregator::AllocCommunicator(const std::vector<uint8_t> &commLabel, int… in AllocCommunicator() function in DistributedDB::CommunicatorAggregator
|