Lines Matching refs:fde
72 fdevent* fde = this->Create(unique_fd(s[1]), fdevent_interrupt, nullptr); in fdevent_context_poll() local
73 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() argument
84 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()
175 fdevent* fde = &it->second; in Loop() local
178 if (fde->timeout) { in Loop()
179 auto deadline = fde->last_active + *fde->timeout; in Loop()
187 D("%s got events %x", dump_fde(fde).c_str(), events); in Loop()
188 poll_events.push_back({fde, events}); in Loop()
189 fde->last_active = post_poll; in Loop()