Home
last modified time | relevance | path

Searched refs:notifier (Results 1 – 25 of 157) sorted by relevance

1234567

/ohos5.0/drivers/hdf_core/adapter/uhdf2/osal/src/
H A Dosal_sysevent.c44 if (notifier == NULL) { in HdfSysEventNotifierGetInstance()
50 OsalMemFree(notifier); in HdfSysEventNotifierGetInstance()
56 hdfSysEventNotifier = notifier; in HdfSysEventNotifierGetInstance()
58 return notifier; in HdfSysEventNotifierGetInstance()
87 if (notifier == NULL) { in OnKEventReceived()
106 OsalMutexLock(&notifier->mutex); in OnKEventReceived()
136 notifier->ioServiceListener.priv = notifier; in InitKeventIoServiceListenerLocked()
137 … int ret = HdfDeviceRegisterEventListener(notifier->keventIoService, &notifier->ioServiceListener); in InitKeventIoServiceListenerLocked()
153 (void)HdfDeviceUnregisterEventListener(notifier->keventIoService, &notifier->ioServiceListener); in DeInitKeventIoServiceListenerLocked()
166 if (notifier == NULL) { in HdfSysEventNotifyRegister()
[all …]
/ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/test/unittest/src/
H A Dnotifier_mgr_test.cpp71 EXPECT_TRUE(notifier != nullptr);
89 EXPECT_TRUE(notifier != nullptr);
106 EXPECT_TRUE(notifier != nullptr);
124 EXPECT_TRUE(notifier != nullptr);
143 EXPECT_TRUE(notifier != nullptr);
162 EXPECT_TRUE(notifier != nullptr);
184 EXPECT_TRUE(notifier != nullptr);
186 EXPECT_TRUE(notifier != nullptr);
204 EXPECT_TRUE(notifier != nullptr);
221 sptr<IRemoteObject> notifier; variable
[all …]
H A Dres_sched_client_test.cpp227 sptr<ResSchedSystemloadNotifierClient> notifier = variable
229 EXPECT_TRUE(notifier != nullptr);
230 ResSchedClient::GetInstance().RegisterSystemloadNotifier(notifier);
247 sptr<ResSchedSystemloadNotifierClient> notifier = variable
249 EXPECT_TRUE(notifier != nullptr);
334 sptr<ResSchedSystemloadNotifierClient> notifier = variable
336 EXPECT_TRUE(notifier != nullptr);
354 sptr<ResSchedSystemloadNotifierClient> notifier = variable
356 EXPECT_TRUE(notifier != nullptr);
371 sptr<ResSchedSystemloadNotifierClient> notifier = variable
[all …]
H A Dres_sched_service_test.cpp242 EXPECT_TRUE(notifier != nullptr);
244 resSchedService_->RegisterSystemloadNotifier(notifier);
266 EXPECT_TRUE(notifier != nullptr);
288 EXPECT_TRUE(notifier != nullptr);
312 EXPECT_TRUE(notifier != nullptr);
338 EXPECT_TRUE(notifier != nullptr);
355 EXPECT_TRUE(notifier != nullptr);
373 EXPECT_TRUE(notifier != nullptr);
391 EXPECT_TRUE(notifier != nullptr);
408 EXPECT_TRUE(notifier != nullptr);
[all …]
/ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/src/
H A Dnotifier_mgr.cpp71 NotifierMgr::GetInstance().OnRemoteNotifierDied(notifier); in Init()
94 if (notifier == nullptr) { in RegisterNotifier()
106 info.notifier = notifier; in RegisterNotifier()
109 notifier->AddDeathRecipient(notifierDeathRecipient_); in RegisterNotifier()
127 if (notifier == nullptr) { in OnRemoteNotifierDied()
131 RemoveNotifierLock(notifier); in OnRemoteNotifierDied()
175 std::vector<sptr<IRemoteObject>> vec{ info.notifier }; in OnApplicationStateChange()
197 if (notifiers.second.notifier != notifier) { in RemoveNotifierLock()
219 notifierArray.push_back(info.notifier); in OnDeviceLevelChangedLock()
251 for (auto& notifier : notifierVec) { in HandleDeviceLevelChange() local
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dtime_tick_monitor.cpp69 NotificationChain *notifier; in StopTimeTickMonitor() local
72 notifier = timeChangedNotifier_; in StopTimeTickMonitor()
75 if (notifier != nullptr) { in StopTimeTickMonitor()
76 notifier->UnRegisterEventType(TIME_CHANGE_EVENT); in StopTimeTickMonitor()
77 RefObject::KillAndDecObjRef(notifier); in StopTimeTickMonitor()
136 NotificationChain *notifier = nullptr; in TimeTick() local
139 notifier = timeChangedNotifier_; in TimeTick()
140 RefObject::IncObjRef(notifier); in TimeTick()
143 if (notifier == nullptr) { in TimeTick()
147 notifier->NotifyEvent(TIME_CHANGE_EVENT, &offset); in TimeTick()
[all …]
H A Dauto_launch.cpp352 autoLaunchItem.notifier = autoLaunchItemMap_[identifier][userId].notifier; in ObserverFunc()
371 AutoLaunchNotifier notifier = autoLaunchItem.notifier; in ObserverFunc() local
453 if (autoLaunchItem.notifier) { in CloseNotifier()
765 if (!param.notifier) { in AutoLaunchExt()
777 param.option.notifier}; in AutoLaunchExt()
837 AutoLaunchNotifier notifier; in ExtObserverFunc() local
870 notifier = autoLaunchItem.notifier; in ExtObserverFunc()
940 if (!notifier) { in SetConflictNotifier()
1219 if (!autoLaunchItem.notifier) { in NotifyInvalidParam()
1316 notifier = extItemMap_[identifier][userId].notifier; in RegisterRelationalObserver()
[all …]
/ohos5.0/foundation/deviceprofile/device_info_manager/old/services/core/test/unittest/
H A Dsubscribe_manager_test.cpp220 sptr<IRemoteObject> notifier = variable
237 sptr<IRemoteObject> notifier = variable
256 sptr<IRemoteObject> notifier = variable
275 sptr<IRemoteObject> notifier = variable
281 SubscribeManager::GetInstance().TryAddNotifierLocked(notifier, subProfileEvents);
284 SubscribeManager::GetInstance().TryAddNotifierLocked(notifier, subProfileEvents);
299 sptr<IRemoteObject> notifier = variable
319 sptr<IRemoteObject> notifier = variable
342 sptr<IRemoteObject> notifier = variable
377 wptr<IRemoteObject> notifier = variable
[all …]
H A Dprofile_change_handler_test.cpp186 sptr<IRemoteObject> notifier = variable
188 int32_t ret = profileChangeHandler_->Subscribe(subInfo, notifier);
308 sptr<IProfileEventNotifier> notifier = variable
310 profileChangeHandler_->NotifyProfileChangedLocked(profileNotification, filterInfo, notifier);
326 sptr<IProfileEventNotifier> notifier = variable
328 profileChangeHandler_->NotifyProfileChangedLocked(profileNotification, filterInfo, notifier);
348 sptr<IProfileEventNotifier> notifier = variable
350 profileChangeHandler_->NotifyProfileChangedLocked(profileNotification, filterInfo, notifier);
363 sptr<IRemoteObject> notifier = variable
372 profileChangeHandler_->profileEventSubscribeInfos_[notifier] = subInfo;
/ohos5.0/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dtask.h30 SimpleEventNotifier<IResponse> *notifier; member
35 Task() : handler(nullptr), request(nullptr), notifier(nullptr) {} in Task()
44 Task(IHandler *handler, IRequest *request, SimpleEventNotifier<IResponse> *notifier) in Task()
45 : handler(handler), request(request), notifier(notifier) in Task()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_watcher.cpp33 auto notifier = GetNotifier(); in OnChange() local
34 if (notifier == nullptr) { in OnChange()
46 notifier->OnChange(rdbOrigin, primaryFields, std::move(values)); in OnChange()
61 void RdbWatcher::SetNotifier(sptr<RdbNotifierProxy> notifier) in SetNotifier() argument
64 if (notifier_ == notifier) { in SetNotifier()
67 notifier_ = notifier; in SetNotifier()
/ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dsync_msg_handler.cpp57 if (task.notifier != nullptr) { in Process()
58 (task.notifier)->AddToBack(response); in Process()
76 int SyncMsgHandler::SendRequest(IRequest *request, SimpleEventNotifier<IResponse> &notifier) in SendRequest() argument
88 Task task(this, request, &notifier); in SendRequest()
96 int SyncMsgHandler::ReceiveResponse(int timeOut, SimpleEventNotifier<IResponse> &notifier, in ReceiveResponse() argument
99 bool notifierCode = notifier.GetFromFront(timeOut, response); in ReceiveResponse()
/ohos5.0/foundation/ability/dmsfwk/services/dtbabilitymgr/src/
H A Ddistributed_ability_manager_service.cpp234 iter->second->SetNotifier(cbType, notifier); in RegisterDeviceSelectionCallback()
237 notifierInfo->SetNotifier(cbType, notifier); in RegisterDeviceSelectionCallback()
590 if (notifier == nullptr) { in HandleDeviceConnect()
594 auto func = [notifier, continuationResults]() { in HandleDeviceConnect()
610 if (notifier == nullptr) { in HandleDeviceDisconnect()
614 auto func = [notifier, continuationResults]() { in HandleDeviceDisconnect()
720 if (iter->second->QueryNotifier(notifier)) { in QueryTokenByNotifier()
731 if (notifier == nullptr) { in ProcessNotifierDied()
734 HandleNotifierDied(notifier); in ProcessNotifierDied()
743 auto func = [this, notifier] () { in HandleNotifierDied()
[all …]
/ohos5.0/foundation/ability/dmsfwk/services/dtbabilitymgr/test/unittest/
H A Ddistributed_ability_manager_service_test.cpp366 sptr<DeviceSelectionNotifierTest> notifier(new DeviceSelectionNotifierTest());
396 sptr<DeviceSelectionNotifierTest> notifier(new DeviceSelectionNotifierTest());
801 bool ret = dtbabilitymgrService_->QueryTokenByNotifier(notifier, token);
810 dtbabilitymgrService_->ProcessNotifierDied(notifier);
821 notifierInfo->SetNotifier(EVENT_CONNECT, notifier);
826 dtbabilitymgrService_->HandleNotifierDied(notifier);
853 notifierInfo->SetNotifier(EVENT_CONNECT, notifier);
859 dtbabilitymgrService_->HandleNotifierDied(notifier);
912 notifierInfo->SetNotifier(EVENT_CONNECT, notifier);
1124 notifierInfo->SetNotifier(EVENT_CONNECT, notifier);
[all …]
/ohos5.0/foundation/deviceprofile/device_info_manager/old/interfaces/innerkits/core/src/
H A Ddistributed_device_profile_client.cpp202 sptr<IRemoteObject> notifier; in SubscribeProfileEvents() local
205 notifier = iter->second.notifier; in SubscribeProfileEvents()
207 notifier = sptr<ProfileEventNotifierStub>( in SubscribeProfileEvents()
218 int32_t errCode = dps->SubscribeProfileEvents(subscribeInfos, notifier, failedEvents); in SubscribeProfileEvents()
229 SubscribeRecord record {subscribeInfos, notifier, subProfileEvents}; in SubscribeProfileEvents()
261 sptr<IRemoteObject> notifier = iter->second.notifier; in UnsubscribeProfileEvents() local
270 int32_t errCode = dps->UnsubscribeProfileEvents(profileEvents, notifier, failedEvents); in UnsubscribeProfileEvents()
294 sptr<IRemoteObject> notifier = in SyncDeviceProfile() local
296 return dps->SyncDeviceProfile(syncOptions, notifier); in SyncDeviceProfile()
/ohos5.0/foundation/ability/dmsfwk/services/dtbabilitymgr/include/
H A Ddistributed_ability_manager_service.h44 int32_t token, const std::string& cbType, const sptr<IRemoteObject>& notifier) override;
51 void ProcessNotifierDied(const sptr<IRemoteObject>& notifier);
66 bool QueryTokenByNotifier(const sptr<IRemoteObject>& notifier, int32_t& token);
67 bool HandleDeviceConnect(const sptr<IRemoteObject>& notifier,
69 bool HandleDeviceDisconnect(const sptr<IRemoteObject>& notifier,
76 void HandleNotifierDied(const sptr<IRemoteObject>& notifier);
/ohos5.0/foundation/ability/dmsfwk/services/dtbabilitymgr/src/continuation_manager/
H A Dnotifier_info.cpp29 void NotifierInfo::SetNotifier(const std::string& cbType, const sptr<IRemoteObject>& notifier) in SetNotifier() argument
31 notifierMap_[cbType] = notifier; in SetNotifier()
42 bool NotifierInfo::QueryNotifier(const sptr<IRemoteObject>& notifier) const in QueryNotifier()
45 if (iter->second == notifier) { in QueryNotifier()
/ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/services/resschedmgr/resschedfwk/include/
H A Dnotifier_mgr.h35 sptr<IRemoteObject> notifier = nullptr; member
43 void RegisterNotifier(int32_t pid, const sptr<IRemoteObject>& notifier);
45 void OnRemoteNotifierDied(const sptr<IRemoteObject>& notifier);
53 void RemoveNotifierLock(const sptr<IRemoteObject>& notifier);
/ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/
H A Ddistributed_object_store_impl.cpp193 uint32_t DistributedObjectStoreImpl::SetStatusNotifier(std::shared_ptr<StatusNotifier> notifier) in SetStatusNotifier() argument
199 …td::shared_ptr<StatusNotifierProxy> watcherProxy = std::make_shared<StatusNotifierProxy>(notifier); in SetStatusNotifier()
293 if (notifier != nullptr) { in OnChanged()
294 notifier->OnChanged(sessionId, networkId, onlineStatus); in OnChanged()
298 …ierProxy::StatusNotifierProxy(const std::shared_ptr<StatusNotifier> &notifier) : notifier(notifier) in StatusNotifierProxy() argument
305 notifier = nullptr; in ~StatusNotifierProxy()
/ohos5.0/base/request/request/services/src/manage/
H A Dnotifier.rs117 notifier.notify_online(NetworkInfo { in init_manager()
137 let notifier; in ut_network() localVariable
143 notifier.notify_online(NetworkInfo { in ut_network()
157 notifier.notify_offline(); in ut_network()
159 notifier.notify_online(NetworkInfo { in ut_network()
179 let notifier = NetworkInner::new(); in ut_network_notify() localVariable
180 notifier.notify_offline(); in ut_network_notify()
181 assert!(notifier.notify_online(NetworkInfo { in ut_network_notify()
186 assert!(!notifier.notify_online(NetworkInfo { in ut_network_notify()
191 assert!(notifier.notify_online(NetworkInfo { in ut_network_notify()
[all …]
/ohos5.0/foundation/arkui/ace_engine/test/unittest/core/common/storage/
H A Dstorage_test.cpp91 auto notifier = [](const std::string& onlineStatus) { return; }; in __anondef05db60102() variable
94 …istributedStorage = StorageProxy::GetInstance()->GetStorage(testSessionId, notifier, taskExecutor);
134 auto notifier = [](const std::string& onlineStatus) { return; }; in __anondef05db60202() variable
137 …istributedStorage = StorageProxy::GetInstance()->GetStorage(testSessionId, notifier, taskExecutor);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_auto_launch_test.cpp214 option.notifier = nullptr;
288 option.notifier = nullptr;
364 option.notifier = nullptr;
423 option.notifier = nullptr;
514 option.notifier = nullptr;
583 option.notifier = nullptr;
648 param.notifier = TestAutoLaunchNotifier; in AutoLaunchCallBack()
656 param.notifier = TestAutoLaunchNotifier; in AutoLaunchCallBackBadParam()
876 option.notifier = ConflictNotifierCallback;
881 option1.notifier = nullptr;
[all …]
/ohos5.0/foundation/ability/dmsfwk/services/dtbabilitymgr/test/unittest/continuation_manager/
H A Dcontinuation_manager_test.cpp201 token, CALLBACK_TYPE1, notifier);
204 token, CALLBACK_TYPE2, notifier);
245 token, INVALID_CALLBACK_TYPE, notifier);
248 token, "", notifier);
277 token, CALLBACK_TYPE1, notifier);
315 token, CALLBACK_TYPE2, notifier);
353 token, CALLBACK_TYPE2, notifier);
391 token, CALLBACK_TYPE1, notifier);
536 token, CALLBACK_TYPE1, notifier);
539 token, CALLBACK_TYPE2, notifier);
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
H A Ddistributeddb_nb_db_damage_test.cpp86 auto notifier = bind(&KvStoreNbCorruptInfo::CorruptCallBack, &corruptInfo, variable
88 g_manager->SetKvStoreCorruptionHandler(notifier);
142 auto notifier = bind(&KvStoreNbCorruptInfo::CorruptCallBack, &corruptInfo, variable
144 g_manager->SetKvStoreCorruptionHandler(notifier);
197 auto notifier = bind(&KvStoreNbCorruptInfo::CorruptCallBack, &corruptInfo, variable
199 g_manager->SetKvStoreCorruptionHandler(notifier);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dgeneric_kvdb.cpp79 void GenericKvDB::OnClose(const std::function<void(void)> &notifier) in OnClose() argument
82 if (notifier) { in OnClose()
83 closeNotifiers_.push_back(notifier); in OnClose()
229 for (const auto &notifier : notifiers) { in DecreaseConnectionCounter() local
230 if (notifier) { in DecreaseConnectionCounter()
231 notifier(); in DecreaseConnectionCounter()

1234567