blob: 2b0c266e26f8db8c791537c88907450b3f3b7a03 (
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
|
#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));
for (;;) {
message = bus_poll(&bus, BUS_NOWAIT);
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;
}
|
