libev/event_compat.h

/*
 * Copyright (c) 2000-2004 Niels Provos <provos@citi.umich.edu>
 * Copyright (c) 2008      Marc Alexander Lehmann <libev@schmorp.de>
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. The name of the author may not be used to endorse or promote products
 *    derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */
#ifdef __cplusplus
extern "C" {
#endif

#ifdef _WIN32
# define WIN32_LEAN_AND_MEAN
# include <windows.h>
# undef WIN32_LEAN_AND_MEAN
typedef unsigned char u_char;
typedef unsigned short u_short;
#else
# include <sys/types.h>
# include <sys/time.h>
# include <inttypes.h>
#endif

#include <stdarg.h>

/* Fix so that ppl dont have to run with <sys/queue.h> */
#ifndef TAILQ_ENTRY
#define _EVENT_DEFINED_TQENTRY
#define TAILQ_ENTRY(type)                                               \
struct {                                                                \
        struct type *tqe_next;  /* next element */                      \
        struct type **tqe_prev; /* address of previous next element */  \
}
#endif /* !TAILQ_ENTRY */
#ifndef RB_ENTRY
#define _EVENT_DEFINED_RBENTRY
#define RB_ENTRY(type)                                                  \
struct {                                                                \
        struct type *rbe_left;          /* left element */              \
        struct type *rbe_right;         /* right element */             \
        struct type *rbe_parent;        /* parent element */            \
        int rbe_color;                  /* node color */                \
}
#endif /* !RB_ENTRY */

/*
 * Key-Value pairs.  Can be used for HTTP headers but also for
 * query argument parsing.
 */
struct evkeyval {
        TAILQ_ENTRY(evkeyval) next;

        char *key;
        char *value;
};

#ifdef _EVENT_DEFINED_TQENTRY
#undef TAILQ_ENTRY
struct event_list;
struct evkeyvalq;
#undef _EVENT_DEFINED_TQENTRY
#else
TAILQ_HEAD (event_list, event);
TAILQ_HEAD (evkeyvalq, evkeyval);
#endif /* _EVENT_DEFINED_TQENTRY */
#ifdef _EVENT_DEFINED_RBENTRY
#undef RB_ENTRY
#undef _EVENT_DEFINED_RBENTRY
#endif /* _EVENT_DEFINED_RBENTRY */

struct eventop {
        char *name;
        void *(*init)(struct event_base *);
        int (*add)(void *, struct event *);
        int (*del)(void *, struct event *);
        int (*recalc)(struct event_base *, void *, int);
        int (*dispatch)(struct event_base *, void *, struct timeval *);
        void (*dealloc)(struct event_base *, void *);
};

/* These functions deal with buffering input and output */

struct evbuffer {
        u_char *buffer;
        u_char *orig_buffer;

        size_t misalign;
        size_t totallen;
        size_t off;

        void (*cb)(struct evbuffer *, size_t, size_t, void *);
        void *cbarg;
};

/* Just for error reporting - use other constants otherwise */
#define EVBUFFER_READ           0x01
#define EVBUFFER_WRITE          0x02
#define EVBUFFER_EOF            0x10
#define EVBUFFER_ERROR          0x20
#define EVBUFFER_TIMEOUT        0x40

struct bufferevent;
typedef void (*evbuffercb)(struct bufferevent *, void *);
typedef void (*everrorcb)(struct bufferevent *, short what, void *);

struct event_watermark {
        size_t low;
        size_t high;
};

struct bufferevent {
        struct event ev_read;
        struct event ev_write;

        struct evbuffer *input;
        struct evbuffer *output;

        struct event_watermark wm_read;
        struct event_watermark wm_write;

        evbuffercb readcb;
        evbuffercb writecb;
        everrorcb errorcb;
        void *cbarg;

        int timeout_read;       /* in seconds */
        int timeout_write;      /* in seconds */

        short enabled;  /* events that are currently enabled */
};

struct bufferevent *bufferevent_new(int fd,
    evbuffercb readcb, evbuffercb writecb, everrorcb errorcb, void *cbarg);
int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev);
int bufferevent_priority_set(struct bufferevent *bufev, int pri);
void bufferevent_free(struct bufferevent *bufev);
int bufferevent_write(struct bufferevent *bufev, const void *data, size_t size);
int bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf);
size_t bufferevent_read(struct bufferevent *bufev, void *data, size_t size);
int bufferevent_enable(struct bufferevent *bufev, short event);
int bufferevent_disable(struct bufferevent *bufev, short event);
void bufferevent_settimeout(struct bufferevent *bufev,
    int timeout_read, int timeout_write);

