123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132 |
- /* Copyright (c) 2009-2015, The Tor Project, Inc. */
- /* See LICENSE for licensing information */
- #ifndef TOR_COMPAT_LIBEVENT_H
- #define TOR_COMPAT_LIBEVENT_H
- #include "orconfig.h"
- #include "testsupport.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 <event2/util.h>
- #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_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);
- #define tor_evdns_add_server_port evdns_add_server_port
- #endif
- void tor_event_free(struct event *ev);
- 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 *);
- #define tor_event_base_loopexit event_base_loopexit
- /** Defines a configuration for using libevent with Tor: passed as an argument
- * to tor_libevent_initialize() to describe how we want to set up. */
- typedef struct tor_libevent_cfg {
- /** Flag: if true, disable IOCP (assuming that it could be enabled). */
- int disable_iocp;
- /** How many CPUs should we use (relevant only with IOCP). */
- int num_cpus;
- /** How many milliseconds should we allow between updating bandwidth limits?
- * (relevant only with bufferevents). */
- int msec_per_tick;
- } tor_libevent_cfg;
- void tor_libevent_initialize(tor_libevent_cfg *cfg);
- MOCK_DECL(struct event_base *, tor_libevent_get_base, (void));
- const char *tor_libevent_get_method(void);
- void tor_check_libevent_header_compatibility(void);
- const char *tor_libevent_get_version_str(void);
- const char *tor_libevent_get_header_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
- int tor_init_libevent_rng(void);
- void tor_gettimeofday_cached(struct timeval *tv);
- void tor_gettimeofday_cache_clear(void);
- #ifdef TOR_UNIT_TESTS
- void tor_gettimeofday_cache_set(const struct timeval *tv);
- #endif
- void tor_gettimeofday_cached_monotonic(struct timeval *tv);
- #ifdef COMPAT_LIBEVENT_PRIVATE
- /** A number representing a version of Libevent.
- This is a 4-byte number, with the first three bytes representing the
- major, minor, and patchlevel respectively of the library. The fourth
- byte is unused.
- This is equivalent to the format of LIBEVENT_VERSION_NUMBER on Libevent
- 2.0.1 or later. For versions of Libevent before 1.4.0, which followed the
- format of "1.0, 1.0a, 1.0b", we define 1.0 to be equivalent to 1.0.0, 1.0a
- to be equivalent to 1.0.1, and so on.
- */
- typedef uint32_t le_version_t;
- /** @{ */
- /** Macros: returns the number of a libevent version as a le_version_t */
- #define V(major, minor, patch) \
- (((major) << 24) | ((minor) << 16) | ((patch) << 8))
- #define V_OLD(major, minor, patch) \
- V((major), (minor), (patch)-'a'+1)
- /** @} */
- /** Represetns a version of libevent so old we can't figure out what version
- * it is. */
- #define LE_OLD V(0,0,0)
- /** Represents a version of libevent so weird we can't figure out what version
- * it is. */
- #define LE_OTHER V(0,0,99)
- STATIC void
- libevent_logging_callback(int severity, const char *msg);
- STATIC le_version_t
- tor_decode_libevent_version(const char *v);
- STATIC int
- le_versions_compatibility(le_version_t v);
- #endif
- #endif
|