X-Git-Url: http://git.archive.openwrt.org/?p=project%2Flibubox.git;a=blobdiff_plain;f=uloop.h;h=bce3974facab201b93d14349dcc60c6b78f3f0f9;hp=f84050ab5c15d34962583fe48fb10f5e080c00a3;hb=a1a97eb11e89c420b84a659a88a4e72c7f04367d;hpb=e82d74f89809c6c01f71168b3b8fdcf490e93fa7 diff --git a/uloop.h b/uloop.h index f84050a..bce3974 100644 --- a/uloop.h +++ b/uloop.h @@ -22,16 +22,29 @@ #include #include +#include +#include + +#if defined(__APPLE__) || defined(__FreeBSD__) +#define USE_KQUEUE +#else +#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) struct uloop_fd { @@ -40,17 +53,32 @@ struct uloop_fd bool eof; bool error; bool registered; +#ifdef USE_KQUEUE + uint8_t kqflags; +#endif }; 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); @@ -58,7 +86,14 @@ 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); -void uloop_end(void); +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; +} + int uloop_init(void); void uloop_run(void); void uloop_done(void);