Lines Matching defs:events

95 static void fdevent_subproc_event_func(int fd, unsigned events, void *userdata);
131 ev.events = 0;
147 ev.events = 0;
151 ** were actively monitoring events, but let's
158 static void fdevent_update(fdevent *fde, unsigned events)
166 ev.events = 0;
169 if(events & FDE_READ) ev.events |= EPOLLIN;
170 if(events & FDE_WRITE) ev.events |= EPOLLOUT;
171 if(events & FDE_ERROR) ev.events |= (EPOLLERR | EPOLLHUP);
173 fde->state = (fde->state & FDE_STATEMASK) | events;
177 ** events being monitored, we need to delete, otherwise
180 if(ev.events) {
192 /* we're not active. if we're watching events, we need
195 if(ev.events) {
206 struct epoll_event events[256];
210 n = epoll_wait(epoll_fd, events, 256, -1);
219 struct epoll_event *ev = events + i;
222 if(ev->events & EPOLLIN) {
223 fde->events |= FDE_READ;
225 if(ev->events & EPOLLOUT) {
226 fde->events |= FDE_WRITE;
228 if(ev->events & (EPOLLERR | EPOLLHUP)) {
229 fde->events |= FDE_ERROR;
231 if(fde->events) {
281 static void fdevent_update(fdevent *fde, unsigned events)
283 if(events & FDE_READ) {
288 if(events & FDE_WRITE) {
293 if(events & FDE_ERROR) {
299 fde->state = (fde->state & FDE_STATEMASK) | events;
369 unsigned events;
405 events = 0;
406 if(FD_ISSET(i, &rfd)) { events |= FDE_READ; n--; }
407 if(FD_ISSET(i, &wfd)) { events |= FDE_WRITE; n--; }
408 if(FD_ISSET(i, &efd)) { events |= FDE_ERROR; n--; }
410 if(events) {
415 fde->events |= events;
417 D("got events fde->fd=%d events=%04x, state=%04x\n",
418 fde->fd, fde->events, fde->state);
509 unsigned events = fde->events;
510 fde->events = 0;
514 fde->func(fde->fd, events, fde->arg);
566 subproc_fde->events |= FDE_READ;
624 fde->events = 0;
628 void fdevent_set(fdevent *fde, unsigned events)
630 events &= FDE_EVENTMASK;
632 if((fde->state & FDE_EVENTMASK) == events) return;
635 fdevent_update(fde, events);
639 fde->state = (fde->state & FDE_STATEMASK) | events;
646 fde->events &= (~events);
647 if(fde->events == 0) {
654 void fdevent_add(fdevent *fde, unsigned events)
657 fde, (fde->state & FDE_EVENTMASK) | (events & FDE_EVENTMASK));
660 void fdevent_del(fdevent *fde, unsigned events)
663 fde, (fde->state & FDE_EVENTMASK) & (~(events & FDE_EVENTMASK)));
687 D("--- ---- waiting for events\n");