rconn: Add new function rconn_reconnect().

diff --git a/lib/rconn.c b/lib/rconn.c
index a37f9fb8ee3c491ea236189ad2c7cf37f2ec3d6e..562f96f3162a2aad085ef31371872bfe67d8313a 100644 (file)
--- a/lib/rconn.c
+++ b/lib/rconn.c
@@ -272,6 +272,15 @@ rconn_connect_unreliably(struct rconn *rc,
     state_transition(rc, S_ACTIVE);
 }
 
+/* If 'rc' is connected, forces it to drop the connection and reconnect. */
+void
+rconn_reconnect(struct rconn *rc)
+{
+    if (rc->state & (S_ACTIVE | S_IDLE)) {
+        disconnect(rc, 0);
+    }
+}
+
 void
 rconn_disconnect(struct rconn *rc)
 {

diff --git a/lib/rconn.h b/lib/rconn.h
index f804b9a7e4df5cff9a55a47367dc0f4fac8fbe88..93ccec05b14a372c24e8dd77634596f96bfebb57 100644 (file)
--- a/lib/rconn.h
+++ b/lib/rconn.h
@@ -67,6 +67,7 @@ int rconn_get_probe_interval(const struct rconn *);
 int rconn_connect(struct rconn *, const char *name);
 void rconn_connect_unreliably(struct rconn *,
                               const char *name, struct vconn *vconn);
+void rconn_reconnect(struct rconn *);
 void rconn_disconnect(struct rconn *);
 void rconn_destroy(struct rconn *);