/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
H A D | change_notification.h | 34 API_EXPORT ChangeNotification(std::vector<Entry> &&insertEntries, std::vector<Entry> &&updateEntries, 35 std::vector<Entry> &&deleteEntries, const std::string &deviceId, bool isClear); 45 API_EXPORT const std::vector<Entry> &GetInsertEntries() const; 50 API_EXPORT const std::vector<Entry> &GetUpdateEntries() const; 55 API_EXPORT const std::vector<Entry> &GetDeleteEntries() const; 69 std::vector<Entry> insertEntries_; 71 std::vector<Entry> updateEntries_; 73 std::vector<Entry> deleteEntries_;
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/include/ |
H A 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...] |
H A 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_1 [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
H A D | distributeddb_data_generate_unit_test.h | 79 const DistributedDB::Entry ENTRY_1 = {KEY_1, VALUE_1}; 80 const DistributedDB::Entry ENTRY_2 = {KEY_2, VALUE_2}; 81 const DistributedDB::Entry NULL_ENTRY_1 = {NULL_KEY_1, VALUE_1}; 82 const DistributedDB::Entry NULL_ENTRY_2 = {KEY_1, NULL_VALUE_1}; 84 const DistributedDB::Entry ENTRY_3 = {KEY_3, VALUE_3}; 85 const DistributedDB::Entry ENTRY_4 = {KEY_4, VALUE_4}; 87 const DistributedDB::Entry KV_ENTRY_1 = {KEY_1, VALUE_1}; 88 const DistributedDB::Entry KV_ENTRY_2 = {KEY_2, VALUE_2}; 89 const DistributedDB::Entry KV_ENTRY_3 = {KEY_3, VALUE_3}; 90 const DistributedDB::Entry KV_ENTRY_ [all...] |
H A 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 keySize, int valSize) in GenerateRecords() 68 Entry entry; in GenerateRecords() 94 void GenerateNumberEntryVector(int entryNum, std::vector<Entry> &entries) in GenerateNumberEntryVector() 100 Entry entry; in GenerateNumberEntryVector()
|
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
H A 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()
|
H A D | change_notification.cpp | 24 ChangeNotification::ChangeNotification(std::vector<Entry> &&insertEntries, std::vector<Entry> &&updateEntries, 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()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
H A 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/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A 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 [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
H A D | distributeddb_kv_batch_crud_test.cpp | 120 const list<Entry> GetInsertList() in GetInsertList() 125 const list<Entry> GetDeleteList() in GetDeleteList() 130 const list<Entry> GetUpdateList() in GetUpdateList() 149 list<Entry> insertCrudList_ = {}; 150 list<Entry> deleteCrudList_ = {}; 151 list<Entry> updateCrudList_ = {}; 168 vector<Entry> entries1; in HWTEST_F() 171 vector<Entry> entries2; in HWTEST_F() 210 vector<Entry> entries1; in HWTEST_F() 213 vector<Entry> entries1U in HWTEST_F() [all...] |
H A D | distributeddb_kv_observer_test.cpp | 182 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() 183 DistributedDB::Entry entry = { KEY_1, VALUE_1 }; in HWTEST_F() 217 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() 218 DistributedDB::Entry entry = { KEY_1, VALUE_1 }; in HWTEST_F() 236 DistributedDB::Entry entry2 = { KEY_2, VALUE_2 }; in HWTEST_F() 255 DistributedDB::Entry entry3 = { KEY_3, VALUE_3 }; in HWTEST_F() 295 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() 296 DistributedDB::Entry entry = { KEY_1, VALUE_1 }; in HWTEST_F() 359 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() 442 vector<DistributedDB::Entry> insertEntrie in HWTEST_F() [all...] |
H A D | distributeddb_nb_observer_test.cpp | 57 Entry* entryPtr_; 188 vector<DistributedDB::Entry> insertLocalEntries; in HWTEST_F() 191 vector<DistributedDB::Entry> insertNativeEntries; in HWTEST_F() 199 vector<DistributedDB::Entry> deleteLocalEntries; in HWTEST_F() 202 vector<DistributedDB::Entry> deleteNativeEntries; in HWTEST_F() 239 vector<DistributedDB::Entry> insertLocalEntries; in CheckObserverAllLocalValue() 261 vector<DistributedDB::Entry> deleteLocalEntries; in CheckObserverAllLocalValue() 293 vector<DistributedDB::Entry> insertNativeEntries; in HWTEST_F() 313 vector<DistributedDB::Entry> deleteNativeEntries; in HWTEST_F() 329 vector<DistributedDB::Entry> insertLocalEntrie in CheckObserverAllNativeValue() [all...] |
/foundation/graphic/graphic_3d/lume/LumeEngine/src/io/ |
H A D | proxy_directory.cpp | 34 uint64_t hash(const CORE_NS::IDirectory::Entry::Type& val) in hash() 41 struct std::hash<CORE_NS::IDirectory::Entry> { 42 using argument_type = CORE_NS::IDirectory::Entry; 54 bool operator==(const IDirectory::Entry& lhs, const IDirectory::Entry& rhs) in operator ==() 63 vector<IDirectory::Entry> ProxyDirectory::GetEntries() const in GetEntries() 65 vector<IDirectory::Entry> result; in GetEntries() 66 std::unordered_set<IDirectory::Entry> entries; in GetEntries()
|
H A D | std_directory.cpp | 67 IDirectory::Entry::Type GetEntryType(const std::filesystem::directory_entry& entry) in GetEntryType() 70 return IDirectory::Entry::DIRECTORY; in GetEntryType() 73 return IDirectory::Entry::FILE; in GetEntryType() 76 return IDirectory::Entry::UNKNOWN; in GetEntryType() 120 vector<IDirectory::Entry> StdDirectory::GetEntries() const in GetEntries() 123 vector<IDirectory::Entry> result; in GetEntries() 129 result.push_back(IDirectory::Entry { GetEntryType(iter), move(str), GetTimeStamp(iter) }); in GetEntries() 146 IDirectory::Entry CreateEntry(const string_view path, const dirent& entry) 152 IDirectory::Entry::Type type = IDirectory::Entry [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_rd_register_observer_test.cpp | 57 list<Entry> g_emptyEntries; 58 Entry g_entry0; 59 Entry g_entry1; 60 Entry g_entry2; 61 Entry g_entry3; 62 Entry g_entry4; 63 Entry g_entry5; 64 Entry g_entry6; 65 Entry g_oldEntry3; 66 Entry g_oldEntry [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
H A 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/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
H A D | rd_single_ver_natural_store_connection.h | 46 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); 137 int SaveEntry(const Entry &entry, bool isDelete, Timestamp timestamp = 0); 139 int SaveEntryNormally(const Entry &entry, bool isDelete); 164 int SetBatchInner(const IOption &option, const std::vector<Entry> [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
H A D | single_store_impl_get_top_test.cpp | 91 std::vector<Entry> input; in HWTEST_F() 93 Entry entry; in HWTEST_F() 104 std::vector<Entry> output; in HWTEST_F() 124 std::vector<Entry> input; in HWTEST_F() 126 Entry entry; in HWTEST_F() 137 std::vector<Entry> output; in HWTEST_F() 157 std::vector<Entry> input; in HWTEST_F() 159 Entry entry; in HWTEST_F() 171 std::vector<Entry> output; in HWTEST_F() 187 std::vector<Entry> inpu in HWTEST_F() [all...] |
/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
H A D | task_queue.cpp | 76 TaskQueue::Entry::Entry(uint64_t identifier, IThreadPool::ITask::Ptr task) : task(move(task)), identifier(identifier) {} in Entry() function in TaskQueue::Entry 78 bool TaskQueue::Entry::operator==(uint64_t rhsIdentifier) const in operator ==() 83 bool TaskQueue::Entry::operator==(const TaskQueue::Entry& other) const in operator ==()
|
/foundation/deviceprofile/device_info_manager/services/core/include/deviceprofilemanager/listener/ |
H A D | kv_data_change_listener.h | 38 void HandleAddChange(const std::vector<DistributedKv::Entry> &insertRecords); 39 void HandleUpdateChange(const std::vector<DistributedKv::Entry> &updateRecords); 40 void HandleDeleteChange(const std::vector<DistributedKv::Entry> &deleteRecords); 41 std::vector<DistributedKv::Entry> ConvertCloudChangeDataToEntries(const std::vector<std::string> &keys); 46 void FilterEntries(const std::vector<DistributedKv::Entry>& records,
|
/foundation/distributeddatamgr/kv_store/test/fuzztest/typesutil_fuzzer/ |
H A D | typesutil_fuzzer.cpp | 43 Entry entryIn; in EntryFuzz() 48 Entry entryOut; in EntryFuzz() 97 Entry insert; in ChangeNotificationFuzz() 98 Entry update; in ChangeNotificationFuzz() 99 Entry del; in ChangeNotificationFuzz() 106 std::vector<Entry> inserts; in ChangeNotificationFuzz() 107 std::vector<Entry> updates; in ChangeNotificationFuzz() 108 std::vector<Entry> deleteds; in ChangeNotificationFuzz() 116 std::vector<Entry> empty; in ChangeNotificationFuzz() 151 Entry entr in GetTotalSizeFuzz() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
H A 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/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
H A D | distributeddb_interfaces_nb_delegate_local_batch_test.cpp | 68 static void CreatEntrys(int recordSize, vector<Key> &keys, vector<Value> &values, vector<Entry> &entries) in CreatEntrys() 75 Entry entry; in CreatEntrys() 151 vector<Entry> entries; in HWTEST_F() 153 Entry entry; in HWTEST_F() 196 vector<Entry> entries; in HWTEST_F() 198 Entry entry; in HWTEST_F() 227 * Create and construct three sets of vector <Entry>, each set of three data contains records: in HWTEST_F() 236 vector<Entry> entrysKeyIllegal = {KV_ENTRY_1, KV_ENTRY_2, {illegalKey, VALUE_3}}; in HWTEST_F() 237 vector<Entry> entrysValueIllegal = {KV_ENTRY_1, KV_ENTRY_2, {KEY_3, illegalValue}}; in HWTEST_F() 238 vector<Entry> entrysIllega in HWTEST_F() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
H A D | device_kvstore_test.cpp | 101 std::vector<Entry> insertEntries_; 102 std::vector<Entry> updateEntries_; 103 std::vector<Entry> deleteEntries_; 233 std::vector<Entry> results; in HWTEST_F() 251 Entry entry; in HWTEST_F() 289 std::vector<Entry> results; in HWTEST_F() 307 Entry entry; in HWTEST_F() 360 Entry entry; in HWTEST_F() 389 std::vector<Entry> results; in HWTEST_F() 407 Entry entr in HWTEST_F() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | udmf_run_time_store_test.cpp | 39 using Entry = DistributedDB::Entry; 130 vector<Entry> entrysRand; in HWTEST_F() 139 vector<Entry> entries; in HWTEST_F() 164 vector<Entry> entrysRand(127, { key, value }); in HWTEST_F() 172 vector<Entry> entries; in HWTEST_F() 197 vector<Entry> entrysRand(127, { key, value }); in HWTEST_F() 206 vector<Entry> entries; in HWTEST_F() 232 vector<Entry> entrysMix1(1, { keyInvalid, value }); in HWTEST_F() 233 vector<Entry> entrysMix in HWTEST_F() [all...] |