From c1407c47b6c507c22152a95006da66f3a095034d Mon Sep 17 00:00:00 2001 From: Curtis McEnroe Date: Thu, 1 Aug 2019 14:43:58 -0400 Subject: Add poll timeout to ingest --- ingest.c | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/ingest.c b/ingest.c index 3fb5e40..1dfae36 100644 --- a/ingest.c +++ b/ingest.c @@ -56,7 +56,14 @@ int main(void) { { .events = POLLIN, .fd = STDIN_FILENO }, { .events = POLLIN, .fd = server }, }; - while (0 < poll(fds, 2, -1)) { + for (;;) { + int nfds = poll(fds, 2, 60 * 1000); + if (nfds < 0) err(EX_IOERR, "poll"); + + if (!nfds) { + // TODO: Increment idle time in info. + } + if (fds[0].revents) { char buf[4096]; ssize_t rlen = read(STDIN_FILENO, buf, sizeof(buf)); @@ -106,5 +113,4 @@ int main(void) { assert(client == maxClient); } } - err(EX_IOERR, "poll"); } -- cgit 1.4.1