Home
last modified time | relevance | path

Searched defs:syncProcess (Results 1 – 12 of 12) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
Dprocess_notifier.cpp38 SyncProcess syncProcess; in Init() local
45 …ocessNotifier::InitSyncProcess(const std::vector<std::string> &tableName, SyncProcess &syncProcess) in InitSyncProcess()
71 auto &syncProcess = user_.empty() ? syncProcess_ : multiSyncProcess_[user_]; in UpdateProcess() local
144 auto &syncProcess = IsMultiUser() ? multiSyncProcess_.at(user_) : syncProcess_; in GetUploadBatchIndex() local
157 auto &syncProcess = IsMultiUser() ? multiSyncProcess_.at(user_) : syncProcess_; in ResetUploadBatchIndex() local
172 auto &syncProcess = IsMultiUser() ? multiSyncProcess_.at(user_) : syncProcess_; in GetLastUploadInfo() local
188 SyncProcess syncProcess; in GetDownloadInfoByTableName() local
211 for (auto &syncProcess : multiSyncProcess_) { in SetAllTableFinish() local
234 auto &syncProcess = IsMultiUser() ? multiSyncProcess_.at(user_) : syncProcess_; in UpdateUploadInfoIfNeeded() local
249 for (auto &syncProcess : multiSyncProcess_) { in UpdateAllTablesFinally() local
Dcloud_syncer_extend.cpp1352 SyncProcess syncProcess; in GetCloudTaskStatus() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
Ddistributeddb_cloud_interfaces_relational_sync_test.cpp642 SyncProcess syncProcess; in InitProcessForTest1() local
680 SyncProcess syncProcess; in InitProcessForMannualSync1() local
724 SyncProcess syncProcess; in InitProcessForTest2() local
768 SyncProcess syncProcess; in InitProcessForTest9() local
776 void GetCallback(SyncProcess &syncProcess, CloudSyncStatusCallback &callback, in GetCallback()
1028 void WaitForSyncFinish(SyncProcess &syncProcess, const int64_t &waitTime) in WaitForSyncFinish()
1491 SyncProcess syncProcess = onProcess.at(DEVICE_CLOUD); in __anona0f839580602() local
1547 SyncProcess syncProcess; variable
1598 std::map<std::string, SyncProcess> syncProcess; in TestSyncForStatus() local
Ddistributeddb_cloud_check_sync_test.cpp481 for (auto syncProcess : expectSyncProcessV) { in CheckSyncProcess() local
796 auto callback = [](const std::map<std::string, SyncProcess> &syncProcess) { in __anon6d2f4c681202()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
Ddistributeddb_cloud_interfaces_relational_remove_device_data_test.cpp453 SyncProcess syncProcess; in InitProcessForCleanCloudData1() local
462 void GetCallback(SyncProcess &syncProcess, CloudSyncStatusCallback &callback, in GetCallback()
538 void WaitForSyncFinish(SyncProcess &syncProcess, const int64_t &waitTime) in WaitForSyncFinish()
792 std::map<std::string, SyncProcess> syncProcess; in __anonba1d04ba0702() local
810 std::map<std::string, SyncProcess> syncProcess; in __anonba1d04ba0802() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
Dcloud_db_sync_utils_test.cpp164 …void CloudDBSyncUtilsTest::GetCallback(SyncProcess &syncProcess, CloudSyncStatusCallback &callback, in GetCallback()
237 void CloudDBSyncUtilsTest::WaitForSyncFinish(SyncProcess &syncProcess, const int64_t &waitTime) in WaitForSyncFinish()
Ddistributeddb_cloud_db_proxy_test.cpp82 SyncProcess syncProcess; in Sync() local
Ddistributeddb_cloud_syncer_lock_test.cpp1545 SyncProcess syncProcess = g_delegate->GetCloudTaskStatus(UINT64_MAX - 1); in __anon0f13a6e92402() local
Ddistributeddb_cloud_syncer_download_assets_only_test.cpp297 void WaitForSyncFinish(SyncProcess &syncProcess, const int64_t &waitTime) in WaitForSyncFinish()
Ddistributeddb_cloud_syncer_download_assets_test.cpp307 void WaitForSyncFinish(SyncProcess &syncProcess, const int64_t &waitTime) in WaitForSyncFinish()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
Drelational_store_delegate_impl.cpp514 SyncProcess syncProcess; in GetCloudTaskStatus() local
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/collaboration_edit/src/
Dnapi_collaboration_edit_object.cpp445 void CollaborationEditObject::SyncCallbackFunc(GRD_SyncProcessT *syncProcess) in SyncCallbackFunc()