Home
last modified time | relevance | path

Searched refs:cloudSyncer (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_upload_test.cpp201 cloudSyncer->CallClose();
239 cloudSyncer->CallClose();
276 cloudSyncer->CallClose();
311 cloudSyncer->CallClose();
361 cloudSyncer->CallClose();
417 cloudSyncer->CallClose();
482 cloudSyncer->CallClose();
540 cloudSyncer->CallClose();
602 cloudSyncer->CallClose();
653 cloudSyncer->CallClose();
[all …]
H A Ddistributeddb_cloud_syncer_progress_manager_test.cpp68 cloudSyncer.SetMockICloudDB(idb);
235 cloudSyncer.SetMockICloudDB(idb);
241 int errCode = cloudSyncer.CallTryToAddSyncTask(std::move(cloudSyncer.taskInfo_));
245 int errCode = cloudSyncer.CallTryToAddSyncTask(std::move(cloudSyncer.taskInfo_));
248 cloudSyncer.PopTaskQueue();
249 cloudSyncer.PopTaskQueue();
253 errCode = cloudSyncer.CallTryToAddSyncTask(std::move(cloudSyncer.taskInfo_));
309 ASSERT_NE(cloudSyncer, nullptr);
318 cloudSyncer->Close();
338 ASSERT_NE(cloudSyncer, nullptr);
[all …]
H A Ddistributeddb_cloud_db_proxy_test.cpp305 ASSERT_NE(cloudSyncer, nullptr);
322 cloudSyncer->Close();
395 ASSERT_NE(cloudSyncer, nullptr);
424 cloudSyncer->Close();
638 ASSERT_NE(cloudSyncer, nullptr);
644 cloudSyncer->SetDownloadFunc([cloudSyncer]() { in __anon9cf3a58a0902()
678 ASSERT_NE(cloudSyncer, nullptr);
682 cloudSyncer->SetDownloadFunc([cloudSyncer, &close]() { in __anon9cf3a58a0a02()
694 cloudSyncer->Close();
729 cloudSyncer->Notify();
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dsync_able_kvdb.cpp644 auto cloudSyncer = GetAndIncCloudSyncer(); in GetTaskCount() local
645 if (cloudSyncer != nullptr) { in GetTaskCount()
646 taskCount += cloudSyncer->GetCloudSyncTaskCount(); in GetTaskCount()
647 RefObject::DecObjRef(cloudSyncer); in GetTaskCount()
668 auto cloudSyncer = GetAndIncCloudSyncer(); in SetGenCloudVersionCallback() local
669 if (cloudSyncer == nullptr) { in SetGenCloudVersionCallback()
673 cloudSyncer->SetGenCloudVersionCallback(callback); in SetGenCloudVersionCallback()
674 RefObject::DecObjRef(cloudSyncer); in SetGenCloudVersionCallback()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/
H A Dmeta_data_manager.cpp179 void MetaDataManager::SetCloudSyncer(const CloudSyncer &cloudSyncer) in SetCloudSyncer() argument
184 cloudSyncer_ = cloudSyncer; in SetCloudSyncer()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/
H A Dmeta_data_manager.h57 API_EXPORT void SetCloudSyncer(const CloudSyncer &cloudSyncer);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dkvstore_meta_manager.cpp336 auto cloudSyncer = [this]() { in SetCloudSyncer() local
344 MetaDataManager::GetInstance().SetCloudSyncer(cloudSyncer); in SetCloudSyncer()