| /system/core/libutils/ |
| D | Looper_test.cpp | 83 virtual int handler(int fd, int events) = 0;
87 return static_cast<CallbackHandler*>(data)->handler(fd, events); in staticHandler()
104 virtual int handler(int fd, int events) { in handler() function in android::StubCallbackHandler
186 StubCallbackHandler handler(true); in TEST_F() local
188 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
198 EXPECT_EQ(0, handler.callbackCount) in TEST_F()
204 StubCallbackHandler handler(true); in TEST_F() local
207 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
217 EXPECT_EQ(1, handler.callbackCount) in TEST_F()
219 EXPECT_EQ(pipe.receiveFd, handler.fd) in TEST_F()
[all …]
|
| D | Looper.cpp | 25 WeakMessageHandler::WeakMessageHandler(const wp<MessageHandler>& handler) : in WeakMessageHandler() argument
26 mHandler(handler) { in WeakMessageHandler()
33 sp<MessageHandler> handler = mHandler.promote(); in handleMessage() local
34 if (handler != nullptr) { in handleMessage()
35 handler->handleMessage(message); in handleMessage()
315 sp<MessageHandler> handler = messageEnvelope.handler; in pollInner() local
323 this, handler.get(), message.what); in pollInner()
325 handler->handleMessage(message); in pollInner()
575 void Looper::sendMessage(const sp<MessageHandler>& handler, const Message& message) { in sendMessage() argument
577 sendMessageAtTime(now, handler, message); in sendMessage()
[all …]
|
| /system/connectivity/wificond/tests/ |
| D | ap_interface_impl_unittest.cpp | 60 OnStationEventHandler handler) { in CaptureStationEventHandler() argument
61 *out_handler = handler; in CaptureStationEventHandler()
67 OnChannelSwitchEventHandler handler) { in CaptureChannelSwitchEventHandler() argument
68 *out_handler = handler; in CaptureChannelSwitchEventHandler()
94 OnStationEventHandler handler; in TEST_F() local
96 .WillOnce(Invoke(bind(CaptureStationEventHandler, &handler, _1, _2))); in TEST_F()
110 handler(NEW_STATION, fake_mac_address_01); in TEST_F()
111 handler(NEW_STATION, fake_mac_address_02); in TEST_F()
112 handler(DEL_STATION, fake_mac_address_01); in TEST_F()
116 OnStationEventHandler handler; in TEST_F() local
[all …]
|
| D | mock_netlink_utils.h | 46 MlmeEventHandler* handler));
49 OnRegDomainChangedHandler handler));
52 OnStationEventHandler handler));
55 OnChannelSwitchEventHandler handler));
58 OnFrameTxStatusEventHandler handler));
|
| /system/core/libcutils/ |
| D | qtaguid.cpp | 58 netdHandler handler = {stubTagSocket, stubUntagSocket, stubSetCounterSet, stubDeleteTagData}; in initHandler() local
63 return handler; in initHandler()
66 handler.netdTagSocket = (int (*)(int, uint32_t, uid_t))dlsym(netdClientHandle, "tagSocket"); in initHandler()
67 if (!handler.netdTagSocket) { in initHandler()
71 handler.netdUntagSocket = (int (*)(int))dlsym(netdClientHandle, "untagSocket"); in initHandler()
72 if (!handler.netdUntagSocket) { in initHandler()
76 handler.netdSetCounterSet = (int (*)(uint32_t, uid_t))dlsym(netdClientHandle, "setCounterSet"); in initHandler()
77 if (!handler.netdSetCounterSet) { in initHandler()
81 handler.netdDeleteTagData = (int (*)(uint32_t, uid_t))dlsym(netdClientHandle, "deleteTagData"); in initHandler()
82 if (!handler.netdDeleteTagData) { in initHandler()
[all …]
|
| /system/core/fs_mgr/libsnapshot/ |
| D | snapuserd_server.cpp | 126 auto handler = AddHandler(out[1], out[2], out[3]); in Receivemsg() local
127 if (!handler) { in Receivemsg()
131 auto retval = "success," + std::to_string(handler->snapuserd()->GetNumSectors()); in Receivemsg()
204 void SnapuserdServer::RunThread(std::shared_ptr<DmUserHandler> handler) { in RunThread() argument
205 LOG(INFO) << "Entering thread for handler: " << handler->misc_name(); in RunThread()
207 if (!handler->snapuserd()->Start()) { in RunThread()
211 handler->snapuserd()->CloseFds(); in RunThread()
212 handler->snapuserd()->CheckMergeCompletionStatus(); in RunThread()
213 handler->snapuserd()->UnmapBufferRegion(); in RunThread()
215 auto misc_name = handler->misc_name(); in RunThread()
[all …]
|
| /system/connectivity/wificond/net/ |
| D | netlink_manager.cpp | 265 std::function<void(unique_ptr<const NL80211Packet>)> handler) { in RegisterHandlerAndSendMessage() argument
273 message_handlers_[packet.GetMessageSequence()] = handler; in RegisterHandlerAndSendMessage()
537 const auto handler = on_station_event_handler_.find(if_index); in BroadcastHandler() local
538 if (handler != on_station_event_handler_.end()) { in BroadcastHandler()
545 handler->second(NEW_STATION, mac_address); in BroadcastHandler()
547 handler->second(DEL_STATION, mac_address); in BroadcastHandler()
592 for (const auto& handler : on_reg_domain_changed_handler_) { in OnRegChangeEvent() local
593 handler.second(handler.first, country_code); in OnRegChangeEvent()
604 const auto handler = on_mlme_event_handler_.find(if_index); in OnMlmeEvent() local
605 if (handler == on_mlme_event_handler_.end()) { in OnMlmeEvent()
[all …]
|
| D | netlink_manager.h | 149 std::function<void(std::unique_ptr<const NL80211Packet>)> handler);
200 OnScanResultsReadyHandler handler);
214 MlmeEventHandler* handler);
230 OnSchedScanResultsReadyHandler handler);
241 OnRegDomainChangedHandler handler);
252 OnStationEventHandler handler);
263 OnChannelSwitchEventHandler handler);
270 uint32_t interface_index, OnFrameTxStatusEventHandler handler);
|
| /system/bt/gd/neighbor/ |
| D | name.cc | 36 os::Handler* handler; member
41 os::Handler* handler; member
53 os::Handler* handler);
54 …void CancelRemoteNameRequest(hci::Address address, CancelRemoteNameCallback, os::Handler* handler);
129 read_callback_handler->handler->Post(common::BindOnce( in OnEvent()
157 os::Handler* handler) { in ReadRemoteNameRequest() argument
162 …handler->Post(common::BindOnce(std::move(callback), hci::ErrorCode::UNSPECIFIED_ERROR, address, kE… in ReadRemoteNameRequest()
167 .handler = handler, in ReadRemoteNameRequest()
175 hci::Address address, CancelRemoteNameCallback callback, os::Handler* handler) { in CancelRemoteNameRequest() argument
180 … handler->Post(common::BindOnce(std::move(callback), hci::ErrorCode::UNSPECIFIED_ERROR, address)); in CancelRemoteNameRequest()
[all …]
|
| /system/update_engine/client_library/ |
| D | client_dbus.cc | 163 for (auto handler : handlers_) { in DBusStatusHandlersRegistered() local
164 handler->IPCError("Could not connect to" + signal_name + " on " + in DBusStatusHandlersRegistered()
173 StatusUpdateHandler* handler) const { in StatusUpdateHandlersRegistered()
176 handler->IPCError("Could not query current status"); in StatusUpdateHandlersRegistered()
180 std::vector<update_engine::StatusUpdateHandler*> just_handler = {handler}; in StatusUpdateHandlersRegistered()
181 for (auto h : handler ? just_handler : handlers_) { in StatusUpdateHandlersRegistered()
191 for (auto handler : handlers_) { in RunStatusUpdateHandlers() local
192 handler->HandleStatusUpdate(ue_status); in RunStatusUpdateHandlers()
197 StatusUpdateHandler* handler) { in UnregisterStatusUpdateHandler() argument
198 auto it = std::find(handlers_.begin(), handlers_.end(), handler); in UnregisterStatusUpdateHandler()
[all …]
|
| /system/bt/gd/common/ |
| D | callback_list.h | 47 CallbackWithHandler(base::RepeatingCallback<CallbackType> callback, os::Handler* handler) in CallbackWithHandler()
48 : callback(callback), handler(handler) {} in CallbackWithHandler()
59 os::Handler* handler; member
76 cb->handler->Post(base::Bind(cb->callback, args...)); in Notify()
|
| D | bidi_queue.h | 36 void RegisterEnqueue(::bluetooth::os::Handler* handler, EnqueueCallback callback) override { in RegisterEnqueue() argument
37 tx_->RegisterEnqueue(handler, callback); in RegisterEnqueue()
44 void RegisterDequeue(::bluetooth::os::Handler* handler, DequeueCallback callback) override { in RegisterDequeue() argument
45 rx_->RegisterDequeue(handler, callback); in RegisterDequeue()
|
| /system/bt/gd/hci/ |
| D | vendor_specific_event_manager.cc | 33 void start(os::Handler* handler, hci::HciLayer* hci_layer, hci::Controller* controller) { in start()
34 module_handler_ = handler; in start()
38 …EventCode::VENDOR_SPECIFIC, handler->BindOn(this, &VendorSpecificEventManager::impl::on_vendor_spe… in start()
44 …r_event(VseSubeventCode event, common::ContextualCallback<void(VendorSpecificEventView)> handler) { in register_event()
50 subevent_handlers_[event] = handler; in register_event()
123 VseSubeventCode event, common::ContextualCallback<void(VendorSpecificEventView)> handler) { in RegisterEventHandler() argument
124 CallOn(pimpl_.get(), &impl::register_event, event, handler); in RegisterEventHandler()
|
| D | hci_layer.cc | 240 void register_event(EventCode event, ContextualCallback<void(EventView)> handler) { in register_event()
248 event_handlers_[event] = handler; in register_event()
255 void register_le_meta_event(ContextualCallback<void(EventView)> handler) { in register_le_meta_event()
261 event_handlers_[EventCode::LE_META_EVENT] = handler; in register_le_meta_event()
268 void register_le_event(SubeventCode event, ContextualCallback<void(LeMetaEventView)> handler) { in register_le_event()
271 subevent_handlers_[event] = handler; in register_le_event()
409 void HciLayer::RegisterEventHandler(EventCode event, ContextualCallback<void(EventView)> handler) { in RegisterEventHandler() argument
410 CallOn(impl_, &impl::register_event, event, handler); in RegisterEventHandler()
413 void HciLayer::RegisterLeMetaEventHandler(ContextualCallback<void(EventView)> handler) { in RegisterLeMetaEventHandler() argument
414 CallOn(impl_, &impl::register_le_meta_event, handler); in RegisterLeMetaEventHandler()
[all …]
|
| D | acl_manager_mock.h | 45 … RegisterCallbacks, (ConnectionManagementCallbacks * callbacks, os::Handler* handler), (override));
61 …egisterCallbacks, (LeConnectionManagementCallbacks * callbacks, os::Handler* handler), (override));
72 …MOCK_METHOD(void, RegisterCallbacks, (ConnectionCallbacks * callbacks, os::Handler* handler), (ove…
73 …MOCK_METHOD(void, RegisterLeCallbacks, (LeConnectionCallbacks * callbacks, os::Handler* handler), …
|
| /system/bt/gd/l2cap/classic/ |
| D | fixed_channel_manager.cc | 27 os::Handler* handler) { in ConnectServices() argument
29 .handler_ = handler, in ConnectServices()
39 … OnConnectionOpenCallback on_connection_open, os::Handler* handler) { in RegisterService() argument
41 .user_handler_ = handler, in RegisterService()
|
| D | l2cap_classic_module.cc | 63 …void RegisterLinkSecurityInterfaceListener(os::Handler* handler, LinkSecurityInterfaceListener* li… in RegisterLinkSecurityInterfaceListener()
65 module_impl_->link_manager_.RegisterLinkSecurityInterfaceListener(handler, listener); in RegisterLinkSecurityInterfaceListener()
128 os::Handler* handler, LinkSecurityInterfaceListener* listener) { in GetSecurityInterface() argument
129 pimpl_->security_interface_impl_.RegisterLinkSecurityInterfaceListener(handler, listener); in GetSecurityInterface()
133 void L2capClassicModule::SetLinkPropertyListener(os::Handler* handler, LinkPropertyListener* listen… in SetLinkPropertyListener() argument
134 pimpl_->link_manager_.RegisterLinkPropertyListener(handler, listener); in SetLinkPropertyListener()
|
| /system/bt/gd/l2cap/le/ |
| D | fixed_channel_manager.cc | 27 … OnConnectionFailureCallback on_fail_callback, os::Handler* handler) { in ConnectServices() argument
29 .handler_ = handler, in ConnectServices()
39 … OnConnectionOpenCallback on_connection_open, os::Handler* handler) { in RegisterService() argument
41 .user_handler_ = handler, in RegisterService()
|
| D | dynamic_channel_manager.cc | 30 … OnConnectionFailureCallback on_fail_callback, os::Handler* handler) { in ConnectChannel() argument
32 .handler_ = handler, in ConnectChannel()
47 … OnConnectionOpenCallback on_connection_open, os::Handler* handler) { in RegisterService() argument
49 .user_handler_ = handler, in RegisterService()
|
| /system/core/libutils/include/utils/ |
| D | Looper.h | 91 WeakMessageHandler(const wp<MessageHandler>& handler);
352 void sendMessage(const sp<MessageHandler>& handler, const Message& message);
362 void sendMessageDelayed(nsecs_t uptimeDelay, const sp<MessageHandler>& handler,
373 void sendMessageAtTime(nsecs_t uptime, const sp<MessageHandler>& handler,
382 void removeMessages(const sp<MessageHandler>& handler);
390 void removeMessages(const sp<MessageHandler>& handler, int what);
444 : uptime(u), handler(std::move(h)), message(m) {} in MessageEnvelope()
447 sp<MessageHandler> handler; member
|
| /system/bt/gd/l2cap/classic/internal/ |
| D | link_mock.h | 36 explicit MockLink(os::Handler* handler, l2cap::internal::ParameterProvider* parameter_provider) in MockLink() argument
37 …: Link(handler, std::make_unique<MockClassicAclConnection>(), parameter_provider, nullptr, nullptr… in MockLink()
38 explicit MockLink(os::Handler* handler, l2cap::internal::ParameterProvider* parameter_provider, in MockLink() argument
40 : Link(handler, std::move(acl_connection), parameter_provider, nullptr, nullptr, nullptr){}; in MockLink()
|
| /system/bt/gd/l2cap/internal/ |
| D | data_pipeline_manager.h | 58 DataPipelineManager(os::Handler* handler, ILink* link, LowerQueueUpEnd* link_queue_up_end) in DataPipelineManager() argument
59 …: handler_(handler), link_(link), scheduler_(std::make_unique<Fifo>(this, link_queue_up_end, handl… in DataPipelineManager()
60 receiver_(link_queue_up_end, handler, this) {} in DataPipelineManager()
|
| /system/bt/gd/os/ |
| D | mock_queue.h | 40 virtual void RegisterEnqueue(Handler* handler, EnqueueCallback callback) { in RegisterEnqueue() argument
42 registered_handler = handler; in RegisterEnqueue()
69 virtual void RegisterDequeue(Handler* handler, DequeueCallback callback) { in RegisterDequeue() argument
71 registered_handler = handler; in RegisterDequeue()
|
| D | queue.h | 42 virtual void RegisterEnqueue(Handler* handler, EnqueueCallback callback) = 0;
52 virtual void RegisterDequeue(Handler* handler, DequeueCallback callback) = 0;
71 void RegisterEnqueue(Handler* handler, EnqueueCallback callback) override;
76 void RegisterDequeue(Handler* handler, DequeueCallback callback) override;
116 void Enqueue(std::unique_ptr<T> t, os::Handler* handler) { in Enqueue() argument
120 …queue_->RegisterEnqueue(handler, common::Bind(&EnqueueBuffer<T>::enqueue_callback, common::Unretai… in Enqueue()
|
| /system/netd/libnetdutils/include/netdutils/ |
| D | ThreadUtil.h | 51 std::unique_ptr<T> handler(reinterpret_cast<T*>(obj)); in runAndDelete()
52 setThreadName(handler->threadName().c_str()); in runAndDelete()
53 handler->run(); in runAndDelete()
|