Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
H A Ddistributeddb_kv_concurrency_crud_test.cpp104 double KvCalculateTime(ConcurParam *&kvThreadParam, const Entry entryCurrent, const SysTime &start,… in KvCalculateTime() argument
107 kvThreadParam->entryPtr_->key = entryCurrent.key; in KvCalculateTime()
108 kvThreadParam->entryPtr_->value = entryCurrent.value; in KvCalculateTime()
209 Entry entryCurrent; variable
219 GenerateRecord(randKeyNo, entryCurrent);
220 operInterval = KvCalculateTime(threadParam, entryCurrent, start, dur);
254 Entry entryCurrent; in StartRandThread() local
255 GenerateRecord(randKeyNo, entryCurrent); in StartRandThread()
256 operInterval = KvCalculateTime(threadParam, entryCurrent, start, dur); in StartRandThread()
H A Ddistributeddb_nb_crud_test.cpp150 nbThreadParam->entryPtr_->key = entryCurrent.key; in NbCalculateTime()
151 nbThreadParam->entryPtr_->value = entryCurrent.value; in NbCalculateTime()
1657 Entry entryCurrent; in StartThreadForLongReadRead() local
1658 GenerateRecord(randKeyNo, entryCurrent); in StartThreadForLongReadRead()
1735 Entry entryCurrent; in StartThreadForLongReadWrite() local
1736 GenerateRecord(randKeyNo, entryCurrent); in StartThreadForLongReadWrite()
1738 entriesBatch.push_back(entryCurrent); in StartThreadForLongReadWrite()
1784 if (CompareVector(entry.key, entryCurrent.key)) { in JudgeInLongWriteWrite()
1789 entriesBatch.push_back(entryCurrent); in JudgeInLongWriteWrite()
1834 Entry entryCurrent; in StartThreadForLongWriteWrite() local
[all …]
H A Ddistributeddb_kv_observer_test.cpp1247 Entry entryCurrent; variable
1248 entryCurrent.key.assign(ONE_K_LONG_STRING, 'a');
1249 entryCurrent.value = VALUE_1;
1250 status = DistributedTestTools::Put(*g_observerDelegate, entryCurrent.key, entryCurrent.value);
1254 insertEntries.push_back(entryCurrent);
1286 Entry entryCurrent; variable
1287 entryCurrent.key = KEY_1;
1288 entryCurrent.value.assign(FOUR_M_LONG_STRING, 'a');
1289 status = DistributedTestTools::Put(*g_observerDelegate, entryCurrent.key, entryCurrent.value);
1293 insertEntries.push_back(entryCurrent);
H A Ddistributeddb_nb_observer_test.cpp2020 …heckPressureLongCompare(vector<Entry> &entriesBatch, ConcurParam *threadParam, Entry &entryCurrent) in CheckPressureLongCompare() argument
2025 if (CompareVector(entry.key, entryCurrent.key)) { in CheckPressureLongCompare()
2030 entriesBatch.push_back(entryCurrent); in CheckPressureLongCompare()
2034 if (CompareVector(entriesBatch[index].key, entryCurrent.key)) { in CheckPressureLongCompare()
2067 Entry entryCurrent; in CheckPressureLongConcurrency() local
2068 GenerateRecord(randKeyNo, entryCurrent); in CheckPressureLongConcurrency()
2070 CheckPressureLongCompare(entriesBatch, threadParam, entryCurrent); in CheckPressureLongConcurrency()
2072 threadParam->entryPtr_->key = entryCurrent.key; in CheckPressureLongConcurrency()
2073 threadParam->entryPtr_->value = entryCurrent.value; in CheckPressureLongConcurrency()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/
H A Ddistributeddb_data_generator.cpp125 DistributedDB::Entry entryCurrent; in GenerateRecords() local
127 GenerateRecord(cnt, entryCurrent, keyPrifix); in GenerateRecords()
128 allKeys.push_back(entryCurrent.key); in GenerateRecords()
129 entriesBatch.push_back(entryCurrent); in GenerateRecords()
156 DistributedDB::Entry entryCurrent; in GenerateMaxBigRecords() local
159 allKeys.push_back(entryCurrent.key); in GenerateMaxBigRecords()
160 entriesBatch.push_back(entryCurrent); in GenerateMaxBigRecords()
169 DistributedDB::Entry entryCurrent; in GenerateTenThousandRecords() local
171 GenerateLongRecord(cnt, entryCurrent, K_SEARCH_5); in GenerateTenThousandRecords()
172 allKeys.push_back(entryCurrent.key); in GenerateTenThousandRecords()
[all …]
H A Ddistributed_test_tools.cpp151 DistributedDB::Entry entryCurrent; in GenRanKeyVal() local
159 entryCurrent.key = tempKey; in GenRanKeyVal()
160 entryCurrent.value.assign(valueLength, val); in GenRanKeyVal()
162 entriesBatch.push_back(entryCurrent); in GenRanKeyVal()