varlink: add new helper that reports whether connection is idle

This is useful to allow event loops to run exactly as long as there's
something to do but not longer.

diff --git a/src/shared/varlink.c b/src/shared/varlink.c
index d2f649485bf27282cb0bda63209684e2321fe4c7..5af2c2c3634791ae4b5183b20492d1da9e9bf101 100644 (file)
--- a/src/shared/varlink.c
+++ b/src/shared/varlink.c
@@ -1282,6 +1282,15 @@ int varlink_wait(Varlink *v, usec_t timeout) {
         return 1;
 }
 
+int varlink_is_idle(Varlink *v) {
+        assert_return(v, -EINVAL);
+
+        /* Returns true if there's nothing pending on the connection anymore, i.e. we processed all incoming
+         * or outgoing messages fully, or finished disconnection */
+
+        return IN_SET(v->state, VARLINK_DISCONNECTED, VARLINK_IDLE_CLIENT, VARLINK_IDLE_SERVER);
+}
+
 int varlink_get_fd(Varlink *v) {
 
         assert_return(v, -EINVAL);

diff --git a/src/shared/varlink.h b/src/shared/varlink.h
index 0984222c96be3b9447732a3486f49161d8c4f553..5eb4676dc83330409e9fd1d80fc244cd55725ea3 100644 (file)
--- a/src/shared/varlink.h
+++ b/src/shared/varlink.h
@@ -71,6 +71,8 @@ sd_event *varlink_get_event(Varlink *v);
 int varlink_process(Varlink *v);
 int varlink_wait(Varlink *v, usec_t timeout);
 
+int varlink_is_idle(Varlink *v);
+
 int varlink_flush(Varlink *v);
 int varlink_close(Varlink *v);