| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 38 SyncProcess syncProcess; in Init() local
39 InitSyncProcess(tableName, syncProcess); in Init()
40 multiSyncProcess_[user] = syncProcess; in Init()
47 syncProcess.errCode = OK; in InitSyncProcess()
48 syncProcess.process = ProcessStatus::PROCESSING; in InitSyncProcess()
135 if (syncProcess.tableProcess.find(tableName) == syncProcess.tableProcess.end()) { in GetUploadBatchIndex()
148 if (syncProcess.tableProcess.find(tableName) == syncProcess.tableProcess.end()) { in ResetUploadBatchIndex()
171 SyncProcess syncProcess; in GetDownloadInfoByTableName() local
173 syncProcess = syncProcess_; in GetDownloadInfoByTableName()
175 syncProcess = multiSyncProcess_[user_]; in GetDownloadInfoByTableName()
[all …]
|
| H A D | cloud_syncer_extend.cpp | 1184 SyncProcess syncProcess; in GetCloudTaskStatus() local
1186 syncProcess.process = ProcessStatus::FINISHED; in GetCloudTaskStatus()
1187 syncProcess.errCode = NOT_FOUND; in GetCloudTaskStatus()
1189 return syncProcess; in GetCloudTaskStatus()
1191 syncProcess.process = iter->second.status; in GetCloudTaskStatus()
1192 syncProcess.errCode = TransferDBErrno(iter->second.errCode); in GetCloudTaskStatus()
1199 syncProcess.tableProcess = notifier->GetCurrentTableProcess(); in GetCloudTaskStatus()
1202 …iter->second.storeId.c_str(), static_cast<int64_t>(syncProcess.process), static_cast<int>(hasNotif… in GetCloudTaskStatus()
1203 return syncProcess; in GetCloudTaskStatus()
|
| H A D | process_notifier.h | 56 void InitSyncProcess(const std::vector<std::string> &tableName, SyncProcess &syncProcess);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_db_sync_utils_test.cpp | 171 syncProcess = std::move(process.begin()->second); in GetCallback()
173 ASSERT_NE(syncProcess.tableProcess.empty(), true); in GetCallback()
174 … LOGI("current sync process status:%d, db status:%d ", syncProcess.process, syncProcess.errCode); in GetCallback()
176 auto table1 = syncProcess.tableProcess.find(item); in GetCallback()
177 if (table1 != syncProcess.tableProcess.end()) { in GetCallback()
188 if (syncProcess.process == FINISHED) { in GetCallback()
197 auto real = syncProcess.tableProcess.find(expect.first); in GetCallback()
198 ASSERT_NE(real, syncProcess.tableProcess.end()); in GetCallback()
211 if (syncProcess.process == FINISHED) { in GetCallback()
237 void CloudDBSyncUtilsTest::WaitForSyncFinish(SyncProcess &syncProcess, const int64_t &waitTime) in WaitForSyncFinish() argument
[all …]
|
| H A D | distributeddb_cloud_db_proxy_test.cpp | 81 SyncProcess syncProcess; in Sync() local
82 const auto callback = [&callCount, &syncProcess, &processMutex, &cv]( in Sync()
86 syncProcess = process.begin()->second; in Sync()
88 syncProcess = process.begin()->second; in Sync()
91 syncProcess = tmpProcess; in Sync()
101 cv.wait(uniqueLock, [&syncProcess]() { in Sync()
102 return syncProcess.process == ProcessStatus::FINISHED; in Sync()
106 return syncProcess.errCode; in Sync()
|
| H A D | cloud_db_sync_utils_test.h | 62 static void GetCallback(SyncProcess &syncProcess, CloudSyncStatusCallback &callback,
68 static void WaitForSyncFinish(SyncProcess &syncProcess, const int64_t &waitTime);
|
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 294 void WaitForSyncFinish(SyncProcess &syncProcess, const int64_t &waitTime) in WaitForSyncFinish() argument
298 …lock, std::chrono::seconds(waitTime), [&syncProcess]() { return syncProcess.process == FINISHED; }… in WaitForSyncFinish()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 643 SyncProcess syncProcess; in InitProcessForTest1() local
644 syncProcess.errCode = OK; in InitProcessForTest1()
681 SyncProcess syncProcess; in InitProcessForMannualSync1() local
682 syncProcess.errCode = OK; in InitProcessForMannualSync1()
725 SyncProcess syncProcess; in InitProcessForTest2() local
726 syncProcess.errCode = OK; in InitProcessForTest2()
769 SyncProcess syncProcess; in InitProcessForTest9() local
770 syncProcess.errCode = OK; in InitProcessForTest9()
1545 SyncProcess syncProcess; variable
1580 syncProcess.process = PREPARED;
[all …]
|
| H A D | distributeddb_cloud_check_sync_test.cpp | 429 for (auto syncProcess : expectSyncProcessV) { in CheckSyncProcess() local
430 map<string, SyncProcess> expectSyncProcessMap = {{"CLOUD", syncProcess}}; in CheckSyncProcess()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_remove_device_data_test.cpp | 452 SyncProcess syncProcess; in InitProcessForCleanCloudData1() local
453 syncProcess.errCode = OK; in InitProcessForCleanCloudData1()
457 expectProcess.push_back(syncProcess); in InitProcessForCleanCloudData1()
471 … LOGI("current sync process status:%d, db status:%d ", syncProcess.process, syncProcess.errCode); in GetCallback()
485 if (syncProcess.process == FINISHED) { in GetCallback()
508 if (syncProcess.process == FINISHED) { in GetCallback()
541 return syncProcess.process == FINISHED; in WaitForSyncFinish()
788 std::map<std::string, SyncProcess> syncProcess; in __anonca7e63500702() local
791 syncProcess = process; in __anonca7e63500702()
806 std::map<std::string, SyncProcess> syncProcess; in __anonca7e63500802() local
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_delegate_impl.cpp | 477 SyncProcess syncProcess; in GetCloudTaskStatus() local
480 syncProcess.errCode = DB_ERROR; in GetCloudTaskStatus()
481 return syncProcess; in GetCloudTaskStatus()
|