| /foundation/ability/ability_runtime/test/unittest/background_task_observer_test/ |
| H A D | background_task_observer_test.cpp | 34 std::shared_ptr<BackgroundTaskObserver> observer_ {nullptr};
45 observer_ = std::make_shared<BackgroundTaskObserver>(); in SetUp()
60 observer_->OnContinuousTaskStart(info); in HWTEST_F()
75 observer_->GetAppManager(); in HWTEST_F()
76 observer_->OnContinuousTaskStart(info); in HWTEST_F()
91 observer_->OnContinuousTaskStop(info); in HWTEST_F()
106 observer_->GetAppManager(); in HWTEST_F()
107 observer_->OnContinuousTaskStop(info); in HWTEST_F()
120 ASSERT_NE(observer_, nullptr); in HWTEST_F()
121 observer_ in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_store_subscribe_test.cpp | 73 static std::shared_ptr<SubObserver> observer_; member in RdbStoreSubTest
87 std::shared_ptr<SubObserver> RdbStoreSubTest::observer_ = nullptr; member in RdbStoreSubTest
94 if (observer_ == nullptr) { in SetUpTestCase()
95 observer_ = std::make_shared<SubObserver>(); in SetUpTestCase()
227 EXPECT_NE(observer_, nullptr) << "observer is null"; in HWTEST_F()
228 auto status = store->Subscribe({ SubscribeMode::REMOTE, "observer" }, observer_.get()); in HWTEST_F()
230 status = store->UnSubscribe({ SubscribeMode::REMOTE, "observer" }, observer_.get()); in HWTEST_F()
244 EXPECT_NE(observer_, nullptr) << "observer is null"; in HWTEST_F()
245 auto status = store->Subscribe({ SubscribeMode::CLOUD, "observer" }, observer_.get()); in HWTEST_F()
247 status = store->UnSubscribe({ SubscribeMode::CLOUD, "observer" }, observer_ in HWTEST_F()
[all...] |
| /foundation/communication/netmanager_ext/frameworks/js/napi/mdns/src/ |
| H A D | mdns_instances.cpp | 27 : observer_(new (std::nothrow) MDnsDiscoveryObserver), manager_(eventManager) in MDnsDiscoveryInstance()
37 if (mdnsDiscovery->observer_ == nullptr) { in MakeMDnsDiscovery()
38 NETMANAGER_EXT_LOGE("mdnsDiscovery->observer_ is nullptr"); in MakeMDnsDiscovery()
42 discoverInstanceMap_[mdnsDiscovery->observer_.GetRefPtr()] = mdnsDiscovery; in MakeMDnsDiscovery()
49 if (mdnsDiscovery->observer_ == nullptr) { in DeleteMDnsDiscovery()
50 NETMANAGER_EXT_LOGE("mdnsDiscovery->observer_ is nullptr"); in DeleteMDnsDiscovery()
53 discoverInstanceMap_.erase(mdnsDiscovery->observer_.GetRefPtr()); in DeleteMDnsDiscovery()
59 return observer_; in GetObserver()
|
| /foundation/graphic/graphic_3d/lume/scenewidgetplugin/plugin/src/ |
| H A D | hierarchy_controller.cpp | 29 observer_ = GetObjectRegistry().Create<IObjectHierarchyObserver>(META_NS::ClassId::ObjectHierarchyObserver); in Build()
30 CORE_ASSERT(observer_); in Build()
33 META_NS::SetObjectFlags(observer_, META_NS::ObjectFlagBits::SERIALIZE, false); in Build()
35 observer_->OnHierarchyChanged()->AddHandler( in Build()
44 observer_.reset(); in Destroy()
49 if (!observer_) { in SetTarget()
58 observer_->SetTarget(hierarchyRoot, mode); in SetTarget()
67 return observer_->GetTarget(); in GetTarget()
72 return observer_->GetAllObserved(); in GetAllObserved()
|
| /foundation/communication/netmanager_base/frameworks/js/napi/connection/options/src/ |
| H A D | netconnection.cpp | 29 observer_(new NetConnCallbackObserver), in NetConnection()
38 NET_CONNECTIONS[netConnection->observer_.GetRefPtr()] = netConnection; in MakeNetConnection()
45 NET_CONNECTIONS.erase(netConnection->observer_.GetRefPtr()); in DeleteNetConnection()
51 return observer_; in GetObserver()
|
| /foundation/resourceschedule/resource_schedule_service/ressched/common/src/ |
| H A D | oobe_manager.cpp | 28 sptr<OOBEManager::ResDataAbilityObserver> OOBEManager::observer_ = nullptr; member in OHOS::ResourceSchedule::OOBEManager
75 if (observer_ != nullptr) { in RegisterObserver()
79 observer_ = new (std::nothrow)ResDataAbilityObserver(); in RegisterObserver()
80 if (observer_ == nullptr) { in RegisterObserver()
84 observer_->SetUpdateFunc(func); in RegisterObserver()
85 helper->RegisterObserver(uri, observer_); in RegisterObserver()
113 helper->UnregisterObserver(uri, observer_); in UnregisterObserver()
115 observer_ = nullptr; in UnregisterObserver()
|
| /foundation/arkui/ace_engine/frameworks/core/components/scroll/ |
| H A D | scroll_controller.h | 38 observer_ = observer;
43 return observer_; in GetObserver()
48 ScrollerObserver observer_; member in OHOS::Ace::ScrollController
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
| H A D | obex_server.cpp | 166 obexServer_.observer_.OnTransportConnect(incomingConnect); in OnTransportConnectIncoming()
173 obexServer_.observer_.OnTransportDisconnected(btAddr); in OnTransportIncomingDisconnected()
189 obexServer_.observer_.OnTransportConnected(btAddrStr); in OnTransportConnected()
198 obexServer_.observer_.OnTransportDisconnected(btAddrStr); in OnTransportDisconnected()
214 obexServer_.observer_.OnConnect(serverSession, req); in HandleDataAvailableConnect()
231 obexServer_.observer_.OnError(-1, "Response BAD_REQUEST send failure!"); in OnTransportDataAvailable()
241 obexServer_.observer_.OnDisconnect(serverSession, *req); in OnTransportDataAvailable()
255 obexServer_.observer_.OnAction(serverSession, *req); in OnTransportDataAvailable()
258 obexServer_.observer_.OnSession(serverSession, *req); in OnTransportDataAvailable()
264 obexServer_.observer_ in OnTransportDataAvailable()
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/transport/ |
| H A D | transport_rfcomm.cpp | 31 : scn_(scn), mtu_(mtu), observer_(observer), dispatcher_(dispatcher) in RfcommTransport()
141 RfcommTransport *newTransport = new (std::nothrow) RfcommTransport(&addr, scn_, mtu_, observer_, dispatcher_); in AddTransportInternal()
171 transport->observer_.OnConnectIncoming( in TransportRfcEventCallback()
217 transport->observer_.OnConnected(newTransport, connectedEvent.sendMTU, connectedEvent.recvMTU); in TransportRfcConnectSuccess()
219 transport->observer_.OnConnected(transport, connectedEvent.sendMTU, connectedEvent.recvMTU); in TransportRfcConnectSuccess()
229 transport->observer_.OnTransportError(transport->transportMap_.at(handle), CONNECT_FAIL); in TransportRfcConnectFail()
245 transport->observer_.OnTransportError(transport, CONNECT_FAIL); in TransportRfcConnectFail()
254 transport->observer_.OnDisconnected(transport); in TransportRfcDisconnected()
270 transport->observer_.OnDisconnected(transportTmp); in TransportRfcDisconnected()
275 transport->observer_ in TransportRfcDisconnected()
[all...] |
| H A D | transport_l2cap.cpp | 30 observer_(createInfo.observer), in L2capTransport()
180 L2capTransportInfo createInfo = {&addr, lpsm_, rpsm_, localMtu_, observer_, dispatcher_}; in AddTransportInternal()
442 transport->observer_.OnTransportError(transport, CONNECT_FAIL); in TransportL2cConnectReqCallbackNative()
467 transport->observer_.OnConnectIncoming(RawAddress::ConvertToString(l2capConnectionInfo.addr.addr), lpsm); in TransportRecvConnectionReqCallbackNative()
482 transport->observer_.OnTransportError(transport, CONNECT_FAIL); in TransportRecvConnectionRspCallbackNative()
526 transport->observer_.OnConnected(l2capTransport, transport->remoteMtu_, transport->localMtu_); in TransportRecvConfigReqCallbackNative()
545 transport->observer_.OnTransportError(transport, CONNECT_FAIL); in TransportRecvConfigRspCallbackNative()
559 transport->observer_.OnIncomingDisconnected(transport->remoteAddr_); in TransportRecvConfigRspCallbackNative()
574 transport->observer_.OnConnected(l2capTransport, transport->remoteMtu_, transport->localMtu_); in TransportRecvConfigRspCallbackNative()
585 transport->observer_ in TransportRecvDisconnectionReqCallbackNative()
[all...] |
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | rdb_local_db_observer.h | 28 explicit RdbStoreLocalDbObserver(const std::shared_ptr<RdbStoreObserver> &observer) : observer_(observer) {}; in RdbStoreLocalDbObserver()
33 return observer_; in GetObserver()
39 std::shared_ptr<RdbStoreObserver> observer_ = nullptr; member in OHOS::NativeRdb::RdbStoreLocalDbObserver
|
| /foundation/filemanagement/user_file_service/frameworks/js/napi/file_access_module/ |
| H A D | napi_observer_callback.h | 51 observer_(observer) {} in NapiObserverCallback()
55 observer_->OnChange(notifyMessage);
57 std::shared_ptr<NapiObserver> observer_ = nullptr; member in OHOS::FileAccessFwk::NapiObserverCallback
|
| /foundation/multimodalinput/input/intention/adapters/dsoftbus_adapter/include/ |
| H A D | dsoftbus_adapter_impl.h | 36 : observer_(observer) {} in Observer()
44 return observer_.lock();
49 return (observer_.lock() < other.observer_.lock());
53 std::weak_ptr<IDSoftbusObserver> observer_; member in OHOS::Msdp::DeviceStatus::final::final
|
| /foundation/multimodalinput/input/intention/adapters/ddm_adapter/include/ |
| H A D | ddm_adapter_impl.h | 50 : observer_(observer) {} in Observer()
58 return observer_.lock();
63 return (observer_.lock() < other.observer_.lock());
67 std::weak_ptr<IBoardObserver> observer_; member in OHOS::Msdp::DeviceStatus::final::final
|
| /foundation/deviceprofile/device_info_manager/services/core/src/persistenceadapter/kvadapter/ |
| H A D | switch_adapter.cpp | 36 if (observer_ == nullptr) { in Init()
37 observer_ = std::make_shared<KvDataChangeListener>(EMPTY_STRING); in Init()
92 if (observer_ == nullptr) { in SubscribeSwitchData()
93 HILOGE("observer_ is empty"); in SubscribeSwitchData()
96 auto res = kvDataMgr_.SubscribeSwitchData(appID, observer_); in SubscribeSwitchData()
115 auto res = kvDataMgr_.UnsubscribeSwitchData(appID, observer_); in UnsubscribeSwitchData()
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/device/ |
| H A D | distributed_module_config.cpp | 34 observer_ = std::move(observer); in Watch()
49 if (observer_ != nullptr) { in Notify()
50 observer_(newStatus); in Notify()
81 if (observer_ != nullptr) { in GetRetryTask()
82 observer_(newStatus); in GetRetryTask()
|
| /foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/src/ |
| H A D | napi_datashare_observer.cpp | 30 observer_->OnChange(); in OnChange()
36 observer_->OnChange(changeInfo, true); in OnChange()
|
| /foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/scrollable/ |
| H A D | scrollable_controller.h | 56 observer_ = observer;
61 return observer_; in GetObserver()
66 ScrollerObserver observer_; member in OHOS::Ace::NG::ScrollableController
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/ble/ |
| H A D | ble_properties.cpp | 31 BaseObserverList<IAdapterBleObserver> *observer_ = nullptr; member
162 if (pimpl->observer_ != nullptr) { in UpdateConfig()
164 pimpl->observer_->ForEach( in UpdateConfig()
171 if (pimpl->observer_ != nullptr) { in UpdateConfig()
173 pimpl->observer_->ForEach( in UpdateConfig()
293 pimpl->observer_ = &observer; in RegisterBleAdapterObserver()
300 pimpl->observer_->Deregister(observer); in DeregisterBleAdapterObserver()
|
| /foundation/distributeddatamgr/data_share/frameworks/js/napi/dataShare/include/ |
| H A D | napi_datashare_observer.h | 27 explicit NAPIDataShareObserver(const std::shared_ptr<NAPIInnerObserver> observer) : observer_(observer){}; in NAPIDataShareObserver()
31 std::shared_ptr<NAPIInnerObserver> observer_ = nullptr; member in OHOS::DataShare::NAPIDataShareObserver
|
| /foundation/communication/netmanager_ext/frameworks/js/napi/ethernet/ |
| H A D | interface_state_observer_wrapper.cpp | 27 : observer_(new InterfaceStateObserver()), manager_(new EventManager()), registered_(false) in InterfaceStateObserverWrapper()
45 if (manager_ == nullptr || observer_ == nullptr) { in On()
63 int32_t ret = DelayedSingleton<EthernetClient>::GetInstance()->RegisterIfacesStateChanged(observer_); in On()
82 if (manager_ == nullptr || observer_ == nullptr) { in Off()
116 auto ret = DelayedSingleton<EthernetClient>::GetInstance()->UnregisterIfacesStateChanged(observer_); in Off()
|
| /foundation/communication/bluetooth/frameworks/js/napi/src/ |
| H A D | napi_bluetooth_a2dp_snk.cpp | 26 std::shared_ptr<NapiA2dpSinkObserver> NapiA2dpSink::observer_ = std::make_shared<NapiA2dpSinkObserver>();
58 if (observer_) { in On()
59 auto status = observer_->eventSubscribe_.Register(env, info); in On()
64 profile->RegisterObserver(observer_); in On()
72 if (observer_) { in Off()
73 auto status = observer_->eventSubscribe_.Deregister(env, info); in Off()
|
| H A D | napi_bluetooth_avrcp_ct.cpp | 26 std::shared_ptr<NapiAvrcpControllerObserver> NapiAvrcpController::observer_ =
58 if (observer_) { in On()
59 auto status = observer_->eventSubscribe_.Register(env, info); in On()
65 profile->RegisterObserver(observer_); in On()
74 if (observer_) { in Off()
75 auto status = observer_->eventSubscribe_.Deregister(env, info); in Off()
|
| H A D | napi_bluetooth_avrcp_tg.cpp | 27 std::shared_ptr<NapiAvrcpTargetObserver> NapiAvrcpTarget::observer_ = std::make_shared<NapiAvrcpTargetObserver>();
58 if (observer_) { in On()
59 auto status = observer_->eventSubscribe_.Register(env, info); in On()
65 profile->RegisterObserver(observer_); in On()
74 if (observer_) { in Off()
75 auto status = observer_->eventSubscribe_.Deregister(env, info); in Off()
|
| /foundation/barrierfree/accessibility/services/test/mock/ |
| H A D | mock_accessible_ability_manager_service_stub.cpp | 294 observer_->OnConfigStateChanged(balance == 0 ? 0 : 0xFFFF); in SetAudioBalance()
295 observer_->OnAudioBalanceChanged(balance == 0 ? 0 : 1); in SetAudioBalance()
296 observer_->OnBrightnessDiscountChanged(balance == 0 ? 0 : 1); in SetAudioBalance()
297 observer_->OnContentTimeoutChanged(balance == 0 ? 0 : 1); in SetAudioBalance()
298 observer_->OnMouseAutoClickChanged(balance == 0 ? 0 : 1); in SetAudioBalance()
299 observer_->OnDaltonizationColorFilterChanged(balance == 0 ? 0 : 1); in SetAudioBalance()
300 observer_->OnShortkeyTargetChanged(balance == 0 ? "test_target1" : "test_target2"); in SetAudioBalance()
467 observer_ = callback; in RegisterConfigObserver()
|