1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
|
/*
* Copyright (c) 2009 Marko Kreen
*
* Permission to use, copy, modify, and/or distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
* copyright notice and this permission notice appear in all copies.
*
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
/**
* @file
* libevent compat.
*
* This module adds few functions to older libevent versions,
* or provides it's own libevent-compatible event loop
* for cases where performance and features of full libevent
* are not needed.
*/
#ifndef _USUAL_EVENT_H_
#define _USUAL_EVENT_H_
#include <usual/base.h>
#ifdef HAVE_SYS_TIME_H
#include <sys/time.h>
#endif
#ifdef HAVE_LIBEVENT
/*
* Real libevent
*/
#include <event.h>
#ifndef HAVE_EVENT_BASE_NEW
/** Compat: make sure event_base_new() always available */
static inline struct event_base *event_base_new(void)
{
return event_init();
}
#endif
#ifndef HAVE_EVENT_LOOPBREAK
/** Compat: dummy event_loopbreak for libevent 1.3 */
static inline void event_loopbreak(void) { }
#endif
#else
/*
* internal libevent
*/
#include <usual/list.h>
#include <usual/time.h>
/**
* Flags for event_set() / event_assign():
* EV_READ, EV_WRITE, EV_SIGNAL, EV_PERSIST
*
* Flags given to user callback:
* EV_READ, EV_WRITE, EV_SIGNAL, EV_TIMEOUT.
*/
enum EventFlags {
EV_TIMEOUT = 1,
EV_READ = 2,
EV_WRITE = 4,
EV_SIGNAL = 8,
EV_PERSIST = 16,
};
/** Flags for event_loop() */
enum EventLoopType {
EVLOOP_ONCE = 1,
EVLOOP_NONBLOCK = 2,
};
/** Event context. event_base contents are not open */
struct event_base;
/** user callback signature */
typedef void (*uevent_cb_f)(int fd, short flags, void *arg);
/** Read fd value from struct event */
#define EVENT_FD(ev) ((ev)->fd)
/** Read signal value from struct event */
#define EVENT_SIGNAL(ev) ((ev)->fd)
/**
* Event structure for internal event loop.
*
* Although the struct is open, no direct accesses should be done.
* Thus also the fields are incompatible with libevent.
*/
struct event {
/* node for fd or signal lists */
struct List node;
/* timeout info */
usec_t timeout_val;
int timeout_idx;
/* back-pointer into pollfd list */
int ev_idx;
/* event base it is attached to */
struct event_base *base;
/* user callback */
uevent_cb_f cb_func;
void *cb_arg;
/* fd or signal */
int fd;
/* both user and internal flags */
short flags;
};
struct event_base *event_init(void) _MUSTCHECK;
struct event_base *event_base_new(void) _MUSTCHECK;
void event_base_free(struct event_base *base);
void event_set(struct event *ev, int fd, short flags, uevent_cb_f cb, void *arg);
int event_loop(int loop_flags) _MUSTCHECK;
int event_loopbreak(void);
int event_add(struct event *ev, struct timeval *timeout) _MUSTCHECK;
int event_del(struct event *ev);
void event_assign(struct event *ev, struct event_base *base,
int fd, short flags, uevent_cb_f cb, void *cb_arg);
int event_base_loop(struct event_base *base, int loop_flags) _MUSTCHECK;
int event_base_loopbreak(struct event_base *base);
#define evtimer_set(ev, cb, arg) event_set(ev, -1, 0, cb, arg)
#define evtimer_add(ev, tv) event_add(ev, tv)
#define evtimer_del(ev) event_del(ev)
#define signal_set(ev, sig, cb, arg) event_set(ev, sig, EV_SIGNAL | EV_PERSIST, cb, arg)
#define signal_add(ev, tv) event_add(ev, tv)
#define signal_del(ev) event_del(ev)
/* random compat */
int event_once(int fd, short flags, uevent_cb_f cb_func, void *cb_arg, struct timeval *timeout);
int event_base_once(struct event_base *base, int fd, short flags, uevent_cb_f cb_func, void *cb_arg, struct timeval *timeout);
int event_loopexit(struct timeval *timeout);
int event_base_loopexit(struct event_base *base, struct timeval *timeout);
int event_base_set(struct event_base *base, struct event *ev);
const char *event_get_version(void);
const char *event_get_method(void);
/* pointless compat */
#define event_dispatch() event_loop(0)
#define event_base_dispatch(base) event_base_loop(base, 0)
#define event_initialized(ev) is_event_active(ev)
#define signal_initialized(ev) is_event_active(ev)
#define evtimer_initialized(ev) is_event_active(ev)
int is_event_active(struct event *ev);
#endif /* internal libevent */
#endif /* _USUAL_EVENT_H_ */
|
