Home
last modified time | relevance | path

Searched refs:DistributedKv (Results 1 - 25 of 408) sorted by relevance

12345678910>>...17

/foundation/ability/form_fwk/test/mock/include/
H A Dmock_single_kv_store.h29 class MockSingleKvStore : public DistributedKv::SingleKvStore {
35 DistributedKv::Status Get(const DistributedKv::Key &key, DistributedKv::Value &value) override
37 return DistributedKv::Status::SUCCESS;
40 DistributedKv::Status GetEntries(
41 const DistributedKv::Key &prefix, std::vector<DistributedKv::Entry> &entries) const override
46 DistributedKv::Status GetEntries(
47 const DistributedKv
[all...]
/foundation/ability/ability_runtime/test/mock/common/include/
H A Dmock_single_kv_store.h27 class MockSingleKvStore : public DistributedKv::SingleKvStore {
33 DistributedKv::Status Get(const DistributedKv::Key &key, DistributedKv::Value &value) override
35 return DistributedKv::Status::SUCCESS;
38 DistributedKv::Status GetEntries(
39 const DistributedKv::Key &prefix, std::vector<DistributedKv::Entry> &entries) const override
44 DistributedKv::Status GetEntries(
45 const DistributedKv
[all...]
/foundation/CastEngine/castengine_wifi_display/services/common/
H A Dkv_operator.cpp21 const OHOS::DistributedKv::AppId KVSTORE_APPID = {"com.ohos.sharing.codec"};
22 const OHOS::DistributedKv::StoreId KVSTORE_STOREID = {"media_sharingcodec"};
32 DistributedKv::Options options = { in OpenKvStore()
36 .area = DistributedKv::Area::EL1, in OpenKvStore()
37 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in OpenKvStore()
41 DistributedKv::AppId appId = { KVSTORE_APPID }; in OpenKvStore()
42 DistributedKv::StoreId storeId = { KVSTORE_STOREID }; in OpenKvStore()
44 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, appId, storeId, kvStorePtr_); in OpenKvStore()
45 if (status != DistributedKv::Status::SUCCESS) { in OpenKvStore()
71 DistributedKv in GetValues()
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/
H A Ddb_adapter.cpp47 const std::shared_ptr<DistributedKv::KvStoreObserver> changeListener) in DBAdapter()
60 DistributedKv::Status DBAdapter::GetKvStorePtr(bool isAutoSync, DistributedKv::DataType dataType) in GetKvStorePtr()
62 DistributedKv::Options options = { in GetKvStorePtr()
67 .securityLevel = DistributedKv::SecurityLevel::S1, in GetKvStorePtr()
68 .area = DistributedKv::EL1, in GetKvStorePtr()
69 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStorePtr()
77 if (dataType == DistributedKv::DataType::TYPE_DYNAMICAL) { in GetKvStorePtr()
85 DistributedKv::Status DBAdapter::GetLocalKvStorePtr() in GetLocalKvStorePtr()
87 DistributedKv in GetLocalKvStorePtr()
[all...]
/foundation/multimedia/media_library/frameworks/services/media_distributed/src/devices_info_interact/
H A Ddevices_info_interact.cpp36 DistributedKv::DistributedKvDataManager kvManager; in ~DevicesInfoInteract()
37 DistributedKv::AppId appId = { BUNDLE_NAME }; in ~DevicesInfoInteract()
52 DistributedKv::DistributedKvDataManager kvManager; in Init()
53 DistributedKv::Options options = { in Init()
58 .securityLevel = DistributedKv::SecurityLevel::NO_LABEL, in Init()
59 .area = DistributedKv::Area::EL2, in Init()
60 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in Init()
63 DistributedKv::AppId appId = { BUNDLE_NAME }; in Init()
64 DistributedKv::StoreId storeId = { ML_MULTIDEV_INFO_ID }; in Init()
65 DistributedKv in Init()
[all...]
/foundation/communication/dsoftbus/core/adapter/kv_store/src/
H A Dlnn_kv_adapter.cpp31 using namespace OHOS::DistributedKv;
59 DistributedKv::Status status = GetKvStorePtr(); in Init()
60 if (kvStorePtr_ && status == DistributedKv::Status::SUCCESS) { in Init()
66 if (status == DistributedKv::Status::SECURITY_LEVEL_ERROR) { in Init()
70 if (status == DistributedKv::Status::STORE_META_CHANGED) { in Init()
88 const std::shared_ptr<DistributedKv::KvStoreObserver> &dataChangeListener) in RegisterDataChangeListener()
106 DistributedKv::Status status = in RegisterDataChangeListener()
107 kvStorePtr_->SubscribeKvStore(DistributedKv::SubscribeType::SUBSCRIBE_TYPE_CLOUD, dataChangeListener_); in RegisterDataChangeListener()
108 if (status != DistributedKv::Status::SUCCESS) { in RegisterDataChangeListener()
129 DistributedKv in UnRegisterDataChangeListener()
[all...]
/foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/kvadapter/
H A Dkv_adapter.cpp31 using namespace OHOS::DistributedKv;
41 const std::shared_ptr<DistributedKv::KvStoreObserver> &dataChangeListener, in KVAdapter()
42 const std::shared_ptr<DistributedKv::KvStoreSyncCallback> &syncCompletedListener, in KVAdapter()
43 const std::shared_ptr<DistributedKv::KvStoreDeathRecipient> &deathListener, in KVAdapter()
44 DistributedKv::DataType dataType) in KVAdapter()
66 DistributedKv::Status status = GetKvStorePtr(dataType_); in Init()
67 if (status == DistributedKv::Status::SUCCESS) { in Init()
76 if (status == DistributedKv::Status::STORE_META_CHANGED) { in Init()
80 if (status == DistributedKv::Status::SECURITY_LEVEL_ERROR) { in Init()
108 DistributedKv in Put()
[all...]
H A Dswitch_adapter.cpp50 DistributedKv::AppId appID; in PutSwitch()
52 const DistributedKv::SwitchData switchData = {value, length}; in PutSwitch()
53 DistributedKv::Status res = kvDataMgr_.PutSwitch(appID, switchData); in PutSwitch()
54 if (res != DistributedKv::Status::SUCCESS) { in PutSwitch()
69 DistributedKv::AppId appID; in GetSwitch()
72 if (res.first != DistributedKv::Status::SUCCESS) { in GetSwitch()
89 DistributedKv::AppId appID; in SubscribeSwitchData()
97 if (res != DistributedKv::Status::SUCCESS) { in SubscribeSwitchData()
112 DistributedKv::AppId appID; in UnsubscribeSwitchData()
116 if (res != DistributedKv in UnsubscribeSwitchData()
[all...]
/foundation/distributedhardware/device_manager/utils/src/kvadapter/
H A Dkv_adapter.cpp32 using namespace OHOS::DistributedKv;
56 DistributedKv::Status status = GetLocalKvStorePtr(); in Init()
57 if (status == DistributedKv::Status::SUCCESS && kvStorePtr_) { in Init()
64 if (status == DistributedKv::Status::STORE_META_CHANGED || in Init()
65 status == DistributedKv::Status::SECURITY_LEVEL_ERROR || in Init()
66 status == DistributedKv::Status::DATA_CORRUPTED) { in Init()
103 DistributedKv::Status status; in Put()
108 DistributedKv::Key kvKey(key); in Put()
109 DistributedKv::Value kvValue(value); in Put()
112 if (status != DistributedKv in Put()
[all...]
/foundation/ability/ability_runtime/services/appmgr/src/
H A Dapp_config_data_manager.cpp31 const DistributedKv::AppId AppConfigDataManager::APP_ID = { "app_config_data_storage" };
32 const DistributedKv::StoreId AppConfigDataManager::STORE_ID = { "app_config_data_infos" };
42 DistributedKv::Status AppConfigDataManager::GetKvStore() in GetKvStore()
44 DistributedKv::Options options = { in GetKvStore()
49 .securityLevel = DistributedKv::SecurityLevel::S2, in GetKvStore()
50 .area = DistributedKv::EL1, in GetKvStore()
51 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStore()
55 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, APP_ID, STORE_ID, kvStorePtr_); in GetKvStore()
56 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
72 DistributedKv in CheckKvStore()
[all...]
/foundation/ability/ability_runtime/services/abilitymgr/include/
H A Dability_auto_startup_data_manager.h51 DistributedKv::Status GetKvStore();
53 DistributedKv::Value ConvertAutoStartupStatusToValue(
55 void ConvertAutoStartupStatusFromValue(const DistributedKv::Value &value, bool &isAutoStartup, bool &isEdmForce);
56 DistributedKv::Key ConvertAutoStartupDataToKey(const AutoStartupInfo &info);
58 const DistributedKv::Key &key, const DistributedKv::Value &value);
62 bool IsEqual(const DistributedKv::Key &key, const AutoStartupInfo &info);
63 bool IsEqual(const DistributedKv::Key &key, const std::string &accessTokenId);
64 bool IsEqual(const DistributedKv::Key &key, int32_t userId);
66 static const DistributedKv
[all...]
H A Dapp_exit_reason_data_manager.h63 DistributedKv::Status GetKvStore();
65 DistributedKv::Value ConvertAppExitReasonInfoToValue(
67 void ConvertAppExitReasonInfoFromValue(const DistributedKv::Value &value, AAFwk::ExitReason &exitReason,
75 DistributedKv::Value ConvertAbilityRecoverInfoToValue(
78 const DistributedKv::Value &value, std::vector<std::string> &recoverInfoList, std::vector<int> &sessionIdList);
80 DistributedKv::Key GetAbilityRecoverInfoKey(uint32_t accessTokenId);
81 DistributedKv::Value ConvertAppExitReasonInfoToValueOfExtensionName(
84 const DistributedKv::AppId appId_ { "app_exit_reason_storage" };
85 const DistributedKv::StoreId storeId_ { "app_exit_reason_infos" };
86 DistributedKv
[all...]
/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) const;
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> &resultStatusSignal) const;
110 DistributedKv::AppId appId_;
111 DistributedKv::StoreId storeId_;
112 DistributedKv
[all...]
H A Ddsched_sync_e2e.h26 using namespace DistributedKv;
28 class DmsKvSyncCB : public OHOS::DistributedKv::KvStoreSyncCallback {
32 void SyncCompleted(const std::map<std::string, DistributedKv::Status> &result) override;
51 void TryTwice(const std::function<DistributedKv::Status()> &func) const;
53 DistributedKv::Status GetKvStore();
60 const DistributedKv::AppId appId_ {DMS_BM_APP_ID};
61 const DistributedKv::StoreId storeId_ {DISTRIBUTE_BM_STORE_ID};
62 DistributedKv::DistributedKvDataManager dataManager_;
63 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_;
/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Dapp_exit_reason_data_manager.cpp48 DistributedKv::Status AppExitReasonDataManager::GetKvStore() in GetKvStore()
50 DistributedKv::Options options = { .createIfMissing = true, in GetKvStore()
54 .securityLevel = DistributedKv::SecurityLevel::S2, in GetKvStore()
55 .area = DistributedKv::EL1, in GetKvStore()
56 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStore()
59 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStore()
60 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
76 DistributedKv::Status status = GetKvStore(); in CheckKvStore()
77 if (status == DistributedKv::Status::SUCCESS && kvStorePtr_ != nullptr) { in CheckKvStore()
105 DistributedKv in SetAppExitReason()
[all...]
H A Dability_auto_startup_data_manager.cpp40 const DistributedKv::AppId AbilityAutoStartupDataManager::APP_ID = { "auto_startup_storage" };
41 const DistributedKv::StoreId AbilityAutoStartupDataManager::STORE_ID = { "auto_startup_infos" };
51 DistributedKv::Status AbilityAutoStartupDataManager::GetKvStore() in GetKvStore()
53 DistributedKv::Options options = { .createIfMissing = true, in GetKvStore()
57 .securityLevel = DistributedKv::SecurityLevel::S2, in GetKvStore()
58 .area = DistributedKv::EL1, in GetKvStore()
59 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStore()
62 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, APP_ID, STORE_ID, kvStorePtr_); in GetKvStore()
63 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
79 DistributedKv in CheckKvStore()
[all...]
/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> &keys);
46 void FilterEntries(const std::vector<DistributedKv::Entry>& records,
/foundation/deviceprofile/device_info_manager/services/core/include/persistenceadapter/kvadapter/
H A Dkv_adapter.h38 const std::shared_ptr<DistributedKv::KvStoreObserver> &dataChangeListener,
39 const std::shared_ptr<DistributedKv::KvStoreSyncCallback> &syncCompletedListener,
40 const std::shared_ptr<DistributedKv::KvStoreDeathRecipient> &deathListener,
41 DistributedKv::DataType dataType);
59 DistributedKv::Status GetKvStorePtr(DistributedKv::DataType dataType);
72 DistributedKv::AppId appId_;
73 DistributedKv::StoreId storeId_;
74 DistributedKv::DistributedKvDataManager kvDataMgr_;
75 DistributedKv
[all...]
/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);
55 std::vector<DistributedKv::Entry> GetEntriesByKeys(const std::vector<std::string> &keys);
65 DistributedKv::Status GetKvStorePtr(bool isAutoSync, DistributedKv::DataType dataType);
67 DistributedKv::Status GetLocalKvStorePtr();
73 DistributedKv::AppId appId_;
74 DistributedKv::StoreId storeId_;
75 DistributedKv
[all...]
/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;
30 using ChangeNotification = DistributedKv::ChangeNotification;
31 using Options = DistributedKv::Options;
32 using SyncPolicy = DistributedKv
[all...]
/foundation/communication/dsoftbus/core/adapter/kv_store/include/
H A Dlnn_kv_adapter.h42 int32_t RegisterDataChangeListener(const std::shared_ptr<DistributedKv::KvStoreObserver> &dataChangeListener);
44 static void CloudSyncCallback(DistributedKv::ProgressDetail &&detail);
47 DistributedKv::Status GetKvStorePtr();
53 DistributedKv::AppId appId_;
54 DistributedKv::StoreId storeId_;
55 DistributedKv::DistributedKvDataManager kvDataMgr_;
56 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_ = nullptr;
57 std::shared_ptr<DistributedKv::KvStoreObserver> dataChangeListener_ = nullptr;
/foundation/distributedhardware/device_manager/utils/include/kvadapter/
H A Dkv_adapter.h34 class KVAdapter : public DistributedKv::KvStoreDeathRecipient, public std::enable_shared_from_this<KVAdapter> {
49 DistributedKv::Status GetLocalKvStorePtr();
54 DistributedKv::AppId appId_;
55 DistributedKv::StoreId storeId_;
56 DistributedKv::DistributedKvDataManager kvDataMgr_;
57 DistributedKv::DataType dataType_ = DistributedKv::DataType::TYPE_STATICS;
58 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_ = nullptr;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/
H A Dstore_account_observer.cpp27 using namespace DistributedKv;
29 void RuntimeStoreAccountObserver::OnAccountChanged(const DistributedKv::AccountEventInfo &eventInfo) in OnAccountChanged()
32 if (eventInfo.status == DistributedKv::AccountStatus::DEVICE_ACCOUNT_DELETE) { in OnAccountChanged()
39 metaData.securityLevel = DistributedKv::SecurityLevel::S1; in OnAccountChanged()
40 metaData.area = DistributedKv::Area::EL1; in OnAccountChanged()
41 metaData.storeType = DistributedKv::KvStoreType::SINGLE_VERSION; in OnAccountChanged()
/foundation/bundlemanager/distributed_bundle_framework/services/dbms/include/
H A Ddistributed_data_storage.h36 class DistributedDataStorageCallback : public OHOS::DistributedKv::KvStoreSyncCallback {
40 void SyncCompleted(const std::map<std::string, DistributedKv::Status> &result) override;
42 DistributedKv::Status GetResultCode();
44 std::promise<OHOS::DistributedKv::Status> resultStatusSignal_;
67 void TryTwice(const std::function<DistributedKv::Status()> &func) const;
69 DistributedKv::Status GetKvStore();
82 const DistributedKv::AppId appId_ {APP_ID};
83 const DistributedKv::StoreId storeId_ {DISTRIBUTE_DATA_STORE_ID};
84 DistributedKv::DistributedKvDataManager dataManager_;
85 std::shared_ptr<DistributedKv
[all...]
/foundation/deviceprofile/device_info_manager/old/services/core/include/dbstorage/
H A Ddevice_profile_storage.h54 virtual int32_t RegisterSyncCallback(const std::shared_ptr<DistributedKv::KvStoreSyncCallback>& sycnCb);
57 void SetOptions(const DistributedKv::Options& options);
60 int32_t SubscribeKvStore(const std::shared_ptr<DistributedKv::KvStoreObserver>& observer);
61 int32_t UnSubscribeKvStore(const std::shared_ptr<DistributedKv::KvStoreObserver>& observer);
66 DistributedKv::Status GetKvStore();
74 DistributedKv::Options options_;
75 DistributedKv::AppId appId_;
76 DistributedKv::StoreId storeId_;
77 DistributedKv::DistributedKvDataManager dataManager_;
79 std::shared_ptr<DistributedKv
[all...]

Completed in 9 milliseconds

12345678910>>...17