Home
last modified time | relevance | path

Searched refs:g_communicatorAggregator (Results 1 – 24 of 24) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_syncer_device_manager_test.cpp36 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
58 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
59 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
60 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
72 g_communicatorAggregator = nullptr; in TearDownTestCase()
92 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
98 ASSERT_EQ(g_deviceC->Initialize(g_communicatorAggregator, syncInterfaceC), E_OK); in SetUp()
147 g_communicatorAggregator->OnlineDevice(g_deviceB->GetDeviceId());
161 g_communicatorAggregator->OnlineDevice(g_deviceB->GetDeviceId());
177 g_communicatorAggregator->OfflineDevice(g_deviceB->GetDeviceId());
[all …]
H A Ddistributeddb_single_ver_p2p_complex_sync_test.cpp135 ASSERT_NE(g_communicatorAggregator, nullptr); in DataSync005()
212 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
404 g_communicatorAggregator->RegOnDispatch(nullptr);
479 g_communicatorAggregator->RegOnDispatch(nullptr);
509 g_communicatorAggregator->OnlineDevice(targetDev);
604 g_communicatorAggregator->RegOnDispatch(nullptr);
656 g_communicatorAggregator->RegOnDispatch(nullptr);
1576 g_communicatorAggregator->ResetSendDelayInfo();
2278 g_communicatorAggregator->MockCommErrCode(E_OK);
2337 g_communicatorAggregator->MockCommErrCode(E_OK);
[all …]
H A Ddistributeddb_anti_dos_sync_test.cpp56 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
83 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
84 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
85 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
123 …g_communicator = static_cast<VirtualCommunicator *>(g_communicatorAggregator->GetCommunicator(remo… in SetUp()
216 g_communicatorAggregator->SetBlockValue(true);
258 g_communicatorAggregator->SetBlockValue(false);
280 g_communicatorAggregator->SetBlockValue(true);
320 g_communicatorAggregator->SetBlockValue(false);
H A Ddistributeddb_ability_sync_test.cpp39 VirtualCommunicatorAggregator *g_communicatorAggregator = nullptr; variable
77 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator; in SetUp()
78 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUp()
80 g_communicatorA = g_communicatorAggregator->AllocCommunicator(DEVICE_A, errCode); in SetUp()
93 if (g_communicatorA != nullptr && g_communicatorAggregator != nullptr) { in TearDown()
94 g_communicatorAggregator->ReleaseCommunicator(g_communicatorA); in TearDown()
97 if (g_communicatorB != nullptr && g_communicatorAggregator != nullptr) { in TearDown()
98 g_communicatorAggregator->ReleaseCommunicator(g_communicatorB); in TearDown()
101 if (g_communicatorAggregator != nullptr) { in TearDown()
102 RefObject::KillAndDecObjRef(g_communicatorAggregator); in TearDown()
[all …]
H A Ddistributeddb_relational_multi_user_test.cpp270 g_communicatorAggregator->RegOnDispatch(nullptr); in DoRemoteQuery()
313 g_communicatorAggregator->RegOnDispatch(nullptr); in CheckSyncResult()
453 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
692 g_communicatorAggregator->SetCurrentUserId(USER_ID_2);
1023 g_communicatorAggregator->DisableCommunicator();
1031 g_communicatorAggregator->EnableCommunicator();
1078 g_communicatorAggregator->RegOnDispatch(nullptr);
1120 g_communicatorAggregator->RegOnDispatch(nullptr);
1162 g_communicatorAggregator->RegOnDispatch(nullptr);
1204 g_communicatorAggregator->RegOnDispatch(nullptr);
[all …]
H A Ddistributeddb_single_ver_multi_user_test.cpp49 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
107 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
108 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
109 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
133 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
138 ASSERT_EQ(g_deviceC->Initialize(g_communicatorAggregator, syncInterfaceC), E_OK); in SetUp()
281 g_communicatorAggregator->RegOnDispatch(nullptr); in TestSyncWithUserChange()
472 g_communicatorAggregator->SetCurrentUserId(USER_ID_2);
473 g_communicatorAggregator->RunCommunicatorLackCallback(label);
544 g_communicatorAggregator->SetCurrentUserId(USER_ID_2);
[all …]
H A Ddistributeddb_single_ver_p2p_sync_check_test.cpp95 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
165 if (g_communicatorAggregator != nullptr) { in TearDown()
166 g_communicatorAggregator->RegOnDispatch(nullptr); in TearDown()
309 g_communicatorAggregator->RegOnDispatch(nullptr);
912 g_communicatorAggregator->RegOnDispatch(nullptr); in PrepareWaterMarkError()
1862 g_communicatorAggregator->RegOnDispatch(nullptr);
1913 g_communicatorAggregator->RegOnDispatch(nullptr);
1950 g_communicatorAggregator->RegOnDispatch(nullptr);
2021 g_communicatorAggregator->RegOnDispatch(nullptr);
2066 g_communicatorAggregator->RegOnDispatch(nullptr);
[all …]
H A Ddistributeddb_single_ver_dlp_test.cpp36 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
129 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
130 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
131 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
152 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
H A Ddistributeddb_multi_ver_p2p_sync_test.cpp147 g_communicatorAggregator = nullptr; in TearDownTestCase()
156 g_communicatorAggregator->Disable(); in SetUp()
170 g_communicatorAggregator->Enable(); in SetUp()
487 g_communicatorAggregator->Disable();
490 g_communicatorAggregator->Enable();
529 g_communicatorAggregator->Disable();
532 g_communicatorAggregator->Enable();
574 g_communicatorAggregator->Disable();
579 g_communicatorAggregator->Enable();
1455 g_communicatorAggregator->Disable();
[all …]
H A Ddistributeddb_relational_ver_p2p_sync_test.cpp72 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
820 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
907 if (g_communicatorAggregator != nullptr) { in TearDown()
908 g_communicatorAggregator->RegOnDispatch(nullptr); in TearDown()
1221 g_communicatorAggregator->RunCommunicatorLackCallback(labelType);
1269 g_communicatorAggregator->RunCommunicatorLackCallback(labelType);
1311 g_communicatorAggregator->RunCommunicatorLackCallback(labelType);
1381 g_communicatorAggregator->RunCommunicatorLackCallback(labelType);
1488 g_communicatorAggregator->RegOnDispatch(nullptr);
1667 g_communicatorAggregator->RunCommunicatorLackCallback(labelType);
[all …]
H A Ddistributeddb_single_ver_p2p_permission_sync_test.cpp46 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
80 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
81 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
82 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
110 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
116 ASSERT_EQ(g_deviceC->Initialize(g_communicatorAggregator, syncInterfaceC), E_OK); in SetUp()
H A Ddistributeddb_single_ver_p2p_simple_sync_test.cpp50 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
106 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
107 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
108 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
136 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
142 ASSERT_EQ(g_deviceC->Initialize(g_communicatorAggregator, syncInterfaceC), E_OK); in SetUp()
1481 g_communicatorAggregator->SetBlockValue(true);
1504 g_communicatorAggregator->SetBlockValue(false);
1746 g_communicatorAggregator->SetDropMessageTypeByDevice(DEVICE_B, QUERY_SYNC_MESSAGE);
1774 g_communicatorAggregator->SetDropMessageTypeByDevice(DEVICE_B, UNKNOW_MESSAGE);
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp51 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
126 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
127 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
128 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
152 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
157 ASSERT_EQ(g_deviceC->Initialize(g_communicatorAggregator, syncInterfaceC), E_OK); in SetUp()
1124 if (g_communicatorAggregator == nullptr) { in CreateKvVirtualDevice()
1137 EXPECT_EQ(device->Initialize(g_communicatorAggregator, interface), E_OK); in CreateKvVirtualDevice()
H A Ddistributeddb_single_ver_multi_sub_user_test.cpp39 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
219 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
220 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
221 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
249 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
H A Ddistributeddb_single_ver_p2p_query_sync_test.cpp55 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
127 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
128 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
129 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
153 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
569 … ASSERT_EQ(virtualDeviceVec[i]->Initialize(g_communicatorAggregator, tmpSyncInterface), E_OK);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_auto_launch_test.cpp49 VirtualCommunicatorAggregator *g_communicatorAggregator = nullptr; variable
119 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
376 g_communicatorAggregator->RunCommunicatorLackCallback(label);
684 g_communicatorAggregator->RunCommunicatorLackCallback(label);
748 g_communicatorAggregator->RunCommunicatorLackCallback(label);
784 g_communicatorAggregator->RunCommunicatorLackCallback(label);
830 g_communicatorAggregator->RunCommunicatorLackCallback(label);
890 g_communicatorAggregator->RunCommunicatorLackCallback(label);
970 g_communicatorAggregator->RunCommunicatorLackCallback(label);
1044 g_communicatorAggregator->RunCommunicatorLackCallback(label);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoredelegate_fuzzer/
H A Drelationalstoredelegate_fuzzer.cpp44 VirtualCommunicatorAggregator *g_communicatorAggregator = nullptr; variable
61 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in Setup()
62 if (g_communicatorAggregator == nullptr) { in Setup()
65 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in Setup()
92 g_communicatorAggregator = nullptr; in TearDown()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_relational_routines_test.cpp38 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
56 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
57 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
58 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
H A Ddistributeddb_interfaces_relational_test.cpp48 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
145 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
146 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
147 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
162 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
179 if (g_communicatorAggregator != nullptr) { in TearDown()
180 g_communicatorAggregator->RegOnDispatch(nullptr); in TearDown()
H A Ddistributeddb_interfaces_relational_sync_test.cpp41 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
161 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
162 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
163 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
179 ASSERT_EQ(g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB), E_OK); in SetUp()
H A Ddistributeddb_interfaces_nb_delegate_rd_test.cpp56 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
148 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
149 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
150 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
H A Ddistributeddb_interfaces_nb_delegate_test.cpp76 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
228 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in SetUpTestCase()
229 ASSERT_TRUE(g_communicatorAggregator != nullptr); in SetUpTestCase()
230 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in SetUpTestCase()
2254 ASSERT_EQ(devices->Initialize(g_communicatorAggregator, syncInterface), E_OK); in InitVirtualDevice()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoremanager_fuzzer/
H A Drelationalstoremanager_fuzzer.cpp38 VirtualCommunicatorAggregator *g_communicatorAggregator = nullptr; variable
44 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in Setup()
45 if (g_communicatorAggregator == nullptr) { in Setup()
48 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in Setup()
61 g_communicatorAggregator = nullptr; in TearDown()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/sync_fuzzer/
H A Dsync_fuzzer.cpp36 VirtualCommunicatorAggregator* g_communicatorAggregator = nullptr; variable
45 g_communicatorAggregator = new (std::nothrow) VirtualCommunicatorAggregator(); in InitEnv()
46 if (g_communicatorAggregator == nullptr) { in InitEnv()
49 RuntimeContext::GetInstance()->SetCommunicatorAggregator(g_communicatorAggregator); in InitEnv()
75 g_deviceB->Initialize(g_communicatorAggregator, syncInterfaceB); in SetUpTestcase()