Lines Matching refs:events
65 pollfd.events = POLLRDHUP; in PollNode()
168 fde->events = 0; in fdevent_remove()
172 static void fdevent_update(fdevent* fde, unsigned events) { in fdevent_update() argument
176 if (events & FDE_READ) { in fdevent_update()
177 node.pollfd.events |= POLLIN; in fdevent_update()
179 node.pollfd.events &= ~POLLIN; in fdevent_update()
182 if (events & FDE_WRITE) { in fdevent_update()
183 node.pollfd.events |= POLLOUT; in fdevent_update()
185 node.pollfd.events &= ~POLLOUT; in fdevent_update()
187 fde->state = (fde->state & FDE_STATEMASK) | events; in fdevent_update()
190 void fdevent_set(fdevent* fde, unsigned events) { in fdevent_set() argument
192 events &= FDE_EVENTMASK; in fdevent_set()
193 if ((fde->state & FDE_EVENTMASK) == events) { in fdevent_set()
197 fdevent_update(fde, events); in fdevent_set()
198 D("fdevent_set: %s, events = %u", dump_fde(fde).c_str(), events); in fdevent_set()
202 fde->events &= events; in fdevent_set()
203 if (fde->events == 0) { in fdevent_set()
210 void fdevent_add(fdevent* fde, unsigned events) { in fdevent_add() argument
212 fdevent_set(fde, (fde->state & FDE_EVENTMASK) | events); in fdevent_add()
215 void fdevent_del(fdevent* fde, unsigned events) { in fdevent_del() argument
217 fdevent_set(fde, (fde->state & FDE_EVENTMASK) & ~events); in fdevent_del()
224 if (pollfd.events & POLLIN) { in dump_pollfds()
227 if (pollfd.events & POLLOUT) { in dump_pollfds()
251 unsigned events = 0; in fdevent_process() local
253 events |= FDE_READ; in fdevent_process()
256 events |= FDE_WRITE; in fdevent_process()
261 events |= FDE_READ | FDE_ERROR; in fdevent_process()
265 events |= FDE_READ | FDE_ERROR; in fdevent_process()
268 if (events != 0) { in fdevent_process()
273 fde->events |= events; in fdevent_process()
274 D("%s got events %x", dump_fde(fde).c_str(), events); in fdevent_process()
283 unsigned events = fde->events; in fdevent_call_fdfunc() local
284 fde->events = 0; in fdevent_call_fdfunc()
288 fde->func(fde->fd, events, fde->arg); in fdevent_call_fdfunc()
336 subproc_fde->events |= FDE_READ; in fdevent_subproc_event_func()