net/i40e/base: replace license text with SPDX tag

[dpdk.git] / lib / librte_pipeline / rte_table_action.c

diff --git a/lib/librte_pipeline/rte_table_action.c b/lib/librte_pipeline/rte_table_action.c
index 8bcc4eb..83ffa5d 100644 (file)
--- a/lib/librte_pipeline/rte_table_action.c
+++ b/lib/librte_pipeline/rte_table_action.c
@@ -44,6 +44,55 @@ fwd_apply(struct fwd_data *data,
        return 0;
 }
 
+/**
+ * RTE_TABLE_ACTION_LB
+ */
+static int
+lb_cfg_check(struct rte_table_action_lb_config *cfg)
+{
+       if ((cfg == NULL) ||
+               (cfg->key_size < RTE_TABLE_ACTION_LB_KEY_SIZE_MIN) ||
+               (cfg->key_size > RTE_TABLE_ACTION_LB_KEY_SIZE_MAX) ||
+               (!rte_is_power_of_2(cfg->key_size)) ||
+               (cfg->f_hash == NULL))
+               return -1;
+
+       return 0;
+}
+
+struct lb_data {
+       uint32_t out[RTE_TABLE_ACTION_LB_TABLE_SIZE];
+} __attribute__((__packed__));
+
+static int
+lb_apply(struct lb_data *data,
+       struct rte_table_action_lb_params *p)
+{
+       memcpy(data->out, p->out, sizeof(data->out));
+
+       return 0;
+}
+
+static __rte_always_inline void
+pkt_work_lb(struct rte_mbuf *mbuf,
+       struct lb_data *data,
+       struct rte_table_action_lb_config *cfg)
+{
+       uint8_t *pkt_key = RTE_MBUF_METADATA_UINT8_PTR(mbuf, cfg->key_offset);
+       uint32_t *out = RTE_MBUF_METADATA_UINT32_PTR(mbuf, cfg->out_offset);
+       uint64_t digest, pos;
+       uint32_t out_val;
+
+       digest = cfg->f_hash(pkt_key,
+               cfg->key_mask,
+               cfg->key_size,
+               cfg->seed);
+       pos = digest & (RTE_TABLE_ACTION_LB_TABLE_SIZE - 1);
+       out_val = data->out[pos];
+
+       *out = out_val;
+}
+
 /**
  * RTE_TABLE_ACTION_MTR
  */
@@ -1148,6 +1197,28 @@ pkt_work_stats(struct stats_data *data,
        data->n_bytes += total_length;
 }
 
+/**
+ * RTE_TABLE_ACTION_TIME
+ */
+struct time_data {
+       uint64_t time;
+} __attribute__((__packed__));
+
+static int
+time_apply(struct time_data *data,
+       struct rte_table_action_time_params *p)
+{
+       data->time = p->time;
+       return 0;
+}
+
+static __rte_always_inline void
+pkt_work_time(struct time_data *data,
+       uint64_t time)
+{
+       data->time = time;
+}
+
 /**
  * Action profile
  */
