style + add timed read example

Signed-off-by: Mattias Andrée <maandree@operamail.com>

25 files changed, 109 insertions, 31 deletions

diff --git a/doc/examples/daemon-depedencies/announce.c b/doc/examples/daemon-depedencies/announce.c
index 752cc16..d928adb 100644
--- a/doc/examples/daemon-depedencies/announce.c
+++ b/doc/examples/daemon-depedencies/announce.c
@@ -10,7 +10,8 @@
 static char arg[4098];
 
 
-int main(int argc, char *argv[])
+int
+main(int argc, char *argv[])
 {
 	bus_t bus;
 	if (argc < 3)
diff --git a/doc/examples/daemon-depedencies/await-ready.c b/doc/examples/daemon-depedencies/await-ready.c
index a787cea..fea2382 100644
--- a/doc/examples/daemon-depedencies/await-ready.c
+++ b/doc/examples/daemon-depedencies/await-ready.c
@@ -17,7 +17,8 @@ static char *started = NULL;
 static char msg[BUS_MEMORY_SIZE];
 
 
-static void announce_wait(pid_t pid)
+static void
+announce_wait(pid_t pid)
 {
 	bus_t bus;
 	int i;
@@ -36,7 +37,8 @@ fail:
 }
 
 
-static int callback(const char *message, void *user_data)
+static int
+callback(const char *message, void *user_data)
 {
 	int i;
 	char *arg2;
@@ -80,7 +82,8 @@ static int callback(const char *message, void *user_data)
 }
 
 
-int main(int argc_, char *argv_[])
+int
+main(int argc_, char *argv_[])
 {
 	bus_t bus;
 	int i;
diff --git a/doc/examples/daemon-depedencies/await-started.c b/doc/examples/daemon-depedencies/await-started.c
index 0408acb..99ba14f 100644
--- a/doc/examples/daemon-depedencies/await-started.c
+++ b/doc/examples/daemon-depedencies/await-started.c
@@ -17,7 +17,8 @@ static char *started = NULL;
 static char msg[BUS_MEMORY_SIZE];
 
 
-static void announce_wait(pid_t pid)
+static void
+announce_wait(pid_t pid)
 {
 	bus_t bus;
 	int i;
@@ -36,7 +37,8 @@ fail:
 }
 
 
-static int callback(const char *message, void *user_data)
+static int
+callback(const char *message, void *user_data)
 {
 	int i;
 	char *arg2;
@@ -80,7 +82,8 @@ static int callback(const char *message, void *user_data)
 }
 
 
-int main(int argc_, char *argv_[])
+int
+main(int argc_, char *argv_[])
 {
 	bus_t bus;
 	int i;
diff --git a/doc/examples/daemon-depedencies/cleanup.c b/doc/examples/daemon-depedencies/cleanup.c
index d3803c3..f9ead6d 100644
--- a/doc/examples/daemon-depedencies/cleanup.c
+++ b/doc/examples/daemon-depedencies/cleanup.c
@@ -6,7 +6,8 @@
 
 
 
-int main()
+int
+main()
 {
 	char *bus_address = getenv("BUS_INIT");
 	if (!bus_address || !*bus_address) {
diff --git a/doc/examples/daemon-depedencies/init.c b/doc/examples/daemon-depedencies/init.c
index 09a6abf..b7182c6 100644
--- a/doc/examples/daemon-depedencies/init.c
+++ b/doc/examples/daemon-depedencies/init.c
@@ -14,7 +14,8 @@ static char **argv;
 static char arg[4098];
 
 
-static void start_daemons()
+static void
+start_daemons()
 {
 	int i;
 	for (i = 1; i < argc; i++)
@@ -23,7 +24,8 @@ static void start_daemons()
 }
 
 
-static int callback(const char *message, void *user_data)
+static int
+callback(const char *message, void *user_data)
 {
 	pid_t pid;
 	char *arg2;
@@ -91,7 +93,8 @@ fail:
 }
 
 
-int main(int argc_, char *argv_[])
+int
+main(int argc_, char *argv_[])
 {
 	char *bus_address = NULL;
 	bus_t bus;
diff --git a/doc/examples/daemon-depedencies/require.c b/doc/examples/daemon-depedencies/require.c
index 6970dc2..e378431 100644
--- a/doc/examples/daemon-depedencies/require.c
+++ b/doc/examples/daemon-depedencies/require.c
@@ -10,7 +10,8 @@
 static char arg[4098];
 
 
-int main(int argc, char *argv[])
+int
+main(int argc, char *argv[])
 {
 	bus_t bus;
 	int i;
diff --git a/doc/examples/daemon-depedencies/start-daemon.c b/doc/examples/daemon-depedencies/start-daemon.c
index acb85ad..7c224d5 100644
--- a/doc/examples/daemon-depedencies/start-daemon.c
+++ b/doc/examples/daemon-depedencies/start-daemon.c
@@ -11,7 +11,8 @@
 static char arg[4098];
 
 
-int main(int argc, char *argv[])
+int
+main(int argc, char *argv[])
 {
 	if (argc != 2)
 		return fprintf(stderr, "This program should be called from ./init\n"), 2;
diff --git a/doc/examples/daemon-depedencies/test-daemon.c b/doc/examples/daemon-depedencies/test-daemon.c
index 386d107..32ee545 100644
--- a/doc/examples/daemon-depedencies/test-daemon.c
+++ b/doc/examples/daemon-depedencies/test-daemon.c
@@ -9,7 +9,8 @@
 static char arg[4098];
 
 
-int main(int argc, char *argv[])
+int
+main(int argc, char *argv[])
 {
 	bus_t bus;
 	if (argc != 3)
diff --git a/doc/examples/nonblocking/cleanup.c b/doc/examples/nonblocking/cleanup.c
index 00f07bc..bf54226 100644
--- a/doc/examples/nonblocking/cleanup.c
+++ b/doc/examples/nonblocking/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/nonblocking/init.c b/doc/examples/nonblocking/init.c
index 870e10d..d1325fb 100644
--- a/doc/examples/nonblocking/init.c
+++ b/doc/examples/nonblocking/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/nonblocking/poll.c b/doc/examples/nonblocking/poll.c
index 2b0c266..5609317 100644
--- a/doc/examples/nonblocking/poll.c
+++ b/doc/examples/nonblocking/poll.c
@@ -8,7 +8,8 @@
 
 
 
-int main()
+int
+main()
 {
 	bus_t bus;
 	const char *message;
diff --git a/doc/examples/nonblocking/write.c b/doc/examples/nonblocking/write.c
index 7fe9690..afe957b 100644
--- a/doc/examples/nonblocking/write.c
+++ b/doc/examples/nonblocking/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) {
diff --git a/doc/examples/telephony-and-music/cleanup.c b/doc/examples/telephony-and-music/cleanup.c
index 00f07bc..bf54226 100644
--- a/doc/examples/telephony-and-music/cleanup.c
+++ b/doc/examples/telephony-and-music/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/telephony-and-music/end-call.c b/doc/examples/telephony-and-music/end-call.c
index 6198cbb..c03eedf 100644
--- a/doc/examples/telephony-and-music/end-call.c
+++ b/doc/examples/telephony-and-music/end-call.c
@@ -11,7 +11,8 @@ static char message[BUS_MEMORY_SIZE];
 
 
 
-int main()
+int
+main()
 {
 	bus_t bus;
 	sprintf(message, "%ji unforce-pause", (intmax_t)getppid());
diff --git a/doc/examples/telephony-and-music/init.c b/doc/examples/telephony-and-music/init.c
index 870e10d..d1325fb 100644
--- a/doc/examples/telephony-and-music/init.c
+++ b/doc/examples/telephony-and-music/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/telephony-and-music/monitor.c b/doc/examples/telephony-and-music/monitor.c
index bf3e290..b3cc832 100644
--- a/doc/examples/telephony-and-music/monitor.c
+++ b/doc/examples/telephony-and-music/monitor.c
@@ -13,7 +13,8 @@ static char* pausers = NULL;
 
 
 
-static int is_moc_playing(void)
+static int
+is_moc_playing(void)
 {
 	return !WEXITSTATUS(system("env LANG=C mocp -i 2>/dev/null | grep 'State: PLAY' >/dev/null"));
 }
@@ -25,7 +26,8 @@ static int is_moc_playing(void)
  * too much for an example, especially since it would also require
  * a mutex to make sure two threads do not modify data at the same
  * time, causing chaos. */
-static int callback(const char *message, void *user_data)
+static int
+callback(const char *message, void *user_data)
 {
  	char *msg = NULL;
 	size_t len = 0;
@@ -83,7 +85,8 @@ done:
 
 
 
-int main()
+int
+main()
 {
 	bus_t bus;
 	t(bus_open(&bus, "/tmp/example-bus", BUS_RDONLY));
diff --git a/doc/examples/telephony-and-music/receive-or-make-call.c b/doc/examples/telephony-and-music/receive-or-make-call.c
index 92132fa..c61dc30 100644
--- a/doc/examples/telephony-and-music/receive-or-make-call.c
+++ b/doc/examples/telephony-and-music/receive-or-make-call.c
@@ -11,7 +11,8 @@ static char message[BUS_MEMORY_SIZE];
 
 
 
-int main()
+int
+main()
 {
 	bus_t bus;
 	sprintf(message, "%ji force-pause", (intmax_t)getppid());
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) {