X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fevent.c;h=11f1ed817003138cf4b2a7e4a3b7e45f341e8a12;hb=57f6341e91373198ad2a4099015f2988795d8a3f;hp=3c2306bd2d8f8d51657a9710fc9b128e72241ee0;hpb=02beca7acb7a6d2ecba71540bab1a53e17838d6a;p=meshlink

diff --git a/src/event.c b/src/event.c
index 3c2306bd..11f1ed81 100644
--- a/src/event.c
+++ b/src/event.c
@@ -73,6 +73,7 @@ void io_add(event_loop_t *loop, io_t *io, io_cb_t cb, void *data, int fd, int fl
 
 	splay_node_t *node = splay_insert_node(&loop->ios, &io->node);
 	assert(node);
+	(void)node;
 }
 
 void io_set(event_loop_t *loop, io_t *io, int flags) {
@@ -170,6 +171,7 @@ static void signalio_handler(event_loop_t *loop, void *data, int flags) {
 	});
 
 	if(sig) {
+		sig->set = false;
 		sig->cb(loop, sig->data);
 	}
 }
@@ -194,7 +196,12 @@ static void pipe_exit(event_loop_t *loop) {
 }
 
 void signal_trigger(event_loop_t *loop, signal_t *sig) {
+	if(sig->set) {
+		return;
+	}
+
 	uint8_t signum = sig->signum;
+	sig->set = true;
 	write(loop->pipefd[1], &signum, 1);
 	return;
 }
@@ -205,6 +212,7 @@ void signal_add(event_loop_t *loop, signal_t *sig, signal_cb_t cb, void *data, u
 	sig->cb = cb;
 	sig->data = data;
 	sig->signum = signum;
+	sig->set = false;
 	sig->node.data = sig;
 
 	if(loop->pipefd[0] == -1) {