diff options
Diffstat (limited to 'src/ipcpd/normal/fmgr.c')
| -rw-r--r-- | src/ipcpd/normal/fmgr.c | 242 |
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 <[email protected]> + * + * 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; +} |