| /packages/modules/adb/fdevent/ |
| D | fdevent.h | 43 struct fdevent;
46 typedef void (*fd_func2)(struct fdevent* fde, unsigned events, void* userdata);
48 void invoke_fde(struct fdevent* fde, unsigned events);
49 std::string dump_fde(const fdevent* fde);
52 fdevent* fde;
54 fdevent_event(fdevent* pfde, unsigned ev) : fde(pfde), events(ev) {} in fdevent_event()
57 struct fdevent final {
75 fdevent* Create(unique_fd fd, std::variant<fd_func, fd_func2> func, void* arg);
80 unique_fd Destroy(fdevent* fde);
83 virtual void Register(fdevent*) = 0;
[all …]
|
| D | fdevent.cpp | 38 void invoke_fde(struct fdevent* fde, unsigned events) { in invoke_fde()
48 std::string dump_fde(const fdevent* fde) { in dump_fde()
63 fdevent* fdevent_context::Create(unique_fd fd, std::variant<fd_func, fd_func2> func, void* arg) { in Create()
70 auto [it, inserted] = this->installed_fdevents_.emplace(fd_num, fdevent{}); in Create()
73 fdevent* fde = &it->second; in Create()
91 unique_fd fdevent_context::Destroy(fdevent* fde) { in Destroy()
110 void fdevent_context::Add(fdevent* fde, unsigned events) { in Add()
115 void fdevent_context::Del(fdevent* fde, unsigned events) { in Del()
120 void fdevent_context::SetTimeout(fdevent* fde, std::optional<std::chrono::milliseconds> timeout) { in SetTimeout()
220 fdevent* fdevent_create(int fd, fd_func func, void* arg) { in fdevent_create()
[all …]
|
| D | fdevent_poll.h | 32 fdevent* fde;
35 explicit PollNode(fdevent* fde) : fde(fde) { in PollNode()
51 virtual void Register(fdevent* fde) final;
52 virtual void Unregister(fdevent* fde) final;
54 virtual void Set(fdevent* fde, unsigned events) final;
65 fdevent* interrupt_fde_ = nullptr;
|
| D | fdevent_epoll.cpp | 55 fdevent* fde = this->Create(std::move(interrupt_fd), fdevent_interrupt, nullptr); in fdevent_context_epoll()
65 static epoll_event calculate_epoll_event(fdevent* fde) { in calculate_epoll_event()
82 void fdevent_context_epoll::Register(fdevent* fde) { in Register()
89 void fdevent_context_epoll::Unregister(fdevent* fde) { in Unregister()
95 void fdevent_context_epoll::Set(fdevent* fde, unsigned events) { in Set()
114 std::unordered_map<fdevent*, fdevent_event*> event_map; in Loop()
148 fdevent* fde = static_cast<fdevent*>(epoll_events[i].data.ptr); in Loop()
|
| D | fdevent_epoll.h | 39 virtual void Register(fdevent* fde) final;
40 virtual void Unregister(fdevent* fde) final;
42 virtual void Set(fdevent* fde, unsigned events) final;
53 fdevent* interrupt_fde_ = nullptr;
|
| D | fdevent_test.cpp | 79 static void FdEventNewCallback(fdevent* fde, unsigned events, void* userdata) { in FdEventNewCallback()
105 fdevent* read_fde_;
106 fdevent* write_fde_;
243 fdevent* fde; in TEST_F()
251 test.fde = fdevent_create(fds[0], [](fdevent* fde, unsigned events, void* arg) { in TEST_F()
341 fdevent* fde1; in TEST_F()
342 fdevent* fde2; in TEST_F()
349 [](fdevent* fde, unsigned events, void* arg) { in TEST_F()
360 [](fdevent* fde, unsigned events, void* arg) { in TEST_F()
|
| D | fdevent_poll.cpp | 72 fdevent* fde = this->Create(unique_fd(s[1]), fdevent_interrupt, nullptr); in fdevent_context_poll()
82 void fdevent_context_poll::Set(fdevent* fde, unsigned events) { in Set()
175 fdevent* fde = &it->second; in Loop()
215 void fdevent_context_poll::Register(fdevent*) {} in Register() argument
217 void fdevent_context_poll::Unregister(fdevent*) {} in Unregister() argument
|
| /packages/modules/adb/ |
| D | Android.bp | 220 "fdevent/fdevent.cpp",
232 "fdevent/fdevent_poll.cpp",
236 "fdevent/fdevent_poll.cpp",
248 "fdevent/fdevent_epoll.cpp",
255 "fdevent/fdevent_test.cpp",
|
| D | socket.h | 120 fdevent* fde = nullptr;
|
| D | README.md | 40 At the heart of both the Server and Daemon is a main thread running an fdevent loop, which is a pla…
42 To allow for operations to run on the Main thread, fdevent features a RunQueue combined with an int…
|
| D | adb_listeners.cpp | 48 fdevent* fde = nullptr;
|
| D | sockets.cpp | 291 auto callback = [](fdevent* fde, unsigned event, void* arg) { in deferred_close()
322 fdevent* fde = fdevent_create(fd.release(), callback, socket_info); in deferred_close()
|
| /packages/modules/adb/daemon/ |
| D | adb_wifi.cpp | 60 fdevent* fd_event_ = nullptr;
67 fdevent* fde = fd_event_; in ~TlsServer()
|
| D | services.cpp | 138 fdevent* fde = fdevent_create( in spin_service()
|
| D | jdwp_service.cpp | 183 fdevent* fde = nullptr;
|
| /packages/modules/adb/client/ |
| D | mdnsresponder_client.cpp | 48 fdevent* g_service_ref_fdes[kNumADBDNSServices];
103 fdevent* fde_;
|
| D | auth.cpp | 410 fdevent* event = fdevent_create(infd, adb_auth_inotify_update, nullptr); in adb_auth_inotify_init()
|
| /packages/modules/adb/client/openscreen/platform/ |
| D | udp_socket.cpp | 628 fdevent* fde_ = nullptr; in JoinMulticastGroup()
|
| /packages/modules/adb/docs/user/ |
| D | adb.1.md | 372 …ll,adb,sockets,packets,rwx,usb,sync,sysdeps,transport,jdwp,services,auth,fdevent,shell,incremental.
|