diff options
Diffstat (limited to 'src/lib')
| -rw-r--r-- | src/lib/CMakeLists.txt | 1 | ||||
| -rw-r--r-- | src/lib/flow.c | 87 | 
2 files changed, 0 insertions, 88 deletions
| diff --git a/src/lib/CMakeLists.txt b/src/lib/CMakeLists.txt index c2d1bcc7..4922e07c 100644 --- a/src/lib/CMakeLists.txt +++ b/src/lib/CMakeLists.txt @@ -28,7 +28,6 @@ set(SOURCE_FILES    da.c    dev.c    du_buff.c -  flow.c    instance_name.c    ipcp.c    irm.c diff --git a/src/lib/flow.c b/src/lib/flow.c deleted file mode 100644 index da0ca148..00000000 --- a/src/lib/flow.c +++ /dev/null @@ -1,87 +0,0 @@ -/* - * Ouroboros - Copyright (C) 2016 - * - * Flows - * - *    Dimitri Staessens <dimitri.staessens@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. - */ - -#include <stdlib.h> -#include <ouroboros/flow.h> - -#define OUROBOROS_PREFIX "ipcpd/flow" - -#include <ouroboros/logs.h> - -flow_t * flow_create(int32_t port_id) -{ -        flow_t * flow = malloc(sizeof *flow); -        if (flow == NULL) { -                LOG_DBGF("Could not malloc flow."); -                return NULL; -        } - -        INIT_LIST_HEAD(&flow->list); - -        flow->port_id = port_id; -        flow->oflags = FLOW_O_DEFAULT; -        flow->state = FLOW_NULL; - -        pthread_mutex_init(&flow->lock, NULL); - -        return flow; -} - -void flow_destroy(flow_t * flow) -{ -        if (flow == NULL) -                return; -        free(flow); -} - -int flow_set_opts(flow_t * flow, uint16_t opts) -{ -        if (flow == NULL) { -                LOG_DBGF("Non-existing flow."); -                return -1; -        } - -        pthread_mutex_lock(&flow->lock); - -        if ((opts & FLOW_O_ACCMODE) == FLOW_O_ACCMODE) { -                flow->oflags = FLOW_O_DEFAULT; -                pthread_mutex_unlock(&flow->lock); -                LOG_WARN("Invalid flow options. Setting default."); -                return -1; -        } - -        flow->oflags = opts; - -        pthread_mutex_unlock(&flow->lock); - -        return 0; -} - -uint16_t flow_get_opts(const flow_t * flow) -{ -        if (flow == NULL) { -                LOG_DBGF("Non-existing flow."); -                return FLOW_O_INVALID; -        } - -        return flow->oflags; -} | 
