X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fevent.h;h=bec32045e0bf501bd9c39985870b6d9d0268b82f;hb=HEAD;hp=31c326be141f37177d636b1dbfd7e65af7f8f3c4;hpb=4c57e6902219ecca1872e18e34365d8e54a0f407;p=meshlink diff --git a/src/event.h b/src/event.h index 31c326be..6b53d919 100644 --- a/src/event.h +++ b/src/event.h @@ -28,6 +28,7 @@ #define IO_WRITE 2 typedef struct event_loop_t event_loop_t; +struct meshlink_handle; typedef void (*io_cb_t)(event_loop_t *loop, void *data, int flags); typedef void (*timeout_cb_t)(event_loop_t *loop, void *data); @@ -52,7 +53,9 @@ typedef struct timeout_t { typedef struct signal_t { struct splay_node_t node; int signum; - bool set; +#ifdef HAVE_STDATOMIC_H + volatile atomic_flag set; +#endif signal_cb_t cb; void *data; } signal_t; @@ -78,25 +81,25 @@ struct event_loop_t { int pipefd[2]; }; -extern void io_add(event_loop_t *loop, io_t *io, io_cb_t cb, void *data, int fd, int flags); -extern void io_del(event_loop_t *loop, io_t *io); -extern void io_set(event_loop_t *loop, io_t *io, int flags); +void io_add(event_loop_t *loop, io_t *io, io_cb_t cb, void *data, int fd, int flags); +void io_del(event_loop_t *loop, io_t *io); +void io_set(event_loop_t *loop, io_t *io, int flags); -extern void timeout_add(event_loop_t *loop, timeout_t *timeout, timeout_cb_t cb, void *data, struct timespec *tv); -extern void timeout_del(event_loop_t *loop, timeout_t *timeout); -extern void timeout_set(event_loop_t *loop, timeout_t *timeout, struct timespec *tv); +void timeout_add(event_loop_t *loop, timeout_t *timeout, timeout_cb_t cb, void *data, struct timespec *tv); +void timeout_del(event_loop_t *loop, timeout_t *timeout); +void timeout_set(event_loop_t *loop, timeout_t *timeout, struct timespec *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); +void signal_add(event_loop_t *loop, signal_t *sig, signal_cb_t cb, void *data, uint8_t signum); +void signal_trigger(event_loop_t *loop, signal_t *sig); +void signal_del(event_loop_t *loop, signal_t *sig); -extern void idle_set(event_loop_t *loop, idle_cb_t cb, void *data); +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, pthread_mutex_t *mutex) __attribute__((__warn_unused_result__)); -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); +void event_loop_init(event_loop_t *loop); +void event_loop_exit(event_loop_t *loop); +bool event_loop_run(event_loop_t *loop, struct meshlink_handle *mesh) __attribute__((__warn_unused_result__)); +void event_loop_flush_output(event_loop_t *loop); +void event_loop_start(event_loop_t *loop); +void event_loop_stop(event_loop_t *loop); #endif