X-Git-Url: http://git.archive.openwrt.org/?p=project%2Flibubox.git;a=blobdiff_plain;f=uloop.h;h=756451405381015cb02f390ad43298ec02ae1ef8;hp=35ee3a5e4c71dfa787aa73a7eaa6894db7e9ad90;hb=155bf39896f126b1ba121b816922a88dc34c31e3;hpb=0d1a602dcfe4e13e470a0c0bb23e1d99be3f15b5 diff --git a/uloop.h b/uloop.h index 35ee3a5..7564514 100644 --- a/uloop.h +++ b/uloop.h @@ -1,28 +1,28 @@ /* - * Copyright (C) 2010 Felix Fietkau + * uloop - event loop implementation * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. + * Copyright (C) 2010-2013 Felix Fietkau * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA. + * 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. */ - #ifndef _ULOOP_H__ #define _ULOOP_H__ #include +#include #include #include +#include #if defined(__APPLE__) || defined(__FreeBSD__) #define USE_KQUEUE @@ -30,15 +30,30 @@ #define USE_EPOLL #endif +#include "list.h" + struct uloop_fd; struct uloop_timeout; +struct uloop_process; typedef void (*uloop_fd_handler)(struct uloop_fd *u, unsigned int events); typedef void (*uloop_timeout_handler)(struct uloop_timeout *t); +typedef void (*uloop_process_handler)(struct uloop_process *c, int ret); #define ULOOP_READ (1 << 0) #define ULOOP_WRITE (1 << 1) #define ULOOP_EDGE_TRIGGER (1 << 2) +#define ULOOP_BLOCKING (1 << 3) + +#define ULOOP_EVENT_MASK (ULOOP_READ | ULOOP_WRITE) + +/* internal flags */ +#define ULOOP_EVENT_BUFFERED (1 << 4) +#ifdef USE_KQUEUE +#define ULOOP_EDGE_DEFER (1 << 5) +#endif + +#define ULOOP_ERROR_CB (1 << 6) struct uloop_fd { @@ -47,28 +62,46 @@ struct uloop_fd bool eof; bool error; bool registered; -#ifdef USE_KQUEUE - uint8_t kqflags; -#endif + uint8_t flags; }; struct uloop_timeout { + struct list_head list; + bool pending; + uloop_timeout_handler cb; - struct uloop_timeout *prev; - struct uloop_timeout *next; struct timeval time; +}; + +struct uloop_process +{ + struct list_head list; bool pending; + + uloop_process_handler cb; + pid_t pid; }; +extern bool uloop_cancelled; +extern bool uloop_handle_sigchld; + int uloop_fd_add(struct uloop_fd *sock, unsigned int flags); int uloop_fd_delete(struct uloop_fd *sock); int uloop_timeout_add(struct uloop_timeout *timeout); int uloop_timeout_set(struct uloop_timeout *timeout, int msecs); int uloop_timeout_cancel(struct uloop_timeout *timeout); +int uloop_timeout_remaining(struct uloop_timeout *timeout); + +int uloop_process_add(struct uloop_process *p); +int uloop_process_delete(struct uloop_process *p); + +static inline void uloop_end(void) +{ + uloop_cancelled = true; +} -void uloop_end(void); int uloop_init(void); void uloop_run(void); void uloop_done(void);