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>

1 files changed, 34 insertions, 0 deletions

diff --git a/src/ipcpd/ipcp.c b/src/ipcpd/ipcp.c
index 1052a686..dcee4b9c 100644
--- a/src/ipcpd/ipcp.c
+++ b/src/ipcpd/ipcp.c
@@ -820,6 +820,33 @@ static void do_flow_dealloc(int          flow_id,
         log_info("Finished deallocating flow %d.", flow_id);
 }
 
+static void do_flow_update(int              flow_id,
+                           const buffer_t * data,
+                           ipcp_msg_t *     ret_msg)
+{
+        int fd;
+
+        if (ipcpd.ops->ipcp_flow_update == NULL) {
+                log_err("Failed to update flow: operation unsupported.");
+                ret_msg->result = -ENOTSUP;
+                return;
+        }
+
+        if (ipcp_get_state() != IPCP_OPERATIONAL) {
+                ret_msg->result = -EIPCPSTATE;
+                return;
+        }
+
+        fd = np1_flow_fd(flow_id);
+        if (fd < 0) {
+                log_warn("Flow update for unknown flow_id %d.", flow_id);
+                ret_msg->result = -1;
+                return;
+        }
+
+        ret_msg->result = ipcpd.ops->ipcp_flow_update(fd, data);
+}
+
 static void * mainloop(void * o)
 {
         int          sfd;
@@ -918,6 +945,13 @@ static void * mainloop(void * o)
                 case IPCP_MSG_CODE__IPCP_FLOW_DEALLOC:
                         do_flow_dealloc(msg->flow_id, msg->timeo_sec, &ret_msg);
                         break;
+                case IPCP_MSG_CODE__IPCP_FLOW_UPDATE:
+                        assert(msg->pk.len > 0 ? msg->pk.data != NULL
+                                               : msg->pk.data == NULL);
+                        data.len = msg->pk.len;
+                        data.data = msg->pk.data;
+                        do_flow_update(msg->flow_id, &data, &ret_msg);
+                        break;
                 default:
                         ret_msg.result = -1;
                         log_err("Unknown message code: %d.", msg->code);