Lines Matching refs:ev
34 #define fpm_event_set_timeout(ev, now) timeradd(&(now), &(ev)->frequency, &(ev)->timeout); argument
37 static void fpm_postponed_children_bury(struct fpm_event_s *ev, short which, void *arg);
38 static void fpm_got_signal(struct fpm_event_s *ev, short which, void *arg);
39 …struct fpm_event_s *fpm_event_queue_isset(struct fpm_event_queue_s *queue, struct fpm_event_s *ev);
40 static int fpm_event_queue_add(struct fpm_event_queue_s **queue, struct fpm_event_s *ev);
41 static int fpm_event_queue_del(struct fpm_event_queue_s **queue, struct fpm_event_s *ev);
56 static void fpm_postponed_children_bury(struct fpm_event_s *ev, short which, void *arg) /* {{{ */ in fpm_postponed_children_bury() argument
62 static void fpm_got_signal(struct fpm_event_s *ev, short which, void *arg) /* {{{ */ in fpm_got_signal() argument
66 int fd = ev->fd; in fpm_got_signal()
145 …m_event_s *fpm_event_queue_isset(struct fpm_event_queue_s *queue, struct fpm_event_s *ev) /* {{{ */ in fpm_event_queue_isset() argument
147 if (!ev) { in fpm_event_queue_isset()
152 if (queue->ev == ev) { in fpm_event_queue_isset()
153 return ev; in fpm_event_queue_isset()
162 static int fpm_event_queue_add(struct fpm_event_queue_s **queue, struct fpm_event_s *ev) /* {{{ */ in fpm_event_queue_add() argument
166 if (!queue || !ev) { in fpm_event_queue_add()
170 if (fpm_event_queue_isset(*queue, ev)) { in fpm_event_queue_add()
180 elt->ev = ev; in fpm_event_queue_add()
190 module->add(ev); in fpm_event_queue_add()
197 static int fpm_event_queue_del(struct fpm_event_queue_s **queue, struct fpm_event_s *ev) /* {{{ */ in fpm_event_queue_del() argument
200 if (!queue || !ev) { in fpm_event_queue_del()
205 if (q->ev == ev) { in fpm_event_queue_del()
221 module->remove(ev); in fpm_event_queue_del()
410 ms = q->ev->timeout; in fpm_event_loop()
412 if (timercmp(&q->ev->timeout, &ms, <)) { in fpm_event_loop()
413 ms = q->ev->timeout; in fpm_event_loop()
443 if (q->ev) { in fpm_event_loop()
444 if (timercmp(&now, &q->ev->timeout, >) || timercmp(&now, &q->ev->timeout, ==)) { in fpm_event_loop()
445 struct fpm_event_s *ev = q->ev; in fpm_event_loop() local
446 if (ev->flags & FPM_EV_PERSIST) { in fpm_event_loop()
447 fpm_event_set_timeout(ev, now); in fpm_event_loop()
467 fpm_event_fire(ev); in fpm_event_loop()
481 void fpm_event_fire(struct fpm_event_s *ev) /* {{{ */ in fpm_event_fire() argument
483 if (!ev || !ev->callback) { in fpm_event_fire()
487 (*ev->callback)( (struct fpm_event_s *) ev, ev->which, ev->arg); in fpm_event_fire()
491 int fpm_event_set(struct fpm_event_s *ev, int fd, int flags, void (*callback)(struct fpm_event_s *,… in fpm_event_set() argument
493 if (!ev || !callback || fd < -1) { in fpm_event_set()
496 memset(ev, 0, sizeof(struct fpm_event_s)); in fpm_event_set()
497 ev->fd = fd; in fpm_event_set()
498 ev->callback = callback; in fpm_event_set()
499 ev->arg = arg; in fpm_event_set()
500 ev->flags = flags; in fpm_event_set()
505 int fpm_event_add(struct fpm_event_s *ev, unsigned long int frequency) /* {{{ */ in fpm_event_add() argument
510 if (!ev) { in fpm_event_add()
514 ev->index = -1; in fpm_event_add()
517 if (ev->flags & FPM_EV_READ) { in fpm_event_add()
518 ev->which = FPM_EV_READ; in fpm_event_add()
519 if (fpm_event_queue_add(&fpm_event_queue_fd, ev) != 0) { in fpm_event_add()
526 ev->which = FPM_EV_TIMEOUT; in fpm_event_add()
536 ev->frequency = tmp; in fpm_event_add()
537 fpm_event_set_timeout(ev, now); in fpm_event_add()
539 if (fpm_event_queue_add(&fpm_event_queue_timer, ev) != 0) { in fpm_event_add()
547 int fpm_event_del(struct fpm_event_s *ev) /* {{{ */ in fpm_event_del() argument
549 if (ev->index >= 0 && fpm_event_queue_del(&fpm_event_queue_fd, ev) != 0) { in fpm_event_del()
553 if (ev->index < 0 && fpm_event_queue_del(&fpm_event_queue_timer, ev) != 0) { in fpm_event_del()
