From 7b8e3ffcbccf6d02bfcb0c9c9c2d259362357fb8 Mon Sep 17 00:00:00 2001 From: Simon Rettberg Date: Wed, 31 Dec 2014 17:19:20 +0100 Subject: [SERVER] Create compilation unit for wait/signalling logic (using eventfd) --- src/server/signal.c | 46 ++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 46 insertions(+) create mode 100644 src/server/signal.c (limited to 'src/server/signal.c') diff --git a/src/server/signal.c b/src/server/signal.c new file mode 100644 index 0000000..f0988b9 --- /dev/null +++ b/src/server/signal.c @@ -0,0 +1,46 @@ +#include "signal.h" +#include +#include +#include +#include +#include + +int signal_new() +{ + return eventfd( 0, EFD_NONBLOCK ); +} + +int signal_call(int signalFd) +{ + static uint64_t one = 1; + return write( signalFd, &one, sizeof one ) == sizeof one; +} + +int signal_wait(int signalFd, int timeoutMs) +{ + struct pollfd ps = { + .fd = signalFd, + .events = POLLIN + }; + int ret = poll( &ps, 1, timeoutMs ); + if ( ret == 0 ) return SIGNAL_TIMEOUT; + if ( ret == -1 ) return SIGNAL_ERROR; + if ( ps.revents & ( POLLERR | POLLNVAL ) ) return SIGNAL_ERROR; + return signal_clear( signalFd ); +} + +int signal_clear(int signalFd) +{ + uint64_t ret; + if ( read( signalFd, &ret, sizeof ret ) != sizeof ret ) { + if ( errno == EAGAIN ) return 0; + return SIGNAL_ERROR; + } + return (int)ret; +} + +void signal_close(int signalFd) +{ + close( signalFd ); +} + -- cgit v1.2.3-55-g7522