| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_executor.h | 63 Key key; member
79 Key key; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_multi_ver_sync_db_interface.cpp | 57 int VirtualMultiVerSyncDBInterface::GetMetaData(const Key &key, Value &value) const in GetMetaData() argument
62 int VirtualMultiVerSyncDBInterface::PutMetaData(const Key &key, const Value &value, bool isInTransaction) in PutMetaData() argument
178 int VirtualMultiVerSyncDBInterface::GetData(const Key &key, Key &value) in GetData() argument
191 int VirtualMultiVerSyncDBInterface::PutData(const Key &key, const Key &value) in PutData() argument
197 int VirtualMultiVerSyncDBInterface::DeleteData(const Key &key) in DeleteData() argument
[all...] |
| H A D | virtual_single_ver_sync_db_Interface.h | 29 Key key; member
|
| H A D | distributeddb_single_ver_p2p_permission_sync_test.cpp | 181 Key key = {'1'}; in HWTEST_F() local
246 Key key = {'1'}; in HWTEST_F() local
403 Key key = {'1'}; in HWTEST_F() local
467 Key key = {'1'}; HWTEST_F() local
535 Key key = {'1'}; HWTEST_F() local
610 Key key = {'1'}; HWTEST_F() local
661 Key key = {'1'}; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/ |
| H A D | js_distributedobject.cpp | 49 char key[KEY_SIZE] = { 0 };
in JSGet() local
76 char key[KEY_SIZE] = { 0 };
in JSPut() local
130 DoPut( napi_env env, JSObjectWrapper *wrapper, char *key, napi_valuetype type, napi_value value) DoPut() argument
170 DoGet(napi_env env, JSObjectWrapper *wrapper, char *key, napi_value &value) DoGet() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | meta_data_manager.cpp | 134 auto key = *strValue; in HandleChanges() local
187 SaveMeta(const std::string &key, const Serializable &value, bool isLocal) SaveMeta() argument
215 LoadMeta(const std::string &key, Serializable &value, bool isLocal) LoadMeta() argument
262 DelMeta(const std::string &key, bool isLocal) DelMeta() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | lru_bucket.h | 66 bool Get(const _Key &key, _Tp &value, bool isLRU = true) in Get() argument
86 bool Set(const _Key &key, const _Tp &value) in Set() argument
119 bool Update(const _Key &key, const _Tp &value) in Update() argument
161 bool Delete(const _Key &key) in Delete() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_utils.cpp | 118 int RdKVPut(GRD_DB *db, const char *collectionName, const Key &key, const Value &value) in RdKVPut() argument
133 int RdKVGet(GRD_DB *db, const char *collectionName, const Key &key, Value &value) in RdKVGet() argument
161 int RdKVDel(GRD_DB *db, const char *collectionName, const Key &key) in RdKVDel() argument
175 int RdKVScan(GRD_DB *db, const char *collectionName, const Key &key, GRD_KvScanMode argument
202 RdKvFetch(GRD_ResultSet *resultSet, Key &key, Value &value) RdKvFetch() argument
235 RdKVBatchPushback(GRD_KVBatchT *batch, const Key &key, const Value &value) RdKVBatchPushback() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_transaction_test.cpp | 49 Key key; member
107 Key key; in NotifierCallback() local
[all...] |
| H A D | distributeddb_interfaces_nb_delegate_schema_put_test.cpp | 81 Key key; in CheckPutSchemaData() local
138 Key key; in CheckPutBatchSchemaData() local
219 Key key; HWTEST_F() local
261 Key key; HWTEST_F() local
313 Key key; HWTEST_F() local
401 Key key; HWTEST_F() local
[all...] |
| H A D | distributeddb_interfaces_register_syncdb_test.cpp | 215 Key key; in HWTEST_F() local
336 Key key; HWTEST_F() local
378 Key key; HWTEST_F() local
418 Key key; HWTEST_F() local
507 Key key; HWTEST_F() local
549 Key key; HWTEST_F() local
664 Key key; HWTEST_F() local
831 Key key; HWTEST_F() local
948 Key key; HWTEST_F() local
990 Key key; HWTEST_F() local
1028 Key key; HWTEST_F() local
1066 Key key; HWTEST_F() local
1126 Key key; HWTEST_F() local
1162 Key key; HWTEST_F() local
1271 Key key; HWTEST_F() local
1452 Key key; HWTEST_F() local
1649 Key key; SnapshotUnRegisterObserver004Inner() local
1710 Key key; HWTEST_F() local
1888 Key key; HWTEST_F() local
[all...] |
| H A D | distributeddb_interfaces_single_version_result_set_test.cpp | 550 Key key; in HWTEST_F() local
|
| H A D | distributeddb_interfaces_space_management_test.cpp | 198 Key key; in HWTEST_F() local
252 Key key; in HWTEST_F() local
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | flat_object_storage_engine.cpp | 79 void FlatObjectStorageEngine::OnComplete(const std::string &key, in OnComplete() argument
92 uint32_t FlatObjectStorageEngine::CreateTable(const std::string &key) in CreateTable() argument
153 GetTable(const std::string &key, std::map<std::string, Value> &result) GetTable() argument
198 UpdateItem(const std::string &key, const std::string &itemKey, Value &value) UpdateItem() argument
219 UpdateItems( const std::string &key, const std::map<std::string, std::vector<uint8_t>> &data) UpdateItems() argument
247 DeleteTable(const std::string &key) DeleteTable() argument
269 GetItem(const std::string &key, const std::string &itemKey, Value &value) GetItem() argument
289 RegisterObserver(const std::string &key, std::shared_ptr<TableWatcher> watcher) RegisterObserver() argument
318 UnRegisterObserver(const std::string &key) UnRegisterObserver() argument
411 GetItems(const std::string &key, std::map<std::string, std::vector<uint8_t>> &data) GetItems() argument
455 std::string key = item.first; NotifyChange() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
| H A D | meta_data_test.cpp | 71 std::string key = appIdMetaData.GetKey();
in HWTEST_F() local
106 std::string key = corruptedMeta.GetKey();
in HWTEST_F() local
146 std::string key = secretKeyMeta.GetKey(fields); HWTEST_F() local
224 std::string key = storeMetaData.GetKey(); HWTEST_F() local
350 std::string key = storeMetaData.GetKey(); HWTEST_F() local
571 std::string key = strategyMeta.GetKey(); HWTEST_F() local
619 std::string key = strategyMeta.GetKey(); HWTEST_F() local
656 std::string key = metaData.storeMetaData.GetKey(); HWTEST_F() local
698 auto key = capMetaRow.GetKeyFor("PEER_DEVICE_ID"); HWTEST_F() local
742 auto key = userMetaRow.GetKeyFor(userMetaData.deviceId); HWTEST_F() local
794 std::string key = matrixMetaData3.GetConsistentKey(); HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | rdb_subscriber_manager.cpp | 31 bool TemplateManager::Get(const Key &key, int32_t userId, Template &tpl)
in Get() argument
36 int32_t TemplateManager::Add(const Key &key, int32_t userId, const Template &tpl)
in Add() argument
46 int32_t TemplateManager::Delete(const Key &key, int32_t userId)
in Delete() argument
114 Add(const Key &key, const sptr<IDataProxyRdbObserver> observer, std::shared_ptr<Context> context, std::shared_ptr<ExecutorPool> executorPool) Add() argument
143 Delete(const Key &key, uint32_t firstCallerTokenId) Delete() argument
186 Disable(const Key &key, uint32_t firstCallerTokenId) Disable() argument
202 Enable(const Key &key, std::shared_ptr<Context> context) Enable() argument
290 EmitByKey(const Key &key, int32_t userId, const std::string &rdbPath, int version) EmitByKey() argument
302 GetEnableObserverCount(const Key &key) GetEnableObserverCount() argument
317 Notify(const Key &key, int32_t userId, const std::vector<ObserverNode> &val, const std::string &rdbDir, int rdbVersion) Notify() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | udmf_run_time_store_test.cpp | 98 void UdmfRunTimeStoreTest::GetRandomKey(std::vector<uint8_t>& key, uint32_t defaultSize) in GetRandomKey() argument
127 Key key; in HWTEST_F() local
160 Key key; in HWTEST_F() local
193 Key key; HWTEST_F() local
224 Key key; HWTEST_F() local
262 Key key; HWTEST_F() local
342 Key key; HWTEST_F() local
400 Key key; HWTEST_F() local
432 Key key; HWTEST_F() local
462 Key key; HWTEST_F() local
498 Key key; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_single_kv_store.cpp | 74 std::string key; in Get() member
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/ |
| H A D | sqlite_store_executor_impl.cpp | 107 int SqliteStoreExecutorImpl::PutData(const std::string &collName, Key &key, const Value &value, bool isNeedAddKeyType) in PutData() argument
135 int SqliteStoreExecutorImpl::InsertData(const std::string &collName, Key &key, const Value &value, in InsertData() argument
164 int SqliteStoreExecutorImpl::GetDataByKey(const std::string &collName, Key &key, Valu argument
190 GetDataById(const std::string &collName, Key &key, Value &value) const GetDataById() argument
217 GeneralInsertSql(const std::string &collName, Key &key, int isIdExist) GeneralInsertSql() argument
239 GetDataByFilter(const std::string &collName, Key &key, const JsonObject &filterObj, std::pair<std::string, std::string> &values, int isIdExist) const GetDataByFilter() argument
290 DelData(const std::string &collName, Key &key) DelData() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/ |
| H A D | sqlite_local_kvdb_connection.cpp | 38 int SQLiteLocalKvDBConnection::Get(const IOption &option, const Key &key, Value &value) const in Get() argument
63 int SQLiteLocalKvDBConnection::Put(const IOption &option, const Key &key, const Value &value) in Put() argument
96 int SQLiteLocalKvDBConnection::Delete(const IOption &option, const Key &key) in Delete() argument
492 CheckDataStatus(const Key &key, const Value &value, bool isDeleted) const CheckDataStatus() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/nbdelegate_fuzzer/ |
| H A D | nbdelegate_fuzzer.cpp | 162 void TestCRUD(const Key &key, const Value &value, KvStoreNbDelegate *kvNbDelegatePtr) in TestCRUD() argument
222 Key key = std::vector<uint8_t>(data, data + (size % 1024)); /* 1024 is max */ FuzzCURD() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_cursor_impl.cpp | 191 auto key = std::string(str, valueLen); in GetData() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/waterversion/ |
| H A D | water_version_manager.cpp | 187 auto key = metaData.keys[i]; in InitMeta() local
250 std::pair<std::string, std::string> WaterVersionManager::Split(const std::string &key) in Split() argument
382 void WaterVersionManager::WaterVersion::AddKey(const std::string &key) in AddKey() argument
392 GenerateWaterVersion(const std::string &key) GenerateWaterVersion() argument
450 SetWaterVersion(const std::string &key, const WaterVersionMetaData &metaData) SetWaterVersion() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | kv_store_delegate_impl.cpp | 55 DBStatus KvStoreDelegateImpl::Put(const Key &key, const Value &value) in Put() argument
89 DBStatus KvStoreDelegateImpl::Delete(const Key &key) in Delete() argument
222 Key key; in RegisterObserver() local
|
| /foundation/distributeddatamgr/data_share/frameworks/native/common/include/ |
| H A D | callbacks_manager.h | 141 DelLocalObservers(const Key &key, void *subscriber, std::vector<Key> &lastDelKeys, std::vector<OperationResult> &result) DelLocalObservers() argument
329 GetAllSubscriberSize(const Key &key) GetAllSubscriberSize() argument
340 SetObserversNotifiedOnEnabled(const Key &key) SetObserversNotifiedOnEnabled() argument
[all...] |