| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
| H A D | local_subscribe_device_store_test.cpp | 161 auto observer = std::make_shared<DeviceObserverTest>(); in HWTEST_F() local
182 std::shared_ptr<DeviceObserverTest> observer = nullptr; in HWTEST_F() local
197 auto observer = std::make_shared<DeviceObserverTest>(); in HWTEST_F() local
223 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
289 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
332 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
367 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
402 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
449 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
496 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
533 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
570 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
605 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
625 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
667 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
709 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
730 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
760 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
840 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
892 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
938 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
984 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1038 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1073 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1116 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1159 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1200 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1261 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1323 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1384 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1446 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1479 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1519 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1557 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1602 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1649 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1693 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1745 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1801 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1853 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
1909 auto observer = std::make_shared<DeviceObserverTest>(); HWTEST_F() local
[all...] |
| H A D | distributed_kv_data_manager_test.cpp | 868 std::shared_ptr<SwitchDataObserver> observer = std::make_shared<SwitchDataObserver>(); in HWTEST_F() local
883 std::shared_ptr<SwitchDataObserver> observer = std::make_shared<SwitchDataObserver>(); in HWTEST_F() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
| H A D | distributeddb_nb_autolaunch_test.cpp | 174 KvStoreObserverImpl *observer = nullptr; in HWTEST_F() local
493 KvStoreObserverImpl observer; in HWTEST_F() local
[all...] |
| H A D | distributeddb_kv_backup_test.cpp | 733 KvStoreObserverImpl observer; in HWTEST_F() local
|
| H A D | distributeddb_nb_enable_sync_by_closed_db_test.cpp | 169 KvStoreObserverImpl *observer = nullptr; in HWTEST_F() local
484 KvStoreObserverImpl observer; in HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/test/fuzztest/distributedkvdatamanager_fuzzer/ |
| H A D | distributedkvdatamanager_fuzzer.cpp | 239 std::shared_ptr<SwitchDataObserver> observer = std::make_shared<SwitchDataObserver>(); in SubscribeSwitchDataFuzz() local
246 std::shared_ptr<SwitchDataObserver> observer = std::make_shared<SwitchDataObserver>(); in UnsubscribeSwitchDataFuzz() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | meta_data_manager.cpp | 309 bool MetaDataManager::Subscribe(std::shared_ptr<Filter> filter, Observer observer) in Subscribe() argument
320 bool MetaDataManager::Subscribe(std::string prefix, Observer observer, bool isLocal) in Subscribe() argument
49 MetaObserver( std::shared_ptr<MetaStore> metaStore, std::shared_ptr<Filter> filter, Observer observer, bool isLocal) MetaObserver() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
| H A D | data_share_service_stub.cpp | 190 sptr<IDataProxyRdbObserver> observer = new (std::nothrow)RdbObserverProxy(remoteObj); in OnSubscribeRdbData() local
259 sptr<PublishedDataObserverProxy> observer = new (std::nothrow)PublishedDataObserverProxy(data.ReadRemoteObject()); in OnSubscribePublishedData() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoredelegate_fuzzer/ |
| H A D | relationalstoredelegate_fuzzer.cpp | 125 auto observer = new (std::nothrow) DistributedDB::StoreObserver; in CombineTest() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_transaction_test.cpp | 319 KvStoreObserverUnitTest *observer = new (std::nothrow) KvStoreObserverUnitTest; in HWTEST_F() local
510 KvStoreObserverUnitTest *observer = new (std::nothrow) KvStoreObserverUnitTest; in HWTEST_F() local
669 KvStoreObserverUnitTest *observer = new (std::nothrow) KvStoreObserverUnitTest; HWTEST_F() local
[all...] |
| H A D | distributeddb_interfaces_database_rd_kernel_test.cpp | 207 KvStoreObserverUnitTest *observer = new (std::nothrow) KvStoreObserverUnitTest; in HWTEST_F() local
[all...] |
| H A D | distributeddb_interfaces_encrypt_delegate_test.cpp | 502 KvStoreObserverUnitTest *observer = new (std::nothrow) KvStoreObserverUnitTest; in HWTEST_F() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/ |
| H A D | rdb_subscriber_manager.cpp | 114 int RdbSubscriberManager::Add(const Key &key, const sptr<IDataProxyRdbObserver> observer,
in Add() argument
382 RdbSubscriberManager::ObserverNode::ObserverNode(const sptr<IDataProxyRdbObserver> &observer,
in ObserverNode() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/nbdelegate_fuzzer/ |
| H A D | nbdelegate_fuzzer.cpp | 218 auto observer = new (std::nothrow) KvStoreObserverFuzzTest; in FuzzCURD() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.cpp | 84 void KvStoreMetaManager::SubscribeMeta(const std::string &keyPrefix, const ChangeObserver &observer) in SubscribeMeta() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | kv_store_delegate_impl.cpp | 145 void KvStoreDelegateImpl::GetKvStoreSnapshot(KvStoreObserver *observer, in GetKvStoreSnapshot() argument
186 KvStoreObserver *observer = nullptr; in ReleaseKvStoreSnapshot() local
205 RegisterObserver(KvStoreObserver *observer) RegisterObserver() argument
243 UnRegisterObserver(const KvStoreObserver *observer) UnRegisterObserver() argument
[all...] |
| /foundation/distributeddatamgr/data_share/frameworks/native/common/include/ |
| H A D | callbacks_manager.h | 88 AddObservers(const std::vector<Key> &keys, void *subscriber, const std::shared_ptr<Observer> observer, std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer)> processOnLocalAdd, std::function<void(const std::vector<Key> &, const std::shared_ptr<Observer> &observer, std::vector<OperationResult> &)> processOnFirstAdd) AddObservers() argument
[all...] |
| /foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/ |
| H A D | datashare_helper.cpp | 319 sptr<ObserverImpl> ObserverImpl::GetObserver(const Uri& uri, const std::shared_ptr<DataShareObserver> &observer) in GetObserver() argument
340 FindObserver(const Uri& uri, const std::shared_ptr<DataShareObserver> &observer) FindObserver() argument
352 DeleteObserver(const Uri& uri, const std::shared_ptr<DataShareObserver> &observer) DeleteObserver() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | kvdb_service_impl_test.cpp | 447 sptr<OHOS::DistributedKv::IKvStoreObserver> observer; in HWTEST_F() local
465 sptr<OHOS::DistributedKv::IKvStoreObserver> observer; in HWTEST_F() local
|
| H A D | data_share_service_impl_test.cpp | 271 sptr<IDataProxyRdbObserver> observer;
in HWTEST_F() local
321 sptr<IDataProxyPublishedDataObserver> observer;
in HWTEST_F() local
350 sptr<IDataProxyPublishedDataObserver> observer;
in HWTEST_F() local
|
| /foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/ |
| H A D | data_share_service_proxy.cpp | 295 SubscribeRdbData(const std::vector<std::string> &uris, const TemplateId &templateId, const sptr<IDataProxyRdbObserver> &observer) SubscribeRdbData() argument
411 SubscribePublishedData( const std::vector<std::string> &uris, int64_t subscriberId, const sptr<IDataProxyPublishedDataObserver> &observer) SubscribePublishedData() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | device_manager_adapter.cpp | 221 Status DeviceManagerAdapter::StartWatchDeviceChange(const AppDeviceChangeListener *observer, in StartWatchDeviceChange() argument
235 Status DeviceManagerAdapter::StopWatchDeviceChange(const AppDeviceChangeListener *observer, in StopWatchDeviceChange() argument
[all...] |
| /foundation/distributeddatamgr/pasteboard/framework/framework/device/ |
| H A D | dev_profile.cpp | 297 void DevProfile::Watch(Observer observer) in Watch() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | kvdb_service_client.cpp | 315 Status KVDBServiceClient::Subscribe(const AppId &appId, const StoreId &storeId, sptr<IKvStoreObserver> observer) in Subscribe() argument
328 Status KVDBServiceClient::Unsubscribe(const AppId &appId, const StoreId &storeId, sptr<IKvStoreObserver> observer) in Unsubscribe() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_common_test.cpp | 719 LockStatusObserver observer; in HWTEST_F() local
|