diff options
author | Mattias Andrée <maandree@operamail.com> | 2015-05-15 15:04:25 +0200 |
---|---|---|
committer | Mattias Andrée <maandree@operamail.com> | 2015-05-15 15:04:25 +0200 |
commit | 40341a0eec50588f574199a3ee213dbb97b576e5 (patch) | |
tree | dcf36c75385bb593086c10c7cf0a502d6f5311c8 /doc/examples/nonblocking/poll.c | |
parent | update examples (diff) | |
download | bus-40341a0eec50588f574199a3ee213dbb97b576e5.tar.gz bus-40341a0eec50588f574199a3ee213dbb97b576e5.tar.bz2 bus-40341a0eec50588f574199a3ee213dbb97b576e5.tar.xz |
fix nowait for polling + add nonblocking example
Signed-off-by: Mattias Andrée <maandree@operamail.com>
Diffstat (limited to '')
-rw-r--r-- | doc/examples/nonblocking/poll.c | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/doc/examples/nonblocking/poll.c b/doc/examples/nonblocking/poll.c new file mode 100644 index 0000000..c918b5b --- /dev/null +++ b/doc/examples/nonblocking/poll.c @@ -0,0 +1,42 @@ +#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; + t(bus_open(&bus, "/tmp/example-bus", BUS_RDONLY)); + t(bus_poll_start(&bus, BUS_NOWAIT)); + for (;;) { + message = bus_poll(&bus); + 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; +} + |