blob: d8c5aac40d5dc64e06595211e9b7ae03ea5969e4 (
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
|
#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;
}
|
