Home
last modified time | relevance | path

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

123456

/foundation/ai/ai_engine/services/server/server_executor/include/
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()
Dsync_msg_handler.h59 int SendRequest(IRequest *request, SimpleEventNotifier<IResponse> &notifier);
69 … int ReceiveResponse(int timeOut, SimpleEventNotifier<IResponse> &notifier, IResponse *&response);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
Dtime_tick_monitor.cpp70 NotificationChain *notifier; in StopTimeTickMonitor() local
73 notifier = timeChangedNotifier_; in StopTimeTickMonitor()
76 if (notifier != nullptr) { in StopTimeTickMonitor()
77 notifier->UnRegisterEventType(TIME_CHANGE_EVENT); in StopTimeTickMonitor()
78 RefObject::KillAndDecObjRef(notifier); in StopTimeTickMonitor()
135 NotificationChain *notifier = nullptr; in TimeTick() local
138 notifier = timeChangedNotifier_; in TimeTick()
139 RefObject::IncObjRef(notifier); in TimeTick()
141 int ret = RuntimeContext::GetInstance()->ScheduleTask([notifier, changedOffset]() { in TimeTick()
142 if (notifier == nullptr) { in TimeTick()
[all …]
Dauto_launch.cpp160 … AutoLaunch::EnableKvStoreAutoLaunch(const KvDBProperties &properties, AutoLaunchNotifier notifier, in EnableKvStoreAutoLaunch() argument
169 …AutoLaunchItem autoLaunchItem { ptr, notifier, option.observer, option.conflictType, option.notifi… in EnableKvStoreAutoLaunch()
350 autoLaunchItem.notifier = autoLaunchItemMap_[identifier][userId].notifier; in ObserverFunc()
364 if (!autoLaunchItem.isWriteOpenNotified && autoLaunchItem.notifier != nullptr) { in ObserverFunc()
369 AutoLaunchNotifier notifier = autoLaunchItem.notifier; in ObserverFunc() local
370 … int retCode = RuntimeContext::GetInstance()->ScheduleTask([notifier, userId, appId, storeId] { in ObserverFunc()
372 notifier(userId, appId, storeId, AutoLaunchStatus::WRITE_OPENED); in ObserverFunc()
428 if (autoLaunchItem.isWriteOpenNotified && autoLaunchItem.notifier) { in DisableKvStoreAutoLaunch()
451 if (autoLaunchItem.notifier) { in CloseNotifier()
456 autoLaunchItem.notifier(userId, appId, storeId, AutoLaunchStatus::WRITE_CLOSED); in CloseNotifier()
[all …]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
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()
56 void RdbWatcher::SetNotifier(sptr<RdbNotifierProxy> notifier) in SetNotifier() argument
59 if (notifier_ == notifier) { in SetNotifier()
62 notifier_ = notifier; in SetNotifier()
/foundation/deviceprofile/device_info_manager/services/core/test/unittest/
Dsubscribe_manager_test.cpp220 sptr<IRemoteObject> notifier = variable
224 …int32_t ret = SubscribeManager::GetInstance().SubscribeProfileEvents(subscribeInfos, notifier, fai…
237 sptr<IRemoteObject> notifier = variable
243 …int32_t ret = SubscribeManager::GetInstance().SubscribeProfileEvents(subscribeInfos, notifier, fai…
256 sptr<IRemoteObject> notifier = variable
270 …int32_t ret = SubscribeManager::GetInstance().SubscribeProfileEvents(subscribeInfos, notifier, fai…
283 sptr<IRemoteObject> notifier = variable
289 …int32_t ret = SubscribeManager::GetInstance().UnsubscribeProfileEvents(profileEvents, notifier, fa…
302 sptr<IRemoteObject> notifier = variable
308 SubscribeManager::GetInstance().TryAddNotifierLocked(notifier, subProfileEvents);
[all …]
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;
/foundation/ai/ai_engine/services/server/server_executor/source/
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()
/foundation/ability/dmsfwk/services/dtbabilitymgr/src/continuation_manager/
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()
/foundation/deviceprofile/device_info_manager/interfaces/innerkits/core/src/
Ddistributed_device_profile_client.cpp171 sptr<IRemoteObject> notifier; in SubscribeProfileEvents() local
174 notifier = iter->second.notifier; in SubscribeProfileEvents()
176 notifier = sptr<ProfileEventNotifierStub>( in SubscribeProfileEvents()
187 int32_t errCode = dps->SubscribeProfileEvents(subscribeInfos, notifier, failedEvents); in SubscribeProfileEvents()
198 SubscribeRecord record {subscribeInfos, notifier, subProfileEvents}; in SubscribeProfileEvents()
230 sptr<IRemoteObject> notifier = iter->second.notifier; in UnsubscribeProfileEvents() local
239 int32_t errCode = dps->UnsubscribeProfileEvents(profileEvents, notifier, failedEvents); in UnsubscribeProfileEvents()
263 sptr<IRemoteObject> notifier = in SyncDeviceProfile() local
265 return dps->SyncDeviceProfile(syncOptions, notifier); in SyncDeviceProfile()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/
Ddistributed_object_store_impl.cpp184 uint32_t DistributedObjectStoreImpl::SetStatusNotifier(std::shared_ptr<StatusNotifier> notifier) in SetStatusNotifier() argument
190 …td::shared_ptr<StatusNotifierProxy> watcherProxy = std::make_shared<StatusNotifierProxy>(notifier); in SetStatusNotifier()
237 if (notifier != nullptr) { in OnChanged()
238 notifier->OnChanged(sessionId, networkId, onlineStatus); in OnChanged()
242 …ierProxy::StatusNotifierProxy(const std::shared_ptr<StatusNotifier> &notifier) : notifier(notifier) in StatusNotifierProxy() argument
249 notifier = nullptr; in ~StatusNotifierProxy()
/foundation/ability/dmsfwk/services/dtbabilitymgr/include/
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);
/foundation/ability/dmsfwk/services/dtbabilitymgr/src/
Ddistributed_ability_manager_service.cpp208 int32_t token, const std::string& cbType, const sptr<IRemoteObject>& notifier) in RegisterDeviceSelectionCallback() argument
229 iter->second->SetNotifier(cbType, notifier); in RegisterDeviceSelectionCallback()
232 notifierInfo->SetNotifier(cbType, notifier); in RegisterDeviceSelectionCallback()
234 notifier->AddDeathRecipient(notifierDeathRecipient_); in RegisterDeviceSelectionCallback()
442 auto notifier = callbackMap_[token]->GetNotifier(EVENT_CONNECT); in OnDeviceConnect() local
443 if (!HandleDeviceConnect(notifier, continuationResults)) { in OnDeviceConnect()
462 auto notifier = callbackMap_[token]->GetNotifier(EVENT_DISCONNECT); in OnDeviceDisconnect() local
463 if (!HandleDeviceDisconnect(notifier, continuationResults)) { in OnDeviceDisconnect()
574 bool DistributedAbilityManagerService::HandleDeviceConnect(const sptr<IRemoteObject>& notifier, in HandleDeviceConnect() argument
581 auto func = [notifier, continuationResults]() { in HandleDeviceConnect()
[all …]
/foundation/arkui/ace_engine/test/unittest/core/common/storage/
Dstorage_test.cpp92 auto notifier = [](const std::string& onlineStatus) { return; }; in __anon90d1b5de0102() variable
95 …istributedStorage = StorageProxy::GetInstance()->GetStorage(testSessionId, notifier, taskExecutor);
136 auto notifier = [](const std::string& onlineStatus) { return; }; in __anon90d1b5de0202() variable
139 …istributedStorage = StorageProxy::GetInstance()->GetStorage(testSessionId, notifier, taskExecutor);
/foundation/ability/dmsfwk/services/dtbabilitymgr/test/unittest/
Ddistributed_ability_manager_service_test.cpp396 sptr<DeviceSelectionNotifierTest> notifier = new DeviceSelectionNotifierTest(); variable
397 ret = dtbabilitymgrService_->RegisterDeviceSelectionCallback(token, EVENT_CONNECT, notifier);
399 ret = dtbabilitymgrService_->RegisterDeviceSelectionCallback(token, EVENT_CONNECT, notifier);
429 sptr<DeviceSelectionNotifierTest> notifier = new DeviceSelectionNotifierTest(); variable
430 ret = dtbabilitymgrService_->RegisterDeviceSelectionCallback(token, EVENT_CONNECT, notifier);
432 ret = dtbabilitymgrService_->RegisterDeviceSelectionCallback(token, EVENT_DISCONNECT, notifier);
463 sptr<DeviceSelectionNotifierTest> notifier = new DeviceSelectionNotifierTest(); variable
468 ret = dtbabilitymgrService_->RegisterDeviceSelectionCallback(token, EVENT_CONNECT, notifier);
544 sptr<DeviceSelectionNotifierTest> notifier = new DeviceSelectionNotifierTest(); variable
545 ret = dtbabilitymgrService_->RegisterDeviceSelectionCallback(token, EVENT_CONNECT, notifier);
[all …]
/foundation/multimedia/player_framework/services/engine/gstreamer/common/playbin_adapter/
Dplaybin_sink_provider.h45 virtual void SetMsgNotifier(PlayBinMsgNotifier notifier) in SetMsgNotifier() argument
47 (void)notifier; in SetMsgNotifier()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/include/
Dauto_launch_export.h35 KvStoreNbConflictNotifier notifier; member
52 AutoLaunchNotifier notifier; member
/foundation/ability/dmsfwk/services/dtbabilitymgr/include/continuation_manager/
Dnotifier_info.h39 void SetNotifier(const std::string& cbType, const sptr<IRemoteObject>& notifier);
41 bool QueryNotifier(const sptr<IRemoteObject>& notifier) const;
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/
Ddistributed_objectstore_impl.h43 uint32_t SetStatusNotifier(std::shared_ptr<StatusNotifier> notifier) override;
58 StatusNotifierProxy(const std::shared_ptr<StatusNotifier> &notifier);
63 std::shared_ptr<StatusNotifier> notifier;
/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_manager_test/
Ddhcp_controller_test.cpp121 std::unique_ptr<DhcpController::DhcpControllerResultNotify> notifier = variable
126 notifier->OnSuccess(status, ifname, result);
128 notifier->OnFailed(status, ifname, reason);
129 notifier->OnSerExitNotify(ifname);
/foundation/arkui/ace_engine/frameworks/core/common/storage/
Dstorage_proxy.cpp48 …std::function<void(const std::string&)>&& notifier, const RefPtr<TaskExecutor>& taskExecutor) const in GetStorage() argument
51 return distributedDelegate_->GetStorage(sessionId, std::move(notifier), taskExecutor); in GetStorage()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
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);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
Ddistributeddb_auto_launch_test.cpp214 option.notifier = nullptr;
269 …auto notifier = [&cvMutex, &cv, &finished, &statusMap] (const std::string &userId, const std::stri… variable
288 option.notifier = nullptr;
290 …EXPECT_TRUE(RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propA, notifier, option) == E…
291 …EXPECT_TRUE(RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propB, notifier, option) == E…
346 …auto notifier = [&cvMutex, &cv, &finished, &statusMap] (const std::string &userId, const std::stri… variable
364 option.notifier = nullptr;
366 int errCode = RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propA, notifier, option);
368 errCode = RuntimeContext::GetInstance()->EnableKvStoreAutoLaunch(g_propB, notifier, option);
423 option.notifier = nullptr;
[all …]
/foundation/multimedia/player_framework/services/engine/gstreamer/player/
Dplayer_codec_ctrl.h34 CapsFixErrorNotifier notifier);
43 CapsFixErrorNotifier notifier);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/
Dauto_launch_callback.cpp51 param.notifier = autoLaunchParam_.notifier; in AutoLaunchRequestNotifier()

123456