| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator_aggregator.cpp | 27 int VirtualCommunicatorAggregator::Initialize(IAdapter *inAdapter, in Initialize()
33 void VirtualCommunicatorAggregator::Finalize() in Finalize()
171 if (VirtualCommunicatorAggregator::GetBlockValue()) { in DispatchMessage()
240 bool VirtualCommunicatorAggregator::GetBlockValue() const in GetBlockValue()
245 void VirtualCommunicatorAggregator::Disable() in Disable()
250 void VirtualCommunicatorAggregator::Enable() in Enable()
268 void VirtualCommunicatorAggregator::RegOnDispatch( in RegOnDispatch()
314 void VirtualCommunicatorAggregator::ResetSendDelayInfo() in ResetSendDelayInfo()
344 void VirtualCommunicatorAggregator::DisableCommunicator() in DisableCommunicator()
352 void VirtualCommunicatorAggregator::EnableCommunicator() in EnableCommunicator()
[all …]
|
| H A D | virtual_communicator.h | 33 class VirtualCommunicatorAggregator; variable
37 …VirtualCommunicator(const std::string &deviceId, VirtualCommunicatorAggregator *communicatorAggreg…
107 VirtualCommunicatorAggregator *communicatorAggregator_;
|
| H A D | virtual_communicator_aggregator.h | 28 class VirtualCommunicatorAggregator : public ICommunicatorAggregator {
100 ~VirtualCommunicatorAggregator() override = default;
101 VirtualCommunicatorAggregator() = default;
|
| H A D | generic_virtual_device.h | 34 int Initialize(VirtualCommunicatorAggregator *comAggregator, ISyncInterface *syncInterface);
51 VirtualCommunicatorAggregator *communicatorAggregator_;
|
| H A D | distributeddb_syncer_device_manager_test.cpp | 36 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr;
58 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
|
| H A D | distributeddb_mock_sync_module_test.cpp | 268 …VirtualCommunicatorAggregator *virtualCommunicatorAggregator = new VirtualCommunicatorAggregator(); in SyncLifeTest001()
287 …VirtualCommunicatorAggregator *virtualCommunicatorAggregator = new VirtualCommunicatorAggregator(); in SyncLifeTest002()
322 …VirtualCommunicatorAggregator *virtualCommunicatorAggregator = new VirtualCommunicatorAggregator(); in SyncLifeTest003()
1098 …VirtualCommunicatorAggregator *virtualCommunicatorAggregator = new VirtualCommunicatorAggregator();
1130 …VirtualCommunicatorAggregator *virtualCommunicatorAggregator = new VirtualCommunicatorAggregator();
1194 …VirtualCommunicatorAggregator *virtualCommunicatorAggregator = new VirtualCommunicatorAggregator();
1255 …VirtualCommunicatorAggregator *virtualCommunicatorAggregator = new VirtualCommunicatorAggregator();
1925 auto virtualCommunicatorAggregator = new(std::nothrow) VirtualCommunicatorAggregator();
|
| H A D | distributeddb_anti_dos_sync_test.cpp | 56 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr;
83 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
|
| H A D | distributeddb_single_ver_dlp_test.cpp | 36 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr;
129 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
|
| H A D | distributeddb_ability_sync_test.cpp | 39 VirtualCommunicatorAggregator *g_communicatorAggregator = nullptr;
77 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator; in SetUp()
|
| H A D | virtual_communicator.cpp | 211 VirtualCommunicatorAggregator *communicatorAggregator) in VirtualCommunicator()
|
| H A D | distributeddb_communicator_proxy_test.cpp | 83 auto communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
|
| H A D | generic_virtual_device.cpp | 76 int GenericVirtualDevice::Initialize(VirtualCommunicatorAggregator *comAggregator, ISyncInterface *… in Initialize()
|
| H A D | distributeddb_single_ver_multi_user_test.cpp | 49 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr;
107 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
|
| H A D | distributeddb_single_ver_p2p_permission_sync_test.cpp | 46 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr;
80 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_relational_routines_test.cpp | 38 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr;
56 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
|
| H A D | runtime_context_process_system_api_adapter_impl_test.cpp | 362 …Context::GetInstance()->SetCommunicatorAggregator(new(std::nothrow) VirtualCommunicatorAggregator);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoredelegate_fuzzer/ |
| H A D | relationalstoredelegate_fuzzer.cpp | 44 VirtualCommunicatorAggregator *g_communicatorAggregator = nullptr;
61 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in Setup()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoremanager_fuzzer/ |
| H A D | relationalstoremanager_fuzzer.cpp | 38 VirtualCommunicatorAggregator *g_communicatorAggregator = nullptr;
44 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in Setup()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_table_compound_primary_key_sync_test.cpp | 95 VirtualCommunicatorAggregator *communicatorAggregator_ = nullptr;
122 communicatorAggregator_ = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUp()
|
| H A D | distributeddb_cloud_table_without_primary_key_sync_test.cpp | 53 VirtualCommunicatorAggregator *communicatorAggregator_ = nullptr;
187 communicatorAggregator_ = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUp()
|
| H A D | distributeddb_cloud_kv_syncer_test.cpp | 68 VirtualCommunicatorAggregator *communicatorAggregator_ = nullptr;
114 communicatorAggregator_ = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUp()
|
| H A D | distributeddb_cloud_db_proxy_test.cpp | 118 VirtualCommunicatorAggregator *communicatorAggregator_ = nullptr;
133 communicatorAggregator_ = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUp()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/sync_fuzzer/ |
| H A D | sync_fuzzer.cpp | 36 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr;
45 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in InitEnv()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_task_merge_test.cpp | 117 VirtualCommunicatorAggregator *communicatorAggregator_ = nullptr;
153 communicatorAggregator_ = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUp()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_test.cpp | 900 auto *pAggregator = new VirtualCommunicatorAggregator();
979 auto *pAggregator = new VirtualCommunicatorAggregator();
1037 auto *pAggregator = new VirtualCommunicatorAggregator();
1208 auto *pAggregator = new VirtualCommunicatorAggregator();
|