/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/test/common/distributeddb/include/ |
D | kv_store_observer_impl.h | 45 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 …]
|
D | distributeddb_data_generator.h | 462 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/ |
D | app_change_notification.h | 30 …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/ |
D | distributeddb_data_generate_unit_test.h | 73 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 …]
|
D | distributeddb_tools_unit_test.h | 141 …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 …]
|
D | distributeddb_data_generate_unit_test.cpp | 44 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/ |
D | change_notification.h | 28 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/ |
D | change_notification.cpp | 24 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 …]
|
D | kvstore_observer_nb_impl.h | 40 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()
|
D | app_change_notification.cpp | 23 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/ |
D | single_ver_natural_store_commit_notify_data.h | 49 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_;
|
D | kvdb_commit_notify_filterable_data.cpp | 33 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/ |
D | kv_store_changed_data_impl.h | 32 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/ |
D | kvstore_observer_impl.cpp | 46 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()
|
D | device_kvstore_observer_impl.cpp | 33 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/ |
D | distributeddb_kv_batch_crud_test.cpp | 119 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 …]
|
D | distributeddb_kv_observer_test.cpp | 181 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 …]
|
D | distributeddb_nb_predicate_query_expand_test.cpp | 90 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/ |
D | kv_store_changed_data.h | 29 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/ |
D | distributeddb_storage_register_observer_test.cpp | 58 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/ |
D | kvstore_snapshot_client_test.cpp | 195 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 …]
|
D | single_kvstore_client_test.cpp | 78 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/ |
D | distributeddb_interfaces_nb_delegate_local_batch_test.cpp | 67 …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/ |
D | sqlite_single_ver_natural_store_connection.h | 48 …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/ |
D | kvdb_commit_notify_data.h | 35 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;
|