| /base/notification/eventhandler/frameworks/cj/src/ |
| H A D | emitter.cpp | 54 auto subscribe = g_emitterImpls.find(eventId); in IsExistValidCallback() local
55 if (subscribe == g_emitterImpls.end()) { in IsExistValidCallback()
59 for (auto callbackInfo : subscribe->second) { in IsExistValidCallback()
85 auto subscribe = g_emitterImpls.find(eventIdValue); in SearchCallbackInfo() local
86 if (subscribe == g_emitterImpls.end()) { in SearchCallbackInfo()
89 for (auto callbackInfo : subscribe->second) { in SearchCallbackInfo()
182 auto subscribe = g_emitterImpls.find(eventId); in Unsubscribe() local
183 if (subscribe != g_emitterImpls.end()) { in Unsubscribe()
184 for (auto callbackInfo : subscribe->second) { in Unsubscribe()
239 auto subscribe in GetListenerCountByEventId() local
314 auto subscribe = g_emitterImpls.find(eventId); ProcessEvent() local
328 auto subscribe = g_emitterImpls.find(eventId); ProcessEvent() local
[all...] |
| /base/web/webview/test/fuzztest/ohos_adapter/battery_adapter/receiveevent_fuzzer/ |
| H A D | receiveevent_fuzzer.cpp | 40 CommonEventSubscribeInfo subscribe; in ReceiveEventFuzzTest() local
43 NWebBatteryEventSubscriber batter(subscribe, eventCallback); in ReceiveEventFuzzTest()
|
| /base/request/request/services/src/service/command/ |
| H A D | subscribe.rs | 22 pub(crate) fn subscribe(&self, data: &mut MsgParcel, reply: &mut MsgParcel) -> IpcResult<()> {
24 info!("Service subscribe tid {}", task_id);
27 error!("End Service subscribe, failed: task_id not valid");
41 let (event, rx) = TaskManagerEvent::subscribe(task_id, token_id);
45 "End Service subscribe, tid: {}, failed: send event failed",
54 "End Service subscribe, tid: {}, failed: receives ret failed",
63 error!("End Service subscribe, tid: {}, failed: {:?}", task_id, ret);
68 let ret = self.client_manager.subscribe(task_id, pid, uid, token_id);
71 debug!("End Service subscribe ok: tid: {}", task_id);
74 error!("End Service subscribe, ti
[all...] |
| H A D | mod.rs | 28 mod subscribe; modules
|
| H A D | get_task.rs | 55 let ret = self.client_manager.subscribe(task_id, pid, uid, token_id);
57 error!("End Service subscribe, tid: {}, failed: {:?}", task_id, ret);
|
| H A D | construct.rs | 266 let ret = self.client_manager.subscribe(task_id, pid, uid, token_id);
268 error!("End Service subscribe, tid: {}, failed: {:?}", task_id, ret);
|
| /base/telephony/call_manager/test/unittest/call_earthquake_alarm_test/src/ |
| H A D | call_earthquake_alarm_test.cpp | 235 auto subscribe = std::make_shared<LocationSubscriber>(subscribeInfo); in HWTEST_F() local
236 subscribe->subscriber_ = subscribe; in HWTEST_F()
237 if (subscribe->subscriber_ == nullptr) { in HWTEST_F()
240 subscribe->Subscriber(); in HWTEST_F()
246 subscribe->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
249 subscribe->subscriber_->OnReceiveEvent(eventData); in HWTEST_F()
250 ASSERT_TRUE(subscribe->subscriber_ != nullptr); in HWTEST_F()
|
| /base/security/asset/services/core_service/src/ |
| H A D | common_event.rs | 21 pub(crate) use listener::subscribe;
|
| H A D | lib.rs | 130 common_event::subscribe(); in start_service()
|
| /base/notification/common_event_service/interfaces/kits/cj/src/ |
| H A D | common_event.cpp | 104 auto subscribe = subscriberImpls.find(subscriber); in DeleteSubscribe() local
105 if (subscribe != subscriberImpls.end()) { in DeleteSubscribe()
106 for (auto asyncCallbackInfoSubscribe : subscribe->second.asyncCallbackInfo) { in DeleteSubscribe()
111 subscriberImpls.erase(subscribe); in DeleteSubscribe()
|
| /base/customization/enterprise_device_management/interfaces/kits/admin_manager/include/ |
| H A D | admin_manager_addon.h | 74 bool subscribe = true; member
130 static napi_value HandleManagedEvent(napi_env env, napi_callback_info info, bool subscribe);
131 static napi_value HandleManagedEventSync(napi_env env, napi_callback_info info, bool subscribe);
|
| /base/notification/eventhandler/frameworks/napi/src/ |
| H A D | events_emitter.cpp | 244 auto subscribe = emitterInstances.find(eventIdValue); in SearchCallbackInfo() local
245 if (subscribe == emitterInstances.end()) { in SearchCallbackInfo()
248 for (auto callbackInfo : subscribe->second) { in SearchCallbackInfo()
517 auto subscribe = emitterInstances.find(eventId); in IsExistValidCallback() local
518 if (subscribe == emitterInstances.end()) { in IsExistValidCallback()
522 if (subscribe->second.size() != 0) { in IsExistValidCallback()
726 auto subscribe = emitterInstances.find(eventId); in JS_GetListenerCount() local
727 if (subscribe != emitterInstances.end()) { in JS_GetListenerCount()
728 for (auto it = subscribe->second.begin(); it != subscribe in JS_GetListenerCount()
[all...] |
| /base/request/request/services/tests/ |
| H A D | start.rs | 36 agent.subscribe(task_id); in sdv_start_basic()
|
| H A D | resume.rs | 36 agent.subscribe(task_id); in sdv_start_resume()
|
| /base/web/webview/test/unittest/battery_mgr_adapter_impl/ |
| H A D | battery_mgr_adapter_test.cpp | 79 CommonEventSubscribeInfo subscribe; in SetUpTestCase() local
82 g_batter = std::make_shared<NWebBatteryEventSubscriber>(subscribe, eventCallback); in SetUpTestCase()
|
| /base/customization/enterprise_device_management/services/edm/include/ |
| H A D | enterprise_device_mgr_stub.h | 54 ErrCode SubscribeManagedEventInner(MessageParcel &data, MessageParcel &reply, bool subscribe);
|
| H A D | enterprise_device_mgr_ability.h | 94 ErrCode HandleApplicationEvent(const std::vector<uint32_t> &events, bool subscribe);
|
| /base/customization/enterprise_device_management/interfaces/inner_api/common/include/ |
| H A D | enterprise_device_mgr_proxy.h | 50 bool subscribe);
|
| /base/account/os_account/interfaces/kits/napi/osaccount/src/ |
| H A D | napi_os_account.cpp | 1459 auto subscribe = g_osAccountSubscribers.find(subscribeCBInfo->osManager); in IsSubscribeInMap() local
1460 if (subscribe == g_osAccountSubscribers.end()) { in IsSubscribeInMap()
1463 auto it = subscribe->second.begin(); in IsSubscribeInMap()
1464 while (it != subscribe->second.end()) { in IsSubscribeInMap()
1487 ACCOUNT_LOGE("Parse subscribe failed"); in Subscribe()
1491 // make osaccount subscribe info in Subscribe()
1670 auto subscribe = g_osAccountSubscribers.find(unsubscribeCBInfo->osManager); in UnsubscribeSync() local
1671 if (subscribe == g_osAccountSubscribers.end()) { in UnsubscribeSync()
1674 auto item = subscribe->second.begin(); in UnsubscribeSync()
1675 while (item != subscribe in UnsubscribeSync()
[all...] |
| /base/security/security_guard/frameworks/js/napi/ |
| H A D | security_guard_napi.cpp | 1050 auto subscribe = g_subscribers.find(env); in IsSubscribeInMap() local
1051 if (subscribe == g_subscribers.end()) { in IsSubscribeInMap()
1054 auto it = subscribe->second.begin(); in IsSubscribeInMap()
1055 while (it != subscribe->second.end()) { in IsSubscribeInMap()
1260 SGLOGE("Parse subscribe failed"); in Subscribe()
1285 auto subscribe = g_subscribers.find(env); in UnsubscribeSync() local
1286 if (subscribe == g_subscribers.end()) { in UnsubscribeSync()
1289 auto item = subscribe->second.begin(); in UnsubscribeSync()
1290 while (item != subscribe->second.end()) { in UnsubscribeSync()
1303 item = subscribe in UnsubscribeSync()
[all...] |
| /base/account/os_account/interfaces/kits/napi/appaccount/src/ |
| H A D | napi_app_account.cpp | 1640 auto subscribe = g_AppAccountSubscribers.find(context->appAccountManager); in IsExitSubscribe() local
1641 if (subscribe == g_AppAccountSubscribers.end()) { in IsExitSubscribe()
1644 for (size_t index = 0; index < subscribe->second.size(); index++) { in IsExitSubscribe()
1645 if (CompareOnAndOffRef(env, subscribe->second[index]->callbackRef, context->callbackRef)) { in IsExitSubscribe()
1693 auto subscribe = g_AppAccountSubscribers.find(context->appAccountManager); in UnsubscribeSync() local
1694 if (subscribe == g_AppAccountSubscribers.end()) { in UnsubscribeSync()
1697 for (size_t index = 0; index < subscribe->second.size(); ++index) { in UnsubscribeSync()
1699 (!CompareOnAndOffRef(env, subscribe->second[index]->callbackRef, context->callbackRef))) { in UnsubscribeSync()
1702 int errCode = AppAccountManager::UnsubscribeAppAccount(subscribe->second[index]->subscriber); in UnsubscribeSync()
1707 delete subscribe in UnsubscribeSync()
[all...] |
| H A D | napi_app_account_common.cpp | 945 auto subscribe = g_AppAccountSubscribers.find(asyncContextForOff->appAccountManager); in UnsubscribeCallbackCompletedCB() local
946 if (subscribe != g_AppAccountSubscribers.end()) { in UnsubscribeCallbackCompletedCB()
947 for (auto offCBInfo : subscribe->second) { in UnsubscribeCallbackCompletedCB()
950 g_AppAccountSubscribers.erase(subscribe); in UnsubscribeCallbackCompletedCB()
|
| /base/customization/enterprise_device_management/interfaces/kits/admin_manager/src/ |
| H A D | admin_manager_addon.cpp | 496 napi_value AdminManager::HandleManagedEvent(napi_env env, napi_callback_info info, bool subscribe) in HandleManagedEvent() argument
522 asyncCallbackInfo->subscribe = subscribe; in HandleManagedEvent()
540 asyncCallbakInfo->subscribe); in NativeSubscribeManagedEvent()
777 napi_value AdminManager::HandleManagedEventSync(napi_env env, napi_callback_info info, bool subscribe) in HandleManagedEventSync() argument
799 int32_t ret = proxy->HandleManagedEvent(elementName, managedEvent, subscribe); in HandleManagedEventSync()
|
| /base/customization/enterprise_device_management/interfaces/inner_api/common/src/ |
| H A D | enterprise_device_mgr_proxy.cpp | 242 const std::vector<uint32_t> &events, bool subscribe) in HandleManagedEvent()
244 EDMLOGD("EnterpriseDeviceMgrProxy::SubscribeManagedEvent: %{public}d", subscribe); in HandleManagedEvent()
259 if (!subscribe) { in HandleManagedEvent()
241 HandleManagedEvent(const AppExecFwk::ElementName &admin, const std::vector<uint32_t> &events, bool subscribe) HandleManagedEvent() argument
|
| /base/customization/enterprise_device_management/services/edm/src/ |
| H A D | enterprise_device_mgr_stub.cpp | 308 ErrCode EnterpriseDeviceMgrStub::SubscribeManagedEventInner(MessageParcel &data, MessageParcel &reply, bool subscribe) in SubscribeManagedEventInner() argument
318 if (subscribe) { in SubscribeManagedEventInner()
|