ipcpd: Add flow-update relay

This adds an ipcp_flow_update() call to relay opaque messages between
the two IRMds (carried by FLOW_IRM_UPDATE messages), which passes it
back up to the peer IRMd via ipcp_flow_update_arr(). The broadcast
layer does not implement this.

Needed for periodic re-keying of encrypted flows via OAP.

Signed-off-by: Dimitri Staessens <dimitri@ouroboros.rocks>
Signed-off-by: Sander Vrijders <sander@ouroboros.rocks>

2 files changed, 35 insertions, 0 deletions

diff --git a/src/irmd/ipcp.c b/src/irmd/ipcp.c
index a7da186c..7eccfc80 100644
--- a/src/irmd/ipcp.c
+++ b/src/irmd/ipcp.c
@@ -444,6 +444,38 @@ int ipcp_flow_join(const struct flow_info * flow,
         return ret;
 }
 
+int ipcp_flow_update(const struct flow_info * flow,
+                     const buffer_t           data)
+{
+        ipcp_msg_t   msg = IPCP_MSG__INIT;
+        ipcp_msg_t * recv_msg;
+        int          ret;
+
+        msg.code         = IPCP_MSG_CODE__IPCP_FLOW_UPDATE;
+        msg.has_flow_id  = true;
+        msg.flow_id      = flow->id;
+        msg.has_pk       = true;
+        msg.pk.data      = data.data;
+        msg.pk.len       = data.len;
+
+        recv_msg = send_recv_ipcp_msg(flow->n_1_pid, &msg);
+        if (recv_msg == NULL) {
+                log_err("Did not receive message.");
+                return -EIPCP;
+        }
+
+        if (!recv_msg->has_result) {
+                log_err("Message has no result");
+                ipcp_msg__free_unpacked(recv_msg, NULL);
+                return -EIPCP;
+        }
+
+        ret = recv_msg->result;
+        ipcp_msg__free_unpacked(recv_msg, NULL);
+
+        return ret;
+}
+
 int ipcp_flow_alloc(const struct flow_info * flow,
                     const buffer_t           dst,
                     const buffer_t           data)
diff --git a/src/irmd/ipcp.h b/src/irmd/ipcp.h
index f1025096..8d06623c 100644
--- a/src/irmd/ipcp.h
+++ b/src/irmd/ipcp.h
@@ -68,4 +68,7 @@ int   ipcp_flow_dealloc(pid_t  pid,
                         int    flow_id,
                         time_t timeo);
 
+int   ipcp_flow_update(const struct flow_info * flow,
+                       const buffer_t           data);
+
 #endif /* OUROBOROS_IRMD_IPCP_H */