Searched refs:receiver (Results 1 - 25 of 25) sorted by relevance

/base/msdp/device_status/test/unittest/intention/common/src/
H A D	channel_test.cpp	51 auto [sender, receiver] = Channel<size_t>::OpenChannel(); in HWTEST_F() 53 receiver.Enable(); in HWTEST_F() 61 size_t received = receiver.Receive(); in HWTEST_F() 80 auto [sender, receiver] = Channel<size_t>::OpenChannel(); in HWTEST_F() 82 receiver.Enable(); in HWTEST_F() 93 size_t received = receiver.Receive(); in HWTEST_F() 109 auto [sender, receiver] = Channel<size_t>::OpenChannel(); in HWTEST_F() 122 auto [sender, receiver] = Channel<size_t>::OpenChannel(); in HWTEST_F() 124 receiver.Enable(); in HWTEST_F()
/base/sensors/miscdevice/services/miscdevice_service/src/
H A D	miscdevice_common_event_subscriber.cpp	26 const EventFwk::CommonEventSubscribeInfo &subscribeInfo, EventReceiver receiver) in MiscdeviceCommonEventSubscriber() 27 : EventFwk::CommonEventSubscriber(subscribeInfo), eventReceiver_(receiver) {} in MiscdeviceCommonEventSubscriber() 25 MiscdeviceCommonEventSubscriber( const EventFwk::CommonEventSubscribeInfo &subscribeInfo, EventReceiver receiver) MiscdeviceCommonEventSubscriber() argument
H A D	miscdevice_service.cpp	97 EventReceiver receiver) __attribute__((no_sanitize("cfi"))) in SubscribeCommonEvent() 99 if (receiver == nullptr) { in SubscribeCommonEvent() 100 MISC_HILOGE("receiver is nullptr"); in SubscribeCommonEvent() 106 auto subscribePtr = std::make_shared<MiscdeviceCommonEventSubscriber>(subscribeInfo, receiver); in SubscribeCommonEvent() 96 SubscribeCommonEvent(const std::string &eventName, EventReceiver receiver) SubscribeCommonEvent() argument
/base/powermgr/thermal_manager/services/native/src/thermal_observer/state_machine/
H A D	screen_state_collection.cpp	66 auto receiver = tms->GetStateMachineObj()->GetCommonEventReceiver(); in RegisterEvent() local 67 if (receiver == nullptr) { in RegisterEvent() 71 receiver->AddEvent(CommonEventSupport::COMMON_EVENT_SCREEN_ON, handlerOn); in RegisterEvent() 73 receiver->AddEvent(CommonEventSupport::COMMON_EVENT_SCREEN_OFF, handlerOff); in RegisterEvent()
H A D	charger_state_collection.cpp	77 auto receiver = tms->GetStateMachineObj()->GetCommonEventReceiver(); in RegisterEvent() local 78 if (receiver == nullptr) { in RegisterEvent() 85 receiver->AddEvent(CommonEventSupport::COMMON_EVENT_BATTERY_CHANGED, batteryChangedHandler); in RegisterEvent() 88 receiver->AddEvent(BatteryInfo::COMMON_EVENT_BATTERY_CHANGED_INNER, batteryChangedInnerHandler); in RegisterEvent() 92 receiver->AddEvent(CommonEventSupport::COMMON_EVENT_THERMAL_LEVEL_CHANGED, thermalLevelHandler); in RegisterEvent()
/base/hiviewdfx/hiview/plugins/sysevent_source/
H A D	event_server.cpp	256 for (auto receiver = receivers.begin(); receiver != receivers.end(); receiver++) { in ReceiveMsg() 257 (*receiver)->HandlerEvent(ConverRawData(buffer)); in ReceiveMsg() 323 for (auto receiver = receivers.begin(); receiver != receivers.end(); receiver++) { in ReceiveMsg() 324 (*receiver)->HandlerEvent(ConverRawData(buffer)); in ReceiveMsg() 426 void EventServer::AddReceiver(std::shared_ptr<EventReceiver> receiver) in AddReceiver() argument 428 receivers_.emplace_back(receiver); in AddReceiver() [all...]
/base/hiviewdfx/hiview/plugins/sysevent_source/test/fuzztest/common/eventserversocket_fuzzer/
H A D	eventserversocket_fuzzer.cpp	73 std::shared_ptr<SysEventReceiver> receiver = std::make_shared<SysEventReceiver>(source); in SysEventServerSocketFuzzTest() local 79 receiver->HandlerEvent(ConverRawData(buffer)); in SysEventServerSocketFuzzTest()
/base/sensors/miscdevice/services/miscdevice_service/include/
H A D	miscdevice_common_event_subscriber.h	29 MiscdeviceCommonEventSubscriber(const EventFwk::CommonEventSubscribeInfo &subscribeInfo, EventReceiver receiver);
H A D	miscdevice_service.h	105 int32_t SubscribeCommonEvent(const std::string &eventName, EventReceiver receiver);
/base/notification/common_event_service/services/src/
H A D	common_event_control_manager.cpp	457 HistorySubscriberRecord receiver; in EnqueueHistoryEventRecord() local 458 receiver.recordTime = vec->recordTime; in EnqueueHistoryEventRecord() 459 receiver.bundleName = vec->eventRecordInfo.bundleName; in EnqueueHistoryEventRecord() 460 receiver.priority = vec->eventSubscribeInfo->GetPriority(); in EnqueueHistoryEventRecord() 461 receiver.userId = vec->eventSubscribeInfo->GetUserId(); in EnqueueHistoryEventRecord() 462 receiver.permission = vec->eventSubscribeInfo->GetPermission(); in EnqueueHistoryEventRecord() 463 receiver.deviceId = vec->eventSubscribeInfo->GetDeviceId(); in EnqueueHistoryEventRecord() 464 receiver.isFreeze = vec->isFreeze; in EnqueueHistoryEventRecord() 465 receiver.freezeTime = vec->freezeTime; in EnqueueHistoryEventRecord() 466 record.receivers.emplace_back(receiver); in EnqueueHistoryEventRecord() 536 sptr<IEventReceive> receiver = iface_cast<IEventReceive>(eventRecordPtr->curReceiver); NotifyOrderedEvent() local 596 sptr<IEventReceive> receiver = iface_cast<IEventReceive>(sp->resultTo); ProcessNextOrderedEvent() local [all...]
/base/telephony/sms_mms/test/gtest/
H A D	mms_receiver_mgr_gtest.cpp	105 const std::shared_ptr<TelEventHandler> receiver = std::make_shared<MmsReceiveManager>(slotId); in HWTEST_F() local 106 EXPECT_EQ(TELEPHONY_SUCCESS, satelliteSmsClient.AddReceiveHandler(slotId, receiver)); in HWTEST_F()
/base/powermgr/power_manager/utils/shell/src/
H A D	power_shell_command.cpp	467 extern "C" void PrintDumpFileError(std::string& receiver, const char* path) in PrintDumpFileError() argument 469 receiver.append("Open Dump file ("); in PrintDumpFileError() 470 receiver.append(path); in PrintDumpFileError() 471 receiver.append(") failed: "); in PrintDumpFileError() 472 receiver.append(std::to_string(errno)); in PrintDumpFileError() 473 receiver.append("\n"); in PrintDumpFileError()
/base/account/os_account/services/accountmgr/src/appaccount/
H A D	app_account_subscribe_manager.cpp	287 for (auto receiver : record->receivers) { in OnAccountsChanged() 290 accessibleAccounts, receiver->bundleName, dataStoragePtr, record->appIndex); in OnAccountsChanged() 297 result = GetAccessibleAccountsBySubscribeInfo(receiver->subscribeInfoPtr, accessibleAccounts, appAccounts); in OnAccountsChanged() 303 auto appAccountEventProxy = iface_cast<IAppAccountEvent>(receiver->eventListener); in OnAccountsChanged()
/base/powermgr/thermal_manager/test/unittest/src/
H A D	thermal_observer_test.cpp	86 auto receiver = std::make_shared<ThermalCommonEventReceiver>(); in HWTEST_F() local 87 receiver->AddEvent(CommonEventSupport::COMMON_EVENT_SCREEN_ON, handlerOn); in HWTEST_F() 88 bool on = receiver->Register(); in HWTEST_F() 91 receiver->HandleEventChanged(data); in HWTEST_F()
/base/hiviewdfx/hiappevent/frameworks/js/napi/include/
H A D	napi_app_event_watcher.h	57 void InitReceiver(const napi_env env, const napi_value receiver);
/base/request/request/test/unittest/cpp_test/fwkTest/src/
H A D	response_message_receiver_test.cpp	385 ResponseMessageReceiver receiver = ResponseMessageReceiver(&handler, sockFd); in HWTEST_F() local 386 EXPECT_EQ(&handler, receiver.handler_); in HWTEST_F() 703 ResponseMessageReceiver receiver = ResponseMessageReceiver(&handler, sockFd); in HWTEST_F() local 704 receiver.OnReadable(fd[0]); in HWTEST_F() 730 receiver.OnReadable(fd[0]); in HWTEST_F() 736 receiver.OnReadable(fd[0]); in HWTEST_F() 742 receiver.messageId_ = msgId; in HWTEST_F() 743 receiver.OnReadable(fd[0]); in HWTEST_F()
/base/telephony/sms_mms/services/sms/satellite_service_interaction/src/
H A D	satellite_sms_client.cpp	171 int32_t SatelliteSmsClient::AddReceiveHandler(int32_t slotId, const std::shared_ptr<TelEventHandler> receiver) in AddReceiveHandler() argument 173 if (receiver == nullptr) { in AddReceiveHandler() 174 TELEPHONY_LOGE("AddReceiveHandler return, receiver is null."); in AddReceiveHandler() 178 receiverMap_.insert(std::make_pair(slotId, receiver)); in AddReceiveHandler()
/base/hiviewdfx/hiview/plugins/sysevent_source/include/
H A D	event_server.h	72 void AddReceiver(std::shared_ptr<EventReceiver> receiver);
/base/telephony/sms_mms/services/sms/include/satellite/
H A D	satellite_sms_client.h	43 int32_t AddReceiveHandler(int32_t slotId, const std::shared_ptr<TelEventHandler> receiver);
/base/hiviewdfx/hiappevent/frameworks/js/napi/src/
H A D	napi_hiappevent_watch.cpp	314 napi_value receiver = NapiUtil::GetProperty(env, watcher, RECEIVE_PROPERTY); in AddWatcher() local 315 if (receiver != nullptr) { in AddWatcher() 316 watcherPtr->InitReceiver(env, receiver); in AddWatcher()
/base/msdp/device_status/intention/cooperate/plugin/src/
H A D	cooperate.cpp	36 auto [sender, receiver] = Channel<CooperateEvent>::OpenChannel(); in Cooperate() 37 receiver_ = receiver; in Cooperate()
/base/notification/common_event_service/services/test/unittest/
H A D	ability_manager_helper_test.cpp	231 void RegisterCancelListener(const sptr<IWantSender> &sender, const sptr<IWantReceiver> &receiver) override 234 void UnregisterCancelListener(const sptr<IWantSender> &sender, const sptr<IWantReceiver> &receiver) override
H A D	common_event_subscribe_unit_test.cpp	291 void RegisterCancelListener(const sptr<IWantSender> &sender, const sptr<IWantReceiver> &receiver) override 294 void UnregisterCancelListener(const sptr<IWantSender> &sender, const sptr<IWantReceiver> &receiver) override
/base/request/request/test/fuzztest/downloaduploadmanager_fuzzer/
H A D	downloaduploadmanager_fuzzer.cpp	625 ResponseMessageReceiver receiver = ResponseMessageReceiver(handler, sockFd); in ResponseMessageFuzzTestResponseMessageReceiver() local
/base/msdp/device_status/test/unittest/intention/cooperate/src/
H A D	cooperate_plugin_test.cpp	388 auto [sender, receiver] = Channel<CooperateEvent>::OpenChannel(); in HWTEST_F() 559 auto [sender, receiver] = Channel<CooperateEvent>::OpenChannel(); in HWTEST_F()

Completed in 20 milliseconds

Indexes created Thu Nov 07 10:32:03 CST 2024