@@ -1156,12 +1227,14 @@ action_valid(enum rte_table_action_type action)
 {
        switch (action) {
        case RTE_TABLE_ACTION_FWD:
+       case RTE_TABLE_ACTION_LB:
        case RTE_TABLE_ACTION_MTR:
        case RTE_TABLE_ACTION_TM:
        case RTE_TABLE_ACTION_ENCAP:
        case RTE_TABLE_ACTION_NAT:
        case RTE_TABLE_ACTION_TTL:
        case RTE_TABLE_ACTION_STATS:
+       case RTE_TABLE_ACTION_TIME:
                return 1;
        default:
                return 0;
@@ -1174,6 +1247,7 @@ action_valid(enum rte_table_action_type action)
 struct ap_config {
        uint64_t action_mask;
        struct rte_table_action_common_config common;
+       struct rte_table_action_lb_config lb;
        struct rte_table_action_mtr_config mtr;
        struct rte_table_action_tm_config tm;
        struct rte_table_action_encap_config encap;
@@ -1186,6 +1260,8 @@ static size_t
 action_cfg_size(enum rte_table_action_type action)
 {
        switch (action) {
+       case RTE_TABLE_ACTION_LB:
+               return sizeof(struct rte_table_action_lb_config);
        case RTE_TABLE_ACTION_MTR:
                return sizeof(struct rte_table_action_mtr_config);
        case RTE_TABLE_ACTION_TM:
@@ -1208,6 +1284,9 @@ action_cfg_get(struct ap_config *ap_config,
        enum rte_table_action_type type)
 {
        switch (type) {
+       case RTE_TABLE_ACTION_LB:
+               return &ap_config->lb;
+
        case RTE_TABLE_ACTION_MTR:
                return &ap_config->mtr;
 
@@ -1257,6 +1336,9 @@ action_data_size(enum rte_table_action_type action,
        case RTE_TABLE_ACTION_FWD:
                return sizeof(struct fwd_data);
 
+       case RTE_TABLE_ACTION_LB:
+               return sizeof(struct lb_data);
+
        case RTE_TABLE_ACTION_MTR:
                return mtr_data_size(&ap_config->mtr);
 
@@ -1276,6 +1358,9 @@ action_data_size(enum rte_table_action_type action,
        case RTE_TABLE_ACTION_STATS:
                return sizeof(struct stats_data);
 
+       case RTE_TABLE_ACTION_TIME:
+               return sizeof(struct time_data);
+
        default:
                return 0;
        }
@@ -1347,6 +1432,10 @@ rte_table_action_profile_action_register(struct rte_table_action_profile *profil
                return -EINVAL;
 
        switch (type) {
+       case RTE_TABLE_ACTION_LB:
+               status = lb_cfg_check(action_config);
+               break;
+
        case RTE_TABLE_ACTION_MTR:
                status = mtr_cfg_check(action_config);
                break;
@@ -1481,6 +1570,10 @@ rte_table_action_apply(struct rte_table_action *action,
                return fwd_apply(action_data,
                        action_params);
 
+       case RTE_TABLE_ACTION_LB:
+               return lb_apply(action_data,
+                       action_params);
+
        case RTE_TABLE_ACTION_MTR:
                return mtr_apply(action_data,
                        action_params,
@@ -1512,6 +1605,10 @@ rte_table_action_apply(struct rte_table_action *action,
                return stats_apply(action_data,
                        action_params);
 
+       case RTE_TABLE_ACTION_TIME:
+               return time_apply(action_data,
+                       action_params);
+
        default:
                return -EINVAL;
        }
@@ -1741,6 +1838,29 @@ rte_table_action_stats_read(struct rte_table_action *action,
        return 0;
 }
 
+int
+rte_table_action_time_read(struct rte_table_action *action,
+       void *data,
+       uint64_t *timestamp)
+{
+       struct time_data *time_data;
+
+       /* Check input arguments */
+       if ((action == NULL) ||
+               ((action->cfg.action_mask &
+               (1LLU << RTE_TABLE_ACTION_TIME)) == 0) ||
+               (data == NULL) ||
+               (timestamp == NULL))
+               return -EINVAL;
+
+       time_data = action_data_get(data, action, RTE_TABLE_ACTION_TIME);
+
+       /* Read */
+       *timestamp = time_data->time;
+
+       return 0;
+}
+
 static __rte_always_inline uint64_t
 pkt_work(struct rte_mbuf *mbuf,
        struct rte_pipeline_table_entry *table_entry,
@@ -1769,6 +1889,14 @@ pkt_work(struct rte_mbuf *mbuf,
                        rte_ntohs(hdr->payload_len) + sizeof(struct ipv6_hdr);
        }
 
+       if (cfg->action_mask & (1LLU << RTE_TABLE_ACTION_LB)) {
+               void *data =
+                       action_data_get(table_entry, action, RTE_TABLE_ACTION_LB);
+
+               pkt_work_lb(mbuf,
+                       data,
+                       &cfg->lb);
+       }
        if (cfg->action_mask & (1LLU << RTE_TABLE_ACTION_MTR)) {
                void *data =
                        action_data_get(table_entry, action, RTE_TABLE_ACTION_MTR);
@@ -1831,6 +1959,13 @@ pkt_work(struct rte_mbuf *mbuf,
                pkt_work_stats(data, total_length);
        }
 
+       if (cfg->action_mask & (1LLU << RTE_TABLE_ACTION_TIME)) {
+               void *data =
+                       action_data_get(table_entry, action, RTE_TABLE_ACTION_TIME);
+
+               pkt_work_time(data, time);
+       }
+
        return drop_mask;
 }
 
@@ -1901,6 +2036,33 @@ pkt4_work(struct rte_mbuf **mbufs,
                        rte_ntohs(hdr3->payload_len) + sizeof(struct ipv6_hdr);
        }
 
+       if (cfg->action_mask & (1LLU << RTE_TABLE_ACTION_LB)) {
+               void *data0 =
+                       action_data_get(table_entry0, action, RTE_TABLE_ACTION_LB);
+               void *data1 =
+                       action_data_get(table_entry1, action, RTE_TABLE_ACTION_LB);
+               void *data2 =
+                       action_data_get(table_entry2, action, RTE_TABLE_ACTION_LB);
+               void *data3 =
+                       action_data_get(table_entry3, action, RTE_TABLE_ACTION_LB);
+
+               pkt_work_lb(mbuf0,
+                       data0,
+                       &cfg->lb);
+
+               pkt_work_lb(mbuf1,
+                       data1,
+                       &cfg->lb);
+
+               pkt_work_lb(mbuf2,
+                       data2,
+                       &cfg->lb);
+
+               pkt_work_lb(mbuf3,
+                       data3,
+                       &cfg->lb);
+       }
+
        if (cfg->action_mask & (1LLU << RTE_TABLE_ACTION_MTR)) {
                void *data0 =
                        action_data_get(table_entry0, action, RTE_TABLE_ACTION_MTR);
@@ -2076,6 +2238,22 @@ pkt4_work(struct rte_mbuf **mbufs,
                pkt_work_stats(data3, total_length3);
        }
 
+       if (cfg->action_mask & (1LLU << RTE_TABLE_ACTION_TIME)) {
+               void *data0 =
+                       action_data_get(table_entry0, action, RTE_TABLE_ACTION_TIME);
+               void *data1 =
+                       action_data_get(table_entry1, action, RTE_TABLE_ACTION_TIME);
+               void *data2 =
+                       action_data_get(table_entry2, action, RTE_TABLE_ACTION_TIME);
+               void *data3 =
+                       action_data_get(table_entry3, action, RTE_TABLE_ACTION_TIME);
+
+               pkt_work_time(data0, time);
+               pkt_work_time(data1, time);
+               pkt_work_time(data2, time);
+               pkt_work_time(data3, time);
+       }
+
        return drop_mask0 |
                (drop_mask1 << 1) |
                (drop_mask2 << 2) |
@@ -2093,7 +2271,8 @@ ah(struct rte_pipeline *p,
        uint64_t pkts_drop_mask = 0;
        uint64_t time = 0;
 
-       if (cfg->action_mask & (1LLU << RTE_TABLE_ACTION_MTR))
+       if (cfg->action_mask & ((1LLU << RTE_TABLE_ACTION_MTR) |
+               (1LLU << RTE_TABLE_ACTION_TIME)))
                time = rte_rdtsc();
 
        if ((pkts_mask & (pkts_mask + 1)) == 0) {