aboutsummaryrefslogtreecommitdiffstats
path: root/doc/examples/timed/slow-poll.c
diff options
context:
space:
mode:
Diffstat (limited to 'doc/examples/timed/slow-poll.c')
-rw-r--r--doc/examples/timed/slow-poll.c46
1 files changed, 46 insertions, 0 deletions
diff --git a/doc/examples/timed/slow-poll.c b/doc/examples/timed/slow-poll.c
new file mode 100644
index 0000000..5076ef6
--- /dev/null
+++ b/doc/examples/timed/slow-poll.c
@@ -0,0 +1,46 @@
+#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);
+ continue;
+ }
+ tick = 0;
+ message = strchr(message, ' ') + 1;
+ if (!strcmp(message, "stop"))
+ break;
+ printf("\033[01m%s\033[21m\n", message);
+ sleep(1);
+ }
+ t(bus_poll_stop(&bus));
+ bus_close(&bus);
+ return 0;
+
+fail:
+ perror("poll");
+ bus_poll_stop(&bus);
+ bus_close(&bus);
+ return 1;
+}
+