Lines Matching refs:event_base

130 struct event_base *event_global_current_base_ = NULL;
138 static void event_queue_insert_active(struct event_base *, struct event_callback *);
139 static void event_queue_insert_active_later(struct event_base *, struct event_callback *);
140 static void event_queue_insert_timeout(struct event_base *, struct event *);
141 static void event_queue_insert_inserted(struct event_base *, struct event *);
142 static void event_queue_remove_active(struct event_base *, struct event_callback *);
143 static void event_queue_remove_active_later(struct event_base *, struct event_callback *);
144 static void event_queue_remove_timeout(struct event_base *, struct event *);
145 static void event_queue_remove_inserted(struct event_base *, struct event *);
146 static void event_queue_make_later_events_active(struct event_base *base);
148 static int evthread_make_base_notifiable_nolock_(struct event_base *base);
153 static void event_queue_reinsert_timeout(struct event_base *,struct event *, int was_common, int is…
156 static int event_haveevents(struct event_base *);
158 static int event_process_active(struct event_base *);
160 static int timeout_next(struct event_base *, struct timeval **);
161 static void timeout_process(struct event_base *);
163 static inline void event_signal_closure(struct event_base *, struct event *ev);
164 static inline void event_persist_closure(struct event_base *, struct event *ev);
166 static int evthread_notify_base(struct event_base *base);
413 gettime(struct event_base *base, struct timeval *tp) in gettime()
438 event_base_gettimeofday_cached(struct event_base *base, struct timeval *tv) in event_base_gettimeofday_cached()
460 clear_time_cache(struct event_base *base) in clear_time_cache()
467 update_time_cache(struct event_base *base) in update_time_cache()
475 event_base_update_cache_time(struct event_base *base) in event_base_update_cache_time()
504 struct event_base *
507 struct event_base *base = event_base_new_with_config(NULL); in event_init()
519 struct event_base *
522 struct event_base *base = NULL; in event_base_new()
564 event_base_get_features(const struct event_base *base) in event_base_get_features()
604 struct event_base *
608 struct event_base *base; in event_base_new_with_config()
615 if ((base = mm_calloc(1, sizeof(struct event_base))) == NULL) { in event_base_new_with_config()
744 event_base_start_iocp_(struct event_base *base, int n_cpus) in event_base_start_iocp_()
761 event_base_stop_iocp_(struct event_base *base) in event_base_stop_iocp_()
775 event_base_cancel_single_callback_(struct event_base *base, in event_base_cancel_single_callback_()
814 static int event_base_free_queues_(struct event_base *base, int run_finalizers) in event_base_free_queues_()
838 event_base_free_(struct event_base *base, int run_finalizers) in event_base_free_()
949 event_base_free_nofinalize(struct event_base *base) in event_base_free_nofinalize()
955 event_base_free(struct event_base *base) in event_base_free()
964 nil_backend_del(struct event_base *b, evutil_socket_t fd, short old, in nil_backend_del()
981 event_reinit(struct event_base *base) in event_reinit()
1090 event_gettime_monotonic(struct event_base *base, struct timeval *tv) in event_gettime_monotonic()
1240 event_base_priority_init(struct event_base *base, int npriorities) in event_base_priority_init()
1280 event_base_get_npriorities(struct event_base *base) in event_base_get_npriorities()
1294 event_base_get_num_events(struct event_base *base, unsigned int type) in event_base_get_num_events()
1315 event_base_get_max_events(struct event_base *base, unsigned int type, int clear) in event_base_get_max_events()
1346 event_haveevents(struct event_base *base) in event_haveevents()
1354 event_signal_closure(struct event_base *base, struct event *ev) in event_signal_closure()
1409 const struct event_base *base) in is_common_timeout()
1430 get_common_timeout_list(struct event_base *base, const struct timeval *tv) in get_common_timeout_list()
1438 struct event_base *base)
1466 struct event_base *base = ctl->base; in common_timeout_callback()
1487 event_base_init_common_timeout(struct event_base *base, in event_base_init_common_timeout()
1562 event_persist_closure(struct event_base *base, struct event *ev) in event_persist_closure()
1634 event_process_active_single_queue(struct event_base *base, in event_process_active_single_queue()
1760 event_process_active(struct event_base *base) in event_process_active()
1815 event_base_dispatch(struct event_base *event_base) in event_base_dispatch() argument
1817 return (event_base_loop(event_base, 0)); in event_base_dispatch()
1821 event_base_get_method(const struct event_base *base) in event_base_get_method()
1832 struct event_base *base = arg; in event_loopexit_cb()
1844 event_base_loopexit(struct event_base *event_base, const struct timeval *tv) in event_base_loopexit() argument
1846 return (event_base_once(event_base, -1, EV_TIMEOUT, event_loopexit_cb, in event_base_loopexit()
1847 event_base, tv)); in event_base_loopexit()
1857 event_base_loopbreak(struct event_base *event_base) in event_base_loopbreak() argument
1860 if (event_base == NULL) in event_base_loopbreak()
1863 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock); in event_base_loopbreak()
1864 event_base->event_break = 1; in event_base_loopbreak()
1866 if (EVBASE_NEED_NOTIFY(event_base)) { in event_base_loopbreak()
1867 r = evthread_notify_base(event_base); in event_base_loopbreak()
1871 EVBASE_RELEASE_LOCK(event_base, th_base_lock); in event_base_loopbreak()
1876 event_base_loopcontinue(struct event_base *event_base) in event_base_loopcontinue() argument
1879 if (event_base == NULL) in event_base_loopcontinue()
1882 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock); in event_base_loopcontinue()
1883 event_base->event_continue = 1; in event_base_loopcontinue()
1885 if (EVBASE_NEED_NOTIFY(event_base)) { in event_base_loopcontinue()
1886 r = evthread_notify_base(event_base); in event_base_loopcontinue()
1890 EVBASE_RELEASE_LOCK(event_base, th_base_lock); in event_base_loopcontinue()
1895 event_base_got_break(struct event_base *event_base) in event_base_got_break() argument
1898 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock); in event_base_got_break()
1899 res = event_base->event_break; in event_base_got_break()
1900 EVBASE_RELEASE_LOCK(event_base, th_base_lock); in event_base_got_break()
1905 event_base_got_exit(struct event_base *event_base) in event_base_got_exit() argument
1908 EVBASE_ACQUIRE_LOCK(event_base, th_base_lock); in event_base_got_exit()
1909 res = event_base->event_gotterm; in event_base_got_exit()
1910 EVBASE_RELEASE_LOCK(event_base, th_base_lock); in event_base_got_exit()
1923 event_base_loop(struct event_base *base, int flags) in event_base_loop()
2051 event_base_once(struct event_base *base, evutil_socket_t fd, short events, in event_base_once()
2113 event_assign(struct event *ev, struct event_base *base, evutil_socket_t fd, short events, void (*ca… in event_assign()
2164 event_base_set(struct event_base *base, struct event *ev) in event_base_set()
2194 event_base_get_running_event(struct event_base *base) in event_base_get_running_event()
2208 event_new(struct event_base *base, evutil_socket_t fd, short events, void (*cb)(evutil_socket_t, sh… in event_new()
2247 event_finalize_nolock_(struct event_base *base, unsigned flags, struct event *ev, event_finalize_ca… in event_finalize_nolock_()
2264 struct event_base *base = ev->ev_base; in event_finalize_impl_()
2289 event_callback_finalize_nolock_(struct event_base *base, unsigned flags, struct event_callback *evc… in event_callback_finalize_nolock_()
2306 event_callback_finalize_(struct event_base *base, unsigned flags, struct event_callback *evcb, void… in event_callback_finalize_()
2317 event_callback_finalize_many_(struct event_base *base, int n_cbs, struct event_callback **evcbs, vo… in event_callback_finalize_many_()
2419 event_get_assignment(const struct event *event, struct event_base **base_out, evutil_socket_t *fd_o… in event_get_assignment()
2448 struct event_base *
2507 evthread_notify_base_default(struct event_base *base) in evthread_notify_base_default()
2524 evthread_notify_base_eventfd(struct event_base *base) in evthread_notify_base_eventfd()
2541 evthread_notify_base(struct event_base *base) in evthread_notify_base()
2557 struct event_base *base = ev->ev_base; in event_remove_timer_nolock_()
2600 struct event_base *base = ev->ev_base; in event_add_nolock_()
2772 struct event_base *base = ev->ev_base; in event_del_()
2812 struct event_base *base; in event_del_nolock_()
2921 struct event_base *base; in event_active_nolock_()
2980 struct event_base *base = ev->ev_base; in event_active_later_nolock_()
2995 event_callback_activate_(struct event_base *base, in event_callback_activate_()
3006 event_callback_activate_nolock_(struct event_base *base, in event_callback_activate_nolock_()
3037 event_callback_activate_later_nolock_(struct event_base *base, in event_callback_activate_later_nolock_()
3050 event_callback_init_(struct event_base *base, in event_callback_init_()
3058 event_callback_cancel_(struct event_base *base, in event_callback_cancel_()
3069 event_callback_cancel_nolock_(struct event_base *base, in event_callback_cancel_nolock_()
3115 event_deferred_cb_cancel_(struct event_base *base, struct event_callback *cb) in event_deferred_cb_cancel_()
3124 event_deferred_cb_schedule_(struct event_base *base, struct event_callback *cb) in event_deferred_cb_schedule_()
3143 timeout_next(struct event_base *base, struct timeval **tv_p) in timeout_next()
3181 timeout_process(struct event_base *base) in timeout_process()
3224 event_queue_remove_inserted(struct event_base *base, struct event *ev) in event_queue_remove_inserted()
3236 event_queue_remove_active(struct event_base *base, struct event_callback *evcb) in event_queue_remove_active()
3252 event_queue_remove_active_later(struct event_base *base, struct event_callback *evcb) in event_queue_remove_active_later()
3267 event_queue_remove_timeout(struct event_base *base, struct event *ev) in event_queue_remove_timeout()
3291 event_queue_reinsert_timeout(struct event_base *base, struct event *ev, in event_queue_reinsert_timeout()
3361 event_queue_insert_inserted(struct event_base *base, struct event *ev) in event_queue_insert_inserted()
3377 event_queue_insert_active(struct event_base *base, struct event_callback *evcb) in event_queue_insert_active()
3398 event_queue_insert_active_later(struct event_base *base, struct event_callback *evcb) in event_queue_insert_active_later()
3415 event_queue_insert_timeout(struct event_base *base, struct event *ev) in event_queue_insert_timeout()
3439 event_queue_make_later_events_active(struct event_base *base) in event_queue_make_later_events_active()
3587 struct event_base *base = arg; in evthread_notify_drain_eventfd()
3603 struct event_base *base = arg; in evthread_notify_drain_default()
3618 evthread_make_base_notifiable(struct event_base *base) in evthread_make_base_notifiable()
3631 evthread_make_base_notifiable_nolock_(struct event_base *base) in evthread_make_base_notifiable_nolock_()
3634 int (*notify)(struct event_base *); in evthread_make_base_notifiable_nolock_()
3680 event_base_foreach_event_nolock_(struct event_base *base, in event_base_foreach_event_nolock_()
3742 dump_inserted_event_fn(const struct event_base *base, const struct event *e, void *arg) in dump_inserted_event_fn()
3776 dump_active_event_fn(const struct event_base *base, const struct event *e, void *arg) in dump_active_event_fn()
3799 event_base_foreach_event(struct event_base *base, in event_base_foreach_event()
3814 event_base_dump_events(struct event_base *base, FILE *output) in event_base_dump_events()
3826 event_base_active_by_fd(struct event_base *base, evutil_socket_t fd, short events) in event_base_active_by_fd()
3862 event_base_active_by_signal(struct event_base *base, int sig) in event_base_active_by_signal()
3871 event_base_add_virtual_(struct event_base *base) in event_base_add_virtual_()
3880 event_base_del_virtual_(struct event_base *base) in event_base_del_virtual_()
3956 event_base_assert_ok_(struct event_base *base) in event_base_assert_ok_()
3964 event_base_assert_ok_nolock_(struct event_base *base) in event_base_assert_ok_nolock_()