aboutsummaryrefslogtreecommitdiffstats
path: root/doc/examples/timed/poll.c
blob: d57d4ea6aeba2cd385f132a37f316042e6d013cd (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
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);
			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;
}