Home
last modified time | relevance | path

Searched refs:entries (Results 1 - 25 of 256) sorted by relevance

1234567891011

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
H A Ddistributeddb_nb_predicate_query_test.cpp96 const vector<string> &schemasValue, vector<Entry> &entries, const std::string schemaDefine) in PrepareSchemaDBAndData()
116 entries.push_back({keys[index], value}); in PrepareSchemaDBAndData()
120 EXPECT_EQ(DistributedDBNbTestTools::Put(*delegate, entries[index].key, entries[index].value), OK); in PrepareSchemaDBAndData()
128 vector<Entry> entries; in CheckSchemaQuery() local
130 DBStatus statusGot = delegate->GetEntries(queryNeedCheck, entries); in CheckSchemaQuery()
132 MST_LOG("GetEntries entries result: %d, statusGot: %d", result, statusGot); in CheckSchemaQuery()
133 for (unsigned long index = 0; index < entries.size(); index++) { in CheckSchemaQuery()
135 result = (entries[index].key == expectEntry[index].key) && result; in CheckSchemaQuery()
136 MST_LOG("check entries[ in CheckSchemaQuery()
95 PrepareSchemaDBAndData(KvStoreNbDelegate *&delegate, KvStoreDelegateManager *&manager, const vector<string> &schemasValue, vector<Entry> &entries, const std::string schemaDefine) PrepareSchemaDBAndData() argument
170 vector<Entry> entries; CheckSchemaQueryForOrderBy() local
204 vector<Entry> entries; CheckSchemaNotExist() local
273 vector<Entry> entries; HWTEST_F() local
393 vector<Entry> entries; HWTEST_F() local
427 CheckSchemaBoolNotExist(KvStoreNbDelegate *&delegate, vector<Entry> &entries) CheckSchemaBoolNotExist() argument
479 CheckSchemaBoolExist(KvStoreNbDelegate *&delegate, vector<Entry> &entries) CheckSchemaBoolExist() argument
525 vector<Entry> entries; HWTEST_F() local
608 vector<Entry> entries; HWTEST_F() local
655 CheckSchemaExceptionValue(KvStoreNbDelegate *&delegate, vector<Entry> &entries) CheckSchemaExceptionValue() argument
715 CheckSchemaIntValue(KvStoreNbDelegate *&delegate, vector<Entry> &entries) CheckSchemaIntValue() argument
786 vector<Entry> entries; HWTEST_F() local
904 vector<Entry> entries; HWTEST_F() local
950 vector<Entry> entries; HWTEST_F() local
1024 vector<Entry> entries; HWTEST_F() local
1058 CheckSchemaDoubleExceptionValue(KvStoreNbDelegate *&delegate, vector<Entry> &entries) CheckSchemaDoubleExceptionValue() argument
1113 CheckSchemaDoubleValue(KvStoreNbDelegate *&delegate, vector<Entry> &entries) CheckSchemaDoubleValue() argument
1168 vector<Entry> entries; HWTEST_F() local
1243 vector<Entry> entries; HWTEST_F() local
1300 vector<Entry> entries; HWTEST_F() local
1353 vector<Entry> entries; HWTEST_F() local
1417 vector<Entry> entries; HWTEST_F() local
1483 vector<Entry> entries; HWTEST_F() local
1561 vector<Entry> entries; HWTEST_F() local
1613 vector<Entry> entries; HWTEST_F() local
1682 vector<Entry> entries; HWTEST_F() local
1746 vector<Entry> entries; HWTEST_F() local
1807 vector<Entry> entries; HWTEST_F() local
1840 vector<Entry> entries; HWTEST_F() local
1927 vector<Entry> entries; HWTEST_F() local
[all...]
H A Ddistributeddb_nb_observer_test.cpp234 * @tc.steps: step2. put one entries (KEY_1, VALUE_1) to local db. in CheckObserverAllLocalValue()
245 * @tc.steps: step3. update one entries (KEY_2, VALUE_2) of local db. in CheckObserverAllLocalValue()
325 * @tc.steps: step2. put one entries (KEY_1, VALUE_1) to local db. in CheckObserverAllNativeValue()
334 * @tc.steps: step3. update one entries (KEY_2, VALUE_2) of local db. in CheckObserverAllNativeValue()
444 * @tc.steps: step3. put one entries (KEY_2, VALUE_2) to local db. in HWTEST_F()
455 * @tc.steps: step4. delete one entries from local db where key = KEY_2. in HWTEST_F()
466 * @tc.steps: step5. put one entries (KEY_1, VALUE_1) to sync db. in HWTEST_F()
477 * @tc.steps: step6. delete one entries from sync db where key = KEY_1. in HWTEST_F()
515 * @tc.steps: step2. delete one entries from local db where key = KEY_1. in HWTEST_F()
525 * @tc.steps: step3. delete one entries fro in HWTEST_F()
1281 CheckPressureForLocalRepeat(KvStoreObserverImpl &observerLocal, KvStoreObserverImpl &observerSync, vector< vector<DistributedDB::Entry> > &entries) CheckPressureForLocalRepeat() argument
1376 CheckPressureForNativeRepeat(KvStoreObserverImpl &observerLocal, KvStoreObserverImpl &observerSync, vector< vector<DistributedDB::Entry> > &entries) CheckPressureForNativeRepeat() argument
1609 CheckPressureAfterClose(KvStoreObserverImpl &observerLocal, KvStoreObserverImpl &observerSync, vector< vector<DistributedDB::Entry> > &entries) CheckPressureAfterClose() argument
1701 CheckPressureAfterReopen(KvStoreObserverImpl &observerLocal, KvStoreObserverImpl &observerSync, vector< vector<DistributedDB::Entry> > &entries) CheckPressureAfterReopen() argument
1914 CheckPressureAcrossDatabase(vector<KvStoreNbDelegate *> &nbDelegateVec, KvStoreObserverImpl *observerLocals, KvStoreObserverImpl *observerSyncs, vector< vector<DistributedDB::Entry> > &entries, unsigned int &opCnt) CheckPressureAcrossDatabase() argument
[all...]
H A Ddistributeddb_nb_cursor_testcase.cpp139 std::vector<DistributedDB::Entry> entries; in ResultSetDb001() local
141 GenerateAppointPrefixAndSizeRecords(entries, entrySize, ONE_HUNDRED_RECORDS); in ResultSetDb001()
143 EXPECT_TRUE(delegate->Put(entries[index].key, entries[index].value) == OK); in ResultSetDb001()
226 std::vector<DistributedDB::Entry> entries; in ResultSetDb002() local
228 GenerateAppointPrefixAndSizeRecords(entries, entrySize, ONE_HUNDRED_RECORDS); in ResultSetDb002()
230 EXPECT_TRUE(delegate->Put(entries[index].key, entries[index].value) == OK); in ResultSetDb002()
239 sort(entries.begin(), entries in ResultSetDb002()
296 std::vector<DistributedDB::Entry> entries; ResultSetDb003() local
372 std::vector<DistributedDB::Entry> entries; ResultSetDb004() local
446 std::vector<DistributedDB::Entry> entries; ResultSetDb005() local
527 std::vector<DistributedDB::Entry> entries; ResultSetDb006() local
588 std::vector<DistributedDB::Entry> entries; ResultSetDb007() local
642 std::vector<DistributedDB::Entry> entries; ResultSetDb008() local
708 std::vector<DistributedDB::Entry> entries; ResultSetDb009() local
791 std::vector<DistributedDB::Entry> entries; ResultSetDb010() local
840 std::vector<DistributedDB::Entry> entries; ResultSetDb011() local
898 std::vector<DistributedDB::Entry> entries; ResultSetDb012() local
966 std::vector<DistributedDB::Entry> entries; ResultSetDb013() local
1033 std::vector<DistributedDB::Entry> entries; ResultSetDb014() local
1104 std::vector<DistributedDB::Entry> entries; ResultSetDb015() local
1167 std::vector<DistributedDB::Entry> entries; ResultSetDb016() local
1230 vector<Entry> entries; ResultSetDb017() local
1455 vector<Entry> entries; ResultSetDb020() local
1469 vector<Entry> entries; ResultSetDb021() local
[all...]
H A Ddistributeddb_nb_predicate_query_expand_test.cpp90 vector<Entry> &entries) in PresetDatasToDB()
103 entries.push_back(entry); in PresetDatasToDB()
117 * @tc.steps: step1. create schema db and put 7 entries which has valid schema constructor in HWTEST_F()
127 vector<Entry> entries; in HWTEST_F() local
128 PresetDatasToDB(g_nbQueryDelegate, KEY_K, schemasValue, entries); in HWTEST_F()
137 vector<Entry> expectEntry1 = {entries[INDEX_FIRST], entries[INDEX_FIFTH], entries[INDEX_ZEROTH], in HWTEST_F()
138 entries[INDEX_THIRD], entries[INDEX_SECON in HWTEST_F()
89 PresetDatasToDB(KvStoreNbDelegate *&delegate, std::vector<uint8_t> keyPrefix, vector<string> &schemasValue, vector<Entry> &entries) PresetDatasToDB() argument
187 vector<Entry> entries; HWTEST_F() local
248 vector<Entry> entries; HWTEST_F() local
296 vector<Entry> entries; HWTEST_F() local
350 vector<Entry> entries; HWTEST_F() local
394 vector<Entry> entries; HWTEST_F() local
443 vector<Entry> entries, entries2; HWTEST_F() local
525 vector<Entry> entries, entriesExpect; HWTEST_F() local
[all...]
/foundation/filemanagement/storage_service/services/storage_daemon/file_sharing/src/
H A Dacl.cpp28 for (const auto &e : entries) { in ReCalcMaskPerm()
38 return entries.empty(); in IsEmpty()
43 if (!entries.count(ACL_TAG::USER_OBJ) || !entries.count(ACL_TAG::GROUP_OBJ) || in IsValid()
44 !entries.count(ACL_TAG::OTHER)) { in IsValid()
47 if (maskDemand && !entries.count(ACL_TAG::MASK)) { in IsValid()
55 if (entries.count(entry)) { in CompareInsertEntry()
56 auto it = entries.find(entry); in CompareInsertEntry()
57 entries.erase(it); in CompareInsertEntry()
60 entries in CompareInsertEntry()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dkvdb_commit_notify_filterable_data.cpp35 std::list<Entry> entries; in GetInsertedEntries() local
37 return entries; in GetInsertedEntries()
42 std::list<Entry> entries; in GetUpdatedEntries() local
44 return entries; in GetUpdatedEntries()
49 std::list<Entry> entries; in GetDeletedEntries() local
51 return entries; in GetDeletedEntries()
56 std::list<KvDBConflictEntry> entries; in GetCommitConflicts() local
58 return entries; in GetCommitConflicts()
/foundation/distributeddatamgr/kv_store/frameworks/common/test/
H A Dconcurrent_map_test.cpp75 [](const decltype(values_)::map_type &entries) { in HWTEST_F()
76 return (entries.find("test") == entries.end()); in HWTEST_F()
81 [](const decltype(values_)::map_type &entries) { in HWTEST_F()
82 return (entries.find("test") == entries.end()); in HWTEST_F()
87 [](decltype(values_)::map_type &entries) { in HWTEST_F()
88 auto it = entries.find("test"); in HWTEST_F()
89 if (it != entries.end()) { in HWTEST_F()
90 entries in HWTEST_F()
[all...]
/foundation/graphic/graphic_2d/frameworks/opengl_wrapper/src/EGL/
H A Degl_wrapper_layer.cpp55 EglWrapperFuncPointer *curr, char const * const *entries) in UpdateApiEntries()
58 while (*entries) { in UpdateApiEntries()
59 char const *name = *entries; in UpdateApiEntries()
68 entries++; in UpdateApiEntries()
73 char const * const *entries, EglWrapperFuncPointer *curr) in SetupFuncMaps()
76 while (*entries) { in SetupFuncMaps()
77 const char *name = *entries; in SetupFuncMaps()
84 entries++; in SetupFuncMaps()
231 char const * const *entries; in SetupLayerFuncTbl() local
234 entries in SetupLayerFuncTbl()
54 UpdateApiEntries(LayerSetupFunc func, EglWrapperFuncPointer *curr, char const * const *entries) UpdateApiEntries() argument
72 SetupFuncMaps(FunctionTable &table, char const * const *entries, EglWrapperFuncPointer *curr) SetupFuncMaps() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_get_data_test.cpp243 void ExpectMissQueryCnt(const std::vector<SingleVerKvEntry *> &entries, size_t expectCount) in ExpectMissQueryCnt() argument
246 for (auto iter = entries.begin(); iter != entries.end(); ++iter) { in ExpectMissQueryCnt()
251 if (nextOne != entries.end()) { in ExpectMissQueryCnt()
385 std::vector<SingleVerKvEntry *> entries; in HWTEST_F() local
388 int errCode = store->GetSyncData(query, SyncTimeRange {}, sizeInfo, token, entries); in HWTEST_F()
389 auto count = entries.size(); in HWTEST_F()
390 SingleVerKvEntry::Release(entries); in HWTEST_F()
393 errCode = store->GetSyncDataNext(entries, token, sizeInfo); in HWTEST_F()
394 count += entries in HWTEST_F()
439 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
493 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
573 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
617 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
703 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
789 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
863 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
933 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1037 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1122 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1187 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1278 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1339 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1471 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1717 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
[all...]
H A Ddistributeddb_storage_transaction_data_test.cpp95 static int RunSyncMergeForOneCommit(std::vector<MultiVerKvEntry *> &entries) in RunSyncMergeForOneCommit() argument
103 int errCode = g_naturalStore->PutCommitData(multiVerCommit, entries, "deviceB"); in RunSyncMergeForOneCommit()
114 for (auto &item : entries) { in RunSyncMergeForOneCommit()
120 entries.clear(); in RunSyncMergeForOneCommit()
186 std::vector<MultiVerKvEntry *> &entries) in PushOneEntry()
212 entries.push_back(entry); in PushOneEntry()
547 std::vector<Entry> entries; in HWTEST_F() local
548 entries.push_back(KV_ENTRY_1); in HWTEST_F()
549 entries.push_back(KV_ENTRY_2); in HWTEST_F()
551 EXPECT_EQ(g_naturalStoreConnection->PutBatch(option, entries), E_O in HWTEST_F()
185 PushOneEntry(uint64_t opr, uint64_t timestamp, const Key &key, const Value &value, std::vector<MultiVerKvEntry *> &entries) PushOneEntry() argument
577 std::vector<Entry> entries; HWTEST_F() local
683 std::vector<Entry> entries; HWTEST_F() local
719 std::vector<Entry> entries; HWTEST_F() local
757 std::vector<Entry> entries; HWTEST_F() local
861 std::vector<Entry> entries; HWTEST_F() local
895 std::vector<Entry> entries; HWTEST_F() local
1015 std::vector<MultiVerKvEntry *> entries; HWTEST_F() local
1061 std::vector<MultiVerKvEntry *> entries; HWTEST_F() local
1207 std::vector<MultiVerKvEntry *> entries; HWTEST_F() local
1265 std::vector<MultiVerKvEntry *> entries; global() local
1324 std::vector<MultiVerKvEntry *> entries; HWTEST_F() local
1362 std::vector<MultiVerKvEntry *> entries; PutFirstSyncCommitData() local
1394 std::vector<MultiVerKvEntry *> entries; PutSecondSyncCommitData() local
1455 ReleaseKvEntries(std::vector<MultiVerKvEntry *> &entries) ReleaseKvEntries() argument
1492 std::vector<MultiVerKvEntry *> entries; HWTEST_F() local
1538 std::vector<MultiVerKvEntry *> entries; HWTEST_F() local
[all...]
H A Ddistributeddb_storage_query_sync_test.cpp61 void ReleaseKvEntries(std::vector<SingleVerKvEntry *> &entries) in ReleaseKvEntries() argument
63 for (auto &itemEntry : entries) { in ReleaseKvEntries()
67 entries.clear(); in ReleaseKvEntries()
167 std::vector<Entry> entries; in SetUp() local
170 g_schemaConnect->GetEntries(option, Query::Select(), entries); in SetUp()
171 ASSERT_FALSE(entries.empty()); in SetUp()
216 std::vector<SingleVerKvEntry *> entries; in HWTEST_F() local
218 EXPECT_EQ(g_store->GetSyncData(queryObj, SyncTimeRange{}, specInfo, token, entries), E_OK); in HWTEST_F()
219 EXPECT_EQ(entries.size(), 1UL); in HWTEST_F()
220 ReleaseKvEntries(entries); in HWTEST_F()
256 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
325 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
388 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
453 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
520 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
568 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
664 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
736 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
931 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1003 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1084 std::vector<SingleVerKvEntry *> entries; HWTEST_F() local
1262 std::vector<Entry> entries; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dsingle_ver_natural_store_connection.cpp33 std::vector<Entry> entries; in Put() local
35 entries.emplace_back(std::move(entry)); in Put()
37 return PutBatch(option, entries); in Put()
40 int SingleVerNaturalStoreConnection::PutBatch(const IOption &option, const std::vector<Entry> &entries) in PutBatch() argument
42 LOGD("[PutBatch] entries size is : %zu, dataType : %d", entries.size(), option.dataType); in PutBatch()
46 int errCode = CheckSyncEntriesValid(entries); in PutBatch()
50 return PutBatchInner(option, entries); in PutBatch()
58 bool SingleVerNaturalStoreConnection::CheckAndGetEntryLen(const std::vector<Entry> &entries, uint32_t limit, in CheckAndGetEntryLen() argument
62 for (const auto &entry : entries) { in CheckAndGetEntryLen()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dudmf_run_time_store_test.cpp117 * @tc.desc: check for legal parameters, sum size of all entries is smaller than 512M.
139 vector<Entry> entries; in HWTEST_F() local
140 status = store->GetEntries(KEY_PREFIX, entries); in HWTEST_F()
142 EXPECT_EQ(129, entries.size()); in HWTEST_F()
150 * @tc.desc: check for legal parameters, sum size of all entries is equal to 512M.
172 vector<Entry> entries; in HWTEST_F() local
173 status = store->GetEntries(KEY_PREFIX, entries); in HWTEST_F()
175 EXPECT_EQ(1, entries.size()); in HWTEST_F()
183 * @tc.desc: test rollback, sum size of all entries is larger to 512M.
206 vector<Entry> entries; in HWTEST_F() local
237 vector<Entry> entries; HWTEST_F() local
278 vector<Entry> entries; HWTEST_F() local
317 vector<Entry> entries; HWTEST_F() local
357 vector<Entry> entries; HWTEST_F() local
473 vector<Entry> entries; HWTEST_F() local
509 vector<Entry> entries; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
H A Dsingle_kvstore_client_test.cpp212 EXPECT_EQ(results.size(), sum) << "entries size is not equal 10."; in HWTEST_F()
260 EXPECT_EQ(results.size(), sum) << "entries size is not equal 10."; in HWTEST_F()
303 EXPECT_EQ(results.size(), 0) << "entries size is not empty."; in HWTEST_F()
496 // store entries to kvstore. in HWTEST_F()
497 std::vector<Entry> entries; in HWTEST_F() local
505 entries.push_back(entry1); in HWTEST_F()
506 entries.push_back(entry2); in HWTEST_F()
507 entries.push_back(entry3); in HWTEST_F()
509 Status status = singleKvStore->PutBatch(entries); in HWTEST_F()
599 std::vector<Entry> entries; in HWTEST_F() local
626 std::vector<Entry> entries; HWTEST_F() local
663 std::vector<Entry> entries; HWTEST_F() local
696 std::vector<Entry> entries; HWTEST_F() local
739 std::vector<Entry> entries; HWTEST_F() local
779 std::vector<Entry> entries; HWTEST_F() local
820 std::vector<Entry> entries; HWTEST_F() local
860 std::vector<Entry> entries; HWTEST_F() local
905 std::vector<Entry> entries; HWTEST_F() local
959 std::vector<Entry> entries; HWTEST_F() local
1016 std::vector<Entry> entries; HWTEST_F() local
[all...]
H A Ddevice_kvstore_test.cpp210 * @tc.desc: get entries and result set by data query.
235 EXPECT_EQ(results.size(), sum) << "entries size is not equal 10."; in HWTEST_F()
264 * @tc.desc: get entries and result set by prefix query.
291 EXPECT_EQ(results.size(), sum) << "entries size is not equal 10."; in HWTEST_F()
320 * @tc.desc: get entries and result set by prefix query.
373 * @tc.desc: get entries and result set by prefix.
391 EXPECT_EQ(results.size(), sum) << "entries size is not equal 10."; in HWTEST_F()
607 // store entries to kvstore. in HWTEST_F()
608 std::vector<Entry> entries; in HWTEST_F() local
616 entries in HWTEST_F()
710 std::vector<Entry> entries; HWTEST_F() local
738 std::vector<Entry> entries; HWTEST_F() local
774 std::vector<Entry> entries; HWTEST_F() local
807 std::vector<Entry> entries; HWTEST_F() local
850 std::vector<Entry> entries; HWTEST_F() local
890 std::vector<Entry> entries; HWTEST_F() local
931 std::vector<Entry> entries; HWTEST_F() local
972 std::vector<Entry> entries; HWTEST_F() local
1018 std::vector<Entry> entries; HWTEST_F() local
1072 std::vector<Entry> entries; HWTEST_F() local
1129 std::vector<Entry> entries; HWTEST_F() local
[all...]
H A Dlocal_subscribe_store_test.cpp509 std::vector<Entry> entries; in HWTEST_F() local
517 entries.push_back(entry1); in HWTEST_F()
518 entries.push_back(entry2); in HWTEST_F()
519 entries.push_back(entry3); in HWTEST_F()
521 Status status = kvStore->PutBatch(entries); in HWTEST_F()
546 std::vector<Entry> entries; in HWTEST_F() local
554 entries.push_back(entry1); in HWTEST_F()
555 entries.push_back(entry2); in HWTEST_F()
556 entries.push_back(entry3); in HWTEST_F()
558 Status status = kvStore->PutBatch(entries); in HWTEST_F()
583 std::vector<Entry> entries; HWTEST_F() local
638 std::vector<Entry> entries; HWTEST_F() local
680 std::vector<Entry> entries; HWTEST_F() local
1035 std::vector<Entry> entries; HWTEST_F() local
1091 std::vector<Entry> entries; HWTEST_F() local
1134 std::vector<Entry> entries; HWTEST_F() local
1177 std::vector<Entry> entries; HWTEST_F() local
1465 std::vector<Entry> entries; HWTEST_F() local
1493 std::vector<Entry> entries; HWTEST_F() local
1533 std::vector<Entry> entries; HWTEST_F() local
1571 std::vector<Entry> entries; HWTEST_F() local
1616 std::vector<Entry> entries; HWTEST_F() local
1663 std::vector<Entry> entries; HWTEST_F() local
1707 std::vector<Entry> entries; HWTEST_F() local
1766 std::vector<Entry> entries; HWTEST_F() local
1822 std::vector<Entry> entries; HWTEST_F() local
1874 std::vector<Entry> entries; HWTEST_F() local
1927 std::vector<Entry> entries; HWTEST_F() local
[all...]
H A Dlocal_subscribe_device_store_test.cpp497 std::vector<Entry> entries; in HWTEST_F() local
505 entries.push_back(entry1); in HWTEST_F()
506 entries.push_back(entry2); in HWTEST_F()
507 entries.push_back(entry3); in HWTEST_F()
509 Status status = kvStore_->PutBatch(entries); in HWTEST_F()
534 std::vector<Entry> entries; in HWTEST_F() local
542 entries.push_back(entry1); in HWTEST_F()
543 entries.push_back(entry2); in HWTEST_F()
544 entries.push_back(entry3); in HWTEST_F()
546 Status status = kvStore_->PutBatch(entries); in HWTEST_F()
571 std::vector<Entry> entries; HWTEST_F() local
626 std::vector<Entry> entries; HWTEST_F() local
668 std::vector<Entry> entries; HWTEST_F() local
1022 std::vector<Entry> entries; HWTEST_F() local
1078 std::vector<Entry> entries; HWTEST_F() local
1121 std::vector<Entry> entries; HWTEST_F() local
1164 std::vector<Entry> entries; HWTEST_F() local
1452 std::vector<Entry> entries; HWTEST_F() local
1480 std::vector<Entry> entries; HWTEST_F() local
1520 std::vector<Entry> entries; HWTEST_F() local
1558 std::vector<Entry> entries; HWTEST_F() local
1603 std::vector<Entry> entries; HWTEST_F() local
1650 std::vector<Entry> entries; HWTEST_F() local
1694 std::vector<Entry> entries; HWTEST_F() local
1753 std::vector<Entry> entries; HWTEST_F() local
1809 std::vector<Entry> entries; HWTEST_F() local
1861 std::vector<Entry> entries; HWTEST_F() local
1914 std::vector<Entry> entries; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_natural_store_connection.h46 int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const override;
48 int GetEntries(const IOption &option, const Query &query, std::vector<Entry> &entries) const override;
115 const Key &keyPrefix, std::vector<Entry> &entries) const;
118 std::vector<Entry> &entries) const;
128 int CheckSyncEntriesValid(const std::vector<Entry> &entries) const override;
130 int PutBatchInner(const IOption &option, const std::vector<Entry> &entries) override;
132 int SaveSyncEntries(const std::vector<Entry> &entries, bool isDelete);
164 int SetBatchInner(const IOption &option, const std::vector<Entry> &entries, bool isDelete);
166 bool IsSinglePutOrDelete(const std::vector<Entry> &entries) in IsSinglePutOrDelete() argument
168 return entries in IsSinglePutOrDelete()
[all...]
H A Drd_single_ver_natural_store_connection.cpp44 std::vector<Entry> &entries) const in GetEntries()
50 return GetEntriesInner(true, option, keyPrefix, entries); in GetEntries()
65 const Key &keyPrefix, std::vector<Entry> &entries) const in GetEntriesInner()
82 errCode = writeHandle_->GetEntries(KV_SCAN_PREFIX, std::pair<Key, Key>(keyPrefix, {}), entries); in GetEntriesInner()
93 errCode = handle->GetEntries(KV_SCAN_PREFIX, std::pair<Key, Key>(keyPrefix, {}), entries); in GetEntriesInner()
299 std::vector<Entry> &entries) const in GetEntriesInner()
312 queryExpression.GetEndKey()), entries); in GetEntriesInner()
325 queryExpression.GetEndKey()), entries); in GetEntriesInner()
331 std::vector<Entry> &entries) const in GetEntries()
337 return GetEntriesInner(option, query, entries); in GetEntries()
529 PutBatchInner(const IOption &option, const std::vector<Entry> &entries) PutBatchInner() argument
534 SetBatchInner(const IOption &option, const std::vector<Entry> &entries, bool isDelete) SetBatchInner() argument
565 SaveSyncEntries(const std::vector<Entry> &entries, bool isDelete) SaveSyncEntries() argument
725 std::vector<Entry> entries; DeleteBatchInner() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_nb_transaction_test.cpp471 * @tc.steps:step4. PutBatch which entries size is 4KB and DeleteBatch record which keys size 3KB, in HWTEST_F()
569 vector<Entry> entries; in HWTEST_F() local
570 EXPECT_EQ(g_kvNbDelegatePtr->GetEntries(prefix, entries), OK); in HWTEST_F()
571 EXPECT_TRUE(DistributedDBToolsUnitTest::IsEntriesEqual(entriesRet, entries, true)); in HWTEST_F()
818 vector<Entry> entries; in HWTEST_F() local
819 EXPECT_EQ(g_kvNbDelegatePtr->GetEntries(prefix, entries), OK); in HWTEST_F()
820 EXPECT_EQ(entries.size(), 1UL); in HWTEST_F()
821 if (entries.size() > 0) { in HWTEST_F()
822 EXPECT_EQ(entries[0].key, KEY_1); in HWTEST_F()
823 EXPECT_EQ(entries[ in HWTEST_F()
870 vector<Entry> entries; HWTEST_F() local
918 vector<Entry> entries; HWTEST_F() local
966 vector<Entry> entries; HWTEST_F() local
994 vector<Entry> entries; HWTEST_F() local
1088 vector<Entry> entries; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/test/unittest/distributeddata/
H A DSchemaJsTest.js25 let entries = [];
27 entries.push({
35 return entries;
53 let entries = putBatchString(10, 'test_key_');
54 kvStore.putBatch(entries).then((data) => {
70 await kvStore.getEntries(query).then((entries) => {
71 console.info('testPutAndGet get success : ' + JSON.stringify(entries));
72 expect(entries.length == 10).assertTrue();
251 await kvStore.getEntries(query).then((entries) => {
252 console.info('SchemaToJsonStringTest003 get success : ' + JSON.stringify(entries));
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/
H A Dmeta_data_manager.h66 std::vector<Bytes> entries; in LoadMeta() local
67 if (!GetEntries(prefix, entries, isLocal)) { in LoadMeta()
70 values.resize(entries.size()); in LoadMeta()
71 for (size_t i = 0; i < entries.size(); ++i) { in LoadMeta()
72 Serializable::Unmarshall({ entries[i].begin(), entries[i].end() }, values[i]); in LoadMeta()
87 API_EXPORT bool GetEntries(const std::string &prefix, std::vector<Bytes> &entries, bool isLocal);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/
H A Ddistributeddb_schema_test_tools.cpp58 vector<Entry> entries; in GenerateFixedJsonSchemaRecords() local
62 entries.push_back(entry); in GenerateFixedJsonSchemaRecords()
64 return entries; in GenerateFixedJsonSchemaRecords()
153 void DistributedDBSchemaTestTools::GenerateCombineSchemaEntries(std::vector<DistributedDB::Entry> &entries, in GenerateCombineSchemaEntries() argument
156 entries.clear(); in GenerateCombineSchemaEntries()
171 entries.push_back(entry); in GenerateCombineSchemaEntries()
178 vector<Entry> entries; in CombinationCheckQueryResult() local
180 result = (delegate.GetEntries(query, entries) == status); in CombinationCheckQueryResult()
182 if (entries.size() != expectEntry.size()) { in CombinationCheckQueryResult()
183 MST_LOG("The entries fro in CombinationCheckQueryResult()
293 TransformToSchemaEntry(std::vector<DistributedDB::Entry> &entries, const std::vector<DistributedDB::Key> &keys, const std::vector<std::string> &schemasValue) TransformToSchemaEntry() argument
307 GenerateSpecificSchemaEntries(const int startPoint, const int recordNumber, std::vector<DistributedDB::Entry> &entries, const std::vector<std::vector<std::string>> &values) GenerateSpecificSchemaEntries() argument
[all...]
/foundation/distributeddatamgr/udmf/framework/innerkitsimpl/test/unittest/
H A Dunified_record_test.cpp106 auto entries = record.GetEntries(); in HWTEST_F() local
107 EXPECT_TRUE(entries->empty()); in HWTEST_F()
131 auto entries = record.GetEntries(); in HWTEST_F() local
132 auto it = entries->find(utdId); in HWTEST_F()
133 ASSERT_TRUE(it != entries->end()); in HWTEST_F()
161 auto entries = record.GetEntries(); in HWTEST_F() local
162 auto it = entries->find(utdId); in HWTEST_F()
163 ASSERT_TRUE(it != entries->end()); in HWTEST_F()
/foundation/graphic/graphic_3d/lume/LumeEngine/src/io/
H A Dproxy_directory.cpp66 std::unordered_set<IDirectory::Entry> entries; in GetEntries() local
69 entries.insert(entry); in GetEntries()
72 result.reserve(entries.size()); in GetEntries()
75 std::move(entries.begin(), entries.end(), std::back_inserter(result)); in GetEntries()

Completed in 30 milliseconds

1234567891011