Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_multi_ver_vacuum_test.cpp424 int retForThreadA = E_OK; in ConcurrentPauseThenCheckResult() local
428 std::thread threadA([&vacuum, &dbIdentifier, &retForThreadA, &isQuitThreadA]() { in ConcurrentPauseThenCheckResult()
430 retForThreadA = vacuum.Pause(dbIdentifier); in ConcurrentPauseThenCheckResult()
442 …bool result = RepeatCheckAsyncResult([&retForThreadA, &isQuitThreadA, &retForThreadB, &isQuitThrea… in ConcurrentPauseThenCheckResult()
444 …return retForThreadA == E_OK && retForThreadB == E_OK && isQuitThreadA == true && isQuitThreadB ==… in ConcurrentPauseThenCheckResult()
455 int retForThreadA = E_OK; in ConcurrentPauseAndAbortThenCheckResult() local
459 std::thread threadA([&vacuum, &dbIdentifier, &retForThreadA, &isQuitThreadA]() { in ConcurrentPauseAndAbortThenCheckResult()
461 retForThreadA = vacuum.Pause(dbIdentifier); in ConcurrentPauseAndAbortThenCheckResult()
473 …bool result = RepeatCheckAsyncResult([&retForThreadA, &isQuitThreadA, &retForThreadB, &isQuitThrea… in ConcurrentPauseAndAbortThenCheckResult()