| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_db_proxy_test.cpp | 140 virtualCloudDb_ = nullptr; in TearDown()
160 proxy.SetCloudDB(virtualCloudDb_);
165 virtualCloudDb_->SetCloudError(true);
172 virtualCloudDb_->SetCloudError(false);
190 proxy.SetCloudDB(virtualCloudDb_);
248 proxy.SetCloudDB(virtualCloudDb_);
308 virtualCloudDb_->SetCloudError(true);
321 virtualCloudDb_->ClearHeartbeatCount();
340 proxy.SetCloudDB(virtualCloudDb_);
450 proxy.SetCloudDB(virtualCloudDb_);
[all …]
|
| H A D | distributeddb_cloud_kv_syncer_test.cpp | 62 std::shared_ptr<VirtualCloudDb> virtualCloudDb_ = nullptr; member in __anon644cd9970110::DistributedDBCloudKvSyncerTest
108 virtualCloudDb_ = std::make_shared<VirtualCloudDb>(); in SetUp()
133 virtualCloudDb_ = nullptr; in TearDown()
260 cloudDbs[USER_ID] = virtualCloudDb_; in GetKvStore()
337 virtualCloudDb_->ForkUpload([&upIdx](const std::string &tableName, VBucket &extend) { in __anon644cd9970602()
355 virtualCloudDb_->ForkUpload(nullptr);
388 virtualCloudDb_->ForkUpload([&upIdx](const std::string &tableName, VBucket &extend) { in __anon644cd9970802()
412 virtualCloudDb_->ForkUpload(nullptr);
445 virtualCloudDb_->ForkUpload([&upIdx](const std::string &tableName, VBucket &extend) { in __anon644cd9970b02()
469 virtualCloudDb_->ForkUpload(nullptr);
|
| H A D | distributeddb_cloud_kv_test.cpp | 132 virtualCloudDb_ = nullptr; in TearDown()
226 cloudDbs[USER_ID] = virtualCloudDb_; in GetKvStore()
740 virtualCloudDb_->SetBlockTime(2000); // 2000ms
810 virtualCloudDb_->SetInsertHook(nullptr);
1022 cloudDbs[USER_ID] = virtualCloudDb_;
1087 virtualCloudDb_->SetInsertHook(nullptr);
1234 virtualCloudDb_->ForkUpload(nullptr);
1374 virtualCloudDb_->SetClearExtend(missCount);
1382 virtualCloudDb_->ForkUpload(nullptr);
1489 virtualCloudDb_->ForkUpload(nullptr);
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_check_sync_test.cpp | 246 virtualCloudDb_->ForkQuery(nullptr); in TearDown()
247 virtualCloudDb_->SetCloudError(false); in TearDown()
292 virtualCloudDb_ = nullptr; in CloseDb()
694 virtualCloudDb_->SetInsertFailed(1);
782 virtualCloudDb_->ForkUpload(nullptr);
857 virtualCloudDb_->ForkUpload(nullptr);
1083 virtualCloudDb_->ForkQuery(nullptr);
1214 virtualCloudDb_->Reset();
1337 virtualCloudDb_->ForkQuery(nullptr);
1500 virtualCloudDb_->ForkQuery(nullptr);
[all …]
|
| H A D | distributeddb_cloud_task_merge_test.cpp | 109 std::shared_ptr<VirtualCloudDb> virtualCloudDb_ = nullptr; member in __anonb94ae3c60110::DistributedDBCloudTaskMergeTest
147 virtualCloudDb_ = std::make_shared<VirtualCloudDb>(); in SetUp()
149 ASSERT_EQ(delegate_->SetCloudDB(virtualCloudDb_), DBStatus::OK); in SetUp()
160 virtualCloudDb_->ForkQuery(nullptr); in TearDown()
161 virtualCloudDb_->SetCloudError(false); in TearDown()
199 virtualCloudDb_ = nullptr; in CloseDb()
227 virtualCloudDb_->Query(tableName, extend, data); in CheckCloudTableCount()
242 virtualCloudDb_->ForkQuery([&count](const std::string &, VBucket &) { in SetForkQueryForCloudMergeSyncTest001()
337 virtualCloudDb_->SetBlockTime(2000); // block 1st sync task 2s.
419 virtualCloudDb_->SetBlockTime(2000); // block 1st sync task 2s.
|
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 112 std::shared_ptr<VirtualCloudDb> virtualCloudDb_ = nullptr; member in __anond35eef630110::DistributedDBCloudAssetsOperationSyncTest
149 virtualCloudDb_ = std::make_shared<VirtualCloudDb>(); in SetUp()
200 virtualCloudDb_->ForkUpload(nullptr); in CloseDb()
201 virtualCloudDb_ = nullptr; in CloseDb()
364 virtualCloudDb_->ForkUpload(nullptr);
420 virtualCloudDb_->ForkUpload(nullptr);
773 virtualCloudDb_->SetConflictInUpload(true);
775 virtualCloudDb_->SetConflictInUpload(false);
1063 virtualCloudDb_->ForkUpload(nullptr);
1102 virtualCloudDb_->ForkUpload(nullptr);
[all …]
|
| H A D | distributeddb_cloud_reference_sync_test.cpp | 65 std::shared_ptr<VirtualCloudDb> virtualCloudDb_ = nullptr; member in __anon789e90cf0110::DistributedDBCloudReferenceSyncTest
107 virtualCloudDb_ = std::make_shared<VirtualCloudDb>(); in SetUp()
108 ASSERT_EQ(delegate_->SetCloudDB(virtualCloudDb_), DBStatus::OK); in SetUp()
122 virtualCloudDb_->ForkQuery(nullptr); in TearDown()
183 virtualCloudDb_ = nullptr; in CloseDb()
357 (void) virtualCloudDb_->Query(tableName, extend, queryRes); in CheckCloudData()
665 EXPECT_EQ(delegate->SetCloudDB(virtualCloudDb_), DBStatus::OK);
825 virtualCloudDb_->ForkQuery(nullptr);
860 virtualCloudDb_ = nullptr;
866 virtualCloudDb_ = std::make_shared<VirtualCloudDb>();
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/ |
| H A D | cloudsync_fuzzer.cpp | 235 virtualCloudDb_->BatchInsert(g_table, std::move(record1), extend1); in InsertCloudTableRecord()
264 virtualCloudDb_ = std::make_shared<VirtualCloudDb>(); in SetUp()
268 delegate_->SetCloudDB(virtualCloudDb_); in SetUp()
283 virtualCloudDb_ = nullptr; in TearDown()
536 std::shared_ptr<VirtualCloudDb> virtualCloudDb_; member in OHOS::CloudSyncTest
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_multi_sub_user_test.cpp | 47 std::shared_ptr<VirtualCloudDb> virtualCloudDb_ = nullptr; variable
128 cloudDbs[USER_ID] = virtualCloudDb_; in SetCloudDB()
163 EXPECT_EQ(delegatePtr->SetCloudDB(virtualCloudDb_), DBStatus::OK); in SetCloudDB()
243 virtualCloudDb_ = std::make_shared<VirtualCloudDb>(); in SetUp()
254 virtualCloudDb_ = nullptr; in TearDown()
|