X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fevent.h;h=cf3c70a163b531b331bef39a9b797d8cff53d875;hb=5a8c20cfd63b480e94101f7333e871511a92fd37;hp=90a5905654629c4fcd71ae858cbc6c56cfc5c466;hpb=7593adb9ad9e6ff73afe29e9bd445cea8615a151;p=meshlink diff --git a/src/event.h b/src/event.h index 90a59056..cf3c70a1 100644 --- a/src/event.h +++ b/src/event.h @@ -1,6 +1,9 @@ +#ifndef MESHLINK_EVENT_H +#define MESHLINK_EVENT_H + /* - event.h -- I/O and timeout event handling - Copyright (C) 2014 Guus Sliepen + event.h -- I/O, timeout and signal event handling + Copyright (C) 2014, 2017 Guus Sliepen 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 @@ -17,10 +20,9 @@ 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ -#ifndef __TINC_EVENT_H__ -#define __TINC_EVENT_H__ - #include "splay_tree.h" +#include "system.h" +#include #define IO_READ 1 #define IO_WRITE 2 @@ -29,6 +31,8 @@ typedef struct event_loop_t event_loop_t; typedef void (*io_cb_t)(event_loop_t *loop, void *data, int flags); typedef void (*timeout_cb_t)(event_loop_t *loop, void *data); +typedef void (*signal_cb_t)(event_loop_t *loop, void *data); +typedef struct timeval(*idle_cb_t)(event_loop_t *loop, void *data); typedef struct io_t { int fd; @@ -45,15 +49,30 @@ typedef struct timeout_t { struct splay_node_t node; } timeout_t; +typedef struct signal_t { + int signum; + signal_cb_t cb; + void *data; + struct splay_node_t node; +} signal_t; + struct event_loop_t { fd_set readfds; fd_set writefds; volatile bool running; struct timeval now; - + bool deletion; + splay_tree_t ios; splay_tree_t timeouts; + splay_tree_t signals; + + idle_cb_t idle_cb; + void *idle_data; + + io_t signalio; + int pipefd[2]; void *data; }; @@ -66,10 +85,17 @@ extern void timeout_add(event_loop_t *loop, timeout_t *timeout, timeout_cb_t cb, extern void timeout_del(event_loop_t *loop, timeout_t *timeout); extern void timeout_set(event_loop_t *loop, timeout_t *timeout, struct timeval *tv); +extern void signal_add(event_loop_t *loop, signal_t *sig, signal_cb_t cb, void *data, uint8_t signum); +extern void signal_trigger(event_loop_t *loop, signal_t *sig); +extern void signal_del(event_loop_t *loop, signal_t *sig); + +extern void idle_set(event_loop_t *loop, idle_cb_t cb, void *data); + extern void event_loop_init(event_loop_t *loop); extern void event_loop_exit(event_loop_t *loop); -extern bool event_loop_run(event_loop_t *loop); +extern bool event_loop_run(event_loop_t *loop, pthread_mutex_t *mutex); extern void event_loop_flush_output(event_loop_t *loop); +extern void event_loop_start(event_loop_t *loop); extern void event_loop_stop(event_loop_t *loop); #endif