Lines Matching refs:ev
31 static int fpm_event_poll_add(struct fpm_event_s *ev);
32 static int fpm_event_poll_remove(struct fpm_event_s *ev);
154 …if (q->ev && q->ev->index >= 0 && q->ev->index < npollfds && q->ev->fd == active_pollfds[q->ev->in… in fpm_event_poll_wait()
157 if (active_pollfds[q->ev->index].revents & POLLIN) { in fpm_event_poll_wait()
160 fpm_event_fire(q->ev); in fpm_event_poll_wait()
179 static int fpm_event_poll_add(struct fpm_event_s *ev) /* {{{ */ in fpm_event_poll_add() argument
186 pollfds[next_free_slot].fd = ev->fd; in fpm_event_poll_add()
190 ev->index = next_free_slot++; in fpm_event_poll_add()
205 pollfds[i].fd = ev->fd; in fpm_event_poll_add()
209 ev->index = next_free_slot++; in fpm_event_poll_add()
216 zlog(ZLOG_ERROR, "poll: not enough space to add event (fd=%d)", ev->fd); in fpm_event_poll_add()
224 static int fpm_event_poll_remove(struct fpm_event_s *ev) /* {{{ */ in fpm_event_poll_remove() argument
229 if (ev->index >= 0 && ev->index < npollfds && pollfds[ev->index].fd == ev->fd) { in fpm_event_poll_remove()
231 next_free_slot = ev->index; in fpm_event_poll_remove()
234 pollfds[ev->index].fd = -1; in fpm_event_poll_remove()
235 pollfds[ev->index].events = 0; in fpm_event_poll_remove()
238 ev->index = -1; in fpm_event_poll_remove()
246 if (pollfds[i].fd != ev->fd) { in fpm_event_poll_remove()
259 ev->index = -1; in fpm_event_poll_remove()
264 zlog(ZLOG_ERROR, "poll: unable to remove event: not found (fd=%d, index=%d)", ev->fd, ev->index); in fpm_event_poll_remove()