Home
last modified time | relevance | path

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

123

/base/notification/distributed_notification_service/services/distributed/src/
H A Ddistributed_preferences_database.cpp38 kvDataManager_ = std::make_unique<DistributedKv::DistributedKvDataManager>(); in GetKvDataManager()
60 DistributedKv::Options options = { in GetKvStore()
63 .securityLevel = DistributedKv::SecurityLevel::S1, in GetKvStore()
64 .area = DistributedKv::EL1, in GetKvStore()
65 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStore()
68 DistributedKv::AppId appId = {.appId = APP_ID}; in GetKvStore()
69 DistributedKv::StoreId storeId = {.storeId = STORE_ID}; in GetKvStore()
70 DistributedKv::Status status = kvDataManager_->GetSingleKvStore(options, appId, storeId, kvStore_); in GetKvStore()
71 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
104 DistributedKv in PutToDistributedDB()
[all...]
H A Ddistributed_database.cpp54 kvDataManager_ = std::make_unique<DistributedKv::DistributedKvDataManager>(); in GetKvDataManager()
88 DistributedKv::Options options { in GetKvStore()
92 .securityLevel = DistributedKv::SecurityLevel::S1, in GetKvStore()
93 .area = DistributedKv::EL1, in GetKvStore()
94 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStore()
97 DistributedKv::AppId appId = {.appId = APP_ID}; in GetKvStore()
98 DistributedKv::StoreId storeId = {.storeId = STORE_ID}; in GetKvStore()
99 DistributedKv::Status status = kvDataManager_->GetSingleKvStore(options, appId, storeId, kvStore_); in GetKvStore()
100 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
109 status = kvStore_->SubscribeKvStore(DistributedKv in GetKvStore()
[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()
101 kvDataManager_ = std::make_unique<DistributedKv::DistributedKvDataManager>(); in GetKvDataManager()
134 DistributedKv::Options options = { in GetKvStore()
137 .securityLevel = DistributedKv::SecurityLevel::S1, in GetKvStore()
138 .area = DistributedKv::EL1, in GetKvStore()
139 .kvStoreType = DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStore()
142 DistributedKv::AppId appId = {.appId = APP_ID}; in GetKvStore()
143 DistributedKv::StoreId storeId = {.storeId = STORE_ID}; in GetKvStore()
144 DistributedKv in GetKvStore()
[all...]
H A Ddistributed_database_callback.cpp28 void DistributedDatabaseCallback::OnChange(const DistributedKv::ChangeNotification &changeNotification) in OnChange()
33 const std::vector<DistributedKv::Entry> &entryList = changeNotification.GetInsertEntries(); in OnChange()
41 const std::vector<DistributedKv::Entry> &entryList = changeNotification.GetUpdateEntries(); in OnChange()
49 const std::vector<DistributedKv::Entry> &entryList = changeNotification.GetDeleteEntries(); in OnChange()
/base/security/dlp_permission_service/services/dlp_permission/sa/storage/src/
H A Ddlp_kv_data_storage.cpp37 if (options_.area == DistributedKv::EL1) { in DlpKvDataStorage()
51 void DlpKvDataStorage::TryTwice(const std::function<DistributedKv::Status()> &func) const in TryTwice()
53 OHOS::DistributedKv::Status status = func(); in TryTwice()
54 if (status == OHOS::DistributedKv::Status::IPC_ERROR) { in TryTwice()
67 OHOS::DistributedKv::Status status = DistributedKv::Status::SUCCESS; in LoadAllData()
68 std::vector<OHOS::DistributedKv::Entry> allEntries; in LoadAllData()
73 if (status != OHOS::DistributedKv::Status::SUCCESS) { in LoadAllData()
82 OHOS::DistributedKv::Status DlpKvDataStorage::GetKvStore() in GetKvStore()
84 OHOS::DistributedKv in GetKvStore()
[all...]
/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
[all...]
/base/account/os_account/services/accountmgr/src/
H A Daccount_data_storage.cpp34 if (options_.area == DistributedKv::EL1) { in AccountDataStorage()
48 void AccountDataStorage::TryTwice(const std::function<DistributedKv::Status()> &func) const in TryTwice()
50 OHOS::DistributedKv::Status status = func(); in TryTwice()
51 if (status == OHOS::DistributedKv::Status::IPC_ERROR) { in TryTwice()
57 OHOS::DistributedKv::Status AccountDataStorage::GetKvStore() in GetKvStore()
59 OHOS::DistributedKv::Options options = { in GetKvStore()
66 .kvStoreType = OHOS::DistributedKv::KvStoreType::SINGLE_VERSION, in GetKvStore()
70 OHOS::DistributedKv::Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStore()
71 if (status != OHOS::DistributedKv::Status::SUCCESS || kvStorePtr_ == nullptr) { in GetKvStore()
86 OHOS::DistributedKv in CheckKvStore()
[all...]
/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
[all...]
/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()
54 DistributedKv::Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_); in GetKvStore()
55 if (status != DistributedKv::Status::SUCCESS) { in GetKvStore()
68 DistributedKv::Status status = GetKvStore(); in CheckKvStore()
69 if (status == DistributedKv::Status::SUCCESS && kvStorePtr_ != nullptr) { in CheckKvStore()
97 DistributedKv in UpdateStaticSubscriberState()
[all...]
/base/notification/common_event_service/services/include/
H A Dstatic_subscriber_data_manager.h42 DistributedKv::Status GetKvStore();
44 DistributedKv::Value ConvertEventsToValue(const std::vector<std::string> &events);
45 bool ConvertValueToEvents(const DistributedKv::Value &value, std::vector<std::string> &events);
47 const DistributedKv::AppId appId_ { "static_subscriber_storage" };
48 const DistributedKv::StoreId storeId_ { "static_subscriber_infos" };
49 DistributedKv::DistributedKvDataManager dataManager_;
50 std::shared_ptr<DistributedKv::SingleKvStore> kvStorePtr_;
/base/notification/distributed_notification_service/services/distributed/test/unittest/
H A Ddistributed_database_callback_test.cpp80 std::vector<DistributedKv::Entry> insertEntries; in HWTEST_F()
81 std::vector<DistributedKv::Entry> updateEntries; in HWTEST_F()
82 std::vector<DistributedKv::Entry> deleteEntries; in HWTEST_F()
83 DistributedKv::ChangeNotification changeNotification( in HWTEST_F()
116 std::vector<DistributedKv::Entry> insertEntries; in HWTEST_F()
117 std::vector<DistributedKv::Entry> updateEntries; in HWTEST_F()
118 std::vector<DistributedKv::Entry> deleteEntries; in HWTEST_F()
119 DistributedKv::ChangeNotification changeNotification( in HWTEST_F()
152 std::vector<DistributedKv::Entry> insertEntries; in HWTEST_F()
153 std::vector<DistributedKv in HWTEST_F()
[all...]
H A Ddistributed_database_test.cpp106 std::vector<DistributedKv::Entry> insertEntries; in HWTEST_F()
107 std::vector<DistributedKv::Entry> updateEntries; in HWTEST_F()
108 std::vector<DistributedKv::Entry> deleteEntries; in HWTEST_F()
109 DistributedKv::ChangeNotification change( in HWTEST_F()
/base/notification/common_event_service/services/test/unittest/static_subscriber_data_manager_unit_test/
H A Dstatic_subscriber_data_manager_unit_test.cpp89 DistributedKv::Key key(bundleName); in HWTEST_F()
90 DistributedKv::Value value("0"); in HWTEST_F()
93 EXPECT_EQ(dataManager->kvStorePtr_->Put(key, value), DistributedKv::Status::SUCCESS); in HWTEST_F()
110 DistributedKv::Key key(bundleName); in HWTEST_F()
111 DistributedKv::Value value{"events1"}; in HWTEST_F()
114 EXPECT_EQ(dataManager->kvStorePtr_->Put(key, value), DistributedKv::Status::SUCCESS); in HWTEST_F()
144 DistributedKv::Key key(bundleName); in HWTEST_F()
145 DistributedKv::Value value ("events1"); in HWTEST_F()
148 EXPECT_EQ(dataManager->kvStorePtr_->Put(key, value), DistributedKv::Status::SUCCESS); in HWTEST_F()
168 EXPECT_EQ(static_cast<DistributedKv in HWTEST_F()
[all...]
/base/notification/distributed_notification_service/frameworks/test/moduletest/
H A Dans_fw_module_test.cpp387 NotificationRequest &req, std::vector<DistributedKv::Entry> &entries, DistributedKv::Entry &outEntry) in GetRequestInDistributedEntryList()
441 DistributedKv::AppId appId = {.appId = KVSTORE_APP_ID}; in SetDistributedScreenStatus()
442 DistributedKv::StoreId storeId = {.storeId = KVSTORE_SCREEN_STATUS_STORE_ID}; in SetDistributedScreenStatus()
443 std::shared_ptr<DistributedKv::MockSingleKvStore> pointer = in SetDistributedScreenStatus()
444 DistributedKv::MockSingleKvStore::GetMockKvStorePointer(appId, storeId); in SetDistributedScreenStatus()
446 DistributedKv::Key key("<remoteDeviceId>" + DELIMITER + "screen_status"); in SetDistributedScreenStatus()
447 DistributedKv::Value value(isScreenOn ? "on" : "off"); in SetDistributedScreenStatus()
1730 DistributedKv::AppId appId = {.appId = KVSTORE_APP_ID}; in HWTEST_F()
1731 DistributedKv in HWTEST_F()
[all...]
/base/notification/distributed_notification_service/services/distributed/include/
H A Ddistributed_preferences_database.h34 using Entry = DistributedKv::Entry;
88 std::unique_ptr<DistributedKv::DistributedKvDataManager> kvDataManager_;
89 std::shared_ptr<DistributedKv::SingleKvStore> kvStore_;
H A Ddistributed_database_callback.h25 class DistributedDatabaseCallback : public DistributedKv::KvStoreObserver {
49 void OnChange(const DistributedKv::ChangeNotification &changeNotification) override;
H A Ddistributed_database.h35 using Entry = DistributedKv::Entry;
135 std::unique_ptr<DistributedKv::DistributedKvDataManager> kvDataManager_;
136 std::shared_ptr<DistributedKv::SingleKvStore> kvStore_;
H A Ddistributed_screen_status_manager.h65 std::unique_ptr<DistributedKv::DistributedKvDataManager> kvDataManager_ = nullptr;
66 std::shared_ptr<DistributedKv::SingleKvStore> kvStore_ = nullptr;
/base/notification/distributed_notification_service/services/distributed/test/unittest/distributed_database_branch_test/
H A Ddistributed_database_branch_test.cpp36 using namespace OHOS::DistributedKv;
140 * @tc.desc : Test GetKvStore function and status != DistributedKv::Status::SUCCESS.
145 database_->kvDataManager_ = std::make_unique<DistributedKv::DistributedKvDataManager>(); in HWTEST_F()
158 database_->kvDataManager_ = std::make_unique<DistributedKv::DistributedKvDataManager>(); in HWTEST_F()
167 * @tc.desc : Test GetKvStore function and SubscribeKvStore != DistributedKv::Status::SUCCESS.
172 database_->kvDataManager_ = std::make_unique<DistributedKv::DistributedKvDataManager>(); in HWTEST_F()
226 * @tc.desc : Test PutToDistributedDB function and status != DistributedKv::Status::SUCCESS.
269 * @tc.desc : Test GetFromDistributedDB function and status != DistributedKv::Status::SUCCESS.
316 * @tc.desc : Test GetEntriesFromDistributedDB function and status != DistributedKv::Status::SUCCESS.
347 * @tc.desc : Test DeleteToDistributedDB function and status != DistributedKv
[all...]
/base/account/os_account/services/accountmgr/test/mock/app_account/
H A Daccount_data_storage.cpp35 void AccountDataStorage::TryTwice(const std::function<DistributedKv::Status()> &func) const in TryTwice()
40 OHOS::DistributedKv::Status AccountDataStorage::GetKvStore() in GetKvStore()
43 return OHOS::DistributedKv::Status::SUCCESS; in GetKvStore()
76 OHOS::DistributedKv::Status AccountDataStorage::GetEntries( in GetEntries()
77 std::string subId, std::vector<OHOS::DistributedKv::Entry> &allEntries) const in GetEntries()
80 return OHOS::DistributedKv::Status::SUCCESS; in GetEntries()
/base/notification/distributed_notification_service/services/distributed/test/unittest/distributed_screen_status_manager_branch_test/
H A Dmock_distributed_kv_data_manager.cpp21 namespace DistributedKv { namespace
33 } // namespace DistributedKv
/base/notification/distributed_notification_service/services/distributed/test/unittest/mock/
H A Dmock_distributed_kv_data_manager.cpp30 namespace DistributedKv { namespace
47 return DistributedKv::Status::SUCCESS; in GetSingleKvStore()
91 } // namespace DistributedKv
/base/account/os_account/services/accountmgr/include/osaccount/
H A Dos_account_data_storage.h29 void SaveEntries(std::vector<OHOS::DistributedKv::Entry> allEntries,
/base/notification/distributed_notification_service/services/ans/include/
H A Ddistributed_kvstore_death_recipient.h25 class DistributedKvStoreDeathRecipient : public DistributedKv::KvStoreDeathRecipient {
44 * @brief Obtains the death event. Inherited from DistributedKv::KvStoreDeathRecipient.
/base/notification/distributed_notification_service/frameworks/test/moduletest/mock/
H A Dmock_change_notification.cpp19 namespace DistributedKv { namespace
61 } // namespace DistributedKv

Completed in 14 milliseconds

123