1187938Semax/*
2187938Semax * event.h
3187938Semax */
4187938Semax
5187938Semax/*-
6187938Semax * Copyright (c) 2009 Maksim Yevmenkin <m_evmenkin@yahoo.com>
7187938Semax * All rights reserved.
8187938Semax *
9187938Semax * Redistribution and use in source and binary forms, with or without
10187938Semax * modification, are permitted provided that the following conditions
11187938Semax * are met:
12187938Semax * 1. Redistributions of source code must retain the above copyright
13187938Semax *    notice, this list of conditions and the following disclaimer.
14187938Semax * 2. Redistributions in binary form must reproduce the above copyright
15187938Semax *    notice, this list of conditions and the following disclaimer in the
16187938Semax *    documentation and/or other materials provided with the distribution.
17187938Semax *
18187938Semax * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
19187938Semax * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20187938Semax * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21187938Semax * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
22187938Semax * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23187938Semax * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24187938Semax * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25187938Semax * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26187938Semax * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27187938Semax * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28187938Semax * SUCH DAMAGE.
29187938Semax */
30187938Semax
31187938Semax/* $FreeBSD$ */
32187938Semax
33187938Semax/*
34187938Semax * Hack to provide libevent (see devel/libevent port) like API.
35187938Semax * Should be removed if FreeBSD ever decides to import libevent into base.
36187938Semax */
37187938Semax
38187938Semax#ifndef	_EVENT_H_
39187938Semax#define	_EVENT_H_	1
40187938Semax
41187938Semax#define	EV_READ         0x02
42187938Semax#define	EV_WRITE        0x04
43228990Suqs#define	EV_PERSIST      0x10		/* Persistent event */
44187938Semax#define	EV_PENDING	(1 << 13)	/* internal use only! */
45187938Semax#define	EV_HAS_TIMEOUT	(1 << 14)	/* internal use only! */
46187938Semax#define	EV_CURRENT	(1 << 15)	/* internal use only! */
47187938Semax
48187938Semaxstruct event
49187938Semax{
50187938Semax	int			fd;
51187938Semax	short			flags;
52187938Semax	void			(*cb)(int, short, void *);
53187938Semax	void			*cbarg;
54187938Semax	struct timeval		timeout;
55187938Semax	struct timeval		expire;
56187938Semax
57187938Semax#ifdef	EVENT_DEBUG
58187938Semax	char const		*files[3];
59187938Semax	int			lines[3];
60187938Semax#endif
61187938Semax
62187938Semax	TAILQ_ENTRY(event)	next;
63187938Semax};
64187938Semax
65187938Semaxvoid	event_init	(void);
66187938Semaxint	event_dispatch	(void);
67187938Semax
68187938Semaxvoid	__event_set	(struct event *, int, short,
69187938Semax			 void (*)(int, short, void *), void *);
70187938Semaxint	__event_add	(struct event *, struct timeval const *);
71187938Semaxint	__event_del	(struct event *);
72187938Semax
73187938Semax#ifdef	EVENT_DEBUG
74187938Semax#define event_log_err(fmt, args...)	syslog(LOG_ERR, fmt, ##args)
75187938Semax#define event_log_info(fmt, args...)	syslog(LOG_INFO, fmt, ##args)
76187938Semax#define event_log_notice(fmt, args...)	syslog(LOG_NOTICE, fmt, ##args)
77187938Semax#define event_log_debug(fmt, args...)	syslog(LOG_DEBUG, fmt, ##args)
78187938Semax
79187938Semax#define	event_set(ev, fd, flags, cb, cbarg) \
80187938Semax	_event_set(__FILE__, __LINE__, ev, fd, flags, cb, cbarg)
81187938Semax#define	event_add(ev, timeout) \
82187938Semax	_event_add(__FILE__, __LINE__, ev, timeout)
83187938Semax#define	event_del(ev) \
84187938Semax	_event_del(__FILE__, __LINE__, ev)
85187938Semax
86187938Semax#define	evtimer_set(ev, cb, cbarg) \
87187938Semax	_event_set(__FILE__, __LINE__, ev, -1, 0, cb, cbarg)
88187938Semax#define	evtimer_add(ev, timeout) \
89187938Semax	_event_add(__FILE__, __LINE__, ev, timeout)
90187938Semax
91187938Semaxstatic inline void
92187938Semax_event_set(char const *file, int line, struct event *ev, int fd, short flags,
93187938Semax		void (*cb)(int, short, void *), void *cbarg)
94187938Semax{
95187938Semax	event_log_debug("set %s:%d ev=%p, fd=%d, flags=%#x, cb=%p, cbarg=%p",
96187938Semax		file, line, ev, fd, flags, cb, cbarg);
97187938Semax
98187938Semax	ev->files[0] = file;
99187938Semax	ev->lines[0] = line;
100187938Semax
101187938Semax	__event_set(ev, fd, flags, cb, cbarg);
102187938Semax}
103187938Semax
104187938Semaxstatic inline int
105187938Semax_event_add(char const *file, int line, struct event *ev,
106187938Semax		struct timeval const *timeout) {
107187938Semax	event_log_debug("add %s:%d ev=%p, fd=%d, flags=%#x, cb=%p, cbarg=%p, " \
108187938Semax		"timeout=%p", file, line, ev, ev->fd, ev->flags, ev->cb,
109187938Semax		ev->cbarg, timeout);
110187938Semax
111187938Semax	ev->files[1] = file;
112187938Semax	ev->lines[1] = line;
113187938Semax
114187938Semax	return (__event_add(ev, timeout));
115187938Semax}
116187938Semax
117187938Semaxstatic inline int
118187938Semax_event_del(char const *file, int line, struct event *ev)
119187938Semax{
120187938Semax	event_log_debug("del %s:%d ev=%p, fd=%d, flags=%#x, cb=%p, cbarg=%p",
121187938Semax		file, line, ev, ev->fd, ev->flags, ev->cb, ev->cbarg);
122187938Semax
123187938Semax	ev->files[2] = file;
124187938Semax	ev->lines[2] = line;
125187938Semax
126187938Semax	return (__event_del(ev));
127187938Semax}
128187938Semax#else
129187938Semax#define event_log_err(fmt, args...)
130187938Semax#define event_log_info(fmt, args...)
131187938Semax#define event_log_notice(fmt, args...)
132187938Semax#define event_log_debug(fmt, args...)
133187938Semax
134187938Semax#define	event_set(ev, fd, flags, cb, cbarg) \
135187938Semax	__event_set(ev, fd, flags, cb, cbarg)
136187938Semax#define	event_add(ev, timeout) \
137187938Semax	__event_add(ev, timeout)
138187938Semax#define	event_del(ev) \
139187938Semax	__event_del(ev)
140187938Semax
141187938Semax#define	evtimer_set(ev, cb, cbarg) \
142187938Semax	__event_set(ev, -1, 0, cb, cbarg)
143187938Semax#define	evtimer_add(ev, timeout) \
144187938Semax	__event_add(ev, timeout)
145187938Semax#endif	/* EVENT_DEBUG */
146187938Semax
147187938Semax#endif	/* ndef _EVENT_H_ */
148