#define EVBUFFER_LENGTH(x)      (x)->off
#define EVBUFFER_DATA(x)        (x)->buffer
#define EVBUFFER_INPUT(x)       (x)->input
#define EVBUFFER_OUTPUT(x)      (x)->output

struct evbuffer *evbuffer_new(void);
void evbuffer_free(struct evbuffer *);
int evbuffer_expand(struct evbuffer *, size_t);
int evbuffer_add(struct evbuffer *, const void *, size_t);
int evbuffer_remove(struct evbuffer *, void *, size_t);
char *evbuffer_readline(struct evbuffer *);
int evbuffer_add_buffer(struct evbuffer *, struct evbuffer *);
int evbuffer_add_printf(struct evbuffer *, const char *fmt, ...);
int evbuffer_add_vprintf(struct evbuffer *, const char *fmt, va_list ap);
void evbuffer_drain(struct evbuffer *, size_t);
int evbuffer_write(struct evbuffer *, int);
int evbuffer_read(struct evbuffer *, int, int);
u_char *evbuffer_find(struct evbuffer *, const u_char *, size_t);
void evbuffer_setcb(struct evbuffer *, void (*)(struct evbuffer *, size_t, size_t, void *), void *);

/* 
 * Marshaling tagged data - We assume that all tags are inserted in their
 * numeric order - so that unknown tags will always be higher than the
 * known ones - and we can just ignore the end of an event buffer.
 */

void evtag_init(void);

void evtag_marshal(struct evbuffer *evbuf, uint32_t tag, const void *data,
    uint32_t len);

void encode_int(struct evbuffer *evbuf, uint32_t number);

void evtag_marshal_int(struct evbuffer *evbuf, uint32_t tag, uint32_t integer);

void evtag_marshal_string(struct evbuffer *buf, uint32_t tag,
    const char *string);

void evtag_marshal_timeval(struct evbuffer *evbuf, uint32_t tag,
    struct timeval *tv);

int evtag_unmarshal(struct evbuffer *src, uint32_t *ptag, struct evbuffer *dst);
int evtag_peek(struct evbuffer *evbuf, uint32_t *ptag);
int evtag_peek_length(struct evbuffer *evbuf, uint32_t *plength);
int evtag_payload_length(struct evbuffer *evbuf, uint32_t *plength);
int evtag_consume(struct evbuffer *evbuf);

int evtag_unmarshal_int(struct evbuffer *evbuf, uint32_t need_tag,
    uint32_t *pinteger);

int evtag_unmarshal_fixed(struct evbuffer *src, uint32_t need_tag, void *data,
    size_t len);

int evtag_unmarshal_string(struct evbuffer *evbuf, uint32_t need_tag,
    char **pstring);

int evtag_unmarshal_timeval(struct evbuffer *evbuf, uint32_t need_tag,
    struct timeval *ptv);

