| /foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/ |
| H A D | js_object_wrapper.cpp | 29 if (watcher_ != nullptr) {
in ~JSObjectWrapper()
30 watcher_ = nullptr;
in ~JSObjectWrapper()
43 if (watcher_ == nullptr) {
in AddWatch()
44 watcher_ = std::make_shared<JSWatcher>(env, objectStore_, object_);
in AddWatch()
45 std::weak_ptr<JSWatcher> watcher = watcher_;
in AddWatch()
48 watcher_->SetListener(changeEventListener, statusEventListener);
in AddWatch()
50 return watcher_->On(type, handler);
in AddWatch()
56 if (watcher_ != nullptr) {
in DeleteWatch()
57 watcher_->Off(type, handler);
in DeleteWatch()
59 if (watcher_ in DeleteWatch()
[all...] |
| H A D | js_watcher.cpp | 285 std::shared_ptr<JSWatcher> lockedWatcher = watcher_.lock();
in OnChanged()
301 std::shared_ptr<WatcherImpl> watcher = std::make_shared<WatcherImpl>(watcher_);
in Add()
344 : objectStore_(objectStore), object_(object), watcher_(watcher)
in ChangeEventListener()
351 NotifierImpl::GetInstance()->AddWatcher(sessionId_, watcher_);
in Add()
372 : watcher_(watcher), sessionId_(sessionId)
in StatusEventListener()
|
| /foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/include/adaptor/ |
| H A D | js_watcher.h | 71 std::weak_ptr<JSWatcher> watcher_;
member in OHOS::ObjectStore::ChangeEventListener
83 std::weak_ptr<JSWatcher> watcher_;
member in OHOS::ObjectStore::StatusEventListener
129 WatcherImpl(std::weak_ptr<JSWatcher> watcher) : watcher_(watcher)
in WatcherImpl()
138 std::weak_ptr<JSWatcher> watcher_;
member in OHOS::ObjectStore::WatcherImpl
|
| H A D | js_object_wrapper.h | 43 std::shared_ptr<JSWatcher> watcher_ = nullptr;
member in OHOS::ObjectStore::JSObjectWrapper
|
| /foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/text/span/ |
| H A D | mutable_span_string.h | 50 WeakPtr<SpanWatcher> watcher_; member in OHOS::Ace::MutableSpanString
|
| H A D | mutable_span_string.cpp | 634 watcher_ = watcher; in SetSpanWatcher()
642 auto watcher = watcher_.Upgrade(); in NotifySpanWatcher()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_general_store.h | 113 return watcher_ != nullptr; in HasWatcher()
118 Watcher *watcher_ = nullptr; member in OHOS::DistributedKv::KVDBGeneralStore::ObserverProxy
|
| H A D | kvdb_general_store.cpp | 514 if (origin != Watcher::Origin::ORIGIN_ALL || observer_.watcher_ != nullptr) { in Watch()
518 observer_.watcher_ = &watcher; in Watch()
524 if (origin != Watcher::Origin::ORIGIN_ALL || observer_.watcher_ != &watcher) { in Unwatch()
528 observer_.watcher_ = nullptr; in Unwatch()
632 watcher_->OnChange(genOrigin, {}, std::move(changeInfo)); in OnChange()
651 watcher_->OnChange(genOrigin, {}, std::move(changeData)); in OnChange()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_service_impl.cpp | 359 if (item.second.watcher_ != nullptr) { in GetWatchers()
360 watchers.insert(item.second.watcher_); in GetWatchers()
582 if (it->second.watcher_ == nullptr) {
959 if (watcher_ != nullptr) {
960 watcher_->SetNotifier(notifier);
966 if (watcher_ != watcher) {
967 watcher_ = watcher;
968 if (watcher_ != nullptr) {
969 watcher_->SetNotifier(notifier_);
977 watcher_
[all...] |
| H A D | rdb_general_store.h | 126 return watcher_ != nullptr; in HasWatcher()
135 Watcher *watcher_ = nullptr; member in OHOS::DistributedRdb::RdbGeneralStore::ObserverProxy
|
| H A D | rdb_general_store.cpp | 677 if (origin != Watcher::Origin::ORIGIN_ALL || observer_.watcher_ != nullptr) { in Watch()
681 observer_.watcher_ = &watcher; in Watch()
687 if (origin != Watcher::Origin::ORIGIN_ALL || observer_.watcher_ != &watcher) { in Unwatch()
691 observer_.watcher_ = nullptr; in Unwatch()
1017 watcher_->OnChange(genOrigin, {}, std::move(changeInfo));
1062 watcher_->OnChange(genOrigin, fields, std::move(changeInfo));
|
| H A D | rdb_service_impl.h | 120 std::shared_ptr<RdbWatcher> watcher_ = nullptr; member
|