Home
last modified time | relevance | path

Searched refs:VirtualCommunicator (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator.cpp44 void VirtualCommunicator::Activate() in Activate()
125 uint32_t VirtualCommunicator::GetCommunicatorMtuSize() const in GetCommunicatorMtuSize()
140 uint32_t VirtualCommunicator::GetTimeout() const in GetTimeout()
151 void VirtualCommunicator::SetTimeout(uint32_t timeout) in SetTimeout()
162 int VirtualCommunicator::GeneralVirtualSyncId() in GeneralVirtualSyncId()
169 void VirtualCommunicator::Disable() in Disable()
174 void VirtualCommunicator::Enable() in Enable()
184 std::string VirtualCommunicator::GetDeviceId() const in GetDeviceId()
189 bool VirtualCommunicator::IsEnabled() const in IsEnabled()
206 VirtualCommunicator::~VirtualCommunicator() in ~VirtualCommunicator()
[all …]
H A Dvirtual_communicator_aggregator.cpp63 VirtualCommunicator *communicator = static_cast<VirtualCommunicator *>(inCommunicator); in ReleaseCommunicator()
120 VirtualCommunicator *communicatorTmp = static_cast<VirtualCommunicator *>(iter.second); in OnlineDevice()
135 VirtualCommunicator *communicatorTmp = static_cast<VirtualCommunicator *>(iter.second); in OfflineDevice()
145 VirtualCommunicator *communicator = new (std::nothrow) VirtualCommunicator(deviceId, this); in AllocCommunicator()
151 … communicators_.insert(std::pair<std::string, VirtualCommunicator *>(deviceId, communicator)); in AllocCommunicator()
162 VirtualCommunicator *communicator = static_cast<VirtualCommunicator *>(iter->second); in GetCommunicator()
195 VirtualCommunicator *communicator = static_cast<VirtualCommunicator *>(iter->second); in DispatchMessageInner()
H A Dvirtual_communicator.h35 class VirtualCommunicator : public ICommunicator {
37 …VirtualCommunicator(const std::string &deviceId, VirtualCommunicatorAggregator *communicatorAggreg…
38 ~VirtualCommunicator() override;
40 DISABLE_COPY_ASSIGN_MOVE(VirtualCommunicator);
H A Ddistributeddb_syncer_device_manager_test.cpp37 VirtualCommunicator* g_virtualCommunicator = nullptr;
62 …g_virtualCommunicator = static_cast<VirtualCommunicator *>(g_communicatorAggregator->AllocCommunic… in SetUpTestCase()
H A Dgeneric_virtual_device.cpp180 static_cast<VirtualCommunicator *>(communicateHandle_)->Enable(); in Online()
186 static_cast<VirtualCommunicator *>(communicateHandle_)->Disable(); in Offline()
H A Ddistributeddb_anti_dos_sync_test.cpp59 VirtualCommunicator *g_communicator = nullptr;
123 …g_communicator = static_cast<VirtualCommunicator *>(g_communicatorAggregator->GetCommunicator(remo… in SetUp()
H A Dvirtual_communicator_aggregator.h110 std::map<std::string, VirtualCommunicator *> communicators_;
H A Ddistributeddb_mock_sync_module_test.cpp814 auto *communicator = new (std::nothrow) VirtualCommunicator("DEVICE", nullptr);
1207 … static_cast<VirtualCommunicator *>(virtualCommunicatorAggregator->GetCommunicator("real_device"));
1755 VirtualCommunicator communicator("device", nullptr);
1810 auto communicator = new (std::nothrow) VirtualCommunicator("device", nullptr);
H A Ddistributeddb_ability_sync_test.cpp409 static_cast<VirtualCommunicator *>(g_communicatorB)->Disable();
H A Ddistributeddb_single_ver_p2p_complex_sync_test.cpp968 VirtualCommunicator tmpCommunicator(deviceId, g_communicatorAggregator);