examples/ip_pipeline/action.c

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright(c) 2010-2018 Intel Corporation
 */
 
#include <stdint.h>
#include <stdlib.h>
#include <string.h>
 
#include <rte_string_fns.h>
#include <rte_table_hash_func.h>
 
#include "action.h"
 
static struct port_in_action_profile_list port_in_action_profile_list;
 
int
port_in_action_profile_init(void)
{
    TAILQ_INIT(&port_in_action_profile_list);
 
    return 0;
}
 
struct port_in_action_profile *
port_in_action_profile_find(const char *name)
{
    struct port_in_action_profile *profile;
 
    if (name == NULL)
        return NULL;
 
    TAILQ_FOREACH(profile, &port_in_action_profile_list, node)
        if (strcmp(profile->name, name) == 0)
            return profile;
 
    return NULL;
}
 
struct port_in_action_profile *
port_in_action_profile_create(const char *name,
    struct port_in_action_profile_params *params)
{
    struct port_in_action_profile *profile;
    struct rte_port_in_action_profile *ap;
    int status;
 
    /* Check input params */
    if ((name == NULL) ||
        port_in_action_profile_find(name) ||
        (params == NULL))
        return NULL;
 
    if ((params->action_mask & (1LLU << RTE_PORT_IN_ACTION_LB)) &&
        (params->lb.f_hash == NULL)) {
        switch (params->lb.key_size) {
        case  8:
            params->lb.f_hash = rte_table_hash_crc_key8;
            break;
 
        case 16:
            params->lb.f_hash = rte_table_hash_crc_key16;
            break;
 
        case 24:
            params->lb.f_hash = rte_table_hash_crc_key24;
            break;
 
        case 32:
            params->lb.f_hash = rte_table_hash_crc_key32;
            break;
 
        case 40:
            params->lb.f_hash = rte_table_hash_crc_key40;
            break;
 
        case 48:
            params->lb.f_hash = rte_table_hash_crc_key48;
            break;
 
        case 56:
            params->lb.f_hash = rte_table_hash_crc_key56;
            break;
 
        case 64:
            params->lb.f_hash = rte_table_hash_crc_key64;
            break;
 
        default:
            return NULL;
        }
 
        params->lb.seed = 0;
    }
    /* Resource */
    ap = rte_port_in_action_profile_create(0);
    if (ap == NULL)
        return NULL;
 
    if (params->action_mask & (1LLU << RTE_PORT_IN_ACTION_FLTR)) {
        status = rte_port_in_action_profile_action_register(ap,
            RTE_PORT_IN_ACTION_FLTR,
            &params->fltr);
 
        if (status) {
            rte_port_in_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_PORT_IN_ACTION_LB)) {
        status = rte_port_in_action_profile_action_register(ap,
            RTE_PORT_IN_ACTION_LB,
            &params->lb);
 
        if (status) {
            rte_port_in_action_profile_free(ap);
            return NULL;
        }
    }
 
    status = rte_port_in_action_profile_freeze(ap);
    if (status) {
        rte_port_in_action_profile_free(ap);
        return NULL;
    }
 
    /* Node allocation */
    profile = calloc(1, sizeof(struct port_in_action_profile));
    if (profile == NULL) {
        rte_port_in_action_profile_free(ap);
        return NULL;
    }
 
    /* Node fill in */
    strlcpy(profile->name, name, sizeof(profile->name));
    memcpy(&profile->params, params, sizeof(*params));
    profile->ap = ap;
 
    /* Node add to list */
    TAILQ_INSERT_TAIL(&port_in_action_profile_list, profile, node);
 
    return profile;
}
 
static struct table_action_profile_list table_action_profile_list;
 
int
table_action_profile_init(void)
{
    TAILQ_INIT(&table_action_profile_list);
 
    return 0;
}
 
struct table_action_profile *
table_action_profile_find(const char *name)
{
    struct table_action_profile *profile;
 
    if (name == NULL)
        return NULL;
 
    TAILQ_FOREACH(profile, &table_action_profile_list, node)
        if (strcmp(profile->name, name) == 0)
            return profile;
 
    return NULL;
}
 
struct table_action_profile *
table_action_profile_create(const char *name,
    struct table_action_profile_params *params)
{
    struct table_action_profile *profile;
    struct rte_table_action_profile *ap;
    int status;
 
    /* Check input params */
    if ((name == NULL) ||
        table_action_profile_find(name) ||
        (params == NULL) ||
        ((params->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) == 0))
        return NULL;
 
    if ((params->action_mask & (1LLU << RTE_TABLE_ACTION_LB)) &&
        (params->lb.f_hash == NULL)) {
        switch (params->lb.key_size) {
        case 8:
            params->lb.f_hash = rte_table_hash_crc_key8;
            break;
 
        case 16:
            params->lb.f_hash = rte_table_hash_crc_key16;
            break;
 
        case 24:
            params->lb.f_hash = rte_table_hash_crc_key24;
            break;
 
        case 32:
            params->lb.f_hash = rte_table_hash_crc_key32;
            break;
 
        case 40:
            params->lb.f_hash = rte_table_hash_crc_key40;
            break;
 
        case 48:
            params->lb.f_hash = rte_table_hash_crc_key48;
            break;
 
        case 56:
            params->lb.f_hash = rte_table_hash_crc_key56;
            break;
 
        case 64:
            params->lb.f_hash = rte_table_hash_crc_key64;
            break;
 
        default:
            return NULL;
        }
 
        params->lb.seed = 0;
    }
 
    /* Resource */
    ap = rte_table_action_profile_create(&params->common);
    if (ap == NULL)
        return NULL;
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_FWD,
            NULL);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_LB)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_LB,
            &params->lb);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_MTR)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_MTR,
            &params->mtr);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_TM)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_TM,
            &params->tm);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_ENCAP)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_ENCAP,
            &params->encap);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_NAT)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_NAT,
            &params->nat);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_TTL)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_TTL,
            &params->ttl);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_STATS)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_STATS,
            &params->stats);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_TIME)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_TIME,
            NULL);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_SYM_CRYPTO)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_SYM_CRYPTO,
            &params->sym_crypto);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_TAG)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_TAG,
            NULL);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    if (params->action_mask & (1LLU << RTE_TABLE_ACTION_DECAP)) {
        status = rte_table_action_profile_action_register(ap,
            RTE_TABLE_ACTION_DECAP,
            NULL);
 
        if (status) {
            rte_table_action_profile_free(ap);
            return NULL;
        }
    }
 
    status = rte_table_action_profile_freeze(ap);
    if (status) {
        rte_table_action_profile_free(ap);
        return NULL;
    }
 
    /* Node allocation */
    profile = calloc(1, sizeof(struct table_action_profile));
    if (profile == NULL) {
        rte_table_action_profile_free(ap);
        return NULL;
    }
 
    /* Node fill in */
    strlcpy(profile->name, name, sizeof(profile->name));
    memcpy(&profile->params, params, sizeof(*params));
    profile->ap = ap;
 
    /* Node add to list */
    TAILQ_INSERT_TAIL(&table_action_profile_list, profile, node);
 
    return profile;
}