/* Copyright (c) 2009, The Tor Project, Inc. */ /* See LICENSE for licensing information */ #ifndef _TOR_COMPAT_LIBEVENT_H #define _TOR_COMPAT_LIBEVENT_H #include "orconfig.h" struct event; struct event_base; #ifdef USE_BUFFEREVENTS struct bufferevent; struct ev_token_bucket_cfg; struct bufferevent_rate_limit_group; #endif #ifdef HAVE_EVENT2_EVENT_H #include #elif !defined(EVUTIL_SOCKET_DEFINED) #define EVUTIL_SOCKET_DEFINED #define evutil_socket_t int #endif void configure_libevent_logging(void); void suppress_libevent_log_msg(const char *msg); #ifdef HAVE_EVENT2_EVENT_H #define tor_event_new event_new #define tor_evtimer_new evtimer_new #define tor_evsignal_new evsignal_new #define tor_event_free event_free #define tor_evdns_add_server_port(sock, tcp, cb, data) \ evdns_add_server_port_with_base(tor_libevent_get_base(), \ (sock),(tcp),(cb),(data)); #else struct event *tor_event_new(struct event_base * base, evutil_socket_t sock, short what, void (*cb)(evutil_socket_t, short, void *), void *arg); struct event *tor_evtimer_new(struct event_base * base, void (*cb)(evutil_socket_t, short, void *), void *arg); struct event *tor_evsignal_new(struct event_base * base, int sig, void (*cb)(evutil_socket_t, short, void *), void *arg); void tor_event_free(struct event *ev); #define tor_evdns_add_server_port evdns_add_server_port #endif typedef struct tor_libevent_action_t tor_libevent_action_t; tor_libevent_action_t *tor_run_in_libevent_loop(void (*cb)(void *arg), void *arg); void tor_cancel_libevent_action(tor_libevent_action_t *action); typedef struct periodic_timer_t periodic_timer_t; periodic_timer_t *periodic_timer_new(struct event_base *base, const struct timeval *tv, void (*cb)(periodic_timer_t *timer, void *data), void *data); void periodic_timer_free(periodic_timer_t *); #ifdef HAVE_EVENT_BASE_LOOPEXIT #define tor_event_base_loopexit event_base_loopexit #else struct timeval; int tor_event_base_loopexit(struct event_base *base, struct timeval *tv); #endif typedef struct tor_libevent_cfg { int disable_iocp; int num_cpus; int msec_per_tick; } tor_libevent_cfg; void tor_libevent_initialize(tor_libevent_cfg *cfg); struct event_base *tor_libevent_get_base(void); const char *tor_libevent_get_method(void); void tor_check_libevent_version(const char *m, int server, const char **badness_out); void tor_check_libevent_header_compatibility(void); const char *tor_libevent_get_version_str(void); #ifdef USE_BUFFEREVENTS const struct timeval *tor_libevent_get_one_tick_timeout(void); int tor_libevent_using_iocp_bufferevents(void); int tor_set_bufferevent_rate_limit(struct bufferevent *bev, struct ev_token_bucket_cfg *cfg); int tor_add_bufferevent_to_rate_limit_group(struct bufferevent *bev, struct bufferevent_rate_limit_group *g); #endif #endif