Home
last modified time | relevance | path

Searched refs:Entry (Results 1 – 25 of 257) sorted by relevance

1234567891011

/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/test/common/distributeddb/include/
Dkv_store_observer_impl.h45 const std::list<DistributedDB::Entry> GetInsertList() const;
47 const std::list<DistributedDB::Entry> GetUpdateList() const;
49 const std::list<DistributedDB::Entry> GetDeleteList() const;
65 const std::list<DistributedDB::Entry> GetCumulatedInsertList() const;
67 const std::list<DistributedDB::Entry> GetCumulatedUpdateList() const;
69 const std::list<DistributedDB::Entry> GetCumulatedDeleteList() const;
72 std::list<DistributedDB::Entry> insertedEntries_ = {};
73 std::list<DistributedDB::Entry> updatedEntries_ = {};
74 std::list<DistributedDB::Entry> deleteEntries_ = {};
79 std::list<DistributedDB::Entry> cumulatedInsertList_ = {};
[all …]
Ddistributeddb_data_generator.h462 const DistributedDB::Entry ENTRY_1 = { .key = KEY_1, .value = VALUE_1 };
463 const DistributedDB::Entry ENTRY_2 = { .key = KEY_2, .value = VALUE_2 };
464 const DistributedDB::Entry ENTRY_3 = { .key = KEY_3, .value = VALUE_3 };
465 const DistributedDB::Entry ENTRY_4 = { .key = KEY_4, .value = VALUE_4 };
466 const DistributedDB::Entry ENTRY_5 = { .key = KEY_5, .value = VALUE_5 };
467 const DistributedDB::Entry ENTRY_6 = { .key = KEY_6, .value = VALUE_6 };
468 const DistributedDB::Entry ENTRY_7 = { .key = KEY_7, .value = VALUE_7 };
469 const DistributedDB::Entry ENTRY_8 = { .key = KEY_8, .value = VALUE_8 };
470 const DistributedDB::Entry ENTRY_9 = { .key = KEY_9, .value = VALUE_9 };
471 const DistributedDB::Entry ENTRY_10 = { .key = KEY_10, .value = VALUE_10 };
[all …]
/foundation/distributeddatamgr/distributeddatamgr/interfaces/innerkits/app_distributeddata/include/
Dapp_change_notification.h30 …AppChangeNotification(const std::list<Entry> &insertEntries, const std::list<Entry> &updateEntries,
31 … const std::list<Entry> &deleteEntries, const std::string &deviceId, const bool isClear);
36 KVSTORE_API const std::list<Entry> &GetInsertEntries() const;
39 KVSTORE_API const std::list<Entry> &GetUpdateEntries() const;
42 KVSTORE_API const std::list<Entry> &GetDeleteEntries() const;
51 std::list<Entry> insertEntries_;
53 std::list<Entry> updateEntries_;
55 std::list<Entry> deleteEntries_;
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/test/unittest/common/common/
Ddistributeddb_data_generate_unit_test.h73 const DistributedDB::Entry ENTRY_1 = {KEY_1, VALUE_1};
74 const DistributedDB::Entry ENTRY_2 = {KEY_2, VALUE_2};
75 const DistributedDB::Entry NULL_ENTRY_1 = {NULL_KEY_1, VALUE_1};
76 const DistributedDB::Entry NULL_ENTRY_2 = {KEY_1, NULL_VALUE_1};
78 const DistributedDB::Entry ENTRY_3 = {KEY_3, VALUE_3};
79 const DistributedDB::Entry ENTRY_4 = {KEY_4, VALUE_4};
81 const DistributedDB::Entry KV_ENTRY_1 = {KEY_1, VALUE_1};
82 const DistributedDB::Entry KV_ENTRY_2 = {KEY_2, VALUE_2};
83 const DistributedDB::Entry KV_ENTRY_3 = {KEY_3, VALUE_3};
84 const DistributedDB::Entry KV_ENTRY_4 = {KEY_4, VALUE_4};
[all …]
Ddistributeddb_tools_unit_test.h141 …static void EntryVectorCallback(DistributedDB::DBStatus, const std::vector<DistributedDB::Entry> &,
142 DistributedDB::DBStatus &, unsigned long &, std::vector<DistributedDB::Entry> &);
158 …static bool IsEntryEqual(const DistributedDB::Entry &entryOrg, const DistributedDB::Entry &entryRe…
160 static bool IsEntriesEqual(const std::vector<DistributedDB::Entry> &entriesOrg,
161 const std::vector<DistributedDB::Entry> &entriesRet, bool needSort = false);
163 static bool CheckObserverResult(const std::vector<DistributedDB::Entry> &orgEntries,
164 const std::list<DistributedDB::Entry> &resultLst);
169 static bool IsEntryExist(const DistributedDB::Entry &entry,
170 const std::vector<DistributedDB::Entry> &entries);
172 static bool IsKvEntryExist(const DistributedDB::Entry &entry,
[all …]
Ddistributeddb_data_generate_unit_test.cpp44 void GenerateEntry(int entryCount, int startPosition, Entry &entryTest) in GenerateEntry()
53 void GenerateEntryVector(int entryVectorCount, int entryCount, std::vector<Entry> &entrysTest) in GenerateEntryVector()
60 Entry entry; in GenerateEntryVector()
66 void GenerateRecords(int recordNum, std::vector<Entry> &entries, std::vector<Key> &keys, int keySiz… in GenerateRecords()
68 Entry entry; in GenerateRecords()
/foundation/distributeddatamgr/distributeddatamgr/interfaces/innerkits/distributeddata/include/
Dchange_notification.h28 ChangeNotification(std::vector<Entry> &&insertEntries,
29 std::vector<Entry> &&updateEntries,
30 std::vector<Entry> &&deleteEntries,
37 KVSTORE_API const std::vector<Entry> &GetInsertEntries() const;
40 KVSTORE_API const std::vector<Entry> &GetUpdateEntries() const;
43 KVSTORE_API const std::vector<Entry> &GetDeleteEntries() const;
60 std::vector<Entry> insertEntries_;
62 std::vector<Entry> updateEntries_;
64 std::vector<Entry> deleteEntries_;
/foundation/distributeddatamgr/distributeddatamgr/frameworks/innerkitsimpl/distributeddatafwk/src/
Dchange_notification.cpp24 ChangeNotification::ChangeNotification(std::vector<Entry> &&insertEntries, std::vector<Entry> &&upd… in ChangeNotification()
25 … std::vector<Entry> &&deleteEntries, const std::string &deviceId, bool isClear) in ChangeNotification()
33 const std::vector<Entry> &ChangeNotification::GetInsertEntries() const in GetInsertEntries()
38 const std::vector<Entry> &ChangeNotification::GetUpdateEntries() const in GetUpdateEntries()
43 const std::vector<Entry> &ChangeNotification::GetDeleteEntries() const in GetDeleteEntries()
103 std::vector<Entry> insertEntries; in Unmarshalling()
104 std::vector<Entry> updateEntries; in Unmarshalling()
105 std::vector<Entry> deleteEntries; in Unmarshalling()
113 sptr<Entry> entryTmp = parcel.ReadParcelable<Entry>(); in Unmarshalling()
128 sptr<Entry> entryTmp = parcel.ReadParcelable<Entry>(); in Unmarshalling()
[all …]
Dkvstore_observer_nb_impl.h40 std::list<DistributedDB::Entry> insertList = data.GetEntriesInserted(); in OnChange()
41 std::list<DistributedDB::Entry> updateList = data.GetEntriesUpdated(); in OnChange()
42 std::list<DistributedDB::Entry> deletedList = data.GetEntriesDeleted(); in OnChange()
44 std::list<Entry> insertListTmp; in OnChange()
45 std::list<Entry> updateListTmp; in OnChange()
46 std::list<Entry> deletedListTmp; in OnChange()
51 Entry tmpEntry; in OnChange()
60 Entry tmpEntry; in OnChange()
69 Entry tmpEntry; in OnChange()
Dapp_change_notification.cpp23 AppChangeNotification::AppChangeNotification(const std::list<Entry> &insertEntries, in AppChangeNotification()
24 const std::list<Entry> &updateEntries, in AppChangeNotification()
25 const std::list<Entry> &deleteEntries, in AppChangeNotification()
35 const std::list<Entry> &AppChangeNotification::GetInsertEntries() const in GetInsertEntries()
40 const std::list<Entry> &AppChangeNotification::GetUpdateEntries() const in GetUpdateEntries()
45 const std::list<Entry> &AppChangeNotification::GetDeleteEntries() const in GetDeleteEntries()
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/storage/src/
Dsingle_ver_natural_store_commit_notify_data.h49 const std::list<Entry> GetInsertedEntries(int &errCode) const override;
51 const std::list<Entry> GetUpdatedEntries(int &errCode) const override;
53 const std::list<Entry> GetDeletedEntries(int &errCode) const override;
63 int InsertCommittedData(const Entry &entry, DataType dataType, bool needMerge = false);
82 int InsertEntry(DataType dataType, const Entry &entry);
84 static const std::list<Entry> FilterEntriesByKey(const std::list<Entry> &entries,
87 void DeleteEntry(const Key &key, std::list<Entry> &entries) const;
103 std::list<Entry> insertedEntries_;
104 std::list<Entry> updatedEntries_;
105 std::list<Entry> deletedEntries_;
Dkvdb_commit_notify_filterable_data.cpp33 const std::list<Entry> KvDBCommitNotifyFilterAbleData::GetInsertedEntries(int &errCode) const in GetInsertedEntries()
35 std::list<Entry> entries; in GetInsertedEntries()
40 const std::list<Entry> KvDBCommitNotifyFilterAbleData::GetUpdatedEntries(int &errCode) const in GetUpdatedEntries()
42 std::list<Entry> entries; in GetUpdatedEntries()
47 const std::list<Entry> KvDBCommitNotifyFilterAbleData::GetDeletedEntries(int &errCode) const in GetDeletedEntries()
49 std::list<Entry> entries; in GetDeletedEntries()
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/interfaces/src/
Dkv_store_changed_data_impl.h32 const std::list<Entry> &GetEntriesInserted() const override;
34 const std::list<Entry> &GetEntriesUpdated() const override;
36 const std::list<Entry> &GetEntriesDeleted() const override;
43 mutable std::list<Entry> insertedEntries_;
44 mutable std::list<Entry> updatedEntries_;
45 mutable std::list<Entry> deletedEntries_;
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/app/src/
Dkvstore_observer_impl.cpp46 std::list<DistributedDB::Entry> insertList = data.GetEntriesInserted(); in OnChange()
47 std::list<DistributedDB::Entry> updateList = data.GetEntriesUpdated(); in OnChange()
48 std::list<DistributedDB::Entry> deletedList = data.GetEntriesDeleted(); in OnChange()
50 std::vector<Entry> inserts; in OnChange()
51 std::vector<Entry> updates; in OnChange()
52 std::vector<Entry> deleteds; in OnChange()
57 Entry tmpEntry; in OnChange()
66 Entry tmpEntry; in OnChange()
75 Entry tmpEntry; in OnChange()
Ddevice_kvstore_observer_impl.cpp33 std::list<DistributedDB::Entry> insertList = data.GetEntriesInserted(); in OnChange()
34 std::list<DistributedDB::Entry> updateList = data.GetEntriesUpdated(); in OnChange()
35 std::list<DistributedDB::Entry> deletedList = data.GetEntriesDeleted(); in OnChange()
37 std::vector<Entry> inserts; in OnChange()
38 std::vector<Entry> updates; in OnChange()
39 std::vector<Entry> deleteds; in OnChange()
53 …vStoreObserverImpl::Transfer(const std::list<DistributedDB::Entry> &input, std::vector<Entry> &out… in Transfer()
78 Entry tmpEntry; in Transfer()
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/test/moduletest/common/distributeddb/src/
Ddistributeddb_kv_batch_crud_test.cpp119 const list<Entry> GetInsertList() in GetInsertList()
124 const list<Entry> GetDeleteList() in GetDeleteList()
129 const list<Entry> GetUpdateList() in GetUpdateList()
148 list<Entry> insertCrudList_ = {};
149 list<Entry> deleteCrudList_ = {};
150 list<Entry> updateCrudList_ = {};
167 vector<Entry> entries1;
170 vector<Entry> entries2;
209 vector<Entry> entries1;
212 vector<Entry> entries1Up;
[all …]
Ddistributeddb_kv_observer_test.cpp181 vector<DistributedDB::Entry> insertEntries;
182 DistributedDB::Entry entry = { KEY_1, VALUE_1 };
216 vector<DistributedDB::Entry> insertEntries;
217 DistributedDB::Entry entry = { KEY_1, VALUE_1 };
235 DistributedDB::Entry entry2 = { KEY_2, VALUE_2 };
254 DistributedDB::Entry entry3 = { KEY_3, VALUE_3 };
294 vector<DistributedDB::Entry> insertEntries;
295 DistributedDB::Entry entry = { KEY_1, VALUE_1 };
358 vector<DistributedDB::Entry> insertEntries;
441 vector<DistributedDB::Entry> insertEntries;
[all …]
Ddistributeddb_nb_predicate_query_expand_test.cpp90 vector<Entry> &entries) in PresetDatasToDB()
94 DistributedDB::Entry entry; in PresetDatasToDB()
127 vector<Entry> entries;
137 vector<Entry> expectEntry1 = {entries[INDEX_FIRST], entries[INDEX_FIFTH], entries[INDEX_ZEROTH],
149 vector<Entry> expectEntry2 = {entries[INDEX_FIRST], entries[INDEX_FIFTH], entries[INDEX_THIRD],
187 vector<Entry> entries;
197 vector<Entry> expectEntry1 = {entries[INDEX_FIRST], entries[INDEX_FIFTH], entries[INDEX_ZEROTH],
210 vector<Entry> expectEntry2 = {entries[INDEX_FIRST], entries[INDEX_FIFTH], entries[INDEX_ZEROTH],
248 vector<Entry> entries;
259 vector<Entry> expectEntry;
[all …]
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/interfaces/include/
Dkv_store_changed_data.h29 DB_API virtual const std::list<Entry> &GetEntriesInserted() const = 0;
31 DB_API virtual const std::list<Entry> &GetEntriesUpdated() const = 0;
33 DB_API virtual const std::list<Entry> &GetEntriesDeleted() const = 0;
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/test/unittest/common/storage/
Ddistributeddb_storage_register_observer_test.cpp58 list<Entry> g_emptyEntries;
59 Entry g_entry0;
60 Entry g_entry1;
61 Entry g_entry2;
62 Entry g_entry3;
63 Entry g_entry4;
64 Entry g_entry5;
65 Entry g_entry6;
66 Entry g_oldEntry3;
67 Entry g_oldEntry4;
[all …]
/foundation/distributeddatamgr/distributeddatamgr/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
Dkvstore_snapshot_client_test.cpp195 std::vector<Entry> entries;
196 Entry entry1, entry2, entry3;
212 std::vector<Entry> students;
241 std::vector<Entry> entries;
242 Entry entry1, entry2, entry3;
258 std::vector<Entry> students;
287 std::vector<Entry> entries;
288 Entry entry1, entry2, entry3;
304 std::vector<Entry> students;
333 std::vector<Entry> entries;
[all …]
Dsingle_kvstore_client_test.cpp78 std::vector<Entry> insertEntries_;
79 std::vector<Entry> updateEntries_;
80 std::vector<Entry> deleteEntries_;
232 std::vector<Entry> results;
250 Entry entry;
447 std::vector<Entry> entries;
448 Entry entry1, entry2, entry3;
490 std::vector<Entry> entriesBefore;
491 Entry entry1, entry2, entry3;
506 std::vector<Entry> entriesAfter;
[all …]
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/test/unittest/common/interfaces/
Ddistributeddb_interfaces_nb_delegate_local_batch_test.cpp67 …static void CreatEntrys(int recordSize, vector<Key> &keys, vector<Value> &values, vector<Entry> &e… in CreatEntrys()
74 Entry entry; in CreatEntrys()
150 vector<Entry> entries;
152 Entry entry;
192 vector<Entry> entrysKeyIllegal = {KV_ENTRY_1, KV_ENTRY_2, {illegalKey, VALUE_3}};
193 vector<Entry> entrysValueIllegal = {KV_ENTRY_1, KV_ENTRY_2, {KEY_3, illegalValue}};
194 vector<Entry> entrysIllegal = {KV_ENTRY_1, KV_ENTRY_2, {illegalKey, illegalValue}};
236 vector<Entry> entrysMaxNumber;
238 Entry entry;
245 Entry entryTemp = {keyTemp, VALUE_1};
[all …]
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/storage/src/sqlite/
Dsqlite_single_ver_natural_store_connection.h48 …int GetEntries(const IOption &option, const Key &keyPrefix, std::vector<Entry> &entries) const ove…
50 …int GetEntries(const IOption &option, const Query &query, std::vector<Entry> &entries) const overr…
55 int PutBatch(const IOption &option, const std::vector<Entry> &entries) override;
115 int PutBatchInner(const IOption &option, const std::vector<Entry> &entries);
118 int SaveSyncEntries(const std::vector<Entry> &entries);
119 int SaveLocalEntries(const std::vector<Entry> &entries);
123 int SaveEntry(const Entry &entry, bool isDelete, TimeStamp timeStamp = 0);
129 int CheckSyncEntriesValid(const std::vector<Entry> &entries) const;
133 int CheckLocalEntriesValid(const std::vector<Entry> &entries) const;
185 int SaveLocalEntry(const Entry &entry, bool isDelete);
/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/libs/distributeddb/storage/include/
Dkvdb_commit_notify_data.h35 virtual const std::list<Entry> GetInsertedEntries(int &errCode) const = 0;
38 virtual const std::list<Entry> GetUpdatedEntries(int &errCode) const = 0;
41 virtual const std::list<Entry> GetDeletedEntries(int &errCode) const = 0;

1234567891011