X-Git-Url: http://git.meshlink.io/?p=meshlink;a=blobdiff_plain;f=src%2Fevent.c;h=39a7d18f6dea3d00c4fa4382b6a8341299f59d43;hp=40dbd18e5e5cce004c3776b7574a02233c0b0636;hb=8d4b96efb7955eaa96174af4804597f92e124041;hpb=d9a6e9b7951388016638d05656645b22d8723fdb diff --git a/src/event.c b/src/event.c index 40dbd18e..39a7d18f 100644 --- a/src/event.c +++ b/src/event.c @@ -364,13 +364,6 @@ bool event_loop_run(event_loop_t *loop, pthread_mutex_t *mutex) { return true; } -void event_flush_output(event_loop_t *loop) { - for splay_each(io_t, io, &loop->ios) - if(FD_ISSET(io->fd, &loop->writefds)) { - io->cb(loop, io->data, IO_WRITE); - } -} - void event_loop_start(event_loop_t *loop) { loop->running = true; } @@ -394,14 +387,14 @@ void event_loop_exit(event_loop_t *loop) { assert(!loop->signals.count); for splay_each(io_t, io, &loop->ios) { - splay_unlink_node(&loop->ios, node); + splay_unlink_node(&loop->ios, splay_node); } for splay_each(timeout_t, timeout, &loop->timeouts) { - splay_unlink_node(&loop->timeouts, node); + splay_unlink_node(&loop->timeouts, splay_node); } for splay_each(signal_t, signal, &loop->signals) { - splay_unlink_node(&loop->signals, node); + splay_unlink_node(&loop->signals, splay_node); } }