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 …]
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; 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);143 unique_fd fdevent_release(fdevent* fde);[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 …]
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;
79 static void FdEventNewCallback(fdevent* fde, unsigned events, void* userdata) { in FdEventNewCallback() argument80 int fd = fde->fd.get(); in FdEventNewCallback()234 fdevent* fde; in TEST_F() member242 test.fde = fdevent_create(fds[0], [](fdevent* fde, unsigned events, void* arg) { in TEST_F() argument249 ssize_t rc = adb_read(fde->fd.get(), buf, sizeof(buf)); in TEST_F()263 CHECK_EQ(fde, test->fde); in TEST_F()267 fdevent_destroy(fde); in TEST_F()270 fdevent_add(test.fde, FDE_READ); in TEST_F()271 fdevent_set_timeout(test.fde, delta); in TEST_F()336 [](fdevent* fde, unsigned events, void* arg) { in TEST_F() argument[all …]
39 virtual void Register(fdevent* fde) final;40 virtual void Unregister(fdevent* fde) final;42 virtual void Set(fdevent* fde, unsigned events) final;
167 fdevent_add(s->fde, FDE_WRITE); in local_socket_flush_incoming()170 fdevent_del(s->fde, FDE_WRITE); in local_socket_flush_incoming()234 fdevent_del(s->fde, FDE_READ); in local_socket_flush_outgoing()238 fdevent_del(s->fde, FDE_READ); in local_socket_flush_outgoing()273 fdevent_add(s->fde, FDE_READ); in local_socket_ready()291 auto callback = [](fdevent* fde, unsigned event, void* arg) { in deferred_close() argument296 while ((rc = adb_read(fde->fd.get(), buf, sizeof(buf))) > 0) { in deferred_close()314 fdevent_destroy(fde); in deferred_close()322 fdevent* fde = fdevent_create(fd.release(), callback, socket_info); in deferred_close() local323 fdevent_add(fde, FDE_READ); 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()
120 fdevent* fde = nullptr; member
155 this->fde = fdevent_create(socket.release(), jdwp_process_event, this); in JdwpProcess()157 if (!this->fde) { in JdwpProcess()168 if (this->fde) { in ~JdwpProcess()169 fdevent_destroy(this->fde); in ~JdwpProcess()170 this->fde = nullptr; in ~JdwpProcess()183 fdevent* fde = nullptr; member282 fdevent_del(proc->fde, FDE_WRITE); in jdwp_process_event()313 fdevent_add(proc->fde, FDE_WRITE); in create_jdwp_connection_fd()
71 fdevent* fde = fd_event_; in ~TlsServer() local72 fdevent_run_on_looper([fde]() { in ~TlsServer()73 if (fde != nullptr) { in ~TlsServer()74 fdevent_destroy(fde); in ~TlsServer()
137 fdevent* fde = fdevent_create( in spin_service() local139 fdevent_add(fde, FDE_READ); in spin_service()
1dictionary=main:da,locale=da,description=Dansk,date=1393228134, ...
1dictionary=main:sv,locale=sv,description=Svenska,date=1414726264, ...