Home
last modified time | relevance | path

Searched refs:Watch (Results 1 - 25 of 31) sorted by relevance

12

/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/rust/examples/listen_rust_sa/src/
H A Dstub.rs23 pub(crate) struct Watch {
28 watch: Arc<Mutex<Watch>>,
42 pub(crate) fn new(watch: Arc<Mutex<Watch>>) -> Self {
H A Dlib.rs30 use stub::{ListenService, Watch};
45 watch: Arc<Mutex<stub::Watch>>,
71 let watch = Arc::new(Mutex::new(Watch { stop_reason: None })); in init()
/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/rust/examples/audio_rust_sa/src/
H A Dlib.rs47 watch: Arc<Mutex<Watch>>,
50 pub struct Watch { structure names
59 impl Watch { impls
124 watch: Arc::new(Mutex::new(Watch::new())), in init()
H A Dstub.rs22 use crate::{interface, Watch};
26 watch: Arc<Mutex<Watch>>,
30 pub(crate) fn new(handler: Handler, watch: Arc<Mutex<Watch>>) -> Self {
/foundation/distributeddatamgr/pasteboard/framework/framework/device/
H A Ddistributed_module_config.cpp32 void DistributedModuleConfig::Watch(Observer observer) in Watch() function in OHOS::MiscServices::DistributedModuleConfig
139 DevProfile::GetInstance().Watch([this](bool isEnable) -> void { in Init()
H A Ddev_profile.cpp297 void DevProfile::Watch(Observer observer) in Watch() function in OHOS::MiscServices::DevProfile
/foundation/distributeddatamgr/pasteboard/framework/framework/include/device/
H A Ddistributed_module_config.h31 void Watch(Observer observer);
H A Ddev_profile.h40 void Watch(Observer observer);
/foundation/distributeddatamgr/data_object/interfaces/innerkits/
H A Ddistributed_objectstore.h91 virtual uint32_t Watch(DistributedObject *object, std::shared_ptr<ObjectWatcher> objectWatcher) = 0;
/foundation/multimedia/av_session/services/session/adapter/
H A Ddistributed_object_adapter.cpp101 ObjectStore::DistributedObjectStore::GetInstance()->Watch( in SetCallback()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dcloud_db.cpp63 int32_t CloudDB::Watch(int32_t origin, Watcher &watcher) in Watch() function in OHOS::DistributedData::CloudDB
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_general_store_test.cpp529 * @tc.name: Watch
530 * @tc.desc: Watch and Unwatch test the functionality of different branches.
535 HWTEST_F(KVDBGeneralStoreTest, Watch, TestSize.Level0) in HWTEST_F()
540 auto ret = store->Watch(GeneralWatcher::Origin::ORIGIN_CLOUD, watcher); in HWTEST_F()
545 ret = store->Watch(GeneralWatcher::Origin::ORIGIN_ALL, watcher); in HWTEST_F()
547 ret = store->Watch(GeneralWatcher::Origin::ORIGIN_ALL, watcher); in HWTEST_F()
655 auto result = store->Watch(GeneralWatcher::Origin::ORIGIN_ALL, watcher); in HWTEST_F()
H A Drdb_general_store_test.cpp817 * @tc.name: Watch
818 * @tc.desc: RdbGeneralStore Watch and Unwatch function test
823 HWTEST_F(RdbGeneralStoreTest, Watch, TestSize.Level1) in HWTEST_F()
828 auto result = store->Watch(GeneralWatcher::Origin::ORIGIN_CLOUD, watcher); in HWTEST_F()
833 result = store->Watch(GeneralWatcher::Origin::ORIGIN_ALL, watcher); in HWTEST_F()
835 result = store->Watch(GeneralWatcher::Origin::ORIGIN_ALL, watcher); in HWTEST_F()
860 auto result = store->Watch(GeneralWatcher::Origin::ORIGIN_ALL, watcher); in HWTEST_F()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/
H A Ddistributed_objectstore_impl.h41 uint32_t Watch(DistributedObject *object, std::shared_ptr<ObjectWatcher> watcher) override;
H A Dflat_object_store.h69 uint32_t Watch(const std::string &objectId, std::shared_ptr<FlatObjectWatcher> watcher);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dcloud_db.h51 virtual int32_t Watch(int32_t origin, Watcher &watcher);
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/
H A Ddistributed_object_store_impl.cpp141 uint32_t DistributedObjectStoreImpl::Watch(DistributedObject *object, std::shared_ptr<ObjectWatcher> watcher) in Watch() function in OHOS::ObjectStore::DistributedObjectStoreImpl
153 LOG_ERROR("DistributedObjectStoreImpl::Watch already gets object"); in Watch()
162 uint32_t status = flatObjectStore_->Watch(object->GetSessionId(), watcherProxy); in Watch()
164 LOG_ERROR("DistributedObjectStoreImpl::Watch failed %{public}d", status); in Watch()
168 LOG_INFO("DistributedObjectStoreImpl:Watch object success."); in Watch()
184 LOG_ERROR("DistributedObjectStoreImpl::Watch failed %{public}d", status); in UnWatch()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/
H A Dgeneral_store_mock.h43 int32_t Watch(int32_t origin, Watcher &watcher) override;
H A Dgeneral_store_mock.cpp87 int32_t GeneralStoreMock::Watch(int32_t origin, Watcher &watcher) in Watch() function in OHOS::DistributedData::GeneralStoreMock
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/
H A Dgeneral_store.h157 virtual int32_t Watch(int32_t origin, Watcher &watcher) = 0;
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/
H A Dobject_store_test.cpp278 * @tc.desc: test DistributedObjectStoreImpl Watch
288 uint32_t status = objectStore->Watch(nullptr, watcher); in HWTEST_F()
294 status = objectStore->Watch(object, watcher); in HWTEST_F()
306 * @tc.desc: test DistributedObjectStoreImpl Watch
320 uint32_t status = objectStore->Watch(object, watcher); in HWTEST_F()
323 status = objectStore->Watch(object, watcher); in HWTEST_F()
330 status = objectStore->Watch(object1, watcher); in HWTEST_F()
371 * @tc.desc: test DistributedObjectStore Watch and UnWatch.
385 uint32_t ret = objectStore->Watch(object, watcherPtr); in HWTEST_F()
1141 * @tc.desc: test FlatObjectStore Watch
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_general_store.h65 int32_t Watch(int32_t origin, Watcher &watcher) override;
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/
H A Djs_watcher.cpp302 uint32_t ret = objectStore_->Watch(object_, watcher); in Add()
304 LOG_ERROR("Watch %{public}s error", object_->GetSessionId().c_str()); in Add()
306 LOG_INFO("Watch %{public}s success", object_->GetSessionId().c_str()); in Add()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_general_store.h78 int32_t Watch(int32_t origin, Watcher &watcher) override;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/
H A Dauto_cache.cpp254 store_->Watch(Origin::ORIGIN_ALL, *this); in Delegate()

Completed in 13 milliseconds

12