doc/examples/timed/read.c


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


static int
callback(const char *message, void *user_data)
{
	(void) user_data;

	if (message == NULL)
		return 1;

	message = strchr(message, ' ') + 1;
	if (!strcmp(message, "stop"))
		return 0;
	printf("%s\n", message);
	return 1;
}


int
main()
{
	bus_t bus;
	struct timespec timeout;
	t(bus_open(&bus, "/tmp/example-bus", BUS_RDONLY));
	t(clock_gettime(CLOCK_MONOTONIC, &timeout));
	timeout.tv_sec += 10;
	t(bus_read_timed(&bus, callback, NULL, &timeout, CLOCK_MONOTONIC));
	bus_close(&bus);
	return 0;

fail:
	perror("poll");
	bus_poll_stop(&bus);
	bus_close(&bus);
	return 1;
}