Home
last modified time | relevance | path

Searched refs:DistributedKv (Results 1 – 25 of 464) sorted by relevance

12345678910>>...19

/ohos5.0/foundation/ability/form_fwk/test/mock/include/
H A Dmock_single_kv_store.h35 DistributedKv::Status Get(const DistributedKv::Key &key, DistributedKv::Value &value) override in Get()
85 DistributedKv::Status Sync( in Sync()
91 DistributedKv::Status Sync( in Sync()
108 DistributedKv::Status SetSyncParam(const DistributedKv::KvSyncParam &syncParam) override in SetSyncParam()
113 DistributedKv::Status GetSyncParam(DistributedKv::KvSyncParam &syncParam) override in GetSyncParam()
148 …DistributedKv::Status Put(const DistributedKv::Key &key, const DistributedKv::Value &value) overri… in Put()
158 DistributedKv::Status Delete(const DistributedKv::Key &key) override in Delete()
163 DistributedKv::Status DeleteBatch(const std::vector<DistributedKv::Key> &keys) override in DeleteBatch()
210 DistributedKv::Status GetEntries_ = DistributedKv::Status::SUCCESS;
211 DistributedKv::Status Delete_ = DistributedKv::Status::SUCCESS;
[all …]
/ohos5.0/foundation/ability/ability_runtime/test/mock/common/include/
H A Dmock_single_kv_store.h33 DistributedKv::Status Get(const DistributedKv::Key &key, DistributedKv::Value &value) override in Get()
56 DistributedKv::Status GetResultSet(const DistributedKv::DataQuery &query, in GetResultSet()
82 DistributedKv::Status Sync( in Sync()
105 DistributedKv::Status SetSyncParam(const DistributedKv::KvSyncParam &syncParam) override in SetSyncParam()
110 DistributedKv::Status GetSyncParam(DistributedKv::KvSyncParam &syncParam) override in GetSyncParam()
151 …DistributedKv::Status Put(const DistributedKv::Key &key, const DistributedKv::Value &value) overri… in Put()
161 DistributedKv::Status Delete(const DistributedKv::Key &key) override in Delete()
166 DistributedKv::Status DeleteBatch(const std::vector<DistributedKv::Key> &keys) override in DeleteBatch()
213 DistributedKv::Status GetEntries_ = DistributedKv::Status::SUCCESS;
214 DistributedKv::Status Delete_ = DistributedKv::Status::SUCCESS;
[all …]
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/
H A Ddb_adapter.cpp60 DistributedKv::Status DBAdapter::GetKvStorePtr(bool isAutoSync, DistributedKv::DataType dataType) in GetKvStorePtr()
62 DistributedKv::Options options = { in GetKvStorePtr()
68 .area = DistributedKv::EL1, in GetKvStorePtr()
87 DistributedKv::Options options = { in GetLocalKvStorePtr()
92 .area = DistributedKv::EL1, in GetLocalKvStorePtr()
252 DistributedKv::Key kvKey(key); in GetDataByKey()
253 DistributedKv::Value kvValue; in GetDataByKey()
320 DistributedKv::Key kvKey(key); in PutData()
346 DistributedKv::Entry entry; in PutDataBatch()
512 DistributedKv::Key kvKey(key); in RemoveDataByKey()
[all …]
/ohos5.0/base/notification/distributed_notification_service/services/distributed/src/
H A Ddistributed_preferences_database.cpp60 DistributedKv::Options options = { in GetKvStore()
64 .area = DistributedKv::EL1, in GetKvStore()
68 DistributedKv::AppId appId = {.appId = APP_ID}; in GetKvStore()
71 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
104 DistributedKv::Key kvStoreKey(key); in PutToDistributedDB()
105 DistributedKv::Value kvStoreValue(value); in PutToDistributedDB()
126 DistributedKv::Key kvStoreKey(key); in GetFromDistributedDB()
127 DistributedKv::Value kvStoreValue; in GetFromDistributedDB()
148 DistributedKv::Key kvStoreKey(prefixKey); in GetEntriesFromDistributedDB()
168 DistributedKv::Key kvStoreKey(key); in DeleteToDistributedDB()
[all …]
H A Ddistributed_database.cpp88 DistributedKv::Options options { in GetKvStore()
93 .area = DistributedKv::EL1, in GetKvStore()
97 DistributedKv::AppId appId = {.appId = APP_ID}; in GetKvStore()
100 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
151 DistributedKv::Key kvStoreKey(key); in PutToDistributedDB()
152 DistributedKv::Value kvStoreValue(value); in PutToDistributedDB()
154 if (status != DistributedKv::Status::SUCCESS) { in PutToDistributedDB()
176 DistributedKv::Key kvStoreKey(key); in GetFromDistributedDB()
177 DistributedKv::Value kvStoreValue; in GetFromDistributedDB()
203 DistributedKv::Key kvStoreKey(prefixKey); in GetEntriesFromDistributedDB()
[all …]
H A Ddistributed_screen_status_manager.cpp76 DistributedKv::AppId appId = {.appId = APP_ID}; in OnDeviceDisconnected()
77 DistributedKv::StoreId storeId = {.storeId = STORE_ID}; in OnDeviceDisconnected()
134 DistributedKv::Options options = { in GetKvStore()
137 .securityLevel = DistributedKv::SecurityLevel::S1, in GetKvStore()
138 .area = DistributedKv::EL1, in GetKvStore()
142 DistributedKv::AppId appId = {.appId = APP_ID}; in GetKvStore()
145 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
193 DistributedKv::Key prefixKey(""); in CheckRemoteDevicesIsUsing()
194 std::vector<DistributedKv::Entry> entries; in CheckRemoteDevicesIsUsing()
196 if (status != DistributedKv::Status::SUCCESS) { in CheckRemoteDevicesIsUsing()
[all …]
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/kvadapter/
H A Dkv_adapter.cpp31 using namespace OHOS::DistributedKv;
108 DistributedKv::Status status; in Put()
117 DistributedKv::Value oldV; in Put()
141 DistributedKv::Status status; in PutBatch()
149 DistributedKv::Value oldV; in PutBatch()
150 DistributedKv::Key kvKey; in PutBatch()
180 DistributedKv::Status status; in Delete()
202 DistributedKv::Value kvValue; in Get()
203 DistributedKv::Status status; in Get()
273 DistributedKv::Status KVAdapter::GetKvStorePtr(DistributedKv::DataType dataType) in GetKvStorePtr()
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/adapter/kv_store/src/
H A Dlnn_kv_adapter.cpp30 using namespace OHOS::DistributedKv;
154 DistributedKv::Status status; in Put()
162 DistributedKv::Value oldV; in Put()
184 DistributedKv::Status status; in PutBatch()
192 DistributedKv::Value oldV; in PutBatch()
193 DistributedKv::Key kvKey; in PutBatch()
220 DistributedKv::Status status; in Delete()
278 DistributedKv::Value kvValue; in Get()
279 DistributedKv::Status status; in Get()
313 DistributedKv::Status status; in GetKvStorePtr()
[all …]
/ohos5.0/base/account/os_account/services/accountmgr/src/
H A Daccount_data_storage.cpp59 OHOS::DistributedKv::Options options = { in GetKvStore()
86 OHOS::DistributedKv::Status status = OHOS::DistributedKv::Status::SUCCESS; in CheckKvStore()
111 OHOS::DistributedKv::Status status = DistributedKv::Status::SUCCESS; in LoadAllData()
164 OHOS::DistributedKv::Key key(keyStr); in RemoveValueFromKvStore()
165 OHOS::DistributedKv::Status status; in RemoveValueFromKvStore()
166 OHOS::DistributedKv::Value value; in RemoveValueFromKvStore()
214 OHOS::DistributedKv::Status status; in DeleteKvStore()
254 OHOS::DistributedKv::Status status = OHOS::DistributedKv::Status::SUCCESS; in LoadDataByLocalFuzzyQuery()
279 OHOS::DistributedKv::Status status; in PutValueToKvStore()
305 OHOS::DistributedKv::Value value; in GetValueFromKvStore()
[all …]
/ohos5.0/base/security/dlp_permission_service/services/dlp_permission/sa/storage/src/
H A Ddlp_kv_data_storage.cpp67 OHOS::DistributedKv::Status status = DistributedKv::Status::SUCCESS; in LoadAllData()
109 OHOS::DistributedKv::Status status = OHOS::DistributedKv::Status::SUCCESS; in CheckKvStore()
137 OHOS::DistributedKv::Key key(keyStr); in RemoveValueFromKvStore()
138 OHOS::DistributedKv::Status status; in RemoveValueFromKvStore()
139 OHOS::DistributedKv::Value value; in RemoveValueFromKvStore()
174 OHOS::DistributedKv::Status status; in DeleteKvStore()
195 OHOS::DistributedKv::Key key(keyStr); in PutValueToKvStore()
197 OHOS::DistributedKv::Status status; in PutValueToKvStore()
219 OHOS::DistributedKv::Key key(keyStr); in GetValueFromKvStore()
220 OHOS::DistributedKv::Value value; in GetValueFromKvStore()
[all …]
/ohos5.0/foundation/multimedia/media_library/frameworks/services/media_distributed/src/devices_info_interact/
H A Ddevices_info_interact.cpp37 DistributedKv::AppId appId = { BUNDLE_NAME }; in ~DevicesInfoInteract()
53 DistributedKv::Options options = { in Init()
59 .area = DistributedKv::Area::EL2, in Init()
63 DistributedKv::AppId appId = { BUNDLE_NAME }; in Init()
66 if (status != DistributedKv::Status::SUCCESS) { in Init()
86 DistributedKv::DataQuery dataQuery; in SyncMLDeviceInfos()
89 DistributedKv::Status status = kvStorePtr_->Sync(devices, DistributedKv::SyncMode::PULL, in SyncMLDeviceInfos()
103 DistributedKv::Key k(key); in GetMLDeviceInfos()
104 DistributedKv::Value v; in GetMLDeviceInfos()
136 DistributedKv::Key k(key); in PutMLDeviceInfos()
[all …]
/ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Dapp_exit_reason_data_manager.cpp53 .area = DistributedKv::EL1, in GetKvStore()
105 DistributedKv::Status status; in SetAppExitReason()
234 DistributedKv::Status status; in UpdateAppExitReason()
306 DistributedKv::Status status; in InnerDeleteAppExitReason()
332 DistributedKv::Value value; in AddAbilityRecoverInfo()
334 … if (status != DistributedKv::Status::SUCCESS && status != DistributedKv::Status::KEY_NOT_FOUND) { in AddAbilityRecoverInfo()
398 DistributedKv::Value value; in DeleteAbilityRecoverInfo()
442 DistributedKv::Value value; in GetAbilityRecoverInfo()
480 DistributedKv::Value value; in GetAbilitySessionId()
581 DistributedKv::Status status; in UpdateAbilityRecoverInfo()
[all …]
H A Dability_auto_startup_data_manager.cpp51 DistributedKv::Status AbilityAutoStartupDataManager::RestoreKvStore(DistributedKv::Status status) in RestoreKvStore()
59 .area = DistributedKv::EL1, in RestoreKvStore()
78 .area = DistributedKv::EL1, in GetKvStore()
134 DistributedKv::Status status; in InsertAutoStartupData()
173 DistributedKv::Status status; in UpdateAutoStartupData()
224 DistributedKv::Status status; in DeleteAutoStartupData()
260 DistributedKv::Status status = DistributedKv::Status::SUCCESS; in DeleteAutoStartupData()
318 DistributedKv::Status status = DistributedKv::Status::SUCCESS; in QueryAutoStartupData()
357 DistributedKv::Status status = DistributedKv::Status::SUCCESS; in QueryAllAutoStartupApplications()
398 DistributedKv::Status status = DistributedKv::Status::SUCCESS; in GetCurrentAppAutoStartupData()
[all …]
/ohos5.0/foundation/ability/ability_runtime/services/appmgr/src/
H A Dapp_config_data_manager.cpp44 DistributedKv::Options options = { in GetKvStore()
50 .area = DistributedKv::EL1, in GetKvStore()
56 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
72 DistributedKv::Status status = GetKvStore(); in CheckKvStore()
98 DistributedKv::Key key(KEY_WAITING_DEBUG_INFO); in SetAppWaitingDebugInfo()
99 DistributedKv::Value value(bundleName); in SetAppWaitingDebugInfo()
100 DistributedKv::Status status; in SetAppWaitingDebugInfo()
106 if (status != DistributedKv::Status::SUCCESS) { in SetAppWaitingDebugInfo()
125 DistributedKv::Status status; in ClearAppWaitingDebugInfo()
149 DistributedKv::Status status; in GetAppWaitingDebugList()
[all …]
/ohos5.0/foundation/distributedhardware/device_manager/utils/src/kvadapter/
H A Dkv_adapter.cpp32 using namespace OHOS::DistributedKv;
103 DistributedKv::Status status; in Put()
108 DistributedKv::Key kvKey(key); in Put()
109 DistributedKv::Value kvValue(value); in Put()
122 DistributedKv::Key kvKey(key); in Get()
123 DistributedKv::Value kvValue; in Get()
124 DistributedKv::Status status; in Get()
150 DistributedKv::Options options = { in GetLocalKvStorePtr()
155 .area = DistributedKv::EL1, in GetLocalKvStorePtr()
222 std::vector<DistributedKv::Key> delKeys; in DeleteBatch()
[all …]
/ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/include/
H A Dability_auto_startup_data_manager.h51 DistributedKv::Status RestoreKvStore(DistributedKv::Status status);
52 DistributedKv::Status GetKvStore();
54 DistributedKv::Value ConvertAutoStartupStatusToValue(
57 DistributedKv::Key ConvertAutoStartupDataToKey(const AutoStartupInfo &info);
59 const DistributedKv::Key &key, const DistributedKv::Value &value);
63 bool IsEqual(const DistributedKv::Key &key, const AutoStartupInfo &info);
65 bool IsEqual(const DistributedKv::Key &key, int32_t userId);
67 static const DistributedKv::AppId APP_ID;
68 static const DistributedKv::StoreId STORE_ID;
69 DistributedKv::DistributedKvDataManager dataManager_;
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dkv_types_util.h23 using Blob = DistributedKv::Blob;
24 using Key = DistributedKv::Key;
25 using Value = DistributedKv::Value;
26 using Entry = DistributedKv::Entry;
27 using AppId = DistributedKv::AppId;
28 using StoreId = DistributedKv::StoreId;
29 using DeviceInfo = DistributedKv::DeviceInfo;
31 using Options = DistributedKv::Options;
32 using SyncPolicy = DistributedKv::SyncPolicy;
34 using Statistic = DistributedKv::Statistic;
[all …]
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/resourcemanager/
H A Ddb_adapter.h34 public DistributedKv::KvStoreDeathRecipient {
37 const std::shared_ptr<DistributedKv::KvStoreObserver> changeListener);
41 int32_t Init(bool isAutoSync, DistributedKv::DataType dataType);
64 DistributedKv::Status GetKvStorePtr(bool isAutoSync, DistributedKv::DataType dataType);
66 DistributedKv::Status GetLocalKvStorePtr();
72 DistributedKv::AppId appId_;
73 DistributedKv::StoreId storeId_;
74 DistributedKv::DistributedKvDataManager kvDataMgr_;
75 std::shared_ptr<DistributedKv::SingleKvStore> kvStoragePtr_;
76 std::shared_ptr<DistributedKv::KvStoreObserver> dataChangeListener_;
[all …]
/ohos5.0/base/security/dlp_permission_service/services/dlp_permission/sa/storage/include/
H A Ddlp_kv_data_storage.h28 DistributedKv::SecurityLevel securityLevel = DistributedKv::SecurityLevel::S1;
29 OHOS::DistributedKv::Area area = OHOS::DistributedKv::EL1;
38 void TryTwice(const std::function<DistributedKv::Status()> &func) const;
46 virtual void SaveEntries(const std::vector<OHOS::DistributedKv::Entry> &allEntries,
50 OHOS::DistributedKv::Status GetEntries(
51 std::string subId, std::vector<OHOS::DistributedKv::Entry> &allEntries) const;
52 OHOS::DistributedKv::Status GetKvStore();
54 OHOS::DistributedKv::DistributedKvDataManager dataManager_;
55 std::shared_ptr<OHOS::DistributedKv::SingleKvStore> kvStorePtr_;
57 OHOS::DistributedKv::AppId appId_;
[all …]
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/include/persistenceadapter/kvadapter/
H A Dkv_adapter.h38 const std::shared_ptr<DistributedKv::KvStoreObserver> &dataChangeListener,
40 const std::shared_ptr<DistributedKv::KvStoreDeathRecipient> &deathListener,
41 DistributedKv::DataType dataType);
58 DistributedKv::Status GetKvStorePtr(DistributedKv::DataType dataType);
71 DistributedKv::AppId appId_;
72 DistributedKv::StoreId storeId_;
73 DistributedKv::DistributedKvDataManager kvDataMgr_;
74 DistributedKv::DataType dataType_;
75 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_ = nullptr;
76 std::shared_ptr<DistributedKv::KvStoreObserver> dataChangeListener_ = nullptr;
[all …]
/ohos5.0/base/notification/common_event_service/services/src/
H A Dstatic_subscriber_data_manager.cpp41 DistributedKv::Status StaticSubscriberDataManager::GetKvStore() in GetKvStore()
43 DistributedKv::Options options = { in GetKvStore()
48 .securityLevel = DistributedKv::SecurityLevel::S1, in GetKvStore()
49 .area = DistributedKv::EL1, in GetKvStore()
50 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStore()
55 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
68 DistributedKv::Status status = GetKvStore(); in CheckKvStore()
97 DistributedKv::Key key(disableEventsDatabaseIt.first); in UpdateStaticSubscriberState()
107 DistributedKv::Key key(disableEventsIt.first); in UpdateStaticSubscriberState()
132 std::vector<DistributedKv::Entry> allEntries; in QueryStaticSubscriberStateData()
[all …]
/ohos5.0/base/account/os_account/services/accountmgr/include/
H A Daccount_data_storage.h31 DistributedKv::SecurityLevel securityLevel = DistributedKv::SecurityLevel::S1;
32 OHOS::DistributedKv::Area area = OHOS::DistributedKv::EL1;
45 void TryTwice(const std::function<DistributedKv::Status()> &func) const;
46 virtual void SaveEntries(std::vector<OHOS::DistributedKv::Entry> allEntries,
57 OHOS::DistributedKv::Status GetEntries(
58 std::string subId, std::vector<OHOS::DistributedKv::Entry> &allEntries) const;
59 OHOS::DistributedKv::Status GetKvStore();
61 OHOS::DistributedKv::DistributedKvDataManager dataManager_;
62 std::shared_ptr<OHOS::DistributedKv::SingleKvStore> kvStorePtr_;
64 OHOS::DistributedKv::AppId appId_;
[all …]
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/
H A Ddistributed_data_storage.h88 bool Query(const std::string& networkId, int32_t missionId, DistributedKv::Value& value) const;
97 DistributedKv::Status GetKvStore();
103 …bool QueryInnerLocked(const std::string& networkId, int32_t missionId, DistributedKv::Value& value…
104 static void GenerateKey(const std::string& uuid, int32_t missionId, DistributedKv::Key& key);
105 static void GenerateValue(const uint8_t* byteStream, size_t len, DistributedKv::Value& value);
106 …OHOS::DistributedKv::Status GetResultSatus(std::promise<OHOS::DistributedKv::Status> &resultStatus…
110 DistributedKv::AppId appId_;
111 DistributedKv::StoreId storeId_;
112 DistributedKv::DistributedKvDataManager dataManager_;
113 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_; // protected by initLock_
H A Ddsched_sync_e2e.h26 using namespace DistributedKv; variable
28 class DmsKvSyncCB : public OHOS::DistributedKv::KvStoreSyncCallback {
32 void SyncCompleted(const std::map<std::string, DistributedKv::Status> &result) override;
49 void TryTwice(const std::function<DistributedKv::Status()> &func) const;
51 DistributedKv::Status GetKvStore();
55 const DistributedKv::AppId appId_ {DMS_BM_APP_ID};
56 const DistributedKv::StoreId storeId_ {DISTRIBUTE_BM_STORE_ID};
57 DistributedKv::DistributedKvDataManager dataManager_;
58 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_;
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/include/deviceprofilemanager/listener/
H A Dkv_data_change_listener.h28 class KvDataChangeListener : public DistributedKv::KvStoreObserver {
33 void OnChange(const DistributedKv::ChangeNotification& changeNotification) override;
34 void OnChange(const DistributedKv::DataOrigin& origin, Keys&& keys) override;
35 void OnSwitchChange(const DistributedKv::SwitchNotification &notification) override;
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> &…
46 void FilterEntries(const std::vector<DistributedKv::Entry>& records,

12345678910>>...19