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