|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#ifndef EV_H_ |
|
#define EV_H_ |
|
|
|
#ifdef __cplusplus |
|
# define EV_CPP(x) x |
|
# if __cplusplus >= 201103L |
|
# define EV_NOEXCEPT noexcept |
|
# else |
|
# define EV_NOEXCEPT |
|
# endif |
|
#else |
|
# define EV_CPP(x) |
|
# define EV_NOEXCEPT |
|
#endif |
|
#define EV_THROW EV_NOEXCEPT |
|
|
|
EV_CPP(extern "C" {) |
|
|
|
|
|
|
|
|
|
#ifndef EV_COMPAT3 |
|
# define EV_COMPAT3 1 |
|
#endif |
|
|
|
#ifndef EV_FEATURES |
|
# if defined __OPTIMIZE_SIZE__ |
|
# define EV_FEATURES 0x7c |
|
# else |
|
# define EV_FEATURES 0x7f |
|
# endif |
|
#endif |
|
|
|
#define EV_FEATURE_CODE ((EV_FEATURES) & 1) |
|
#define EV_FEATURE_DATA ((EV_FEATURES) & 2) |
|
#define EV_FEATURE_CONFIG ((EV_FEATURES) & 4) |
|
#define EV_FEATURE_API ((EV_FEATURES) & 8) |
|
#define EV_FEATURE_WATCHERS ((EV_FEATURES) & 16) |
|
#define EV_FEATURE_BACKENDS ((EV_FEATURES) & 32) |
|
#define EV_FEATURE_OS ((EV_FEATURES) & 64) |
|
|
|
|
|
#ifndef EV_MINPRI |
|
# define EV_MINPRI (EV_FEATURE_CONFIG ? -2 : 0) |
|
#endif |
|
#ifndef EV_MAXPRI |
|
# define EV_MAXPRI (EV_FEATURE_CONFIG ? +2 : 0) |
|
#endif |
|
|
|
#ifndef EV_MULTIPLICITY |
|
# define EV_MULTIPLICITY EV_FEATURE_CONFIG |
|
#endif |
|
|
|
#ifndef EV_PERIODIC_ENABLE |
|
# define EV_PERIODIC_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_STAT_ENABLE |
|
# define EV_STAT_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_PREPARE_ENABLE |
|
# define EV_PREPARE_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_CHECK_ENABLE |
|
# define EV_CHECK_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_IDLE_ENABLE |
|
# define EV_IDLE_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_FORK_ENABLE |
|
# define EV_FORK_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_CLEANUP_ENABLE |
|
# define EV_CLEANUP_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_SIGNAL_ENABLE |
|
# define EV_SIGNAL_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_CHILD_ENABLE |
|
# ifdef _WIN32 |
|
# define EV_CHILD_ENABLE 0 |
|
# else |
|
# define EV_CHILD_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
#endif |
|
|
|
#ifndef EV_ASYNC_ENABLE |
|
# define EV_ASYNC_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_EMBED_ENABLE |
|
# define EV_EMBED_ENABLE EV_FEATURE_WATCHERS |
|
#endif |
|
|
|
#ifndef EV_WALK_ENABLE |
|
# define EV_WALK_ENABLE 0 |
|
#endif |
|
|
|
|
|
|
|
#if EV_CHILD_ENABLE && !EV_SIGNAL_ENABLE |
|
# undef EV_SIGNAL_ENABLE |
|
# define EV_SIGNAL_ENABLE 1 |
|
#endif |
|
|
|
|
|
|
|
#ifndef EV_TSTAMP_T |
|
# define EV_TSTAMP_T double |
|
#endif |
|
typedef EV_TSTAMP_T ev_tstamp; |
|
|
|
#include <string.h> |
|
|
|
#ifndef EV_ATOMIC_T |
|
# include <signal.h> |
|
# define EV_ATOMIC_T sig_atomic_t volatile |
|
#endif |
|
|
|
#if EV_STAT_ENABLE |
|
# ifdef _WIN32 |
|
# include <time.h> |
|
# include <sys/types.h> |
|
# endif |
|
# include <sys/stat.h> |
|
#endif |
|
|
|
|
|
#if EV_MULTIPLICITY |
|
struct ev_loop; |
|
# define EV_P struct ev_loop *loop |
|
# define EV_P_ EV_P, |
|
# define EV_A loop |
|
# define EV_A_ EV_A, |
|
# define EV_DEFAULT_UC ev_default_loop_uc_ () |
|
# define EV_DEFAULT_UC_ EV_DEFAULT_UC, |
|
# define EV_DEFAULT ev_default_loop (0) |
|
# define EV_DEFAULT_ EV_DEFAULT, |
|
#else |
|
# define EV_P void |
|
# define EV_P_ |
|
# define EV_A |
|
# define EV_A_ |
|
# define EV_DEFAULT |
|
# define EV_DEFAULT_ |
|
# define EV_DEFAULT_UC |
|
# define EV_DEFAULT_UC_ |
|
# undef EV_EMBED_ENABLE |
|
#endif |
|
|
|
|
|
#if __STDC_VERSION__ >= 199901L || __GNUC__ >= 3 |
|
# define EV_INLINE static inline |
|
#else |
|
# define EV_INLINE static |
|
#endif |
|
|
|
#ifdef EV_API_STATIC |
|
# define EV_API_DECL static |
|
#else |
|
# define EV_API_DECL extern |
|
#endif |
|
|
|
|
|
#ifndef EV_PROTOTYPES |
|
# define EV_PROTOTYPES 1 |
|
#endif |
|
|
|
|
|
|
|
#define EV_VERSION_MAJOR 4 |
|
#define EV_VERSION_MINOR 33 |
|
|
|
|
|
enum { |
|
EV_UNDEF = (int)0xFFFFFFFF, |
|
EV_NONE = 0x00, |
|
EV_READ = 0x01, |
|
EV_WRITE = 0x02, |
|
EV__IOFDSET = 0x80, |
|
EV_IO = EV_READ, |
|
EV_TIMER = 0x00000100, |
|
#if EV_COMPAT3 |
|
EV_TIMEOUT = EV_TIMER, |
|
#endif |
|
EV_PERIODIC = 0x00000200, |
|
EV_SIGNAL = 0x00000400, |
|
EV_CHILD = 0x00000800, |
|
EV_STAT = 0x00001000, |
|
EV_IDLE = 0x00002000, |
|
EV_PREPARE = 0x00004000, |
|
EV_CHECK = 0x00008000, |
|
EV_EMBED = 0x00010000, |
|
EV_FORK = 0x00020000, |
|
EV_CLEANUP = 0x00040000, |
|
EV_ASYNC = 0x00080000, |
|
EV_CUSTOM = 0x01000000, |
|
EV_ERROR = (int)0x80000000 |
|
}; |
|
|
|
|
|
#ifndef EV_COMMON |
|
# define EV_COMMON void *data; |
|
#endif |
|
|
|
#ifndef EV_CB_DECLARE |
|
# define EV_CB_DECLARE(type) void (*cb)(EV_P_ struct type *w, int revents); |
|
#endif |
|
#ifndef EV_CB_INVOKE |
|
# define EV_CB_INVOKE(watcher,revents) (watcher)->cb (EV_A_ (watcher), (revents)) |
|
#endif |
|
|
|
|
|
#define EV_CB(type,name) void name (EV_P_ struct ev_ ## type *w, int revents) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#if EV_MINPRI == EV_MAXPRI |
|
# define EV_DECL_PRIORITY |
|
#elif !defined (EV_DECL_PRIORITY) |
|
# define EV_DECL_PRIORITY int priority; |
|
#endif |
|
|
|
|
|
#define EV_WATCHER(type) \ |
|
int active; \ |
|
int pending; \ |
|
EV_DECL_PRIORITY \ |
|
EV_COMMON \ |
|
EV_CB_DECLARE (type) |
|
|
|
#define EV_WATCHER_LIST(type) \ |
|
EV_WATCHER (type) \ |
|
struct ev_watcher_list *next; |
|
|
|
#define EV_WATCHER_TIME(type) \ |
|
EV_WATCHER (type) \ |
|
ev_tstamp at; |
|
|
|
|
|
typedef struct ev_watcher |
|
{ |
|
EV_WATCHER (ev_watcher) |
|
} ev_watcher; |
|
|
|
|
|
typedef struct ev_watcher_list |
|
{ |
|
EV_WATCHER_LIST (ev_watcher_list) |
|
} ev_watcher_list; |
|
|
|
|
|
typedef struct ev_watcher_time |
|
{ |
|
EV_WATCHER_TIME (ev_watcher_time) |
|
} ev_watcher_time; |
|
|
|
|
|
|
|
typedef struct ev_io |
|
{ |
|
EV_WATCHER_LIST (ev_io) |
|
|
|
int fd; |
|
int events; |
|
} ev_io; |
|
|
|
|
|
|
|
typedef struct ev_timer |
|
{ |
|
EV_WATCHER_TIME (ev_timer) |
|
|
|
ev_tstamp repeat; |
|
} ev_timer; |
|
|
|
|
|
|
|
typedef struct ev_periodic |
|
{ |
|
EV_WATCHER_TIME (ev_periodic) |
|
|
|
ev_tstamp offset; |
|
ev_tstamp interval; |
|
ev_tstamp (*reschedule_cb)(struct ev_periodic *w, ev_tstamp now) EV_NOEXCEPT; |
|
} ev_periodic; |
|
|
|
|
|
|
|
typedef struct ev_signal |
|
{ |
|
EV_WATCHER_LIST (ev_signal) |
|
|
|
int signum; |
|
} ev_signal; |
|
|
|
|
|
|
|
|
|
typedef struct ev_child |
|
{ |
|
EV_WATCHER_LIST (ev_child) |
|
|
|
int flags; |
|
int pid; |
|
int rpid; |
|
int rstatus; |
|
} ev_child; |
|
|
|
#if EV_STAT_ENABLE |
|
|
|
# ifdef _WIN32 |
|
typedef struct _stati64 ev_statdata; |
|
# else |
|
typedef struct stat ev_statdata; |
|
# endif |
|
|
|
|
|
|
|
typedef struct ev_stat |
|
{ |
|
EV_WATCHER_LIST (ev_stat) |
|
|
|
ev_timer timer; |
|
ev_tstamp interval; |
|
const char *path; |
|
ev_statdata prev; |
|
ev_statdata attr; |
|
|
|
int wd; |
|
} ev_stat; |
|
#endif |
|
|
|
|
|
|
|
typedef struct ev_idle |
|
{ |
|
EV_WATCHER (ev_idle) |
|
} ev_idle; |
|
|
|
|
|
|
|
|
|
typedef struct ev_prepare |
|
{ |
|
EV_WATCHER (ev_prepare) |
|
} ev_prepare; |
|
|
|
|
|
|
|
typedef struct ev_check |
|
{ |
|
EV_WATCHER (ev_check) |
|
} ev_check; |
|
|
|
|
|
|
|
typedef struct ev_fork |
|
{ |
|
EV_WATCHER (ev_fork) |
|
} ev_fork; |
|
|
|
|
|
|
|
typedef struct ev_cleanup |
|
{ |
|
EV_WATCHER (ev_cleanup) |
|
} ev_cleanup; |
|
|
|
#if EV_EMBED_ENABLE |
|
|
|
|
|
typedef struct ev_embed |
|
{ |
|
EV_WATCHER (ev_embed) |
|
|
|
struct ev_loop *other; |
|
#undef EV_IO_ENABLE |
|
#define EV_IO_ENABLE 1 |
|
ev_io io; |
|
#undef EV_PREPARE_ENABLE |
|
#define EV_PREPARE_ENABLE 1 |
|
ev_prepare prepare; |
|
ev_check check; |
|
ev_timer timer; |
|
ev_periodic periodic; |
|
ev_idle idle; |
|
ev_fork fork; |
|
ev_cleanup cleanup; |
|
} ev_embed; |
|
#endif |
|
|
|
#if EV_ASYNC_ENABLE |
|
|
|
|
|
typedef struct ev_async |
|
{ |
|
EV_WATCHER (ev_async) |
|
|
|
EV_ATOMIC_T sent; |
|
} ev_async; |
|
|
|
# define ev_async_pending(w) (+(w)->sent) |
|
#endif |
|
|
|
|
|
union ev_any_watcher |
|
{ |
|
struct ev_watcher w; |
|
struct ev_watcher_list wl; |
|
|
|
struct ev_io io; |
|
struct ev_timer timer; |
|
struct ev_periodic periodic; |
|
struct ev_signal signal; |
|
struct ev_child child; |
|
#if EV_STAT_ENABLE |
|
struct ev_stat stat; |
|
#endif |
|
#if EV_IDLE_ENABLE |
|
struct ev_idle idle; |
|
#endif |
|
struct ev_prepare prepare; |
|
struct ev_check check; |
|
#if EV_FORK_ENABLE |
|
struct ev_fork fork; |
|
#endif |
|
#if EV_CLEANUP_ENABLE |
|
struct ev_cleanup cleanup; |
|
#endif |
|
#if EV_EMBED_ENABLE |
|
struct ev_embed embed; |
|
#endif |
|
#if EV_ASYNC_ENABLE |
|
struct ev_async async; |
|
#endif |
|
}; |
|
|
|
|
|
enum { |
|
|
|
EVFLAG_AUTO = 0x00000000U, |
|
|
|
EVFLAG_NOENV = 0x01000000U, |
|
EVFLAG_FORKCHECK = 0x02000000U, |
|
|
|
EVFLAG_NOINOTIFY = 0x00100000U, |
|
#if EV_COMPAT3 |
|
EVFLAG_NOSIGFD = 0, |
|
#endif |
|
EVFLAG_SIGNALFD = 0x00200000U, |
|
EVFLAG_NOSIGMASK = 0x00400000U, |
|
EVFLAG_NOTIMERFD = 0x00800000U |
|
}; |
|
|
|
|
|
enum { |
|
EVBACKEND_SELECT = 0x00000001U, |
|
EVBACKEND_POLL = 0x00000002U, |
|
EVBACKEND_EPOLL = 0x00000004U, |
|
EVBACKEND_KQUEUE = 0x00000008U, |
|
EVBACKEND_DEVPOLL = 0x00000010U, |
|
EVBACKEND_PORT = 0x00000020U, |
|
EVBACKEND_LINUXAIO = 0x00000040U, |
|
EVBACKEND_IOURING = 0x00000080U, |
|
EVBACKEND_ALL = 0x000000FFU, |
|
EVBACKEND_MASK = 0x0000FFFFU |
|
}; |
|
|
|
#if EV_PROTOTYPES |
|
EV_API_DECL int ev_version_major (void) EV_NOEXCEPT; |
|
EV_API_DECL int ev_version_minor (void) EV_NOEXCEPT; |
|
|
|
EV_API_DECL unsigned int ev_supported_backends (void) EV_NOEXCEPT; |
|
EV_API_DECL unsigned int ev_recommended_backends (void) EV_NOEXCEPT; |
|
EV_API_DECL unsigned int ev_embeddable_backends (void) EV_NOEXCEPT; |
|
|
|
EV_API_DECL ev_tstamp ev_time (void) EV_NOEXCEPT; |
|
EV_API_DECL void ev_sleep (ev_tstamp delay) EV_NOEXCEPT; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
EV_API_DECL void ev_set_allocator (void *(*cb)(void *ptr, long size) EV_NOEXCEPT) EV_NOEXCEPT; |
|
|
|
|
|
|
|
|
|
|
|
EV_API_DECL void ev_set_syserr_cb (void (*cb)(const char *msg) EV_NOEXCEPT) EV_NOEXCEPT; |
|
|
|
#if EV_MULTIPLICITY |
|
|
|
|
|
|
|
EV_API_DECL struct ev_loop *ev_default_loop (unsigned int flags EV_CPP (= 0)) EV_NOEXCEPT; |
|
|
|
#ifdef EV_API_STATIC |
|
EV_API_DECL struct ev_loop *ev_default_loop_ptr; |
|
#endif |
|
|
|
EV_INLINE struct ev_loop * |
|
ev_default_loop_uc_ (void) EV_NOEXCEPT |
|
{ |
|
extern struct ev_loop *ev_default_loop_ptr; |
|
|
|
return ev_default_loop_ptr; |
|
} |
|
|
|
EV_INLINE int |
|
ev_is_default_loop (EV_P) EV_NOEXCEPT |
|
{ |
|
return EV_A == EV_DEFAULT_UC; |
|
} |
|
|
|
|
|
EV_API_DECL struct ev_loop *ev_loop_new (unsigned int flags EV_CPP (= 0)) EV_NOEXCEPT; |
|
|
|
EV_API_DECL ev_tstamp ev_now (EV_P) EV_NOEXCEPT; |
|
|
|
#else |
|
|
|
EV_API_DECL int ev_default_loop (unsigned int flags EV_CPP (= 0)) EV_NOEXCEPT; |
|
|
|
EV_API_DECL ev_tstamp ev_rt_now; |
|
|
|
EV_INLINE ev_tstamp |
|
ev_now (void) EV_NOEXCEPT |
|
{ |
|
return ev_rt_now; |
|
} |
|
|
|
|
|
EV_INLINE int |
|
ev_is_default_loop (void) EV_NOEXCEPT |
|
{ |
|
return 1; |
|
} |
|
|
|
#endif |
|
|
|
|
|
EV_API_DECL void ev_loop_destroy (EV_P); |
|
|
|
|
|
|
|
|
|
|
|
EV_API_DECL void ev_loop_fork (EV_P) EV_NOEXCEPT; |
|
|
|
EV_API_DECL unsigned int ev_backend (EV_P) EV_NOEXCEPT; |
|
|
|
EV_API_DECL void ev_now_update (EV_P) EV_NOEXCEPT; |
|
|
|
#if EV_WALK_ENABLE |
|
|
|
|
|
|
|
EV_API_DECL void ev_walk (EV_P_ int types, void (*cb)(EV_P_ int type, void *w)) EV_NOEXCEPT; |
|
#endif |
|
|
|
#endif |
|
|
|
|
|
enum { |
|
EVRUN_NOWAIT = 1, |
|
EVRUN_ONCE = 2 |
|
}; |
|
|
|
|
|
enum { |
|
EVBREAK_CANCEL = 0, |
|
EVBREAK_ONE = 1, |
|
EVBREAK_ALL = 2 |
|
}; |
|
|
|
#if EV_PROTOTYPES |
|
EV_API_DECL int ev_run (EV_P_ int flags EV_CPP (= 0)); |
|
EV_API_DECL void ev_break (EV_P_ int how EV_CPP (= EVBREAK_ONE)) EV_NOEXCEPT; |
|
|
|
|
|
|
|
|
|
|
|
|
|
EV_API_DECL void ev_ref (EV_P) EV_NOEXCEPT; |
|
EV_API_DECL void ev_unref (EV_P) EV_NOEXCEPT; |
|
|
|
|
|
|
|
|
|
|
|
EV_API_DECL void ev_once (EV_P_ int fd, int events, ev_tstamp timeout, void (*cb)(int revents, void *arg), void *arg) EV_NOEXCEPT; |
|
|
|
EV_API_DECL void ev_invoke_pending (EV_P); |
|
|
|
# if EV_FEATURE_API |
|
EV_API_DECL unsigned int ev_iteration (EV_P) EV_NOEXCEPT; |
|
EV_API_DECL unsigned int ev_depth (EV_P) EV_NOEXCEPT; |
|
EV_API_DECL void ev_verify (EV_P) EV_NOEXCEPT; |
|
|
|
EV_API_DECL void ev_set_io_collect_interval (EV_P_ ev_tstamp interval) EV_NOEXCEPT; |
|
EV_API_DECL void ev_set_timeout_collect_interval (EV_P_ ev_tstamp interval) EV_NOEXCEPT; |
|
|
|
|
|
EV_API_DECL void ev_set_userdata (EV_P_ void *data) EV_NOEXCEPT; |
|
EV_API_DECL void *ev_userdata (EV_P) EV_NOEXCEPT; |
|
typedef void (*ev_loop_callback)(EV_P); |
|
EV_API_DECL void ev_set_invoke_pending_cb (EV_P_ ev_loop_callback invoke_pending_cb) EV_NOEXCEPT; |
|
|
|
EV_API_DECL void ev_set_loop_release_cb (EV_P_ void (*release)(EV_P) EV_NOEXCEPT, void (*acquire)(EV_P) EV_NOEXCEPT) EV_NOEXCEPT; |
|
|
|
EV_API_DECL unsigned int ev_pending_count (EV_P) EV_NOEXCEPT; |
|
|
|
|
|
|
|
|
|
EV_API_DECL void ev_suspend (EV_P) EV_NOEXCEPT; |
|
EV_API_DECL void ev_resume (EV_P) EV_NOEXCEPT; |
|
#endif |
|
|
|
#endif |
|
|
|
|
|
|
|
#define ev_init(ev,cb_) do { \ |
|
((ev_watcher *)(void *)(ev))->active = \ |
|
((ev_watcher *)(void *)(ev))->pending = 0; \ |
|
ev_set_priority ((ev), 0); \ |
|
ev_set_cb ((ev), cb_); \ |
|
} while (0) |
|
|
|
#define ev_io_modify(ev,events_) do { (ev)->events = (ev)->events & EV__IOFDSET | (events_); } while (0) |
|
#define ev_io_set(ev,fd_,events_) do { (ev)->fd = (fd_); (ev)->events = (events_) | EV__IOFDSET; } while (0) |
|
#define ev_timer_set(ev,after_,repeat_) do { ((ev_watcher_time *)(ev))->at = (after_); (ev)->repeat = (repeat_); } while (0) |
|
#define ev_periodic_set(ev,ofs_,ival_,rcb_) do { (ev)->offset = (ofs_); (ev)->interval = (ival_); (ev)->reschedule_cb = (rcb_); } while (0) |
|
#define ev_signal_set(ev,signum_) do { (ev)->signum = (signum_); } while (0) |
|
#define ev_child_set(ev,pid_,trace_) do { (ev)->pid = (pid_); (ev)->flags = !!(trace_); } while (0) |
|
#define ev_stat_set(ev,path_,interval_) do { (ev)->path = (path_); (ev)->interval = (interval_); (ev)->wd = -2; } while (0) |
|
#define ev_idle_set(ev) |
|
#define ev_prepare_set(ev) |
|
#define ev_check_set(ev) |
|
#define ev_embed_set(ev,other_) do { (ev)->other = (other_); } while (0) |
|
#define ev_fork_set(ev) |
|
#define ev_cleanup_set(ev) |
|
#define ev_async_set(ev) |
|
|
|
#define ev_io_init(ev,cb,fd,events) do { ev_init ((ev), (cb)); ev_io_set ((ev),(fd),(events)); } while (0) |
|
#define ev_timer_init(ev,cb,after,repeat) do { ev_init ((ev), (cb)); ev_timer_set ((ev),(after),(repeat)); } while (0) |
|
#define ev_periodic_init(ev,cb,ofs,ival,rcb) do { ev_init ((ev), (cb)); ev_periodic_set ((ev),(ofs),(ival),(rcb)); } while (0) |
|
#define ev_signal_init(ev,cb,signum) do { ev_init ((ev), (cb)); ev_signal_set ((ev), (signum)); } while (0) |
|
#define ev_child_init(ev,cb,pid,trace) do { ev_init ((ev), (cb)); ev_child_set ((ev),(pid),(trace)); } while (0) |
|
#define ev_stat_init(ev,cb,path,interval) do { ev_init ((ev), (cb)); ev_stat_set ((ev),(path),(interval)); } while (0) |
|
#define ev_idle_init(ev,cb) do { ev_init ((ev), (cb)); ev_idle_set ((ev)); } while (0) |
|
#define ev_prepare_init(ev,cb) do { ev_init ((ev), (cb)); ev_prepare_set ((ev)); } while (0) |
|
#define ev_check_init(ev,cb) do { ev_init ((ev), (cb)); ev_check_set ((ev)); } while (0) |
|
#define ev_embed_init(ev,cb,other) do { ev_init ((ev), (cb)); ev_embed_set ((ev),(other)); } while (0) |
|
#define ev_fork_init(ev,cb) do { ev_init ((ev), (cb)); ev_fork_set ((ev)); } while (0) |
|
#define ev_cleanup_init(ev,cb) do { ev_init ((ev), (cb)); ev_cleanup_set ((ev)); } while (0) |
|
#define ev_async_init(ev,cb) do { ev_init ((ev), (cb)); ev_async_set ((ev)); } while (0) |
|
|
|
#define ev_is_pending(ev) (0 + ((ev_watcher *)(void *)(ev))->pending) |
|
#define ev_is_active(ev) (0 + ((ev_watcher *)(void *)(ev))->active) |
|
|
|
#define ev_cb_(ev) (ev)->cb |
|
#define ev_cb(ev) (memmove (&ev_cb_ (ev), &((ev_watcher *)(ev))->cb, sizeof (ev_cb_ (ev))), (ev)->cb) |
|
|
|
#if EV_MINPRI == EV_MAXPRI |
|
# define ev_priority(ev) ((ev), EV_MINPRI) |
|
# define ev_set_priority(ev,pri) ((ev), (pri)) |
|
#else |
|
# define ev_priority(ev) (+(((ev_watcher *)(void *)(ev))->priority)) |
|
# define ev_set_priority(ev,pri) ( (ev_watcher *)(void *)(ev))->priority = (pri) |
|
#endif |
|
|
|
#define ev_periodic_at(ev) (+((ev_watcher_time *)(ev))->at) |
|
|
|
#ifndef ev_set_cb |
|
|
|
# define ev_set_cb(ev,cb_) (ev_cb_ (ev) = (cb_), memmove (&((ev_watcher *)(ev))->cb, &ev_cb_ (ev), sizeof (ev_cb_ (ev)))) |
|
#endif |
|
|
|
|
|
|
|
#if EV_PROTOTYPES |
|
|
|
|
|
|
|
EV_API_DECL void ev_feed_event (EV_P_ void *w, int revents) EV_NOEXCEPT; |
|
EV_API_DECL void ev_feed_fd_event (EV_P_ int fd, int revents) EV_NOEXCEPT; |
|
#if EV_SIGNAL_ENABLE |
|
EV_API_DECL void ev_feed_signal (int signum) EV_NOEXCEPT; |
|
EV_API_DECL void ev_feed_signal_event (EV_P_ int signum) EV_NOEXCEPT; |
|
#endif |
|
EV_API_DECL void ev_invoke (EV_P_ void *w, int revents); |
|
EV_API_DECL int ev_clear_pending (EV_P_ void *w) EV_NOEXCEPT; |
|
|
|
EV_API_DECL void ev_io_start (EV_P_ ev_io *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_io_stop (EV_P_ ev_io *w) EV_NOEXCEPT; |
|
|
|
EV_API_DECL void ev_timer_start (EV_P_ ev_timer *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_timer_stop (EV_P_ ev_timer *w) EV_NOEXCEPT; |
|
|
|
EV_API_DECL void ev_timer_again (EV_P_ ev_timer *w) EV_NOEXCEPT; |
|
|
|
EV_API_DECL ev_tstamp ev_timer_remaining (EV_P_ ev_timer *w) EV_NOEXCEPT; |
|
|
|
#if EV_PERIODIC_ENABLE |
|
EV_API_DECL void ev_periodic_start (EV_P_ ev_periodic *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_periodic_stop (EV_P_ ev_periodic *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_periodic_again (EV_P_ ev_periodic *w) EV_NOEXCEPT; |
|
#endif |
|
|
|
|
|
#if EV_SIGNAL_ENABLE |
|
EV_API_DECL void ev_signal_start (EV_P_ ev_signal *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_signal_stop (EV_P_ ev_signal *w) EV_NOEXCEPT; |
|
#endif |
|
|
|
|
|
# if EV_CHILD_ENABLE |
|
EV_API_DECL void ev_child_start (EV_P_ ev_child *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_child_stop (EV_P_ ev_child *w) EV_NOEXCEPT; |
|
# endif |
|
|
|
# if EV_STAT_ENABLE |
|
EV_API_DECL void ev_stat_start (EV_P_ ev_stat *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_stat_stop (EV_P_ ev_stat *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_stat_stat (EV_P_ ev_stat *w) EV_NOEXCEPT; |
|
# endif |
|
|
|
# if EV_IDLE_ENABLE |
|
EV_API_DECL void ev_idle_start (EV_P_ ev_idle *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_idle_stop (EV_P_ ev_idle *w) EV_NOEXCEPT; |
|
# endif |
|
|
|
#if EV_PREPARE_ENABLE |
|
EV_API_DECL void ev_prepare_start (EV_P_ ev_prepare *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_prepare_stop (EV_P_ ev_prepare *w) EV_NOEXCEPT; |
|
#endif |
|
|
|
#if EV_CHECK_ENABLE |
|
EV_API_DECL void ev_check_start (EV_P_ ev_check *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_check_stop (EV_P_ ev_check *w) EV_NOEXCEPT; |
|
#endif |
|
|
|
# if EV_FORK_ENABLE |
|
EV_API_DECL void ev_fork_start (EV_P_ ev_fork *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_fork_stop (EV_P_ ev_fork *w) EV_NOEXCEPT; |
|
# endif |
|
|
|
# if EV_CLEANUP_ENABLE |
|
EV_API_DECL void ev_cleanup_start (EV_P_ ev_cleanup *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_cleanup_stop (EV_P_ ev_cleanup *w) EV_NOEXCEPT; |
|
# endif |
|
|
|
# if EV_EMBED_ENABLE |
|
|
|
EV_API_DECL void ev_embed_start (EV_P_ ev_embed *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_embed_stop (EV_P_ ev_embed *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_embed_sweep (EV_P_ ev_embed *w) EV_NOEXCEPT; |
|
# endif |
|
|
|
# if EV_ASYNC_ENABLE |
|
EV_API_DECL void ev_async_start (EV_P_ ev_async *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_async_stop (EV_P_ ev_async *w) EV_NOEXCEPT; |
|
EV_API_DECL void ev_async_send (EV_P_ ev_async *w) EV_NOEXCEPT; |
|
# endif |
|
|
|
#if EV_COMPAT3 |
|
#define EVLOOP_NONBLOCK EVRUN_NOWAIT |
|
#define EVLOOP_ONESHOT EVRUN_ONCE |
|
#define EVUNLOOP_CANCEL EVBREAK_CANCEL |
|
#define EVUNLOOP_ONE EVBREAK_ONE |
|
#define EVUNLOOP_ALL EVBREAK_ALL |
|
#if EV_PROTOTYPES |
|
EV_INLINE void ev_loop (EV_P_ int flags) { ev_run (EV_A_ flags); } |
|
EV_INLINE void ev_unloop (EV_P_ int how ) { ev_break (EV_A_ how ); } |
|
EV_INLINE void ev_default_destroy (void) { ev_loop_destroy (EV_DEFAULT); } |
|
EV_INLINE void ev_default_fork (void) { ev_loop_fork (EV_DEFAULT); } |
|
#if EV_FEATURE_API |
|
EV_INLINE unsigned int ev_loop_count (EV_P) { return ev_iteration (EV_A); } |
|
EV_INLINE unsigned int ev_loop_depth (EV_P) { return ev_depth (EV_A); } |
|
EV_INLINE void ev_loop_verify (EV_P) { ev_verify (EV_A); } |
|
#endif |
|
#endif |
|
#else |
|
typedef struct ev_loop ev_loop; |
|
#endif |
|
|
|
#endif |
|
|
|
EV_CPP(}) |
|
|
|
#endif |
|
|
|
|