aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/bus.c13
-rw-r--r--src/bus.h14
2 files changed, 27 insertions, 0 deletions
diff --git a/src/bus.c b/src/bus.c
index 369fa2f..19270fb 100644
--- a/src/bus.c
+++ b/src/bus.c
@@ -766,6 +766,19 @@ bus_poll_stop(const bus_t *bus)
}
+/**
+ * Wait for a message to be broadcasted on the bus.
+ * The caller should make a copy of the received message,
+ * without freeing the original copy, and parse it in a
+ * separate thread. When the new thread has started be
+ * started, the caller of this function should then
+ * either call `bus_poll` again or `bus_poll_stop`.
+ *
+ * @param bus Bus information
+ * @param flags `IPC_NOWAIT` if the bus should fail and set `errno` to
+ * `EAGAIN` if this isn't already a message available on the bus
+ * @return The received message, `NULL` on error
+ */
const char *
bus_poll(bus_t *bus, int flags)
{
diff --git a/src/bus.h b/src/bus.h
index d8112f2..3ab83de 100644
--- a/src/bus.h
+++ b/src/bus.h
@@ -211,6 +211,20 @@ int bus_poll_start(bus_t *bus);
* @return 0 on success, -1 on error
*/
int bus_poll_stop(const bus_t *bus);
+
+/**
+ * Wait for a message to be broadcasted on the bus.
+ * The caller should make a copy of the received message,
+ * without freeing the original copy, and parse it in a
+ * separate thread. When the new thread has started be
+ * started, the caller of this function should then
+ * either call `bus_poll` again or `bus_poll_stop`.
+ *
+ * @param bus Bus information
+ * @param flags `IPC_NOWAIT` if the bus should fail and set `errno` to
+ * `EAGAIN` if this isn't already a message available on the bus
+ * @return The received message, `NULL` on error
+ */
const char *bus_poll(bus_t *bus, int flags);