Lines Matching full:event_base
126 struct event_base *event_global_current_base_ = NULL;
134 static void event_queue_insert_active(struct event_base *, struct event_callback *);
135 static void event_queue_insert_active_later(struct event_base *, struct event_callback *);
136 static void event_queue_insert_timeout(struct event_base *, struct event *);
137 static void event_queue_insert_inserted(struct event_base *, struct event *);
138 static void event_queue_remove_active(struct event_base *, struct event_callback *);
139 static void event_queue_remove_active_later(struct event_base *, struct event_callback *);
140 static void event_queue_remove_timeout(struct event_base *, struct event *);
141 static void event_queue_remove_inserted(struct event_base *, struct event *);
142 static void event_queue_make_later_events_active(struct event_base *base);
144 static int evthread_make_base_notifiable_nolock_(struct event_base *base);
149 static void event_queue_reinsert_timeout(struct event_base *,struct event *, int was_common, int is_common, int old_timeout_idx);
152 static int event_haveevents(struct event_base *);
154 static int event_process_active(struct event_base *);
156 static int timeout_next(struct event_base *, struct timeval **);
157 static void timeout_process(struct event_base *);
159 static inline void event_signal_closure(struct event_base *, struct event *ev);
160 static inline void event_persist_closure(struct event_base *, struct event *ev);
162 static int evthread_notify_base(struct event_base *base);
373 gettime(struct event_base *base, struct timeval *tp)
398 event_base_gettimeofday_cached(struct event_base *base, struct timeval *tv)
420 clear_time_cache(struct event_base *base)
427 update_time_cache(struct event_base *base)
435 event_base_update_cache_time(struct event_base *base)
464 struct event_base *
467 struct event_base *base = event_base_new_with_config(NULL);
470 event_errx(1, "%s: Unable to construct event_base", __func__);
479 struct event_base *
482 struct event_base *base = NULL;
524 event_base_get_features(const struct event_base *base)
564 struct event_base *
568 struct event_base *base;
575 if ((base = mm_calloc(1, sizeof(struct event_base))) == NULL) {
702 event_base_start_iocp_(struct event_base *base, int n_cpus)
719 event_base_stop_iocp_(struct event_base *base)
733 event_base_cancel_single_callback_(struct event_base *base,
772 static int event_base_free_queues_(struct event_base *base, int run_finalizers)
796 event_base_free_(struct event_base *base, int run_finalizers)
906 event_base_free_nofinalize(struct event_base *base)
912 event_base_free(struct event_base *base)
921 nil_backend_del(struct event_base *b, evutil_socket_t fd, short old,
938 event_reinit(struct event_base *base)
1045 /* Get the monotonic time for this event_base' timer */
1047 event_gettime_monotonic(struct event_base *base, struct timeval *tv)
1197 event_base_priority_init(struct event_base *base, int npriorities)
1237 event_base_get_npriorities(struct event_base *base)
1251 event_base_get_num_events(struct event_base *base, unsigned int type)
1272 event_base_get_max_events(struct event_base *base, unsigned int type, int clear)
1303 event_haveevents(struct event_base *base)
1311 event_signal_closure(struct event_base *base, struct event *ev)
1351 * of index into the event_base's aray of common timeouts.
1366 const struct event_base *base)
1387 get_common_timeout_list(struct event_base *base, const struct timeval *tv)
1395 struct event_base *base)
1405 * event_base's minheap. */
1423 struct event_base *base = ctl->base;
1444 event_base_init_common_timeout(struct event_base *base,
1474 "we only support %d per event_base", __func__,
1519 event_persist_closure(struct event_base *base, struct event *ev)
1591 event_process_active_single_queue(struct event_base *base,
1715 event_process_active(struct event_base *base)
1770 event_base_dispatch(struct event_base *event_base)
1772 return (event_base_loop(event_base, 0));
1776 event_base_get_method(const struct event_base *base)
1782 /** Callback: used to implement event_base_loopexit by telling the event_base
1787 struct event_base *base = arg;
1799 event_base_loopexit(struct event_base *event_base, const struct timeval *tv)
1801 return (event_base_once(event_base, -1, EV_TIMEOUT, event_loopexit_cb,
1802 event_base, tv));
1812 event_base_loopbreak(struct event_base *event_base)
1815 if (event_base == NULL)
1818 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock);
1819 event_base->event_break = 1;
1821 if (EVBASE_NEED_NOTIFY(event_base)) {
1822 r = evthread_notify_base(event_base);
1826 EVBASE_RELEASE_LOCK(event_base, th_base_lock);
1831 event_base_loopcontinue(struct event_base *event_base)
1834 if (event_base == NULL)
1837 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock);
1838 event_base->event_continue = 1;
1840 if (EVBASE_NEED_NOTIFY(event_base)) {
1841 r = evthread_notify_base(event_base);
1845 EVBASE_RELEASE_LOCK(event_base, th_base_lock);
1850 event_base_got_break(struct event_base *event_base)
1853 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock);
1854 res = event_base->event_break;
1855 EVBASE_RELEASE_LOCK(event_base, th_base_lock);
1860 event_base_got_exit(struct event_base *event_base)
1863 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock);
1864 res = event_base->event_gotterm;
1865 EVBASE_RELEASE_LOCK(event_base, th_base_lock);
1878 event_base_loop(struct event_base *base, int flags)
1891 " can run on each event_base at once.", __func__);
2006 event_base_once(struct event_base *base, evutil_socket_t fd, short events,
2065 event_assign(struct event *ev, struct event_base *base, evutil_socket_t fd, short events, void (*callback)(evutil_socket_t, short, void *), void *arg)
2114 event_base_set(struct event_base *base, struct event *ev)
2144 event_base_get_running_event(struct event_base *base)
2158 event_new(struct event_base *base, evutil_socket_t fd, short events, void (*cb)(evutil_socket_t, short, void *), void *arg)
2197 event_finalize_nolock_(struct event_base *base, unsigned flags, struct event *ev, event_finalize_callback_fn cb)
2214 struct event_base *base = ev->ev_base;
2216 event_warnx("%s: event has no event_base set.", __func__);
2239 event_callback_finalize_nolock_(struct event_base *base, unsigned flags, struct event_callback *evcb, void (*cb)(struct event_callback *, void *))
2256 event_callback_finalize_(struct event_base *base, unsigned flags, struct event_callback *evcb, void (*cb)(struct event_callback *, void *))
2267 event_callback_finalize_many_(struct event_base *base, int n_cbs, struct event_callback **evcbs, void (*cb)(struct event_callback *, void *))
2330 event_warnx("%s: event has no event_base set.", __func__);
2369 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)
2398 struct event_base *
2439 event_warnx("%s: event has no event_base set.", __func__);
2452 /* Helper callback: wake an event_base from another thread. This version
2453 * works by writing a byte to one end of a socketpair, so that the event_base
2457 evthread_notify_base_default(struct event_base *base)
2471 /* Helper callback: wake an event_base from another thread. This version
2474 evthread_notify_base_eventfd(struct event_base *base)
2491 evthread_notify_base(struct event_base *base)
2507 struct event_base *base = ev->ev_base;
2529 event_warnx("%s: event has no event_base set.", __func__);
2550 struct event_base *base = ev->ev_base;
2724 event_warnx("%s: event has no event_base set.", __func__);
2763 struct event_base *base;
2850 event_warnx("%s: event has no event_base set.", __func__);
2867 struct event_base *base;
2926 struct event_base *base = ev->ev_base;
2941 event_callback_activate_(struct event_base *base,
2952 event_callback_activate_nolock_(struct event_base *base,
2982 event_callback_activate_later_nolock_(struct event_base *base,
2995 event_callback_init_(struct event_base *base,
3003 event_callback_cancel_(struct event_base *base,
3014 event_callback_cancel_nolock_(struct event_base *base,
3060 event_deferred_cb_cancel_(struct event_base *base, struct event_callback *cb)
3069 event_deferred_cb_schedule_(struct event_base *base, struct event_callback *cb)
3088 timeout_next(struct event_base *base, struct timeval **tv_p)
3126 timeout_process(struct event_base *base)
3173 event_queue_remove_inserted(struct event_base *base, struct event *ev)
3185 event_queue_remove_active(struct event_base *base, struct event_callback *evcb)
3201 event_queue_remove_active_later(struct event_base *base, struct event_callback *evcb)
3216 event_queue_remove_timeout(struct event_base *base, struct event *ev)
3240 event_queue_reinsert_timeout(struct event_base *base, struct event *ev,
3310 event_queue_insert_inserted(struct event_base *base, struct event *ev)
3326 event_queue_insert_active(struct event_base *base, struct event_callback *evcb)
3347 event_queue_insert_active_later(struct event_base *base, struct event_callback *evcb)
3364 event_queue_insert_timeout(struct event_base *base, struct event *ev)
3388 event_queue_make_later_events_active(struct event_base *base)
3536 struct event_base *base = arg;
3552 struct event_base *base = arg;
3567 evthread_make_base_notifiable(struct event_base *base)
3580 evthread_make_base_notifiable_nolock_(struct event_base *base)
3583 int (*notify)(struct event_base *);
3629 event_base_foreach_event_nolock_(struct event_base *base,
3691 dump_inserted_event_fn(const struct event_base *base, const struct event *e, void *arg)
3724 dump_active_event_fn(const struct event_base *base, const struct event *e, void *arg)
3747 event_base_foreach_event(struct event_base *base,
3762 event_base_dump_events(struct event_base *base, FILE *output)
3774 event_base_active_by_fd(struct event_base *base, evutil_socket_t fd, short events)
3782 event_base_active_by_signal(struct event_base *base, int sig)
3791 event_base_add_virtual_(struct event_base *base)
3800 event_base_del_virtual_(struct event_base *base)
3876 event_base_assert_ok_(struct event_base *base)
3884 event_base_assert_ok_nolock_(struct event_base *base)
