X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fevent.c;h=a7c1f25a3f3b9b05edd94a6ee579b818dd5b3412;hb=ee00033298d347b3da13dfca0d18db1c897953e1;hp=8ceab36240224ab8192a80071469ff8160f0cba0;hpb=4b6c01b1d5383b1a7417244a31ad4652aab2d5db;p=meshlink diff --git a/src/event.c b/src/event.c index 8ceab362..a7c1f25a 100644 --- a/src/event.c +++ b/src/event.c @@ -199,7 +199,9 @@ static void signalio_handler(event_loop_t *loop, void *data, int flags) { }); if(sig) { +#ifdef HAVE_STDATOMIC_H atomic_flag_clear(&sig->set); +#endif sig->cb(loop, sig->data); } } @@ -224,10 +226,14 @@ static void pipe_exit(event_loop_t *loop) { } void signal_trigger(event_loop_t *loop, signal_t *sig) { +#ifdef HAVE_STDATOMIC_H + if(atomic_flag_test_and_set(&sig->set)) { return; } +#endif + uint8_t signum = sig->signum; write(loop->pipefd[1], &signum, 1); return; @@ -241,7 +247,9 @@ void signal_add(event_loop_t *loop, signal_t *sig, signal_cb_t cb, void *data, u sig->signum = signum; sig->node.data = sig; +#ifdef HAVE_STDATOMIC_H atomic_flag_clear(&sig->set); +#endif if(loop->pipefd[0] == -1) { pipe_init(loop);