Lines Matching refs:event_base
121 struct event_base *event_global_current_base_ = NULL;
133 static void event_queue_insert(struct event_base *, struct event *, int);
134 static void event_queue_remove(struct event_base *, struct event *, int);
135 static int event_haveevents(struct event_base *);
137 static int event_process_active(struct event_base *);
139 static int timeout_next(struct event_base *, struct timeval **);
140 static void timeout_process(struct event_base *);
141 static void timeout_correct(struct event_base *, struct timeval *);
143 static inline void event_signal_closure(struct event_base *, struct event *ev);
144 static inline void event_persist_closure(struct event_base *, struct event *ev);
146 static int evthread_notify_base(struct event_base *base);
357 gettime(struct event_base *base, struct timeval *tp)
391 event_base_gettimeofday_cached(struct event_base *base, struct timeval *tv)
417 clear_time_cache(struct event_base *base)
424 update_time_cache(struct event_base *base)
431 struct event_base *
434 struct event_base *base = event_base_new_with_config(NULL);
437 event_errx(1, "%s: Unable to construct event_base", __func__);
446 struct event_base *
449 struct event_base *base = NULL;
491 event_base_get_features(const struct event_base *base)
507 struct event_base *base = baseptr;
513 event_base_get_deferred_cb_queue(struct event_base *base)
551 struct event_base *
555 struct event_base *base;
562 if ((base = mm_calloc(1, sizeof(struct event_base))) == NULL) {
657 event_base_start_iocp(struct event_base *base, int n_cpus)
674 event_base_stop_iocp(struct event_base *base)
688 event_base_free(struct event_base *base)
796 event_reinit(struct event_base *base)
1007 event_base_priority_init(struct event_base *base, int npriorities)
1041 event_haveevents(struct event_base *base)
1049 event_signal_closure(struct event_base *base, struct event *ev)
1089 * of index into the event_base's aray of common timeouts.
1104 const struct event_base *base)
1125 get_common_timeout_list(struct event_base *base, const struct timeval *tv)
1133 struct event_base *base)
1143 * event_base's minheap. */
1161 struct event_base *base = ctl->base;
1182 event_base_init_common_timeout(struct event_base *base,
1212 "we only support %d per event_base", __func__,
1257 event_persist_closure(struct event_base *base, struct event *ev)
1330 event_process_active_single_queue(struct event_base *base,
1428 event_process_active(struct event_base *base)
1466 event_base_dispatch(struct event_base *event_base)
1468 return (event_base_loop(event_base, 0));
1472 event_base_get_method(const struct event_base *base)
1478 /** Callback: used to implement event_base_loopexit by telling the event_base
1483 struct event_base *base = arg;
1495 event_base_loopexit(struct event_base *event_base, const struct timeval *tv)
1497 return (event_base_once(event_base, -1, EV_TIMEOUT, event_loopexit_cb,
1498 event_base, tv));
1508 event_base_loopbreak(struct event_base *event_base)
1511 if (event_base == NULL)
1514 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock);
1515 event_base->event_break = 1;
1517 if (EVBASE_NEED_NOTIFY(event_base)) {
1518 r = evthread_notify_base(event_base);
1522 EVBASE_RELEASE_LOCK(event_base, th_base_lock);
1527 event_base_got_break(struct event_base *event_base)
1530 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock);
1531 res = event_base->event_break;
1532 EVBASE_RELEASE_LOCK(event_base, th_base_lock);
1537 event_base_got_exit(struct event_base *event_base)
1540 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock);
1541 res = event_base->event_gotterm;
1542 EVBASE_RELEASE_LOCK(event_base, th_base_lock);
1555 event_base_loop(struct event_base *base, int flags)
1568 " can run on each event_base at once.", __func__);
1689 event_base_once(struct event_base *base, evutil_socket_t fd, short events,
1736 event_assign(struct event *ev, struct event_base *base, evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg)
1783 event_base_set(struct event_base *base, struct event *ev)
1807 event_new(struct event_base *base, evutil_socket_t fd, short events, void (*cb)(evutil_socket_t, short, void *), void *arg)
1872 event_warnx("%s: event has no event_base set.", __func__);
1915 event_get_assignment(const struct event *event, struct event_base **base_out, evutil_socket_t *fd_out, short *events_out, event_callback_fn *callback_out, void **arg_out)
1944 struct event_base *
1978 event_warnx("%s: event has no event_base set.", __func__);
1991 /* Helper callback: wake an event_base from another thread. This version
1992 * works by writing a byte to one end of a socketpair, so that the event_base
1996 evthread_notify_base_default(struct event_base *base)
2010 /* Helper callback: wake an event_base from another thread. This version
2013 evthread_notify_base_eventfd(struct event_base *base)
2029 evthread_notify_base(struct event_base *base)
2048 struct event_base *base = ev->ev_base;
2200 event_warnx("%s: event has no event_base set.", __func__);
2217 struct event_base *base;
2292 event_warnx("%s: event has no event_base set.", __func__);
2309 struct event_base *base;
2398 timeout_next(struct event_base *base, struct timeval **tv_p)
2441 timeout_correct(struct event_base *base, struct timeval *tv)
2494 timeout_process(struct event_base *base)
2521 event_queue_remove(struct event_base *base, struct event *ev, int queue)
2591 event_queue_insert(struct event_base *base, struct event *ev, int queue)
2736 struct event_base *base = arg;
2752 struct event_base *base = arg;
2767 evthread_make_base_notifiable(struct event_base *base)
2770 int (*notify)(struct event_base *) = evthread_notify_base_default;
2846 event_base_dump_events(struct event_base *base, FILE *output)
2877 event_base_add_virtual(struct event_base *base)
2885 event_base_del_virtual(struct event_base *base)
2911 event_base_assert_ok(struct event_base *base)
