| /system/core/libutils/ |
| D | Looper_test.cpp | 117 virtual int handler(int fd, int events) = 0;
121 return static_cast<CallbackHandler*>(data)->handler(fd, events); in staticHandler()
138 virtual int handler(int fd, int events) { in handler() function in android::StubCallbackHandler
220 StubCallbackHandler handler(true); in TEST_F() local
222 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
232 EXPECT_EQ(0, handler.callbackCount) in TEST_F()
238 StubCallbackHandler handler(true); in TEST_F() local
241 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
251 EXPECT_EQ(1, handler.callbackCount) in TEST_F()
253 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
97 WillOnce(Invoke(bind(CaptureStationEventHandler, &handler, _1, _2))); in TEST_F()
111 handler(NEW_STATION, fake_mac_address_01); in TEST_F()
115 handler(NEW_STATION, fake_mac_address_02); in TEST_F()
119 handler(DEL_STATION, fake_mac_address_01); in TEST_F()
126 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/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()
536 const auto handler = on_station_event_handler_.find(if_index); in BroadcastHandler() local
537 if (handler != on_station_event_handler_.end()) { in BroadcastHandler()
544 handler->second(NEW_STATION, mac_address); in BroadcastHandler()
546 handler->second(DEL_STATION, mac_address); in BroadcastHandler()
591 for (const auto& handler : on_reg_domain_changed_handler_) { in OnRegChangeEvent() local
592 handler.second(country_code); in OnRegChangeEvent()
603 const auto handler = on_mlme_event_handler_.find(if_index); in OnMlmeEvent() local
604 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 …]
|
| D | name_db.cc | 41 …adRemoteNameRequest(hci::Address address, ReadRemoteNameDbCallback callback, os::Handler* handler);
68 hci::Address address, ReadRemoteNameDbCallback callback, os::Handler* handler) { in ReadRemoteNameRequest() argument
74 address_to_pending_read_map_[address] = {std::move(callback), std::move(handler)}; in ReadRemoteNameRequest()
119 hci::Address address, ReadRemoteNameDbCallback callback, os::Handler* handler) { in ReadRemoteNameRequest() argument
125 handler)); in ReadRemoteNameRequest()
|
| /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/core/adb/fdevent/ |
| D | fdevent_test.cpp | 55 FdHandler* handler = reinterpret_cast<FdHandler*>(userdata); in FdEventCallback() local
58 ASSERT_EQ(fd, handler->read_fd_); in FdEventCallback()
61 handler->queue_.push(c); in FdEventCallback()
62 fdevent_add(handler->write_fde_, FDE_WRITE); in FdEventCallback()
65 ASSERT_EQ(fd, handler->write_fd_); in FdEventCallback()
66 ASSERT_FALSE(handler->queue_.empty()); in FdEventCallback()
67 char c = handler->queue_.front(); in FdEventCallback()
68 handler->queue_.pop(); in FdEventCallback()
70 if (handler->queue_.empty()) { in FdEventCallback()
71 fdevent_del(handler->write_fde_, FDE_WRITE); in FdEventCallback()
[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/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/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/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 | 59 …void RegisterLinkSecurityInterfaceListener(os::Handler* handler, LinkSecurityInterfaceListener* li… in RegisterLinkSecurityInterfaceListener()
61 module_impl_->link_manager_.RegisterLinkSecurityInterfaceListener(handler, listener); in RegisterLinkSecurityInterfaceListener()
120 os::Handler* handler, LinkSecurityInterfaceListener* listener) { in GetSecurityInterface() argument
121 pimpl_->security_interface_impl_.RegisterLinkSecurityInterfaceListener(handler, listener); in GetSecurityInterface()
|
| D | fixed_channel_manager_mock.h | 32 …::Address device, OnConnectionFailureCallback on_fail_callback, os::Handler* handler), (override));
35 OnConnectionOpenCallback on_connection_open, os::Handler* handler),
|
| /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/hci/ |
| D | hci_layer.cc | 170 void register_event(EventCode event, ContextualCallback<void(EventPacketView)> handler) { in register_event()
173 event_handlers_[event] = handler; in register_event()
180 void register_le_event(SubeventCode event, ContextualCallback<void(LeMetaEventView)> handler) { in register_le_event()
183 subevent_handlers_[event] = handler; in register_le_event()
268 …ciLayer::RegisterEventHandler(EventCode event, ContextualCallback<void(EventPacketView)> handler) { in RegisterEventHandler() argument
269 CallOn(impl_, &impl::register_event, event, handler); in RegisterEventHandler()
276 …er::RegisterLeEventHandler(SubeventCode event, ContextualCallback<void(LeMetaEventView)> handler) { in RegisterLeEventHandler() argument
277 CallOn(impl_, &impl::register_le_event, event, handler); in RegisterLeEventHandler()
361 Handler* handler = GetHandler(); in Start() local
362 …impl_->acl_queue_.GetDownEnd()->RegisterDequeue(handler, BindOn(impl_, &impl::on_outbound_acl_read… in Start()
[all …]
|
| D | acl_manager_mock.h | 45 … RegisterCallbacks, (ConnectionManagementCallbacks * callbacks, os::Handler* handler), (override));
58 …egisterCallbacks, (LeConnectionManagementCallbacks * callbacks, os::Handler* handler), (override));
68 …MOCK_METHOD(void, RegisterCallbacks, (ConnectionCallbacks * callbacks, os::Handler* handler), (ove…
69 …MOCK_METHOD(void, RegisterLeCallbacks, (LeConnectionCallbacks * callbacks, os::Handler* handler), …
|
| /system/bt/gd/os/ |
| 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()
|