add timed example and fix timed polling

Signed-off-by: Mattias Andrée <maandree@operamail.com>

1 files changed, 45 insertions, 0 deletions

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;
+}
+