Home
last modified time | relevance | path

Searched refs:entries (Results 151 - 175 of 256) sorted by relevance

1234567891011

/foundation/deviceprofile/device_info_manager/old/services/core/include/subscribemanager/
H A Dprofile_change_handler.h44 void ConvertEntry(const std::vector<DistributedKv::Entry>& entries, ProfileChangeType changeType,
/foundation/distributeddatamgr/kv_store/frameworks/cj/src/
H A Ddistributed_kv_store_impl.cpp385 static CArrEntry EntriesToCArrEntry(const std::vector<Entry> &entries) in EntriesToCArrEntry() argument
387 CEntry *cEntries = static_cast<CEntry*>(malloc(entries.size() * sizeof(CEntry))); in EntriesToCArrEntry()
391 for (size_t i = 0; i < entries.size(); i++) { in EntriesToCArrEntry()
392 cEntries[i].key = MallocCString(entries[i].key.ToString()); in EntriesToCArrEntry()
393 cEntries[i].value = KVValueToValueType(entries[i].value); in EntriesToCArrEntry()
395 return CArrEntry{.head = cEntries, .size = int64_t(entries.size())}; in EntriesToCArrEntry()
460 std::vector<DistributedKVStore::Entry> entries; in GetEntries() local
462 Status status = kvStore_->GetEntries(dataQuery, entries); in GetEntries()
464 return EntriesToCArrEntry(entries); in GetEntries()
469 std::vector<DistributedKVStore::Entry> entries; in GetEntries() local
761 std::vector<DistributedKVStore::Entry> entries; GetEntriesByDataQuery() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.h181 const std::vector<DistributedDB::Entry> &entries);
184 const std::vector<DistributedDB::Entry> &entries);
209 std::vector<DistributedDB::SingleVerKvEntry *> &entries);
211 static void ConvertSingleVerEntryToItems(std::vector<DistributedDB::SingleVerKvEntry *> &entries,
214 static void ReleaseSingleVerEntry(std::vector<DistributedDB::SingleVerKvEntry *> &entries);
/foundation/distributeddatamgr/pasteboard/framework/test/src/
H A Dpaste_data_record_test.cpp44 void CheckEntries(const std::vector<std::shared_ptr<PasteDataEntry>> &entries);
124 void PasteDataRecordTest::CheckEntries(const std::vector<std::shared_ptr<PasteDataEntry>> &entries) in CheckEntries() argument
126 for (auto const &entry : entries) { in CheckEntries()
228 * @tc.require:entries
250 * @tc.require:entries
264 * @tc.require:entries
301 auto entries = record->GetEntries(); in HWTEST_F() local
302 CheckEntries(entries); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Dikvstore_observer.cpp39 int64_t GetBufferSize(const std::vector<Entry> &entries) in GetBufferSize() argument
42 for (const auto &item : entries) { in GetBufferSize()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_transaction_record_test.cpp476 * @tc.steps: step2. Put 2 entries into the database. in HWTEST_F()
796 * @tc.steps: step1. Put the batch data into the database(3 entries have the same prefix key, in HWTEST_F()
818 * @tc.expected: step2. GetEntries returns E_OK and the number of the result entries is E_OK. in HWTEST_F()
919 * @tc.expected: step2. GetEntries returns E_OK and the entries size is 1. in HWTEST_F()
938 std::vector<Entry> entries; in HWTEST_F() local
945 entries.push_back(entry); in HWTEST_F()
946 entries.push_back(entry1); in HWTEST_F()
950 EXPECT_EQ(g_transaction->PutBatch(entries), E_OK); in HWTEST_F()
1055 std::vector<Entry> entries; in HWTEST_F() local
1062 entries in HWTEST_F()
[all...]
H A Ddistributeddb_storage_rd_single_ver_natural_executor_test.cpp256 vector<Entry> entries; in HWTEST_F() local
257 EXPECT_EQ(g_nullHandle->GetAllSyncedEntries(devName, entries), -E_NOT_SUPPORT); in HWTEST_F()
316 std::vector<Entry> entries; in HWTEST_F() local
317 EXPECT_EQ(emptyConn->PutBatch(option, entries), -E_INVALID_DB); in HWTEST_F()
321 EXPECT_EQ(emptyConn->PutBatch(option, entries), -E_INVALID_DB); in HWTEST_F()
324 EXPECT_EQ(emptyConn->PutBatch(option, entries), -E_NOT_SUPPORT); in HWTEST_F()
H A Ddistributeddb_storage_index_optimize_test.cpp342 std::vector<Entry> entries; in HWTEST_F() local
349 ASSERT_EQ(g_kvNbDelegatePtr->GetEntries(query1, entries), OK); in HWTEST_F()
350 EXPECT_TRUE(value == entries[0].value); in HWTEST_F()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/
H A Dflat_object_storage_engine.cpp231 std::vector<DistributedDB::Entry> entries; in UpdateItems() local
234 entries.emplace_back(entry); in UpdateItems()
238 auto status = delegate->PutBatch(entries); in UpdateItems()
423 std::vector<DistributedDB::Entry> entries; in GetItems() local
424 DistributedDB::DBStatus status = delegates_.at(key)->GetEntries(StringUtils::StrToBytes(""), entries); in GetItems()
429 for (auto &item : entries) { in GetItems()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/include/
H A Ddistributeddb_data_generator.h535 void GenerateFixedRecords(std::vector<DistributedDB::Entry> &entries, std::vector<DistributedDB::Key> &allKeys,
540 void GenerateRecordsForImage(std::vector<DistributedDB::Entry> &entries, EntrySize &entrySize,
545 void GenerateAppointPrefixAndSizeRecords(std::vector<DistributedDB::Entry> &entries, const EntrySize &entrySize,
547 void GenerateAppointPrefixAndSizeRecords(std::vector<DistributedDB::Entry> &entries, int startpoint,
553 void GenerateFixedLenRandRecords(std::vector<DistributedDB::Entry> &entries, std::vector<DistributedDB::Key> &allKeys,
560 void GenerateRandomRecords(std::vector<DistributedDB::Entry> &entries, EntrySize &entrySize, int num);
H A Ddistributeddb_schema_test_tools.h303 static void GenerateCombineSchemaEntries(std::vector<DistributedDB::Entry> &entries,
306 static bool TransformToSchemaEntry(std::vector<DistributedDB::Entry> &entries,
309 std::vector<DistributedDB::Entry> &entries, const std::vector<std::vector<std::string>> &values = {});
H A Ddistributeddb_nb_test_tools.h204 const DistributedDB::Key &keyPrefix, std::vector<DistributedDB::Entry> &entries);
210 const std::vector<DistributedDB::Entry> &entries, bool isNeedRetry = false);
225 const std::vector<DistributedDB::Entry> &entries);
245 const std::vector<DistributedDB::Entry> &entries, int recordCnt);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_multi_ver_transaction.cpp113 // just for query entries.
301 int SQLiteMultiVerTransaction::GetEntries(const Key &keyPrefix, std::vector<Entry> &entries) const in GetEntries()
315 entries.clear(); in GetEntries()
316 entries.shrink_to_fit(); in GetEntries()
324 entries.push_back(std::move(entry)); in GetEntries()
341 if (entries.empty()) { in GetEntries()
389 int SQLiteMultiVerTransaction::PutBatch(const std::vector<Entry> &entries) in PutBatch() argument
391 for (auto iter = entries.begin(); iter != entries.end(); iter++) { in PutBatch()
401 int SQLiteMultiVerTransaction::PutBatch(const std::vector<MultiVerKvEntry *> &entries, boo argument
1015 GetRawDataByVersion(sqlite3_stmt *&statement, const Version &version, std::vector<MultiVerEntryData> &entries) GetRawDataByVersion() argument
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_manager.cpp795 std::vector<DistributedDB::Entry> entries; in ProcessOldEntry() local
796 auto status = delegate_->GetEntries(std::vector<uint8_t>(appId.begin(), appId.end()), entries); in ProcessOldEntry()
798 ZLOGI("Get old entries empty, bundleName: %{public}s", appId.c_str()); in ProcessOldEntry()
802 ZLOGE("Get old entries failed, bundleName: %{public}s, status %{public}d", appId.c_str(), status); in ProcessOldEntry()
808 for (auto &item : entries) { in ProcessOldEntry()
830 ZLOGE("Delete old entries failed, deleteKey: %{public}s, status: %{public}d", deleteKey.c_str(), result); in ProcessOldEntry()
833 ZLOGI("Delete old entries success, deleteKey: %{public}s", deleteKey.c_str()); in ProcessOldEntry()
849 std::vector<DistributedDB::Entry> entries; in SaveToStore() local
850 entries.emplace_back(saveInfoEntry); in SaveToStore()
856 entries in SaveToStore()
919 std::vector<DistributedDB::Entry> entries; RevokeSaveToStore() local
950 std::vector<DistributedDB::Entry> entries; RetrieveFromStore() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dsingle_store_impl.cpp114 Status SingleStoreImpl::PutBatch(const std::vector<Entry> &entries) in PutBatch() argument
124 for (const auto &entry : entries) { in PutBatch()
139 ZLOGE("status:0x%{public}x entries size:%{public}zu", status, entries.size()); in PutBatch()
379 std::vector<Entry> entries; in GetEntries() local
380 auto status = GetEntries(prefix, entries); in GetEntries()
381 onResult(status, std::move(entries)); in GetEntries()
401 Status SingleStoreImpl::GetEntries(const Key &prefix, std::vector<Entry> &entries) const in GetEntries()
413 auto status = GetEntries(dbQuery, entries); in GetEntries()
420 Status SingleStoreImpl::GetEntries(const DataQuery &query, std::vector<Entry> &entries) cons
[all...]
/foundation/ability/ability_runtime/test/mock/common/include/
H A Dmock_single_kv_store.h39 const DistributedKv::Key &prefix, std::vector<DistributedKv::Entry> &entries) const override
45 const DistributedKv::DataQuery &query, std::vector<DistributedKv::Entry> &entries) const override
156 DistributedKv::Status PutBatch(const std::vector<DistributedKv::Entry> &entries) override
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/sync_fuzzer/
H A Dsync_fuzzer.cpp93 std::vector<Entry> entries; in CreateEntries() local
101 entries.push_back(entry); in CreateEntries()
103 return entries; in CreateEntries()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_general_store.cpp654 void KVDBGeneralStore::ObserverProxy::ConvertChangeData(const std::list<DBEntry> &entries, std::vector<Values> &values) in ConvertChangeData() argument
656 for (auto &entry : entries) { in ConvertChangeData()
708 auto entries = data.GetEntries();
709 for (size_t i = 0; i < entries.size(); i++) {
710 if (entries[i].key.empty()) {
713 auto oriKey = entries[i].key;
737 auto entries = data.GetEntries();
738 for (size_t i = 0; i < entries.size(); i++) {
739 if (entries[i].key.empty()) {
750 auto oriKey = entries[
[all...]
/foundation/distributeddatamgr/kv_store/test/fuzztest/devicekvstore_fuzzer/
H A Ddevicekvstore_fuzzer.cpp101 std::vector<Entry> entries; in PutBatchFuzz() local
112 entries.push_back(entry1); in PutBatchFuzz()
113 entries.push_back(entry2); in PutBatchFuzz()
114 entries.push_back(entry3); in PutBatchFuzz()
118 deviceKvStore_->PutBatch(entries); in PutBatchFuzz()
155 std::vector<Entry> entries; in GetEntriesFuzz2() local
160 deviceKvStore_->GetEntries(dataQuery, entries); in GetEntriesFuzz2()
/foundation/distributeddatamgr/kv_store/test/fuzztest/singlekvstore_fuzzer/
H A Dsinglekvstore_fuzzer.cpp103 std::vector<Entry> entries; in PutBatchFuzz() local
114 entries.push_back(entry1); in PutBatchFuzz()
115 entries.push_back(entry2); in PutBatchFuzz()
116 entries.push_back(entry3); in PutBatchFuzz()
120 singleKvStore_->PutBatch(entries); in PutBatchFuzz()
157 std::vector<Entry> entries; in GetEntriesFuzz2() local
162 singleKvStore_->GetEntries(dataQuery, entries); in GetEntriesFuzz2()
/foundation/deviceprofile/device_info_manager/services/core/test/unittest/
H A Dprofile_utils_test.cpp619 map<string, string> entries; in HWTEST_F() local
620 int32_t res1 = ProfileUtils::DeviceProfileToEntries(deviceProfile, entries); in HWTEST_F()
624 int32_t res2 = ProfileUtils::EntriesToDeviceProfile(entries, outDeviceProfile); in HWTEST_F()
641 map<string, string> entries; in HWTEST_F() local
642 int32_t res1 = ProfileUtils::ServiceProfileToEntries(serviceProfile, entries); in HWTEST_F()
646 int32_t res2 = ProfileUtils::EntriesToServiceProfile(entries, outServiceProfile); in HWTEST_F()
765 map<string, string> entries; in HWTEST_F() local
766 int32_t res1 = ProfileUtils::CharacteristicProfileToEntries(charProfile, entries); in HWTEST_F()
770 int32_t res2 = ProfileUtils::EntriesToCharProfile(entries, outCharProfile); in HWTEST_F()
783 map<string, string> entries; in HWTEST_F() local
797 map<string, string> entries; HWTEST_F() local
811 map<string, string> entries; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/adapter/kv_store/src/
H A Dlnn_kv_adapter.cpp192 std::vector<DistributedKv::Entry> entries; in PutBatch() local
203 entries.emplace_back(entry); in PutBatch()
205 if (entries.empty()) { in PutBatch()
209 status = kvStorePtr_->PutBatch(entries); in PutBatch()
251 // if prefix is empty, get all entries. in DeleteByPrefix()
/foundation/deviceprofile/device_info_manager/old/services/core/src/dbstorage/
H A Ddevice_profile_storage.cpp231 std::vector<Entry> entries; in PutDeviceProfileBatch() local
246 entries.emplace_back(entry); in PutDeviceProfileBatch()
248 if (entries.empty()) { in PutDeviceProfileBatch()
253 Status status = kvStorePtr_->PutBatch(entries); in PutDeviceProfileBatch()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h53 // Get the max timestamp of all entries in database.
81 std::vector<SingleVerKvEntry *> &entries) const override;
83 int GetSyncDataNext(std::vector<SingleVerKvEntry *> &entries, ContinueToken &continueStmtToken,
86 int PutSyncDataWithQuery(const QueryObject &object, const std::vector<SingleVerKvEntry *> &entries,
104 int InterceptData(std::vector<SingleVerKvEntry *> &entries, const std::string &sourceID,
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/
H A Djs_device_kv_store.cpp200 std::vector<Entry> entries; in GetEntries() member
215 status = kvStore->GetEntries(keyPrefix, ctxt->entries); in GetEntries()
220 status = kvStore->GetEntries(query, ctxt->entries); in GetEntries()
224 status = kvStore->GetEntries(query, ctxt->entries); in GetEntries()
232 ctxt->status = JSUtil::SetValue(env, ctxt->entries, result, isSchemaStore); in GetEntries()

Completed in 25 milliseconds

1234567891011