Merged in sandervrijders/ouroboros/be (pull request #172)

ipcpd: normal: Establish N-1 management flows

1 files changed, 242 insertions, 0 deletions

diff --git a/src/ipcpd/normal/fmgr.c b/src/ipcpd/normal/fmgr.c
new file mode 100644
index 00000000..9521805f
--- /dev/null
+++ b/src/ipcpd/normal/fmgr.c
@@ -0,0 +1,242 @@
+/*
+ * Ouroboros - Copyright (C) 2016
+ *
+ * Flow manager of the IPC Process
+ *
+ *    Sander Vrijders <sander.vrijders@intec.ugent.be>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ */
+
+#define OUROBOROS_PREFIX "flow-manager"
+
+#include <ouroboros/config.h>
+#include <ouroboros/logs.h>
+#include <ouroboros/dev.h>
+#include <ouroboros/list.h>
+
+#include <stdlib.h>
+#include <stdbool.h>
+#include <pthread.h>
+#include <string.h>
+
+#include "fmgr.h"
+#include "ribmgr.h"
+#include "frct.h"
+
+struct n_1_flow {
+        int fd;
+        char * ae_name;
+        struct list_head next;
+};
+
+struct fmgr {
+        pthread_t listen_thread;
+
+        struct list_head n_1_flows;
+        pthread_mutex_t n_1_flows_lock;
+
+} * instance = NULL;
+
+static int add_n_1_fd(int fd,
+                      char * ae_name)
+{
+        struct n_1_flow * tmp;
+
+        if (ae_name == NULL)
+                return -1;
+
+        tmp = malloc(sizeof(*tmp));
+        if (tmp == NULL)
+                return -1;
+
+        tmp->fd = fd;
+        tmp->ae_name = ae_name;
+
+        pthread_mutex_lock(&instance->n_1_flows_lock);
+        list_add(&tmp->next, &instance->n_1_flows);
+        pthread_mutex_unlock(&instance->n_1_flows_lock);
+
+        return 0;
+}
+
+static void * fmgr_listen(void * o)
+{
+        int fd;
+        char * ae_name;
+
+        while (true) {
+                fd = flow_accept(&ae_name);
+                if (fd < 0) {
+                        LOG_ERR("Failed to accept flow.");
+                        continue;
+                }
+
+                if (!(strcmp(ae_name, MGMT_AE) == 0 ||
+                      strcmp(ae_name, DT_AE) == 0)) {
+                        if (flow_alloc_resp(fd, -1))
+                                LOG_ERR("Failed to reply to flow allocation.");
+                        flow_dealloc(fd);
+                        continue;
+                }
+
+                if (flow_alloc_resp(fd, 0)) {
+                        LOG_ERR("Failed to reply to flow allocation.");
+                        flow_dealloc(fd);
+                        continue;
+                }
+
+                LOG_DBG("Accepted new flow allocation request for AE %s.",
+                        ae_name);
+
+                if (strcmp(ae_name, MGMT_AE) == 0 &&
+                    ribmgr_mgmt_flow(fd)) {
+                        LOG_ERR("Failed to hand file descriptor to RIB.");
+                        flow_dealloc(fd);
+                        continue;
+                }
+
+                if (strcmp(ae_name, DT_AE) == 0 &&
+                    frct_dt_flow(fd)) {
+                        LOG_ERR("Failed to hand file descriptor to FRCT.");
+                        flow_dealloc(fd);
+                        continue;
+                }
+
+                if (add_n_1_fd(fd, ae_name)) {
+                        LOG_ERR("Failed to add file descriptor to list.");
+                        flow_dealloc(fd);
+                        continue;
+                }
+        }
+
+        return (void *) 0;
+}
+
+int fmgr_init()
+{
+        instance = malloc(sizeof(*instance));
+        if (instance == NULL) {
+                return -1;
+        }
+
+        INIT_LIST_HEAD(&instance->n_1_flows);
+
+        pthread_mutex_init(&instance->n_1_flows_lock, NULL);
+
+        pthread_create(&instance->listen_thread,
+                       NULL,
+                       fmgr_listen,
+                       NULL);
+
+        return 0;
+}
+
+int fmgr_fini()
+{
+        struct list_head * pos = NULL;
+
+        pthread_cancel(instance->listen_thread);
+
+        pthread_join(instance->listen_thread,
+                     NULL);
+
+        list_for_each(pos, &instance->n_1_flows) {
+                struct n_1_flow * e =
+                        list_entry(pos, struct n_1_flow, next);
+                if (e->ae_name != NULL)
+                        free(e->ae_name);
+                flow_dealloc(e->fd);
+        }
+
+        free(instance);
+
+        return 0;
+}
+
+int fmgr_mgmt_flow(char * dst_name)
+{
+        int fd;
+        int result;
+
+        /* FIXME: Request retransmission. */
+        fd = flow_alloc(dst_name, MGMT_AE, NULL);
+        if (fd < 0) {
+                LOG_ERR("Failed to allocate flow to %s", dst_name);
+                return -1;
+        }
+
+        result = flow_alloc_res(fd);
+        if (result < 0) {
+                LOG_ERR("Result of flow allocation to %s is %d",
+                        dst_name, result);
+                return -1;
+        }
+
+        if (ribmgr_mgmt_flow(fd)) {
+                LOG_ERR("Failed to hand file descriptor to RIB manager");
+                flow_dealloc(fd);
+                return -1;
+        }
+
+        if (add_n_1_fd(fd, strdup(MGMT_AE))) {
+                LOG_ERR("Failed to add file descriptor to list.");
+                flow_dealloc(fd);
+                return -1;
+        }
+
+        return 0;
+}
+
+int fmgr_dt_flow(char * dst_name)
+{
+        LOG_MISSING;
+
+        return -1;
+}
+
+int fmgr_flow_alloc(pid_t         n_api,
+                    int           port_id,
+                    char *        dst_ap_name,
+                    char *        src_ae_name,
+                    enum qos_cube qos)
+{
+        LOG_MISSING;
+
+        return -1;
+}
+
+int fmgr_flow_alloc_resp(pid_t n_api,
+                         int   port_id,
+                         int   response)
+{
+        LOG_MISSING;
+
+        return -1;
+}
+
+int fmgr_flow_dealloc(int port_id)
+{
+        LOG_MISSING;
+
+        return -1;
+}
+
+int fmgr_flow_msg()
+{
+        LOG_MISSING;
+
+        return -1;
+}