| /system/core/libutils/tests/ |
| D | Looper_test.cpp | 63 virtual int handler(int fd, int events) = 0;
67 return static_cast<CallbackHandler*>(data)->handler(fd, events); in staticHandler()
84 virtual int handler(int fd, int events) { in handler() function in android::StubCallbackHandler
166 StubCallbackHandler handler(true); in TEST_F() local
168 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
178 EXPECT_EQ(0, handler.callbackCount) in TEST_F()
184 StubCallbackHandler handler(true); in TEST_F() local
187 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
197 EXPECT_EQ(1, handler.callbackCount) in TEST_F()
199 EXPECT_EQ(pipe.receiveFd, handler.fd) in TEST_F()
[all …]
|
| /system/update_engine/client_library/ |
| D | client_dbus.cc | 132 for (auto handler : handlers_) { in DBusStatusHandlersRegistered() local
133 handler->IPCError("Could not connect to" + signal_name + in DBusStatusHandlersRegistered()
142 StatusUpdateHandler* handler) const { in StatusUpdateHandlersRegistered()
154 handler->IPCError("Could not query current status"); in StatusUpdateHandlersRegistered()
158 std::vector<update_engine::StatusUpdateHandler*> just_handler = {handler}; in StatusUpdateHandlersRegistered()
159 for (auto h : handler ? just_handler : handlers_) { in StatusUpdateHandlersRegistered()
174 for (auto handler : handlers_) { in RunStatusUpdateHandlers() local
175 handler->HandleStatusUpdate( in RunStatusUpdateHandlers()
181 StatusUpdateHandler* handler) { in UnregisterStatusUpdateHandler() argument
182 auto it = std::find(handlers_.begin(), handlers_.end(), handler); in UnregisterStatusUpdateHandler()
[all …]
|
| D | client_binder.cc | 155 for (auto& handler : client_->handlers_) { in HandleStatusUpdate() local
156 handler->HandleStatusUpdate(last_checked_time, progress, update_status, in HandleStatusUpdate()
164 StatusUpdateHandler* handler) { in RegisterStatusUpdateHandler() argument
173 handlers_.push_back(handler); in RegisterStatusUpdateHandler()
183 handler->IPCError("Could not get status from binder service"); in RegisterStatusUpdateHandler()
186 handler->HandleStatusUpdate(last_checked_time, progress, update_status, in RegisterStatusUpdateHandler()
193 StatusUpdateHandler* handler) { in UnregisterStatusUpdateHandler() argument
194 auto it = std::find(handlers_.begin(), handlers_.end(), handler); in UnregisterStatusUpdateHandler()
|
| D | client_dbus.h | 76 bool RegisterStatusUpdateHandler(StatusUpdateHandler* handler) override;
77 bool UnregisterStatusUpdateHandler(StatusUpdateHandler* handler) override;
91 void StatusUpdateHandlersRegistered(StatusUpdateHandler* handler) const;
|
| /system/connectivity/wificond/net/ |
| D | netlink_manager.cpp | 242 std::function<void(unique_ptr<const NL80211Packet>)> handler) { in RegisterHandlerAndSendMessage() argument
250 message_handlers_[packet.GetMessageSequence()] = handler; in RegisterHandlerAndSendMessage()
513 const auto handler = on_station_event_handler_.find(if_index); in BroadcastHandler() local
514 if (handler != on_station_event_handler_.end()) { in BroadcastHandler()
521 handler->second(NEW_STATION, mac_address); in BroadcastHandler()
523 handler->second(DEL_STATION, mac_address); in BroadcastHandler()
566 const auto handler = on_reg_domain_changed_handler_.find(wiphy_index); in OnRegChangeEvent() local
567 if (handler == on_reg_domain_changed_handler_.end()) { in OnRegChangeEvent()
572 handler->second(country_code); in OnRegChangeEvent()
582 const auto handler = on_mlme_event_handler_.find(if_index); in OnMlmeEvent() local
[all …]
|
| D | netlink_manager.h | 122 std::function<void(std::unique_ptr<const NL80211Packet>)> handler);
173 OnScanResultsReadyHandler handler);
187 MlmeEventHandler* handler);
203 OnSchedScanResultsReadyHandler handler);
214 OnRegDomainChangedHandler handler);
225 OnStationEventHandler handler);
|
| D | netlink_utils.cpp | 399 MlmeEventHandler* handler) { in SubscribeMlmeEvent() argument
400 netlink_manager_->SubscribeMlmeEvent(interface_index, handler); in SubscribeMlmeEvent()
409 OnRegDomainChangedHandler handler) { in SubscribeRegDomainChange() argument
410 netlink_manager_->SubscribeRegDomainChange(wiphy_index, handler); in SubscribeRegDomainChange()
418 OnStationEventHandler handler) { in SubscribeStationEvent() argument
419 netlink_manager_->SubscribeStationEvent(interface_index, handler); in SubscribeStationEvent()
|
| D | netlink_utils.h | 193 MlmeEventHandler* handler);
204 OnRegDomainChangedHandler handler);
215 OnStationEventHandler handler);
|
| /system/core/sdcard/ |
| D | fuse.cpp | 587 static int handle_lookup(struct fuse* fuse, struct fuse_handler* handler, in handle_lookup() argument
598 DLOG(INFO) << "[" << handler->token << "] LOOKUP " << name << " @ " << hdr->nodeid in handle_lookup()
613 static int handle_forget(struct fuse* fuse, struct fuse_handler* handler, in handle_forget() argument
620 DLOG(INFO) << "[" << handler->token << "] FORGET #" << req->nlookup in handle_forget()
634 static int handle_getattr(struct fuse* fuse, struct fuse_handler* handler, in handle_getattr() argument
642 DLOG(INFO) << "[" << handler->token << "] GETATTR flags=" << req->getattr_flags in handle_getattr()
657 static int handle_setattr(struct fuse* fuse, struct fuse_handler* handler, in handle_setattr() argument
666 DLOG(INFO) << "[" << handler->token << "] SETATTR fh=" << std::hex << req->fh in handle_setattr()
712 DLOG(INFO) << "[" << handler->token << "] Calling utimensat on " << path in handle_setattr()
721 static int handle_mknod(struct fuse* fuse, struct fuse_handler* handler, in handle_mknod() argument
[all …]
|
| /system/core/libutils/ |
| D | Looper.cpp | 23 WeakMessageHandler::WeakMessageHandler(const wp<MessageHandler>& handler) : in WeakMessageHandler() argument
24 mHandler(handler) { in WeakMessageHandler()
31 sp<MessageHandler> handler = mHandler.promote(); in handleMessage() local
32 if (handler != NULL) { in handleMessage()
33 handler->handleMessage(message); in handleMessage()
318 sp<MessageHandler> handler = messageEnvelope.handler; in pollInner() local
326 this, handler.get(), message.what); in pollInner()
328 handler->handleMessage(message); in pollInner()
578 void Looper::sendMessage(const sp<MessageHandler>& handler, const Message& message) { in sendMessage() argument
580 sendMessageAtTime(now, handler, message); in sendMessage()
[all …]
|
| /system/core/adb/ |
| D | fdevent_test.cpp | 45 FdHandler* handler = reinterpret_cast<FdHandler*>(userdata); in FdEventCallback() local
48 ASSERT_EQ(fd, handler->read_fd_); in FdEventCallback()
51 handler->queue_.push(c); in FdEventCallback()
52 fdevent_add(&handler->write_fde_, FDE_WRITE); in FdEventCallback()
55 ASSERT_EQ(fd, handler->write_fd_); in FdEventCallback()
56 ASSERT_FALSE(handler->queue_.empty()); in FdEventCallback()
57 char c = handler->queue_.front(); in FdEventCallback()
58 handler->queue_.pop(); in FdEventCallback()
60 if (handler->queue_.empty()) { in FdEventCallback()
61 fdevent_del(&handler->write_fde_, FDE_WRITE); in FdEventCallback()
|
| /system/core/libutils/include/utils/ |
| D | Looper.h | 87 WeakMessageHandler(const wp<MessageHandler>& handler);
348 void sendMessage(const sp<MessageHandler>& handler, const Message& message);
358 void sendMessageDelayed(nsecs_t uptimeDelay, const sp<MessageHandler>& handler,
369 void sendMessageAtTime(nsecs_t uptime, const sp<MessageHandler>& handler,
378 void removeMessages(const sp<MessageHandler>& handler);
386 void removeMessages(const sp<MessageHandler>& handler, int what);
440 const Message& m) : uptime(u), handler(h), message(m) { in MessageEnvelope()
444 sp<MessageHandler> handler; member
|
| /system/connectivity/wificond/scanning/offload/ |
| D | offload_service_utils.cpp | 39 OffloadDeathRecipientHandler handler) { in GetOffloadDeathRecipient() argument
40 return new OffloadDeathRecipient(handler); in GetOffloadDeathRecipient()
64 OffloadDeathRecipientHandler handler) in OffloadDeathRecipient() argument
65 : handler_(handler) {} in OffloadDeathRecipient()
|
| D | offload_service_utils.h | 34 OffloadDeathRecipient(OffloadDeathRecipientHandler handler);
58 OffloadDeathRecipientHandler handler);
|
| /system/connectivity/wificond/tests/ |
| D | ap_interface_impl_unittest.cpp | 55 OnStationEventHandler handler) { in CaptureStationEventHandler() argument
56 *out_handler = handler; in CaptureStationEventHandler()
127 OnStationEventHandler handler; in TEST_F() local
130 WillOnce(Invoke(bind(CaptureStationEventHandler, &handler, _1, _2))); in TEST_F()
142 handler(NEW_STATION, fake_mac_address); in TEST_F()
144 handler(NEW_STATION, fake_mac_address); in TEST_F()
146 handler(DEL_STATION, fake_mac_address); in TEST_F()
|
| D | mock_netlink_utils.h | 40 MlmeEventHandler* handler));
43 OnRegDomainChangedHandler handler));
46 OnStationEventHandler handler));
|
| /system/core/libcutils/tests/ |
| D | sockets_test.cpp | 132 cutils_socket_t handler = accept(server, nullptr, nullptr); in TEST() local
135 TestConnectedSockets(handler, client, SOCK_STREAM); in TEST()
154 cutils_socket_t handler = accept(server, nullptr, nullptr); in TEST() local
157 TestConnectedSockets(handler, client, SOCK_STREAM); in TEST()
177 cutils_socket_t handler = accept(server, nullptr, nullptr); in TEST() local
180 TestReceiveTimeout(handler); in TEST()
183 EXPECT_EQ(0, socket_close(handler)); in TEST()
|
| /system/update_engine/ |
| D | update_engine_client.cc | 503 auto handler = new UpdateWaitHandler(true, client_.get()); in ProcessFlags() local
504 handlers_.emplace_back(handler); in ProcessFlags()
505 client_->RegisterStatusUpdateHandler(handler); in ProcessFlags()
511 auto handler = new WatchingStatusUpdateHandler(); in ProcessFlags() local
512 handlers_.emplace_back(handler); in ProcessFlags()
513 client_->RegisterStatusUpdateHandler(handler); in ProcessFlags()
544 auto handler = new UpdateWaitHandler(false, nullptr); in ProcessFlags() local
545 handlers_.emplace_back(handler); in ProcessFlags()
546 client_->RegisterStatusUpdateHandler(handler); in ProcessFlags()
|
| D | sideload_main.cc | 149 brillo::AsynchronousSignalHandler handler; in ApplyUpdatePayload() local
150 handler.Init(); in ApplyUpdatePayload()
152 subprocess.Init(&handler); in ApplyUpdatePayload()
|
| /system/connectivity/wificond/aidl/android/net/wifi/ |
| D | IWifiScannerImpl.aidl | 51 oneway void subscribeScanEvents(IScanEvent handler); in subscribeScanEvents() argument
59 oneway void subscribePnoScanEvents(IPnoScanEvent handler); in subscribePnoScanEvents() argument
|
| /system/netd/server/ |
| D | thread_util.h | 39 std::unique_ptr<T> handler(reinterpret_cast<T*>(obj)); in runAndDelete()
40 handler->run(); in runAndDelete()
|
| D | NetlinkManager.cpp | 122 NetlinkHandler *handler = new NetlinkHandler(this, *sock, format); in setupSocket() local
123 if (handler->start()) { in setupSocket()
129 return handler; in setupSocket()
|
| D | DnsProxyListener.cpp | 63 void tryThreadOrError(SocketClient* cli, T* handler) { in tryThreadOrError() argument
66 const int rval = threadLaunch(handler); in tryThreadOrError()
77 delete handler; in tryThreadOrError()
388 DnsProxyListener::GetAddrInfoHandler* handler = in runCommand() local
391 tryThreadOrError(cli, handler); in runCommand()
436 DnsProxyListener::GetHostByNameHandler* handler = in runCommand() local
439 tryThreadOrError(cli, handler); in runCommand()
578 DnsProxyListener::GetHostByAddrHandler* handler = in runCommand() local
580 tryThreadOrError(cli, handler); in runCommand()
|
| /system/update_engine/client_library/include/update_engine/ |
| D | client.h | 114 virtual bool RegisterStatusUpdateHandler(StatusUpdateHandler* handler) = 0;
117 virtual bool UnregisterStatusUpdateHandler(StatusUpdateHandler* handler) = 0;
|
| /system/bt/tools/hci/ |
| D | main.c | 23 handler_t handler; member
168 if (!command->handler) { in main()
173 return command->handler(argc - 2, &argv[2]); in main()
|