Home
last modified time | relevance | path

Searched refs:KvStoreObserver (Results 1 - 25 of 96) sorted by relevance

1234

/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dkvstore_observer.h26 class API_EXPORT KvStoreObserver { class
38 API_EXPORT KvStoreObserver() = default;
43 API_EXPORT virtual ~KvStoreObserver() {} in ~KvStoreObserver()
H A Dkvstore.h141 * @param observer Callback client provided, client must implement KvStoreObserver and
146 virtual Status SubscribeKvStore(SubscribeType type, std::shared_ptr<KvStoreObserver> observer) = 0;
159 virtual Status UnSubscribeKvStore(SubscribeType type, std::shared_ptr<KvStoreObserver> observer) = 0;
H A Ddistributed_kv_data_manager.h195 API_EXPORT Status SubscribeSwitchData(const AppId &appId, std::shared_ptr<KvStoreObserver> observer);
208 API_EXPORT Status UnsubscribeSwitchData(const AppId &appId, std::shared_ptr<KvStoreObserver> observer);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_snapshot_delegate_impl.h27 KvStoreSnapshotDelegateImpl(IKvDBSnapshot *snapshot, KvStoreObserver *observer);
45 void GetObserver(KvStoreObserver *&observer) const;
49 KvStoreObserver * const observer_;
H A Dkv_store_delegate_impl.h63 void GetKvStoreSnapshot(KvStoreObserver *observer,
70 DBStatus RegisterObserver(KvStoreObserver *observer) override;
73 DBStatus UnRegisterObserver(const KvStoreObserver *observer) override;
112 std::map<const KvStoreObserver*, const KvDBObserverHandle*> observerMap_;
H A Dkv_store_nb_delegate_impl.h76 DBStatus RegisterObserver(const Key &key, unsigned int mode, KvStoreObserver *observer) override;
78 DBStatus UnRegisterObserver(const KvStoreObserver *observer) override;
205 DBStatus RegisterDeviceObserver(const Key &key, unsigned int mode, KvStoreObserver *observer);
207 DBStatus RegisterCloudObserver(const Key &key, unsigned int mode, KvStoreObserver *observer);
209 DBStatus UnRegisterDeviceObserver(const KvStoreObserver *observer);
211 DBStatus UnRegisterCloudObserver(const KvStoreObserver *observer);
217 std::map<const KvStoreObserver *, const KvDBObserverHandle *> observerMap_;
218 std::map<const KvStoreObserver *, unsigned int> cloudObserverMap_;
H A Dkv_store_snapshot_delegate_impl.cpp24 KvStoreSnapshotDelegateImpl::KvStoreSnapshotDelegateImpl(IKvDBSnapshot *snapshot, KvStoreObserver *observer) in KvStoreSnapshotDelegateImpl()
84 void KvStoreSnapshotDelegateImpl::GetObserver(KvStoreObserver *&observer) const in GetObserver()
H A Dkv_store_delegate_impl.cpp145 void KvStoreDelegateImpl::GetKvStoreSnapshot(KvStoreObserver *observer, in GetKvStoreSnapshot()
186 KvStoreObserver *observer = nullptr; in ReleaseKvStoreSnapshot()
205 DBStatus KvStoreDelegateImpl::RegisterObserver(KvStoreObserver *observer) in RegisterObserver()
238 observerMap_.insert(std::pair<const KvStoreObserver *, const KvDBObserverHandle *>(observer, observerHandle)); in RegisterObserver()
243 DBStatus KvStoreDelegateImpl::UnRegisterObserver(const KvStoreObserver *observer) in UnRegisterObserver()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Dkvdb_notifier_client.h42 void AddSwitchCallback(const std::string &appId, std::shared_ptr<KvStoreObserver> observer);
44 void DeleteSwitchCallback(const std::string &appId, std::shared_ptr<KvStoreObserver> observer);
54 ConcurrentMap<uintptr_t, std::shared_ptr<KvStoreObserver>> switchObservers_;
H A Dkvstore_observer_client.h29 explicit KvStoreObserverClient(std::shared_ptr<KvStoreObserver> kvStoreObserver);
40 std::shared_ptr<KvStoreObserver> kvStoreObserver_;
H A Dkvdb_notifier_client.cpp90 [&notification](auto &, std::shared_ptr<KvStoreObserver> &observer) { in OnSwitchChange()
147 void KVDBNotifierClient::AddSwitchCallback(const std::string &appId, std::shared_ptr<KvStoreObserver> observer) in AddSwitchCallback()
159 void KVDBNotifierClient::DeleteSwitchCallback(const std::string &appId, std::shared_ptr<KvStoreObserver> observer) in DeleteSwitchCallback()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Dkv_store_observer.h23 class KvStoreObserver : public StoreObserver { class
25 ~KvStoreObserver() override {}
H A Dkv_store_delegate.h67 DB_API virtual void GetKvStoreSnapshot(KvStoreObserver *observer,
74 DB_API virtual DBStatus RegisterObserver(KvStoreObserver *observer) = 0;
77 DB_API virtual DBStatus UnRegisterObserver(const KvStoreObserver *observer) = 0;
/foundation/deviceprofile/device_info_manager/old/services/core/test/unittest/
H A Dprofile_storage_test.cpp582 std::shared_ptr<DistributedKv::KvStoreObserver> kvStoreObserver_ = nullptr; in HWTEST_F()
675 std::shared_ptr<DistributedKv::KvStoreObserver> kvStoreObserver_ = in HWTEST_F()
676 std::make_shared<DistributedKv::KvStoreObserver>(); in HWTEST_F()
690 std::shared_ptr<DistributedKv::KvStoreObserver> kvStoreObserver_ = nullptr; in HWTEST_F()
704 std::shared_ptr<DistributedKv::KvStoreObserver> kvStoreObserver_ = in HWTEST_F()
705 std::make_shared<DistributedKv::KvStoreObserver>(); in HWTEST_F()
790 std::shared_ptr<DistributedKv::KvStoreObserver> kvStoreObserver_ = in HWTEST_F()
791 std::make_shared<DistributedKv::KvStoreObserver>(); in HWTEST_F()
806 std::shared_ptr<DistributedKv::KvStoreObserver> kvStoreObserver_ = nullptr; in HWTEST_F()
821 std::shared_ptr<DistributedKv::KvStoreObserver> kvStoreObserver in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dobserver_bridge.h24 class ObserverBridge : public DistributedDB::KvStoreObserver {
26 using Observer = DistributedKv::KvStoreObserver;
55 std::shared_ptr<DistributedKv::KvStoreObserver> observer_;
H A Dstore_manager.h30 Status SubscribeSwitchData(const AppId &appId, std::shared_ptr<KvStoreObserver> observer);
31 Status UnsubscribeSwitchData(const AppId &appId, std::shared_ptr<KvStoreObserver> observer);
/foundation/communication/dsoftbus/core/adapter/kv_store/include/
H A Dlnn_kv_adapter.h42 int32_t RegisterDataChangeListener(const std::shared_ptr<DistributedKv::KvStoreObserver> &dataChangeListener);
57 std::shared_ptr<DistributedKv::KvStoreObserver> dataChangeListener_ = nullptr;
/foundation/deviceprofile/device_info_manager/old/services/core/include/dbstorage/
H A Ddevice_profile_storage_manager.h58 int32_t SubscribeKvStore(const std::shared_ptr<DistributedKv::KvStoreObserver>& observer);
59 int32_t UnSubscribeKvStore(const std::shared_ptr<DistributedKv::KvStoreObserver>& observer);
93 std::shared_ptr<DistributedKv::KvStoreObserver> kvStoreObserver_;
H A Ddevice_profile_storage.h60 int32_t SubscribeKvStore(const std::shared_ptr<DistributedKv::KvStoreObserver>& observer);
61 int32_t UnSubscribeKvStore(const std::shared_ptr<DistributedKv::KvStoreObserver>& observer);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_store.h86 void RegisterObserverAction(const KvStoreObserver *observer, const ObserverAction &action);
88 void UnRegisterObserverAction(const KvStoreObserver *observer);
131 std::map<const KvStoreObserver *, ObserverAction> cloudObserverMap_;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/
H A Ddb_store_mock.h31 using KvStoreObserver = DistributedDB::KvStoreObserver;
70 DBStatus RegisterObserver(const Key &key, unsigned int mode, KvStoreObserver *observer) override;
71 DBStatus UnRegisterObserver(const KvStoreObserver *observer) override;
126 mutable ConcurrentMap<KvStoreObserver *, std::set<Key>> observers_;
/foundation/ability/dmsfwk/services/dtbschedmgr/include/mission/
H A Ddistributed_data_change_listener.h24 class DistributedDataChangeListener : public DistributedKv::KvStoreObserver {
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/dbadapter/include/
H A Dmock_db_change_listener.h24 class MockDBChangeListener : public DistributedKv::KvStoreObserver {
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/
H A Dwatcher.h25 class Watcher : public DistributedDB::KvStoreObserver {
/foundation/deviceprofile/device_info_manager/services/core/include/persistenceadapter/kvadapter/
H A Dkv_adapter.h38 const std::shared_ptr<DistributedKv::KvStoreObserver> &dataChangeListener,
77 std::shared_ptr<DistributedKv::KvStoreObserver> dataChangeListener_ = nullptr;

Completed in 9 milliseconds

1234