Searched refs:fde (Results 1 – 15 of 15) sorted by relevance
38 void invoke_fde(struct fdevent* fde, unsigned events) { in invoke_fde() argument39 if (auto f = std::get_if<fd_func>(&fde->func)) { in invoke_fde()40 (*f)(fde->fd.get(), events, fde->arg); in invoke_fde()41 } else if (auto f = std::get_if<fd_func2>(&fde->func)) { in invoke_fde()42 (*f)(fde, events, fde->arg); in invoke_fde()48 std::string dump_fde(const fdevent* fde) { in dump_fde() argument50 if (fde->state & FDE_READ) { in dump_fde()53 if (fde->state & FDE_WRITE) { in dump_fde()56 if (fde->state & FDE_ERROR) { in dump_fde()59 return android::base::StringPrintf("(fdevent %" PRIu64 ": fd %d %s)", fde->id, fde->fd.get(), in dump_fde()[all …]
52 fdevent* fde = this->Create(std::move(interrupt_fd), fdevent_interrupt, nullptr); in fdevent_context_epoll() local53 CHECK(fde != nullptr); in fdevent_context_epoll()54 this->Add(fde, FDE_READ); in fdevent_context_epoll()62 static epoll_event calculate_epoll_event(fdevent* fde) { in calculate_epoll_event() argument65 if (fde->state & FDE_READ) { in calculate_epoll_event()68 if (fde->state & FDE_WRITE) { in calculate_epoll_event()71 if (fde->state & FDE_ERROR) { in calculate_epoll_event()75 result.data.ptr = fde; in calculate_epoll_event()79 void fdevent_context_epoll::Register(fdevent* fde) { in Register() argument80 epoll_event ev = calculate_epoll_event(fde); in Register()[all …]
72 fdevent* fde = this->Create(unique_fd(s[1]), fdevent_interrupt, nullptr); in fdevent_context_poll() local73 CHECK(fde != nullptr); in fdevent_context_poll()74 this->Add(fde, FDE_READ); in fdevent_context_poll()82 void fdevent_context_poll::Set(fdevent* fde, unsigned events) { in Set() argument84 fde->state = events; in Set()85 D("fdevent_set: %s, events = %u", dump_fde(fde).c_str(), events); in Set()116 for (const auto& [fd, fde] : this->installed_fdevents_) { in Loop()120 if (fde.state & FDE_READ) { in Loop()123 if (fde.state & FDE_WRITE) { in Loop()126 if (fde.state & FDE_ERROR) { in Loop()[all …]
45 typedef void (*fd_func2)(struct fdevent* fde, unsigned events, void* userdata);47 void invoke_fde(struct fdevent* fde, unsigned events);48 std::string dump_fde(const fdevent* fde);51 fdevent* fde; member79 unique_fd Destroy(fdevent* fde);87 virtual void Set(fdevent* fde, unsigned events) = 0;88 void Add(fdevent* fde, unsigned events);89 void Del(fdevent* fde, unsigned events);95 void SetTimeout(fdevent* fde, std::optional<std::chrono::milliseconds> timeout);142 unique_fd fdevent_release(fdevent* fde);[all …]
32 fdevent* fde; member35 explicit PollNode(fdevent* fde) : fde(fde) { in PollNode()37 pollfd.fd = fde->fd.get(); 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;
76 static void FdEventNewCallback(fdevent* fde, unsigned events, void* userdata) { in FdEventNewCallback() argument77 int fd = fde->fd.get(); in FdEventNewCallback()238 fdevent* fde; in TEST_F() member246 test.fde = fdevent_create(fds[0], [](fdevent* fde, unsigned events, void* arg) { in TEST_F() argument253 ssize_t rc = adb_read(fde->fd.get(), buf, sizeof(buf)); in TEST_F()267 CHECK_EQ(fde, test->fde); in TEST_F()271 fdevent_destroy(fde); in TEST_F()274 fdevent_add(test.fde, FDE_READ); in TEST_F()275 fdevent_set_timeout(test.fde, delta); in TEST_F()
39 virtual void Register(fdevent* fde) final;40 virtual void Unregister(fdevent* fde) final;42 virtual void Set(fdevent* fde, unsigned events) final;
129 fdevent_add(s->fde, FDE_WRITE); in local_socket_flush_incoming()132 fdevent_add(s->fde, FDE_WRITE); in local_socket_flush_incoming()147 fdevent_del(s->fde, FDE_WRITE); in local_socket_flush_incoming()180 s->fde->force_eof); in local_socket_flush_outgoing()207 fdevent_del(s->fde, FDE_READ); in local_socket_flush_outgoing()212 if ((s->fde->force_eof && !r) || is_eof) { in local_socket_flush_outgoing()213 D(" closing because is_eof=%d r=%d s->fde.force_eof=%d", is_eof, r, s->fde->force_eof); in local_socket_flush_outgoing()242 fdevent_add(s->fde, FDE_READ); in local_socket_ready()260 auto callback = [](fdevent* fde, unsigned event, void* arg) { in deferred_close() argument265 while ((rc = adb_read(fde->fd.get(), buf, sizeof(buf))) > 0) { in deferred_close()[all …]
45 fdevent* fde = nullptr; member in alistener63 fdevent_destroy(fde); in ~alistener()173 fdevent_set(l->fde, FDE_READ); in enable_server_sockets()235 listener->fde = fdevent_create(listener->fd, ss_listener_event_func, listener.get()); in install_listener()240 listener->fde = fdevent_create(listener->fd, listener_event_func, listener.get()); in install_listener()243 fdevent_set(listener->fde, FDE_READ); in install_listener()
62 fdevent* fde = nullptr; member
157 this->fde = fdevent_create(socket.release(), jdwp_process_event, this); in JdwpProcess()159 if (!this->fde) { in JdwpProcess()170 if (this->fde) { in ~JdwpProcess()171 fdevent_destroy(this->fde); in ~JdwpProcess()172 this->fde = nullptr; in ~JdwpProcess()185 fdevent* fde = nullptr; member284 fdevent_del(proc->fde, FDE_WRITE); in jdwp_process_event()315 fdevent_add(proc->fde, FDE_WRITE); in create_jdwp_connection_fd()
71 fdevent* fde = fd_event_; in ~TlsServer() local72 fdevent_run_on_main_thread([fde]() { in ~TlsServer()73 if (fde != nullptr) { in ~TlsServer()74 fdevent_destroy(fde); in ~TlsServer()
136 fdevent* fde = fdevent_create( in spin_service() local138 fdevent_add(fde, FDE_READ); in spin_service()
1dictionary=main:da,locale=da,description=Dansk,date=1393228134, ...