#ifdef __cplusplus
}
#endif
Revision:	1.7
Committed:	Thu Jan 31 13:10:56 2008 UTC (16 years, 3 months ago) by root
Content type:	text/plain
Branch:	MAIN
CVS Tags:	rel-3_51, rel-3_31, rel-3_33, rel-3_53, rel-3_52, rel-3_7, rel-3_6, rel-3_4, rel-3_3, rel-3_2, rel-3_1, rel-4_01, rel-4_00, rel-4_03, rel-4_02, rel-3_9, rel-3_8, rel-3_44, rel-3_45, rel-3_41, rel-3_42, rel-3_43, rel-3_48, rel-3_49, rel-3_431
Changes since 1.6:	+1 -0 lines
Log Message:	first round of ev_async
#	User	Rev	Content
1	root	1.1	/*
2			* Copyright (c) 2000-2004 Niels Provos <provos@citi.umich.edu>
3	root	1.7	* Copyright (c) 2008 Marc Alexander Lehmann <libev@schmorp.de>
4	root	1.1	* All rights reserved.
5			*
6			* Redistribution and use in source and binary forms, with or without
7			* modification, are permitted provided that the following conditions
8			* are met:
9			* 1. Redistributions of source code must retain the above copyright
10			* notice, this list of conditions and the following disclaimer.
11			* 2. Redistributions in binary form must reproduce the above copyright
12			* notice, this list of conditions and the following disclaimer in the
13			* documentation and/or other materials provided with the distribution.
14			* 3. The name of the author may not be used to endorse or promote products
15			* derived from this software without specific prior written permission.
16			*
17			* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18			* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19			* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20			* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21			* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22			* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23			* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24			* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25			* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26			* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27			*/
28			#ifdef __cplusplus
29			extern "C" {
30			#endif
31
32	root	1.5	#ifdef _WIN32
33			# define WIN32_LEAN_AND_MEAN
34			# include <windows.h>
35			# undef WIN32_LEAN_AND_MEAN
36	root	1.1	typedef unsigned char u_char;
37			typedef unsigned short u_short;
38	root	1.5	#else
39			# include <sys/types.h>
40			# include <sys/time.h>
41			# include <inttypes.h>
42	root	1.1	#endif
43
44	root	1.5	#include <stdarg.h>
45
46	root	1.1	/* Fix so that ppl dont have to run with <sys/queue.h> */
47			#ifndef TAILQ_ENTRY
48			#define _EVENT_DEFINED_TQENTRY
49			#define TAILQ_ENTRY(type) \
50			struct { \
51			struct type tqe_next; / next element */ \
52			struct type *tqe_prev; / address of previous next element */ \
53			}
54			#endif /* !TAILQ_ENTRY */
55			#ifndef RB_ENTRY
56			#define _EVENT_DEFINED_RBENTRY
57			#define RB_ENTRY(type) \
58			struct { \
59			struct type rbe_left; / left element */ \
60			struct type rbe_right; / right element */ \
61			struct type rbe_parent; / parent element */ \
62			int rbe_color; /* node color */ \
63			}
64			#endif /* !RB_ENTRY */
65
66			/*
67			* Key-Value pairs. Can be used for HTTP headers but also for
68			* query argument parsing.
69			*/
70			struct evkeyval {
71			TAILQ_ENTRY(evkeyval) next;
72
73			char *key;
74			char *value;
75			};
76
77			#ifdef _EVENT_DEFINED_TQENTRY
78			#undef TAILQ_ENTRY
79			struct event_list;
80			struct evkeyvalq;
81			#undef _EVENT_DEFINED_TQENTRY
82			#else
83			TAILQ_HEAD (event_list, event);
84			TAILQ_HEAD (evkeyvalq, evkeyval);
85			#endif /* _EVENT_DEFINED_TQENTRY */
86			#ifdef _EVENT_DEFINED_RBENTRY
87			#undef RB_ENTRY
88			#undef _EVENT_DEFINED_RBENTRY
89			#endif /* _EVENT_DEFINED_RBENTRY */
90
91			struct eventop {
92			char *name;
93			void (init)(struct event_base *);
94			int (add)(void , struct event *);
95			int (del)(void , struct event *);
96			int (recalc)(struct event_base , void *, int);
97			int (dispatch)(struct event_base , void , struct timeval );
98			void (dealloc)(struct event_base , void *);
99			};
100
101			/* These functions deal with buffering input and output */
102
103			struct evbuffer {
104			u_char *buffer;
105			u_char *orig_buffer;
106
107			size_t misalign;
108			size_t totallen;
109			size_t off;
110
111			void (cb)(struct evbuffer , size_t, size_t, void *);
112			void *cbarg;
113			};
114
115			/* Just for error reporting - use other constants otherwise */
116			#define EVBUFFER_READ 0x01
117			#define EVBUFFER_WRITE 0x02
118			#define EVBUFFER_EOF 0x10
119			#define EVBUFFER_ERROR 0x20
120			#define EVBUFFER_TIMEOUT 0x40
121
122			struct bufferevent;
123			typedef void (evbuffercb)(struct bufferevent , void *);
124			typedef void (everrorcb)(struct bufferevent , short what, void *);
125
126			struct event_watermark {
127			size_t low;
128			size_t high;
129			};
130
131			struct bufferevent {
132			struct event ev_read;
133			struct event ev_write;
134
135			struct evbuffer *input;
136			struct evbuffer *output;
137
138			struct event_watermark wm_read;
139			struct event_watermark wm_write;
140
141			evbuffercb readcb;
142			evbuffercb writecb;
143			everrorcb errorcb;
144			void *cbarg;
145
146			int timeout_read; /* in seconds */
147			int timeout_write; /* in seconds */
148
149			short enabled; /* events that are currently enabled */
150			};
151
152			struct bufferevent *bufferevent_new(int fd,
153			evbuffercb readcb, evbuffercb writecb, everrorcb errorcb, void *cbarg);
154			int bufferevent_base_set(struct event_base base, struct bufferevent bufev);
155			int bufferevent_priority_set(struct bufferevent *bufev, int pri);
156			void bufferevent_free(struct bufferevent *bufev);
157	root	1.6	int bufferevent_write(struct bufferevent bufev, const void data, size_t size);
158	root	1.1	int bufferevent_write_buffer(struct bufferevent bufev, struct evbuffer buf);
159			size_t bufferevent_read(struct bufferevent bufev, void data, size_t size);
160			int bufferevent_enable(struct bufferevent *bufev, short event);
161			int bufferevent_disable(struct bufferevent *bufev, short event);
162			void bufferevent_settimeout(struct bufferevent *bufev,
163			int timeout_read, int timeout_write);
164
165			#define EVBUFFER_LENGTH(x) (x)->off
166			#define EVBUFFER_DATA(x) (x)->buffer
167			#define EVBUFFER_INPUT(x) (x)->input
168			#define EVBUFFER_OUTPUT(x) (x)->output
169
170			struct evbuffer *evbuffer_new(void);
171			void evbuffer_free(struct evbuffer *);
172			int evbuffer_expand(struct evbuffer *, size_t);
173			int evbuffer_add(struct evbuffer , const void , size_t);
174			int evbuffer_remove(struct evbuffer , void , size_t);
175			char evbuffer_readline(struct evbuffer );
176			int evbuffer_add_buffer(struct evbuffer , struct evbuffer );
177			int evbuffer_add_printf(struct evbuffer , const char fmt, ...);
178			int evbuffer_add_vprintf(struct evbuffer , const char fmt, va_list ap);
179			void evbuffer_drain(struct evbuffer *, size_t);
180			int evbuffer_write(struct evbuffer *, int);
181			int evbuffer_read(struct evbuffer *, int, int);
182			u_char evbuffer_find(struct evbuffer , const u_char *, size_t);
183			void evbuffer_setcb(struct evbuffer , void ()(struct evbuffer , size_t, size_t, void ), void *);
184
185			/*
186			* Marshaling tagged data - We assume that all tags are inserted in their
187			* numeric order - so that unknown tags will always be higher than the
188			* known ones - and we can just ignore the end of an event buffer.
189			*/
190
191			void evtag_init(void);
192
193	root	1.6	void evtag_marshal(struct evbuffer evbuf, uint32_t tag, const void data,
194	root	1.1	uint32_t len);
195
196			void encode_int(struct evbuffer *evbuf, uint32_t number);
197
198	root	1.6	void evtag_marshal_int(struct evbuffer *evbuf, uint32_t tag, uint32_t integer);
199	root	1.1
200	root	1.6	void evtag_marshal_string(struct evbuffer *buf, uint32_t tag,
201	root	1.1	const char *string);
202
203	root	1.6	void evtag_marshal_timeval(struct evbuffer *evbuf, uint32_t tag,
204	root	1.1	struct timeval *tv);
205
206	root	1.6	int evtag_unmarshal(struct evbuffer src, uint32_t ptag, struct evbuffer *dst);
207			int evtag_peek(struct evbuffer evbuf, uint32_t ptag);
208	root	1.1	int evtag_peek_length(struct evbuffer evbuf, uint32_t plength);
209			int evtag_payload_length(struct evbuffer evbuf, uint32_t plength);
210			int evtag_consume(struct evbuffer *evbuf);
211
212	root	1.6	int evtag_unmarshal_int(struct evbuffer *evbuf, uint32_t need_tag,
213	root	1.1	uint32_t *pinteger);
214
215	root	1.6	int evtag_unmarshal_fixed(struct evbuffer src, uint32_t need_tag, void data,
216	root	1.1	size_t len);
217
218	root	1.6	int evtag_unmarshal_string(struct evbuffer *evbuf, uint32_t need_tag,
219	root	1.1	char **pstring);
220
221	root	1.6	int evtag_unmarshal_timeval(struct evbuffer *evbuf, uint32_t need_tag,
222	root	1.1	struct timeval *ptv);
223
224			#ifdef __cplusplus
225			}
226			#endif