aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/bus.c39
-rw-r--r--src/bus.h6
2 files changed, 45 insertions, 0 deletions
diff --git a/src/bus.c b/src/bus.c
index db16894..b17d897 100644
--- a/src/bus.c
+++ b/src/bus.c
@@ -665,3 +665,42 @@ fail:
return -1;
}
+
+int
+bus_poll_start(const bus_t *bus)
+{
+ return release_semaphore(bus, S, SEM_UNDO);
+}
+
+
+int
+bus_poll_stop(const bus_t *bus)
+{
+ return acquire_semaphore(bus, S, SEM_UNDO);
+}
+
+
+int
+bus_poll_continue(const bus_t *bus)
+{
+ t(release_semaphore(bus, W, SEM_UNDO));
+ t(acquire_semaphore(bus, S, SEM_UNDO));
+ t(zero_semaphore(bus, S));
+ t(release_semaphore(bus, S, SEM_UNDO));
+ t(acquire_semaphore(bus, W, SEM_UNDO));
+ return 0;
+fail:
+ return -1;
+}
+
+
+const char *
+bus_poll(const bus_t *bus)
+{
+ t(release_semaphore(bus, Q, 0));
+ t(zero_semaphore(bus, Q));
+ return bus->message;
+fail:
+ return NULL;
+}
+
diff --git a/src/bus.h b/src/bus.h
index d67b4f2..64acba7 100644
--- a/src/bus.h
+++ b/src/bus.h
@@ -173,6 +173,12 @@ int bus_write(const bus_t *bus, const char *message);
int bus_read(const bus_t *bus, int (*callback)(const char *message, void *user_data), void *user_data);
+int bus_poll_start(const bus_t *bus);
+int bus_poll_stop(const bus_t *bus);
+int bus_poll_continue(const bus_t *bus);
+const char *bus_poll(const bus_t *bus);
+
+
#endif