Searched refs:dbIdentifier (Results 1 – 4 of 4) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_vacuum.cpp | 43 if (dbIdentifier.empty() || dbHandle == nullptr) { in Launch()
48 if (dbMapVacuumTask_.count(dbIdentifier) == 0) { in Launch()
75 if (dbIdentifier.empty()) { in Pause()
80 if (dbMapVacuumTask_.count(dbIdentifier) == 0) { in Pause()
114 if (dbIdentifier.empty()) { in Continue()
119 if (dbMapVacuumTask_.count(dbIdentifier) == 0) { in Continue()
164 if (dbIdentifier.empty()) { in Abort()
172 if (dbMapVacuumTask_.count(dbIdentifier) == 0) { in Abort()
208 if (dbIdentifier.empty()) { in AutoRelaunchOnce()
213 if (dbMapVacuumTask_.count(dbIdentifier) == 0) { in AutoRelaunchOnce()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | multi_ver_vacuum.h | 71 int Launch(const std::string &dbIdentifier, MultiVerVacuumExecutor *dbHandle);
75 int Pause(const std::string &dbIdentifier);
79 int Continue(const std::string &dbIdentifier, bool autoRelaunchOnce);
82 int Abort(const std::string &dbIdentifier);
85 int AutoRelaunchOnce(const std::string &dbIdentifier);
87 int QueryStatus(const std::string &dbIdentifier, VacuumTaskStatus &outStatus) const;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_multi_ver_vacuum_test.cpp | 422 bool ConcurrentPauseThenCheckResult(MultiVerVacuum &vacuum, const std::string &dbIdentifier) in ConcurrentPauseThenCheckResult() argument
428 std::thread threadA([&vacuum, &dbIdentifier, &retForThreadA, &isQuitThreadA]() { in ConcurrentPauseThenCheckResult()
430 retForThreadA = vacuum.Pause(dbIdentifier); in ConcurrentPauseThenCheckResult()
434 std::thread threadB([&vacuum, &dbIdentifier, &retForThreadB, &isQuitThreadB]() { in ConcurrentPauseThenCheckResult()
436 retForThreadB = vacuum.Pause(dbIdentifier); in ConcurrentPauseThenCheckResult()
450 …return CheckVacuumTaskStatus(vacuum, dbIdentifier, VacuumTaskStatus::PAUSE_DONE, 1); // only 1 time in ConcurrentPauseThenCheckResult()
453 …ool ConcurrentPauseAndAbortThenCheckResult(MultiVerVacuum &vacuum, const std::string &dbIdentifier) in ConcurrentPauseAndAbortThenCheckResult() argument
459 std::thread threadA([&vacuum, &dbIdentifier, &retForThreadA, &isQuitThreadA]() { in ConcurrentPauseAndAbortThenCheckResult()
461 retForThreadA = vacuum.Pause(dbIdentifier); in ConcurrentPauseAndAbortThenCheckResult()
465 std::thread threadB([&vacuum, &dbIdentifier, &retForThreadB, &isQuitThreadB]() { in ConcurrentPauseAndAbortThenCheckResult()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 54 std::vector<uint8_t> dbIdentifier = syncInterface->GetIdentifier(); in Initialize() local
55 dbIdentifier.resize(3); // only show 3 bytes in Initialize()
57 DBCommon::VectorToHexString(dbIdentifier) + "_" + deviceId_.c_str(); in Initialize()
|