diff options
Diffstat (limited to '')
| -rw-r--r-- | doc/examples/timed/.gitignore | 1 | ||||
| -rw-r--r-- | doc/examples/timed/Makefile | 2 | ||||
| -rw-r--r-- | doc/examples/timed/README | 5 | ||||
| -rw-r--r-- | doc/examples/timed/cleanup.c | 3 | ||||
| -rw-r--r-- | doc/examples/timed/init.c | 3 | ||||
| -rw-r--r-- | doc/examples/timed/poll.c | 3 | ||||
| -rw-r--r-- | doc/examples/timed/read.c | 45 | ||||
| -rw-r--r-- | doc/examples/timed/write.c | 3 |
8 files changed, 59 insertions, 6 deletions
diff --git a/doc/examples/timed/.gitignore b/doc/examples/timed/.gitignore index e5c1856..b1076f0 100644 --- a/doc/examples/timed/.gitignore +++ b/doc/examples/timed/.gitignore @@ -2,4 +2,5 @@ cleanup init write poll +read diff --git a/doc/examples/timed/Makefile b/doc/examples/timed/Makefile index 1b1cbd3..fe1285c 100644 --- a/doc/examples/timed/Makefile +++ b/doc/examples/timed/Makefile @@ -1,4 +1,4 @@ -COMMANDS = init cleanup write poll +COMMANDS = init cleanup write poll read all: ${COMMANDS} diff --git a/doc/examples/timed/README b/doc/examples/timed/README index b0989bf..db34fa0 100644 --- a/doc/examples/timed/README +++ b/doc/examples/timed/README @@ -12,7 +12,10 @@ When you are done run ./cleanup. Running instances of ./poll will wait for new messages continuously, but with one second timeouts. -./poll, ./init and ./cleanup are run without any +Running instances of ./read will read for ten seconds +then time out. + +./poll, ./read, ./init and ./cleanup are run without any additional arguments. ./write is run with the message as the second argument. diff --git a/doc/examples/timed/cleanup.c b/doc/examples/timed/cleanup.c index 00f07bc..bf54226 100644 --- a/doc/examples/timed/cleanup.c +++ b/doc/examples/timed/cleanup.c @@ -1,7 +1,8 @@ #include <bus.h> #include <stdio.h> -int main() +int +main() { return bus_unlink("/tmp/example-bus") && (perror("cleanup"), 1); } diff --git a/doc/examples/timed/init.c b/doc/examples/timed/init.c index 870e10d..d1325fb 100644 --- a/doc/examples/timed/init.c +++ b/doc/examples/timed/init.c @@ -1,7 +1,8 @@ #include <bus.h> #include <stdio.h> -int main() +int +main() { return bus_create("/tmp/example-bus", 0, NULL) && (perror("init"), 1); } diff --git a/doc/examples/timed/poll.c b/doc/examples/timed/poll.c index d8c5aac..d57d4ea 100644 --- a/doc/examples/timed/poll.c +++ b/doc/examples/timed/poll.c @@ -8,7 +8,8 @@ -int main() +int +main() { bus_t bus; const char *message; diff --git a/doc/examples/timed/read.c b/doc/examples/timed/read.c new file mode 100644 index 0000000..abe733f --- /dev/null +++ b/doc/examples/timed/read.c @@ -0,0 +1,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; +} + diff --git a/doc/examples/timed/write.c b/doc/examples/timed/write.c index b6b4c16..250ba14 100644 --- a/doc/examples/timed/write.c +++ b/doc/examples/timed/write.c @@ -11,7 +11,8 @@ static char message[BUS_MEMORY_SIZE]; -int main(int argc, char *argv[]) +int +main(int argc, char *argv[]) { bus_t bus; if (argc < 2) { |