From 0f31d194025df5d63fcee65e32baa90cc5aa0ad6 Mon Sep 17 00:00:00 2001
From: Mattias Andrée <maandree@operamail.com>
Date: Sun, 17 May 2015 14:28:20 +0200
Subject: add timed example and fix timed polling
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: Mattias Andrée <maandree@operamail.com>
---
 doc/examples/timed/poll.c | 45 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 45 insertions(+)
 create mode 100644 doc/examples/timed/poll.c

(limited to 'doc/examples/timed/poll.c')

diff --git a/doc/examples/timed/poll.c b/doc/examples/timed/poll.c
new file mode 100644
index 0000000..d8c5aac
--- /dev/null
+++ b/doc/examples/timed/poll.c
@@ -0,0 +1,45 @@
+#include <bus.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <string.h>
+#include <errno.h>
+
+#define t(stmt)  if (stmt) goto fail
+
+
+
+int main()
+{
+	bus_t bus;
+	const char *message;
+	long long tick = 0;
+	struct timespec timeout;
+	t(bus_open(&bus, "/tmp/example-bus", BUS_RDONLY));
+	t(bus_poll_start(&bus));
+	for (;;) {
+		t(clock_gettime(CLOCK_MONOTONIC, &timeout));
+		timeout.tv_sec += 1;
+		message = bus_poll_timed(&bus, &timeout, CLOCK_MONOTONIC);
+		if (message == NULL) {
+			t(errno != EAGAIN);
+			printf("waiting... %lli\n", ++tick);
+			sleep(1);
+			continue;
+		}
+		tick = 0;
+		message = strchr(message, ' ') + 1;
+		if (!strcmp(message, "stop"))
+			break;
+		printf("\033[01m%s\033[21m\n", message);
+	}
+	t(bus_poll_stop(&bus));
+	bus_close(&bus);
+	return 0;
+
+fail:
+	perror("poll");
+	bus_poll_stop(&bus);
+	bus_close(&bus);
+	return 1;
+}
+
-- 
cgit v1.2.3-70-g09d2