examples/ip_pipeline: add table entry commands
authorJasvinder Singh <jasvinder.singh@intel.com>
Thu, 29 Mar 2018 18:31:54 +0000 (19:31 +0100)
committerCristian Dumitrescu <cristian.dumitrescu@intel.com>
Thu, 5 Apr 2018 17:00:18 +0000 (19:00 +0200)
Add commands to add pipeline table entries which contains match and
action part.

Signed-off-by: Cristian Dumitrescu <cristian.dumitrescu@intel.com>
Signed-off-by: Jasvinder Singh <jasvinder.singh@intel.com>
Signed-off-by: Kevin Laatz <kevin.laatz@intel.com>
examples/ip_pipeline/cli.c
examples/ip_pipeline/pipeline.h
examples/ip_pipeline/thread.c

index 33babb5..dab0d96 100644 (file)
@@ -8,6 +8,7 @@
 #include <string.h>
 
 #include <rte_common.h>
+#include <rte_cycles.h>
 
 #include "cli.h"
 #include "kni.h"
@@ -2261,6 +2262,1283 @@ cmd_pipeline_table_stats(char **tokens,
                stats.n_pkts_dropped_lkp_miss);
 }
 
+/**
+ * <match> ::=
+ *
+ * match
+ *    acl
+ *       priority <priority>
+ *       ipv4 | ipv6 <sa> <sa_depth> <da> <da_depth>
+ *       <sp0> <sp1> <dp0> <dp1> <proto>
+ *    | array
+ *       pos
+ *    | hash
+ *       raw <key>
+ *       | ipv4_5tuple <sa> <da> <sp> <dp> <proto>
+ *       | ipv6_5tuple <sa> <da> <sp> <dp> <proto>
+ *       | ipv4_addr <addr>
+ *       | ipv6_addr <addr>
+ *       | qinq <svlan> <cvlan>
+ *    | lpm
+ *       ipv4 | ipv6 <addr> <depth>
+ */
+struct pkt_key_qinq {
+       uint16_t ethertype_svlan;
+       uint16_t svlan;
+       uint16_t ethertype_cvlan;
+       uint16_t cvlan;
+} __attribute__((__packed__));
+
+struct pkt_key_ipv4_5tuple {
+       uint8_t time_to_live;
+       uint8_t proto;
+       uint16_t hdr_checksum;
+       uint32_t sa;
+       uint32_t da;
+       uint16_t sp;
+       uint16_t dp;
+} __attribute__((__packed__));
+
+struct pkt_key_ipv6_5tuple {
+       uint16_t payload_length;
+       uint8_t proto;
+       uint8_t hop_limit;
+       uint8_t sa[16];
+       uint8_t da[16];
+       uint16_t sp;
+       uint16_t dp;
+} __attribute__((__packed__));
+
+struct pkt_key_ipv4_addr {
+       uint32_t addr;
+} __attribute__((__packed__));
+
+struct pkt_key_ipv6_addr {
+       uint8_t addr[16];
+} __attribute__((__packed__));
+
+static uint32_t
+parse_match(char **tokens,
+       uint32_t n_tokens,
+       char *out,
+       size_t out_size,
+       struct table_rule_match *m)
+{
+       memset(m, 0, sizeof(*m));
+
+       if (n_tokens < 2)
+               return 0;
+
+       if (strcmp(tokens[0], "match") != 0) {
+               snprintf(out, out_size, MSG_ARG_NOT_FOUND, "match");
+               return 0;
+       }
+
+       if (strcmp(tokens[1], "acl") == 0) {
+               if (n_tokens < 14) {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+                       return 0;
+               }
+
+               m->match_type = TABLE_ACL;
+
+               if (strcmp(tokens[2], "priority") != 0) {
+                       snprintf(out, out_size, MSG_ARG_NOT_FOUND, "priority");
+                       return 0;
+               }
+
+               if (parser_read_uint32(&m->match.acl.priority,
+                       tokens[3]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "priority");
+                       return 0;
+               }
+
+               if (strcmp(tokens[4], "ipv4") == 0) {
+                       struct in_addr saddr, daddr;
+
+                       m->match.acl.ip_version = 1;
+
+                       if (parse_ipv4_addr(tokens[5], &saddr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "sa");
+                               return 0;
+                       }
+                       m->match.acl.ipv4.sa = rte_be_to_cpu_32(saddr.s_addr);
+
+                       if (parse_ipv4_addr(tokens[7], &daddr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "da");
+                               return 0;
+                       }
+                       m->match.acl.ipv4.da = rte_be_to_cpu_32(daddr.s_addr);
+               } else if (strcmp(tokens[4], "ipv6") == 0) {
+                       struct in6_addr saddr, daddr;
+
+                       m->match.acl.ip_version = 0;
+
+                       if (parse_ipv6_addr(tokens[5], &saddr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "sa");
+                               return 0;
+                       }
+                       memcpy(m->match.acl.ipv6.sa, saddr.s6_addr, 16);
+
+                       if (parse_ipv6_addr(tokens[7], &daddr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "da");
+                               return 0;
+                       }
+                       memcpy(m->match.acl.ipv6.da, daddr.s6_addr, 16);
+               } else {
+                       snprintf(out, out_size, MSG_ARG_NOT_FOUND,
+                               "ipv4 or ipv6");
+                       return 0;
+               }
+
+               if (parser_read_uint32(&m->match.acl.sa_depth,
+                       tokens[6]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "sa_depth");
+                       return 0;
+               }
+
+               if (parser_read_uint32(&m->match.acl.da_depth,
+                       tokens[8]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "da_depth");
+                       return 0;
+               }
+
+               if (parser_read_uint16(&m->match.acl.sp0, tokens[9]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "sp0");
+                       return 0;
+               }
+
+               if (parser_read_uint16(&m->match.acl.sp1, tokens[10]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "sp1");
+                       return 0;
+               }
+
+               if (parser_read_uint16(&m->match.acl.dp0, tokens[11]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "dp0");
+                       return 0;
+               }
+
+               if (parser_read_uint16(&m->match.acl.dp1, tokens[12]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "dp1");
+                       return 0;
+               }
+
+               if (parser_read_uint8(&m->match.acl.proto, tokens[13]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "proto");
+                       return 0;
+               }
+
+               m->match.acl.proto_mask = 0xff;
+
+               return 14;
+       } /* acl */
+
+       if (strcmp(tokens[1], "array") == 0) {
+               if (n_tokens < 3) {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+                       return 0;
+               }
+
+               m->match_type = TABLE_ARRAY;
+
+               if (parser_read_uint32(&m->match.array.pos, tokens[2]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "pos");
+                       return 0;
+               }
+
+               return 3;
+       } /* array */
+
+       if (strcmp(tokens[1], "hash") == 0) {
+               if (n_tokens < 3) {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+                       return 0;
+               }
+
+               m->match_type = TABLE_HASH;
+
+               if (strcmp(tokens[2], "raw") == 0) {
+                       uint32_t key_size = TABLE_RULE_MATCH_SIZE_MAX;
+
+                       if (n_tokens < 4) {
+                               snprintf(out, out_size, MSG_ARG_MISMATCH,
+                                       tokens[0]);
+                               return 0;
+                       }
+
+                       if (parse_hex_string(tokens[3],
+                               m->match.hash.key, &key_size) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "key");
+                               return 0;
+                       }
+
+                       return 4;
+               } /* hash raw */
+
+               if (strcmp(tokens[2], "ipv4_5tuple") == 0) {
+                       struct pkt_key_ipv4_5tuple *ipv4 =
+                               (struct pkt_key_ipv4_5tuple *) m->match.hash.key;
+                       struct in_addr saddr, daddr;
+                       uint16_t sp, dp;
+                       uint8_t proto;
+
+                       if (n_tokens < 8) {
+                               snprintf(out, out_size, MSG_ARG_MISMATCH,
+                                       tokens[0]);
+                               return 0;
+                       }
+
+                       if (parse_ipv4_addr(tokens[3], &saddr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "sa");
+                               return 0;
+                       }
+
+                       if (parse_ipv4_addr(tokens[4], &daddr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "da");
+                               return 0;
+                       }
+
+                       if (parser_read_uint16(&sp, tokens[5]) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "sp");
+                               return 0;
+                       }
+
+                       if (parser_read_uint16(&dp, tokens[6]) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "dp");
+                               return 0;
+                       }
+
+                       if (parser_read_uint8(&proto, tokens[7]) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID,
+                                       "proto");
+                               return 0;
+                       }
+
+                       ipv4->sa = saddr.s_addr;
+                       ipv4->da = daddr.s_addr;
+                       ipv4->sp = rte_cpu_to_be_16(sp);
+                       ipv4->dp = rte_cpu_to_be_16(dp);
+                       ipv4->proto = proto;
+
+                       return 8;
+               } /* hash ipv4_5tuple */
+
+               if (strcmp(tokens[2], "ipv6_5tuple") == 0) {
+                       struct pkt_key_ipv6_5tuple *ipv6 =
+                               (struct pkt_key_ipv6_5tuple *) m->match.hash.key;
+                       struct in6_addr saddr, daddr;
+                       uint16_t sp, dp;
+                       uint8_t proto;
+
+                       if (n_tokens < 8) {
+                               snprintf(out, out_size, MSG_ARG_MISMATCH,
+                                       tokens[0]);
+                               return 0;
+                       }
+
+                       if (parse_ipv6_addr(tokens[3], &saddr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "sa");
+                               return 0;
+                       }
+
+                       if (parse_ipv6_addr(tokens[4], &daddr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "da");
+                               return 0;
+                       }
+
+                       if (parser_read_uint16(&sp, tokens[5]) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "sp");
+                               return 0;
+                       }
+
+                       if (parser_read_uint16(&dp, tokens[6]) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID, "dp");
+                               return 0;
+                       }
+
+                       if (parser_read_uint8(&proto, tokens[7]) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID,
+                                       "proto");
+                               return 0;
+                       }
+
+                       memcpy(ipv6->sa, saddr.s6_addr, 16);
+                       memcpy(ipv6->da, daddr.s6_addr, 16);
+                       ipv6->sp = rte_cpu_to_be_16(sp);
+                       ipv6->dp = rte_cpu_to_be_16(dp);
+                       ipv6->proto = proto;
+
+                       return 8;
+               } /* hash ipv6_5tuple */
+
+               if (strcmp(tokens[2], "ipv4_addr") == 0) {
+                       struct pkt_key_ipv4_addr *ipv4_addr =
+                               (struct pkt_key_ipv4_addr *) m->match.hash.key;
+                       struct in_addr addr;
+
+                       if (n_tokens < 4) {
+                               snprintf(out, out_size, MSG_ARG_MISMATCH,
+                                       tokens[0]);
+                               return 0;
+                       }
+
+                       if (parse_ipv4_addr(tokens[3], &addr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID,
+                                       "addr");
+                               return 0;
+                       }
+
+                       ipv4_addr->addr = addr.s_addr;
+
+                       return 4;
+               } /* hash ipv4_addr */
+
+               if (strcmp(tokens[2], "ipv6_addr") == 0) {
+                       struct pkt_key_ipv6_addr *ipv6_addr =
+                               (struct pkt_key_ipv6_addr *) m->match.hash.key;
+                       struct in6_addr addr;
+
+                       if (n_tokens < 4) {
+                               snprintf(out, out_size, MSG_ARG_MISMATCH,
+                                       tokens[0]);
+                               return 0;
+                       }
+
+                       if (parse_ipv6_addr(tokens[3], &addr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID,
+                                       "addr");
+                               return 0;
+                       }
+
+                       memcpy(ipv6_addr->addr, addr.s6_addr, 16);
+
+                       return 4;
+               } /* hash ipv6_5tuple */
+
+               if (strcmp(tokens[2], "qinq") == 0) {
+                       struct pkt_key_qinq *qinq =
+                               (struct pkt_key_qinq *) m->match.hash.key;
+                       uint16_t svlan, cvlan;
+
+                       if (n_tokens < 5) {
+                               snprintf(out, out_size, MSG_ARG_MISMATCH,
+                                       tokens[0]);
+                               return 0;
+                       }
+
+                       if ((parser_read_uint16(&svlan, tokens[3]) != 0) ||
+                               (svlan > 0xFFF)) {
+                               snprintf(out, out_size, MSG_ARG_INVALID,
+                                       "svlan");
+                               return 0;
+                       }
+
+                       if ((parser_read_uint16(&cvlan, tokens[4]) != 0) ||
+                               (cvlan > 0xFFF)) {
+                               snprintf(out, out_size, MSG_ARG_INVALID,
+                                       "cvlan");
+                               return 0;
+                       }
+
+                       qinq->svlan = rte_cpu_to_be_16(svlan);
+                       qinq->cvlan = rte_cpu_to_be_16(cvlan);
+
+                       return 5;
+               } /* hash qinq */
+
+               snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+               return 0;
+       } /* hash */
+
+       if (strcmp(tokens[1], "lpm") == 0) {
+               if (n_tokens < 5) {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+                       return 0;
+               }
+
+               m->match_type = TABLE_LPM;
+
+               if (strcmp(tokens[2], "ipv4") == 0) {
+                       struct in_addr addr;
+
+                       m->match.lpm.ip_version = 1;
+
+                       if (parse_ipv4_addr(tokens[3], &addr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID,
+                                       "addr");
+                               return 0;
+                       }
+
+                       m->match.lpm.ipv4 = rte_be_to_cpu_32(addr.s_addr);
+               } else if (strcmp(tokens[2], "ipv6") == 0) {
+                       struct in6_addr addr;
+
+                       m->match.lpm.ip_version = 0;
+
+                       if (parse_ipv6_addr(tokens[3], &addr) != 0) {
+                               snprintf(out, out_size, MSG_ARG_INVALID,
+                                       "addr");
+                               return 0;
+                       }
+
+                       memcpy(m->match.lpm.ipv6, addr.s6_addr, 16);
+               } else {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH,
+                               "ipv4 or ipv6");
+                       return 0;
+               }
+
+               if (parser_read_uint8(&m->match.lpm.depth, tokens[4]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "depth");
+                       return 0;
+               }
+
+               return 5;
+       } /* lpm */
+
+       snprintf(out, out_size, MSG_ARG_MISMATCH,
+               "acl or array or hash or lpm");
+       return 0;
+}
+
+/**
+ * table_action ::=
+ *
+ * action
+ *    fwd
+ *       drop
+ *       | port <port_id>
+ *       | meta
+ *       | table <table_id>
+ *    [balance <out0> ... <out7>]
+ *    [meter
+ *       tc0 meter <meter_profile_id> policer g <pa> y <pa> r <pa>
+ *       [tc1 meter <meter_profile_id> policer g <pa> y <pa> r <pa>
+ *       tc2 meter <meter_profile_id> policer g <pa> y <pa> r <pa>
+ *       tc3 meter <meter_profile_id> policer g <pa> y <pa> r <pa>]]
+ *    [tm subport <subport_id> pipe <pipe_id>]
+ *    [encap
+ *       ether <da> <sa>
+ *       | vlan <da> <sa> <pcp> <dei> <vid>
+ *       | qinq <da> <sa> <pcp> <dei> <vid> <pcp> <dei> <vid>
+ *       | mpls unicast | multicast
+ *          <da> <sa>
+ *          label0 <label> <tc> <ttl>
+ *          [label1 <label> <tc> <ttl>
+ *          [label2 <label> <tc> <ttl>
+ *          [label3 <label> <tc> <ttl>]]]
+ *       | pppoe <da> <sa> <session_id>]
+ *    [nat ipv4 | ipv6 <addr> <port>]
+ *    [ttl dec | keep]
+ *    [stats]
+ *    [time]
+ *
+ * where:
+ *    <pa> ::= g | y | r | drop
+ */
+static uint32_t
+parse_table_action_fwd(char **tokens,
+       uint32_t n_tokens,
+       struct table_rule_action *a)
+{
+       if ((n_tokens == 0) || (strcmp(tokens[0], "fwd") != 0))
+               return 0;
+
+       tokens++;
+       n_tokens--;
+
+       if (n_tokens && (strcmp(tokens[0], "drop") == 0)) {
+               a->fwd.action = RTE_PIPELINE_ACTION_DROP;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_FWD;
+               return 1 + 1;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "port") == 0)) {
+               uint32_t id;
+
+               if ((n_tokens < 2) ||
+                       parser_read_uint32(&id, tokens[1]))
+                       return 0;
+
+               a->fwd.action = RTE_PIPELINE_ACTION_PORT;
+               a->fwd.id = id;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_FWD;
+               return 1 + 2;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "meta") == 0)) {
+               a->fwd.action = RTE_PIPELINE_ACTION_PORT_META;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_FWD;
+               return 1 + 1;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "table") == 0)) {
+               uint32_t id;
+
+               if ((n_tokens < 2) ||
+                       parser_read_uint32(&id, tokens[1]))
+                       return 0;
+
+               a->fwd.action = RTE_PIPELINE_ACTION_TABLE;
+               a->fwd.id = id;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_FWD;
+               return 1 + 2;
+       }
+
+       return 0;
+}
+
+static int
+parse_policer_action(char *token, enum rte_table_action_policer *a)
+{
+       if (strcmp(token, "g") == 0) {
+               *a = RTE_TABLE_ACTION_POLICER_COLOR_GREEN;
+               return 0;
+       }
+
+       if (strcmp(token, "y") == 0) {
+               *a = RTE_TABLE_ACTION_POLICER_COLOR_YELLOW;
+               return 0;
+       }
+
+       if (strcmp(token, "r") == 0) {
+               *a = RTE_TABLE_ACTION_POLICER_COLOR_RED;
+               return 0;
+       }
+
+       if (strcmp(token, "drop") == 0) {
+               *a = RTE_TABLE_ACTION_POLICER_DROP;
+               return 0;
+       }
+
+       return -1;
+}
+
+static uint32_t
+parse_table_action_meter_tc(char **tokens,
+       uint32_t n_tokens,
+       struct rte_table_action_mtr_tc_params *mtr)
+{
+       if ((n_tokens < 9) ||
+               strcmp(tokens[0], "meter") ||
+               parser_read_uint32(&mtr->meter_profile_id, tokens[1]) ||
+               strcmp(tokens[2], "policer") ||
+               strcmp(tokens[3], "g") ||
+               parse_policer_action(tokens[4], &mtr->policer[e_RTE_METER_GREEN]) ||
+               strcmp(tokens[5], "y") ||
+               parse_policer_action(tokens[6], &mtr->policer[e_RTE_METER_YELLOW]) ||
+               strcmp(tokens[7], "r") ||
+               parse_policer_action(tokens[8], &mtr->policer[e_RTE_METER_RED]))
+               return 0;
+
+       return 9;
+}
+
+static uint32_t
+parse_table_action_meter(char **tokens,
+       uint32_t n_tokens,
+       struct table_rule_action *a)
+{
+       if ((n_tokens == 0) || strcmp(tokens[0], "meter"))
+               return 0;
+
+       tokens++;
+       n_tokens--;
+
+       if ((n_tokens < 10) ||
+               strcmp(tokens[0], "tc0") ||
+               (parse_table_action_meter_tc(tokens + 1,
+                       n_tokens - 1,
+                       &a->mtr.mtr[0]) == 0))
+               return 0;
+
+       tokens += 10;
+       n_tokens -= 10;
+
+       if ((n_tokens == 0) || strcmp(tokens[0], "tc1")) {
+               a->mtr.tc_mask = 1;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_MTR;
+               return 1 + 10;
+       }
+
+       if ((n_tokens < 30) ||
+               (parse_table_action_meter_tc(tokens + 1,
+                       n_tokens - 1, &a->mtr.mtr[1]) == 0) ||
+               strcmp(tokens[10], "tc2") ||
+               (parse_table_action_meter_tc(tokens + 11,
+                       n_tokens - 11, &a->mtr.mtr[2]) == 0) ||
+               strcmp(tokens[20], "tc3") ||
+               (parse_table_action_meter_tc(tokens + 21,
+                       n_tokens - 21, &a->mtr.mtr[3]) == 0))
+               return 0;
+
+       a->mtr.tc_mask = 0xF;
+       a->action_mask |= 1 << RTE_TABLE_ACTION_MTR;
+       return 1 + 10 + 3 * 10;
+}
+
+static uint32_t
+parse_table_action_tm(char **tokens,
+       uint32_t n_tokens,
+       struct table_rule_action *a)
+{
+       uint32_t subport_id, pipe_id;
+
+       if ((n_tokens < 5) ||
+               strcmp(tokens[0], "tm") ||
+               strcmp(tokens[1], "subport") ||
+               parser_read_uint32(&subport_id, tokens[2]) ||
+               strcmp(tokens[3], "pipe") ||
+               parser_read_uint32(&pipe_id, tokens[4]))
+               return 0;
+
+       a->tm.subport_id = subport_id;
+       a->tm.pipe_id = pipe_id;
+       a->action_mask |= 1 << RTE_TABLE_ACTION_TM;
+       return 5;
+}
+
+static uint32_t
+parse_table_action_encap(char **tokens,
+       uint32_t n_tokens,
+       struct table_rule_action *a)
+{
+       if ((n_tokens == 0) || strcmp(tokens[0], "encap"))
+               return 0;
+
+       tokens++;
+       n_tokens--;
+
+       /* ether */
+       if (n_tokens && (strcmp(tokens[0], "ether") == 0)) {
+               if ((n_tokens < 3) ||
+                       parse_mac_addr(tokens[1], &a->encap.ether.ether.da) ||
+                       parse_mac_addr(tokens[2], &a->encap.ether.ether.sa))
+                       return 0;
+
+               a->encap.type = RTE_TABLE_ACTION_ENCAP_ETHER;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;
+               return 1 + 3;
+       }
+
+       /* vlan */
+       if (n_tokens && (strcmp(tokens[0], "vlan") == 0)) {
+               uint32_t pcp, dei, vid;
+
+               if ((n_tokens < 6) ||
+                       parse_mac_addr(tokens[1], &a->encap.vlan.ether.da) ||
+                       parse_mac_addr(tokens[2], &a->encap.vlan.ether.sa) ||
+                       parser_read_uint32(&pcp, tokens[3]) ||
+                       (pcp > 0x7) ||
+                       parser_read_uint32(&dei, tokens[4]) ||
+                       (dei > 0x1) ||
+                       parser_read_uint32(&vid, tokens[5]) ||
+                       (vid > 0xFFF))
+                       return 0;
+
+               a->encap.vlan.vlan.pcp = pcp & 0x7;
+               a->encap.vlan.vlan.dei = dei & 0x1;
+               a->encap.vlan.vlan.vid = vid & 0xFFF;
+               a->encap.type = RTE_TABLE_ACTION_ENCAP_VLAN;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;
+               return 1 + 6;
+       }
+
+       /* qinq */
+       if (n_tokens && (strcmp(tokens[0], "qinq") == 0)) {
+               uint32_t svlan_pcp, svlan_dei, svlan_vid;
+               uint32_t cvlan_pcp, cvlan_dei, cvlan_vid;
+
+               if ((n_tokens < 9) ||
+                       parse_mac_addr(tokens[1], &a->encap.qinq.ether.da) ||
+                       parse_mac_addr(tokens[2], &a->encap.qinq.ether.sa) ||
+                       parser_read_uint32(&svlan_pcp, tokens[3]) ||
+                       (svlan_pcp > 0x7) ||
+                       parser_read_uint32(&svlan_dei, tokens[4]) ||
+                       (svlan_dei > 0x1) ||
+                       parser_read_uint32(&svlan_vid, tokens[5]) ||
+                       (svlan_vid > 0xFFF) ||
+                       parser_read_uint32(&cvlan_pcp, tokens[6]) ||
+                       (cvlan_pcp > 0x7) ||
+                       parser_read_uint32(&cvlan_dei, tokens[7]) ||
+                       (cvlan_dei > 0x1) ||
+                       parser_read_uint32(&cvlan_vid, tokens[8]) ||
+                       (cvlan_vid > 0xFFF))
+                       return 0;
+
+               a->encap.qinq.svlan.pcp = svlan_pcp & 0x7;
+               a->encap.qinq.svlan.dei = svlan_dei & 0x1;
+               a->encap.qinq.svlan.vid = svlan_vid & 0xFFF;
+               a->encap.qinq.cvlan.pcp = cvlan_pcp & 0x7;
+               a->encap.qinq.cvlan.dei = cvlan_dei & 0x1;
+               a->encap.qinq.cvlan.vid = cvlan_vid & 0xFFF;
+               a->encap.type = RTE_TABLE_ACTION_ENCAP_QINQ;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;
+               return 1 + 9;
+       }
+
+       /* mpls */
+       if (n_tokens && (strcmp(tokens[0], "mpls") == 0)) {
+               uint32_t label, tc, ttl;
+
+               if (n_tokens < 8)
+                       return 0;
+
+               if (strcmp(tokens[1], "unicast") == 0)
+                       a->encap.mpls.unicast = 1;
+               else if (strcmp(tokens[1], "multicast") == 0)
+                       a->encap.mpls.unicast = 0;
+               else
+                       return 0;
+
+               if (parse_mac_addr(tokens[2], &a->encap.mpls.ether.da) ||
+                       parse_mac_addr(tokens[3], &a->encap.mpls.ether.sa) ||
+                       strcmp(tokens[4], "label0") ||
+                       parser_read_uint32(&label, tokens[5]) ||
+                       (label > 0xFFFFF) ||
+                       parser_read_uint32(&tc, tokens[6]) ||
+                       (tc > 0x7) ||
+                       parser_read_uint32(&ttl, tokens[7]) ||
+                       (ttl > 0x3F))
+                       return 0;
+
+               a->encap.mpls.mpls[0].label = label;
+               a->encap.mpls.mpls[0].tc = tc;
+               a->encap.mpls.mpls[0].ttl = ttl;
+
+               tokens += 8;
+               n_tokens -= 8;
+
+               if ((n_tokens == 0) || strcmp(tokens[0], "label1")) {
+                       a->encap.mpls.mpls_count = 1;
+                       a->encap.type = RTE_TABLE_ACTION_ENCAP_MPLS;
+                       a->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;
+                       return 1 + 8;
+               }
+
+               if ((n_tokens < 4) ||
+                       parser_read_uint32(&label, tokens[1]) ||
+                       (label > 0xFFFFF) ||
+                       parser_read_uint32(&tc, tokens[2]) ||
+                       (tc > 0x7) ||
+                       parser_read_uint32(&ttl, tokens[3]) ||
+                       (ttl > 0x3F))
+                       return 0;
+
+               a->encap.mpls.mpls[1].label = label;
+               a->encap.mpls.mpls[1].tc = tc;
+               a->encap.mpls.mpls[1].ttl = ttl;
+
+               tokens += 4;
+               n_tokens -= 4;
+
+               if ((n_tokens == 0) || strcmp(tokens[0], "label2")) {
+                       a->encap.mpls.mpls_count = 2;
+                       a->encap.type = RTE_TABLE_ACTION_ENCAP_MPLS;
+                       a->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;
+                       return 1 + 8 + 4;
+               }
+
+               if ((n_tokens < 4) ||
+                       parser_read_uint32(&label, tokens[1]) ||
+                       (label > 0xFFFFF) ||
+                       parser_read_uint32(&tc, tokens[2]) ||
+                       (tc > 0x7) ||
+                       parser_read_uint32(&ttl, tokens[3]) ||
+                       (ttl > 0x3F))
+                       return 0;
+
+               a->encap.mpls.mpls[2].label = label;
+               a->encap.mpls.mpls[2].tc = tc;
+               a->encap.mpls.mpls[2].ttl = ttl;
+
+               tokens += 4;
+               n_tokens -= 4;
+
+               if ((n_tokens == 0) || strcmp(tokens[0], "label3")) {
+                       a->encap.mpls.mpls_count = 3;
+                       a->encap.type = RTE_TABLE_ACTION_ENCAP_MPLS;
+                       a->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;
+                       return 1 + 8 + 4 + 4;
+               }
+
+               if ((n_tokens < 4) ||
+                       parser_read_uint32(&label, tokens[1]) ||
+                       (label > 0xFFFFF) ||
+                       parser_read_uint32(&tc, tokens[2]) ||
+                       (tc > 0x7) ||
+                       parser_read_uint32(&ttl, tokens[3]) ||
+                       (ttl > 0x3F))
+                       return 0;
+
+               a->encap.mpls.mpls[3].label = label;
+               a->encap.mpls.mpls[3].tc = tc;
+               a->encap.mpls.mpls[3].ttl = ttl;
+
+               a->encap.mpls.mpls_count = 4;
+               a->encap.type = RTE_TABLE_ACTION_ENCAP_MPLS;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;
+               return 1 + 8 + 4 + 4 + 4;
+       }
+
+       /* pppoe */
+       if (n_tokens && (strcmp(tokens[0], "pppoe") == 0)) {
+               if ((n_tokens < 4) ||
+                       parse_mac_addr(tokens[1], &a->encap.pppoe.ether.da) ||
+                       parse_mac_addr(tokens[2], &a->encap.pppoe.ether.sa) ||
+                       parser_read_uint16(&a->encap.pppoe.pppoe.session_id,
+                               tokens[3]))
+                       return 0;
+
+               a->encap.type = RTE_TABLE_ACTION_ENCAP_PPPOE;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_ENCAP;
+               return 1 + 4;
+       }
+
+       return 0;
+}
+
+static uint32_t
+parse_table_action_nat(char **tokens,
+       uint32_t n_tokens,
+       struct table_rule_action *a)
+{
+       if ((n_tokens < 4) ||
+               strcmp(tokens[0], "nat"))
+               return 0;
+
+       if (strcmp(tokens[1], "ipv4") == 0) {
+               struct in_addr addr;
+               uint16_t port;
+
+               if (parse_ipv4_addr(tokens[2], &addr) ||
+                       parser_read_uint16(&port, tokens[3]))
+                       return 0;
+
+               a->nat.ip_version = 1;
+               a->nat.addr.ipv4 = rte_be_to_cpu_32(addr.s_addr);
+               a->nat.port = port;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_NAT;
+               return 4;
+       }
+
+       if (strcmp(tokens[1], "ipv6") == 0) {
+               struct in6_addr addr;
+               uint16_t port;
+
+               if (parse_ipv6_addr(tokens[2], &addr) ||
+                       parser_read_uint16(&port, tokens[3]))
+                       return 0;
+
+               a->nat.ip_version = 0;
+               memcpy(a->nat.addr.ipv6, addr.s6_addr, 16);
+               a->nat.port = port;
+               a->action_mask |= 1 << RTE_TABLE_ACTION_NAT;
+               return 4;
+       }
+
+       return 0;
+}
+
+static uint32_t
+parse_table_action_ttl(char **tokens,
+       uint32_t n_tokens,
+       struct table_rule_action *a)
+{
+       if ((n_tokens < 2) ||
+               strcmp(tokens[0], "ttl"))
+               return 0;
+
+       if (strcmp(tokens[1], "dec") == 0)
+               a->ttl.decrement = 1;
+       else if (strcmp(tokens[1], "keep") == 0)
+               a->ttl.decrement = 0;
+       else
+               return 0;
+
+       a->action_mask |= 1 << RTE_TABLE_ACTION_TTL;
+       return 2;
+}
+
+static uint32_t
+parse_table_action_stats(char **tokens,
+       uint32_t n_tokens,
+       struct table_rule_action *a)
+{
+       if ((n_tokens < 1) ||
+               strcmp(tokens[0], "stats"))
+               return 0;
+
+       a->stats.n_packets = 0;
+       a->stats.n_bytes = 0;
+       a->action_mask |= 1 << RTE_TABLE_ACTION_STATS;
+       return 1;
+}
+
+static uint32_t
+parse_table_action_time(char **tokens,
+       uint32_t n_tokens,
+       struct table_rule_action *a)
+{
+       if ((n_tokens < 1) ||
+               strcmp(tokens[0], "time"))
+               return 0;
+
+       a->time.time = rte_rdtsc();
+       a->action_mask |= 1 << RTE_TABLE_ACTION_TIME;
+       return 1;
+}
+
+static uint32_t
+parse_table_action(char **tokens,
+       uint32_t n_tokens,
+       char *out,
+       size_t out_size,
+       struct table_rule_action *a)
+{
+       uint32_t n_tokens0 = n_tokens;
+
+       memset(a, 0, sizeof(*a));
+
+       if ((n_tokens < 2) ||
+               strcmp(tokens[0], "action"))
+               return 0;
+
+       tokens++;
+       n_tokens--;
+
+       if (n_tokens && (strcmp(tokens[0], "fwd") == 0)) {
+               uint32_t n;
+
+               n = parse_table_action_fwd(tokens, n_tokens, a);
+               if (n == 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID,
+                               "action fwd");
+                       return 0;
+               }
+
+               tokens += n;
+               n_tokens -= n;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "meter") == 0)) {
+               uint32_t n;
+
+               n = parse_table_action_meter(tokens, n_tokens, a);
+               if (n == 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID,
+                               "action meter");
+                       return 0;
+               }
+
+               tokens += n;
+               n_tokens -= n;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "tm") == 0)) {
+               uint32_t n;
+
+               n = parse_table_action_tm(tokens, n_tokens, a);
+               if (n == 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID,
+                               "action tm");
+                       return 0;
+               }
+
+               tokens += n;
+               n_tokens -= n;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "encap") == 0)) {
+               uint32_t n;
+
+               n = parse_table_action_encap(tokens, n_tokens, a);
+               if (n == 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID,
+                               "action encap");
+                       return 0;
+               }
+
+               tokens += n;
+               n_tokens -= n;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "nat") == 0)) {
+               uint32_t n;
+
+               n = parse_table_action_nat(tokens, n_tokens, a);
+               if (n == 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID,
+                               "action nat");
+                       return 0;
+               }
+
+               tokens += n;
+               n_tokens -= n;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "ttl") == 0)) {
+               uint32_t n;
+
+               n = parse_table_action_ttl(tokens, n_tokens, a);
+               if (n == 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID,
+                               "action ttl");
+                       return 0;
+               }
+
+               tokens += n;
+               n_tokens -= n;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "stats") == 0)) {
+               uint32_t n;
+
+               n = parse_table_action_stats(tokens, n_tokens, a);
+               if (n == 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID,
+                               "action stats");
+                       return 0;
+               }
+
+               tokens += n;
+               n_tokens -= n;
+       }
+
+       if (n_tokens && (strcmp(tokens[0], "time") == 0)) {
+               uint32_t n;
+
+               n = parse_table_action_time(tokens, n_tokens, a);
+               if (n == 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID,
+                               "action time");
+                       return 0;
+               }
+
+               tokens += n;
+               n_tokens -= n;
+       }
+
+       if (n_tokens0 - n_tokens == 1) {
+               snprintf(out, out_size, MSG_ARG_INVALID, "action");
+               return 0;
+       }
+
+       return n_tokens0 - n_tokens;
+}
+
+/**
+ * pipeline <pipeline_name> table <table_id> rule add
+ *    match <match>
+ *    action <table_action>
+ */
+static void
+cmd_pipeline_table_rule_add(char **tokens,
+       uint32_t n_tokens,
+       char *out,
+       size_t out_size)
+{
+       struct table_rule_match m;
+       struct table_rule_action a;
+       char *pipeline_name;
+       void *data;
+       uint32_t table_id, t0, n_tokens_parsed;
+       int status;
+
+       if (n_tokens < 8) {
+               snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+               return;
+       }
+
+       pipeline_name = tokens[1];
+
+       if (strcmp(tokens[2], "table") != 0) {
+               snprintf(out, out_size, MSG_ARG_NOT_FOUND, "table");
+               return;
+       }
+
+       if (parser_read_uint32(&table_id, tokens[3]) != 0) {
+               snprintf(out, out_size, MSG_ARG_INVALID, "table_id");
+               return;
+       }
+
+       if (strcmp(tokens[4], "rule") != 0) {
+               snprintf(out, out_size, MSG_ARG_NOT_FOUND, "rule");
+               return;
+       }
+
+       if (strcmp(tokens[5], "add") != 0) {
+               snprintf(out, out_size, MSG_ARG_NOT_FOUND, "add");
+               return;
+       }
+
+       t0 = 6;
+
+       /* match */
+       n_tokens_parsed = parse_match(tokens + t0,
+               n_tokens - t0,
+               out,
+               out_size,
+               &m);
+       if (n_tokens_parsed == 0)
+               return;
+       t0 += n_tokens_parsed;
+
+       /* action */
+       n_tokens_parsed = parse_table_action(tokens + t0,
+               n_tokens - t0,
+               out,
+               out_size,
+               &a);
+       if (n_tokens_parsed == 0)
+               return;
+       t0 += n_tokens_parsed;
+
+       if (t0 != n_tokens) {
+               snprintf(out, out_size, MSG_ARG_INVALID, tokens[0]);
+               return;
+       }
+
+       status = pipeline_table_rule_add(pipeline_name, table_id,
+               &m, &a, &data);
+       if (status) {
+               snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);
+               return;
+       }
+}
+
+/**
+ * pipeline <pipeline_name> table <table_id> rule add
+ *    match
+ *       default
+ *    action
+ *       fwd
+ *          drop
+ *          | port <port_id>
+ *          | meta
+ *          | table <table_id>
+ */
+static void
+cmd_pipeline_table_rule_add_default(char **tokens,
+       uint32_t n_tokens,
+       char *out,
+       size_t out_size)
+{
+       struct table_rule_action action;
+       void *data;
+       char *pipeline_name;
+       uint32_t table_id;
+       int status;
+
+       if ((n_tokens != 11) && (n_tokens != 12)) {
+               snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+               return;
+       }
+
+       pipeline_name = tokens[1];
+
+       if (strcmp(tokens[2], "table") != 0) {
+               snprintf(out, out_size, MSG_ARG_NOT_FOUND, "table");
+               return;
+       }
+
+       if (parser_read_uint32(&table_id, tokens[3]) != 0) {
+               snprintf(out, out_size, MSG_ARG_INVALID, "table_id");
+               return;
+       }
+
+       if (strcmp(tokens[4], "rule") != 0) {
+               snprintf(out, out_size, MSG_ARG_NOT_FOUND, "rule");
+               return;
+       }
+
+       if (strcmp(tokens[5], "add") != 0) {
+               snprintf(out, out_size, MSG_ARG_NOT_FOUND, "add");
+               return;
+       }
+
+       if (strcmp(tokens[6], "match") != 0) {
+               snprintf(out, out_size, MSG_ARG_INVALID, "match");
+               return;
+       }
+
+       if (strcmp(tokens[7], "default") != 0) {
+               snprintf(out, out_size, MSG_ARG_INVALID, "default");
+               return;
+       }
+
+       if (strcmp(tokens[8], "action") != 0) {
+               snprintf(out, out_size, MSG_ARG_INVALID, "action");
+               return;
+       }
+
+       if (strcmp(tokens[9], "fwd") != 0) {
+               snprintf(out, out_size, MSG_ARG_INVALID, "fwd");
+               return;
+       }
+
+       action.action_mask = 1 << RTE_TABLE_ACTION_FWD;
+
+       if (strcmp(tokens[10], "drop") == 0) {
+               if (n_tokens != 11) {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+                       return;
+               }
+
+               action.fwd.action = RTE_PIPELINE_ACTION_DROP;
+       } else if (strcmp(tokens[10], "port") == 0) {
+               uint32_t id;
+
+               if (n_tokens != 12) {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+                       return;
+               }
+
+               if (parser_read_uint32(&id, tokens[11]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "port_id");
+                       return;
+               }
+
+               action.fwd.action = RTE_PIPELINE_ACTION_PORT;
+               action.fwd.id = id;
+       } else if (strcmp(tokens[10], "meta") == 0) {
+               if (n_tokens != 11) {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+                       return;
+               }
+
+               action.fwd.action = RTE_PIPELINE_ACTION_PORT_META;
+       } else if (strcmp(tokens[10], "table") == 0) {
+               uint32_t id;
+
+               if (n_tokens != 12) {
+                       snprintf(out, out_size, MSG_ARG_MISMATCH, tokens[0]);
+                       return;
+               }
+
+               if (parser_read_uint32(&id, tokens[11]) != 0) {
+                       snprintf(out, out_size, MSG_ARG_INVALID, "table_id");
+                       return;
+               }
+
+               action.fwd.action = RTE_PIPELINE_ACTION_TABLE;
+               action.fwd.id = id;
+       } else {
+               snprintf(out, out_size, MSG_ARG_INVALID,
+                       "drop or port or meta or table");
+               return;
+       }
+
+       status = pipeline_table_rule_add_default(pipeline_name,
+               table_id,
+               &action,
+               &data);
+       if (status) {
+               snprintf(out, out_size, MSG_CMD_FAIL, tokens[0]);
+               return;
+       }
+}
+
 /**
  * thread <thread_id> pipeline <pipeline_name> enable
  */
@@ -2516,6 +3794,23 @@ cli_process(char *in, char *out, size_t out_size)
                                out, out_size);
                        return;
                }
+
+               if ((n_tokens >= 7) &&
+                       (strcmp(tokens[2], "table") == 0) &&
+                       (strcmp(tokens[4], "rule") == 0) &&
+                       (strcmp(tokens[5], "add") == 0) &&
+                       (strcmp(tokens[6], "match") == 0)) {
+                       if ((n_tokens >= 8) &&
+                               (strcmp(tokens[7], "default") == 0)) {
+                               cmd_pipeline_table_rule_add_default(tokens,
+                                       n_tokens, out, out_size);
+                               return;
+                       }
+
+                       cmd_pipeline_table_rule_add(tokens, n_tokens,
+                               out, out_size);
+                       return;
+               }
        }
 
        if (strcmp(tokens[0], "thread") == 0) {
index 5757eb5..64efbed 100644 (file)
@@ -295,4 +295,17 @@ pipeline_table_stats_read(const char *pipeline_name,
        struct rte_pipeline_table_stats *stats,
        int clear);
 
+int
+pipeline_table_rule_add(const char *pipeline_name,
+       uint32_t table_id,
+       struct table_rule_match *match,
+       struct table_rule_action *action,
+       void **data);
+
+int
+pipeline_table_rule_add_default(const char *pipeline_name,
+       uint32_t table_id,
+       struct table_rule_action *action,
+       void **data);
+
 #endif /* _INCLUDE_PIPELINE_H_ */
index b1a2926..0291883 100644 (file)
@@ -488,6 +488,8 @@ enum pipeline_req_type {
 
        /* Table */
        PIPELINE_REQ_TABLE_STATS_READ,
+       PIPELINE_REQ_TABLE_RULE_ADD,
+       PIPELINE_REQ_TABLE_RULE_ADD_DEFAULT,
 
        PIPELINE_REQ_MAX
 };
@@ -504,6 +506,15 @@ struct pipeline_msg_req_table_stats_read {
        int clear;
 };
 
+struct pipeline_msg_req_table_rule_add {
+       struct table_rule_match match;
+       struct table_rule_action action;
+};
+
+struct pipeline_msg_req_table_rule_add_default {
+       struct table_rule_action action;
+};
+
 struct pipeline_msg_req {
        enum pipeline_req_type type;
        uint32_t id; /* Port IN, port OUT or table ID */
@@ -513,6 +524,8 @@ struct pipeline_msg_req {
                struct pipeline_msg_req_port_in_stats_read port_in_stats_read;
                struct pipeline_msg_req_port_out_stats_read port_out_stats_read;
                struct pipeline_msg_req_table_stats_read table_stats_read;
+               struct pipeline_msg_req_table_rule_add table_rule_add;
+               struct pipeline_msg_req_table_rule_add_default table_rule_add_default;
        };
 };
 
@@ -528,6 +541,14 @@ struct pipeline_msg_rsp_table_stats_read {
        struct rte_pipeline_table_stats stats;
 };
 
+struct pipeline_msg_rsp_table_rule_add {
+       void *data;
+};
+
+struct pipeline_msg_rsp_table_rule_add_default {
+       void *data;
+};
+
 struct pipeline_msg_rsp {
        int status;
 
@@ -536,6 +557,8 @@ struct pipeline_msg_rsp {
                struct pipeline_msg_rsp_port_in_stats_read port_in_stats_read;
                struct pipeline_msg_rsp_port_out_stats_read port_out_stats_read;
                struct pipeline_msg_rsp_table_stats_read table_stats_read;
+               struct pipeline_msg_rsp_table_rule_add table_rule_add;
+               struct pipeline_msg_rsp_table_rule_add_default table_rule_add_default;
        };
 };
 
@@ -807,6 +830,272 @@ pipeline_table_stats_read(const char *pipeline_name,
        return status;
 }
 
+static int
+match_check(struct table_rule_match *match,
+       struct pipeline *p,
+       uint32_t table_id)
+{
+       struct table *table;
+
+       if ((match == NULL) ||
+               (p == NULL) ||
+               (table_id >= p->n_tables))
+               return -1;
+
+       table = &p->table[table_id];
+       if (match->match_type != table->params.match_type)
+               return -1;
+
+       switch (match->match_type) {
+       case TABLE_ACL:
+       {
+               struct table_acl_params *t = &table->params.match.acl;
+               struct table_rule_match_acl *r = &match->match.acl;
+
+               if ((r->ip_version && (t->ip_version == 0)) ||
+                       ((r->ip_version == 0) && t->ip_version))
+                       return -1;
+
+               if (r->ip_version) {
+                       if ((r->sa_depth > 32) ||
+                               (r->da_depth > 32))
+                               return -1;
+               } else {
+                       if ((r->sa_depth > 128) ||
+                               (r->da_depth > 128))
+                               return -1;
+               }
+               return 0;
+       }
+
+       case TABLE_ARRAY:
+               return 0;
+
+       case TABLE_HASH:
+               return 0;
+
+       case TABLE_LPM:
+       {
+               struct table_lpm_params *t = &table->params.match.lpm;
+               struct table_rule_match_lpm *r = &match->match.lpm;
+
+               if ((r->ip_version && (t->key_size != 4)) ||
+                       ((r->ip_version == 0) && (t->key_size != 16)))
+                       return -1;
+
+               if (r->ip_version) {
+                       if (r->depth > 32)
+                               return -1;
+               } else {
+                       if (r->depth > 128)
+                               return -1;
+               }
+               return 0;
+       }
+
+       case TABLE_STUB:
+               return -1;
+
+       default:
+               return -1;
+       }
+}
+
+static int
+action_check(struct table_rule_action *action,
+       struct pipeline *p,
+       uint32_t table_id)
+{
+       struct table_action_profile *ap;
+
+       if ((action == NULL) ||
+               (p == NULL) ||
+               (table_id >= p->n_tables))
+               return -1;
+
+       ap = p->table[table_id].ap;
+       if (action->action_mask != ap->params.action_mask)
+               return -1;
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) {
+               if ((action->fwd.action == RTE_PIPELINE_ACTION_PORT) &&
+                       (action->fwd.id >= p->n_ports_out))
+                       return -1;
+
+               if ((action->fwd.action == RTE_PIPELINE_ACTION_TABLE) &&
+                       (action->fwd.id >= p->n_tables))
+                       return -1;
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_MTR)) {
+               uint32_t tc_mask0 = (1 << ap->params.mtr.n_tc) - 1;
+               uint32_t tc_mask1 = action->mtr.tc_mask;
+
+               if (tc_mask1 != tc_mask0)
+                       return -1;
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_TM)) {
+               uint32_t n_subports_per_port =
+                       ap->params.tm.n_subports_per_port;
+               uint32_t n_pipes_per_subport =
+                       ap->params.tm.n_pipes_per_subport;
+               uint32_t subport_id = action->tm.subport_id;
+               uint32_t pipe_id = action->tm.pipe_id;
+
+               if ((subport_id >= n_subports_per_port) ||
+                       (pipe_id >= n_pipes_per_subport))
+                       return -1;
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_ENCAP)) {
+               uint64_t encap_mask = ap->params.encap.encap_mask;
+               enum rte_table_action_encap_type type = action->encap.type;
+
+               if ((encap_mask & (1LLU << type)) == 0)
+                       return -1;
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_NAT)) {
+               int ip_version0 = ap->params.common.ip_version;
+               int ip_version1 = action->nat.ip_version;
+
+               if ((ip_version1 && (ip_version0 == 0)) ||
+                       ((ip_version1 == 0) && ip_version0))
+                       return -1;
+       }
+
+       return 0;
+}
+
+static int
+action_default_check(struct table_rule_action *action,
+       struct pipeline *p,
+       uint32_t table_id)
+{
+       if ((action == NULL) ||
+               (action->action_mask != (1LLU << RTE_TABLE_ACTION_FWD)) ||
+               (p == NULL) ||
+               (table_id >= p->n_tables))
+               return -1;
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) {
+               if ((action->fwd.action == RTE_PIPELINE_ACTION_PORT) &&
+                       (action->fwd.id >= p->n_ports_out))
+                       return -1;
+
+               if ((action->fwd.action == RTE_PIPELINE_ACTION_TABLE) &&
+                       (action->fwd.id >= p->n_tables))
+                       return -1;
+       }
+
+       return 0;
+}
+
+int
+pipeline_table_rule_add(const char *pipeline_name,
+       uint32_t table_id,
+       struct table_rule_match *match,
+       struct table_rule_action *action,
+       void **data)
+{
+       struct pipeline *p;
+       struct pipeline_msg_req *req;
+       struct pipeline_msg_rsp *rsp;
+       int status;
+
+       /* Check input params */
+       if ((pipeline_name == NULL) ||
+               (match == NULL) ||
+               (action == NULL) ||
+               (data == NULL))
+               return -1;
+
+       p = pipeline_find(pipeline_name);
+       if ((p == NULL) ||
+               (p->enabled == 0) ||
+               (table_id >= p->n_tables) ||
+               match_check(match, p, table_id) ||
+               action_check(action, p, table_id))
+               return -1;
+
+       /* Allocate request */
+       req = pipeline_msg_alloc();
+       if (req == NULL)
+               return -1;
+
+       /* Write request */
+       req->type = PIPELINE_REQ_TABLE_RULE_ADD;
+       req->id = table_id;
+       memcpy(&req->table_rule_add.match, match, sizeof(*match));
+       memcpy(&req->table_rule_add.action, action, sizeof(*action));
+
+       /* Send request and wait for response */
+       rsp = pipeline_msg_send_recv(p, req);
+       if (rsp == NULL)
+               return -1;
+
+       /* Read response */
+       status = rsp->status;
+       if (status == 0)
+               *data = rsp->table_rule_add.data;
+
+       /* Free response */
+       pipeline_msg_free(rsp);
+
+       return status;
+}
+
+int
+pipeline_table_rule_add_default(const char *pipeline_name,
+       uint32_t table_id,
+       struct table_rule_action *action,
+       void **data)
+{
+       struct pipeline *p;
+       struct pipeline_msg_req *req;
+       struct pipeline_msg_rsp *rsp;
+       int status;
+
+       /* Check input params */
+       if ((pipeline_name == NULL) ||
+               (action == NULL) ||
+               (data == NULL))
+               return -1;
+
+       p = pipeline_find(pipeline_name);
+       if ((p == NULL) ||
+               (p->enabled == 0) ||
+               (table_id >= p->n_tables) ||
+               action_default_check(action, p, table_id))
+               return -1;
+
+       /* Allocate request */
+       req = pipeline_msg_alloc();
+       if (req == NULL)
+               return -1;
+
+       /* Write request */
+       req->type = PIPELINE_REQ_TABLE_RULE_ADD_DEFAULT;
+       req->id = table_id;
+       memcpy(&req->table_rule_add_default.action, action, sizeof(*action));
+
+       /* Send request and wait for response */
+       rsp = pipeline_msg_send_recv(p, req);
+       if (rsp == NULL)
+               return -1;
+
+       /* Read response */
+       status = rsp->status;
+       if (status == 0)
+               *data = rsp->table_rule_add_default.data;
+
+       /* Free response */
+       pipeline_msg_free(rsp);
+
+       return status;
+}
+
 /**
  * Data plane threads: message handling
  */
@@ -908,6 +1197,461 @@ pipeline_msg_handle_table_stats_read(struct pipeline_data *p,
        return rsp;
 }
 
+union table_rule_match_low_level {
+       struct rte_table_acl_rule_add_params acl_add;
+       struct rte_table_acl_rule_delete_params acl_delete;
+       struct rte_table_array_key array;
+       uint8_t hash[TABLE_RULE_MATCH_SIZE_MAX];
+       struct rte_table_lpm_key lpm_ipv4;
+       struct rte_table_lpm_ipv6_key lpm_ipv6;
+};
+
+static int
+match_convert_ipv6_depth(uint32_t depth, uint32_t *depth32)
+{
+       if (depth > 128)
+               return -1;
+
+       switch (depth / 32) {
+       case 0:
+               depth32[0] = depth;
+               depth32[1] = 0;
+               depth32[2] = 0;
+               depth32[3] = 0;
+               return 0;
+
+       case 1:
+               depth32[0] = 32;
+               depth32[1] = depth - 32;
+               depth32[2] = 0;
+               depth32[3] = 0;
+               return 0;
+
+       case 2:
+               depth32[0] = 32;
+               depth32[1] = 32;
+               depth32[2] = depth - 64;
+               depth32[3] = 0;
+               return 0;
+
+       case 3:
+               depth32[0] = 32;
+               depth32[1] = 32;
+               depth32[2] = 32;
+               depth32[3] = depth - 96;
+               return 0;
+
+       case 4:
+               depth32[0] = 32;
+               depth32[1] = 32;
+               depth32[2] = 32;
+               depth32[3] = 32;
+               return 0;
+
+       default:
+               return -1;
+       }
+}
+
+static int
+match_convert(struct table_rule_match *mh,
+       union table_rule_match_low_level *ml,
+       int add)
+{
+       memset(ml, 0, sizeof(*ml));
+
+       switch (mh->match_type) {
+       case TABLE_ACL:
+               if (mh->match.acl.ip_version)
+                       if (add) {
+                               ml->acl_add.field_value[0].value.u8 =
+                                       mh->match.acl.proto;
+                               ml->acl_add.field_value[0].mask_range.u8 =
+                                       mh->match.acl.proto_mask;
+
+                               ml->acl_add.field_value[1].value.u32 =
+                                       mh->match.acl.ipv4.sa;
+                               ml->acl_add.field_value[1].mask_range.u32 =
+                                       mh->match.acl.sa_depth;
+
+                               ml->acl_add.field_value[2].value.u32 =
+                                       mh->match.acl.ipv4.da;
+                               ml->acl_add.field_value[2].mask_range.u32 =
+                                       mh->match.acl.da_depth;
+
+                               ml->acl_add.field_value[3].value.u16 =
+                                       mh->match.acl.sp0;
+                               ml->acl_add.field_value[3].mask_range.u16 =
+                                       mh->match.acl.sp1;
+
+                               ml->acl_add.field_value[4].value.u16 =
+                                       mh->match.acl.dp0;
+                               ml->acl_add.field_value[4].mask_range.u16 =
+                                       mh->match.acl.dp1;
+
+                               ml->acl_add.priority =
+                                       (int32_t) mh->match.acl.priority;
+                       } else {
+                               ml->acl_delete.field_value[0].value.u8 =
+                                       mh->match.acl.proto;
+                               ml->acl_delete.field_value[0].mask_range.u8 =
+                                       mh->match.acl.proto_mask;
+
+                               ml->acl_delete.field_value[1].value.u32 =
+                                       mh->match.acl.ipv4.sa;
+                               ml->acl_delete.field_value[1].mask_range.u32 =
+                                       mh->match.acl.sa_depth;
+
+                               ml->acl_delete.field_value[2].value.u32 =
+                                       mh->match.acl.ipv4.da;
+                               ml->acl_delete.field_value[2].mask_range.u32 =
+                                       mh->match.acl.da_depth;
+
+                               ml->acl_delete.field_value[3].value.u16 =
+                                       mh->match.acl.sp0;
+                               ml->acl_delete.field_value[3].mask_range.u16 =
+                                       mh->match.acl.sp1;
+
+                               ml->acl_delete.field_value[4].value.u16 =
+                                       mh->match.acl.dp0;
+                               ml->acl_delete.field_value[4].mask_range.u16 =
+                                       mh->match.acl.dp1;
+                       }
+               else
+                       if (add) {
+                               uint32_t *sa32 =
+                                       (uint32_t *) mh->match.acl.ipv6.sa;
+                               uint32_t *da32 =
+                                       (uint32_t *) mh->match.acl.ipv6.da;
+                               uint32_t sa32_depth[4], da32_depth[4];
+                               int status;
+
+                               status = match_convert_ipv6_depth(
+                                       mh->match.acl.sa_depth,
+                                       sa32_depth);
+                               if (status)
+                                       return status;
+
+                               status = match_convert_ipv6_depth(
+                                       mh->match.acl.da_depth,
+                                       da32_depth);
+                               if (status)
+                                       return status;
+
+                               ml->acl_add.field_value[0].value.u8 =
+                                       mh->match.acl.proto;
+                               ml->acl_add.field_value[0].mask_range.u8 =
+                                       mh->match.acl.proto_mask;
+
+                               ml->acl_add.field_value[1].value.u32 = sa32[0];
+                               ml->acl_add.field_value[1].mask_range.u32 =
+                                       sa32_depth[0];
+                               ml->acl_add.field_value[2].value.u32 = sa32[1];
+                               ml->acl_add.field_value[2].mask_range.u32 =
+                                       sa32_depth[1];
+                               ml->acl_add.field_value[3].value.u32 = sa32[2];
+                               ml->acl_add.field_value[3].mask_range.u32 =
+                                       sa32_depth[2];
+                               ml->acl_add.field_value[4].value.u32 = sa32[3];
+                               ml->acl_add.field_value[4].mask_range.u32 =
+                                       sa32_depth[3];
+
+                               ml->acl_add.field_value[5].value.u32 = da32[0];
+                               ml->acl_add.field_value[5].mask_range.u32 =
+                                       da32_depth[0];
+                               ml->acl_add.field_value[6].value.u32 = da32[1];
+                               ml->acl_add.field_value[6].mask_range.u32 =
+                                       da32_depth[1];
+                               ml->acl_add.field_value[7].value.u32 = da32[2];
+                               ml->acl_add.field_value[7].mask_range.u32 =
+                                       da32_depth[2];
+                               ml->acl_add.field_value[8].value.u32 = da32[3];
+                               ml->acl_add.field_value[8].mask_range.u32 =
+                                       da32_depth[3];
+
+                               ml->acl_add.field_value[9].value.u16 =
+                                       mh->match.acl.sp0;
+                               ml->acl_add.field_value[9].mask_range.u16 =
+                                       mh->match.acl.sp1;
+
+                               ml->acl_add.field_value[10].value.u16 =
+                                       mh->match.acl.dp0;
+                               ml->acl_add.field_value[10].mask_range.u16 =
+                                       mh->match.acl.dp1;
+
+                               ml->acl_add.priority =
+                                       (int32_t) mh->match.acl.priority;
+                       } else {
+                               uint32_t *sa32 =
+                                       (uint32_t *) mh->match.acl.ipv6.sa;
+                               uint32_t *da32 =
+                                       (uint32_t *) mh->match.acl.ipv6.da;
+                               uint32_t sa32_depth[4], da32_depth[4];
+                               int status;
+
+                               status = match_convert_ipv6_depth(
+                                       mh->match.acl.sa_depth,
+                                       sa32_depth);
+                               if (status)
+                                       return status;
+
+                               status = match_convert_ipv6_depth(
+                                       mh->match.acl.da_depth,
+                                       da32_depth);
+                               if (status)
+                                       return status;
+
+                               ml->acl_delete.field_value[0].value.u8 =
+                                       mh->match.acl.proto;
+                               ml->acl_delete.field_value[0].mask_range.u8 =
+                                       mh->match.acl.proto_mask;
+
+                               ml->acl_delete.field_value[1].value.u32 =
+                                       sa32[0];
+                               ml->acl_delete.field_value[1].mask_range.u32 =
+                                       sa32_depth[0];
+                               ml->acl_delete.field_value[2].value.u32 =
+                                       sa32[1];
+                               ml->acl_delete.field_value[2].mask_range.u32 =
+                                       sa32_depth[1];
+                               ml->acl_delete.field_value[3].value.u32 =
+                                       sa32[2];
+                               ml->acl_delete.field_value[3].mask_range.u32 =
+                                       sa32_depth[2];
+                               ml->acl_delete.field_value[4].value.u32 =
+                                       sa32[3];
+                               ml->acl_delete.field_value[4].mask_range.u32 =
+                                       sa32_depth[3];
+
+                               ml->acl_delete.field_value[5].value.u32 =
+                                       da32[0];
+                               ml->acl_delete.field_value[5].mask_range.u32 =
+                                       da32_depth[0];
+                               ml->acl_delete.field_value[6].value.u32 =
+                                       da32[1];
+                               ml->acl_delete.field_value[6].mask_range.u32 =
+                                       da32_depth[1];
+                               ml->acl_delete.field_value[7].value.u32 =
+                                       da32[2];
+                               ml->acl_delete.field_value[7].mask_range.u32 =
+                                       da32_depth[2];
+                               ml->acl_delete.field_value[8].value.u32 =
+                                       da32[3];
+                               ml->acl_delete.field_value[8].mask_range.u32 =
+                                       da32_depth[3];
+
+                               ml->acl_delete.field_value[9].value.u16 =
+                                       mh->match.acl.sp0;
+                               ml->acl_delete.field_value[9].mask_range.u16 =
+                                       mh->match.acl.sp1;
+
+                               ml->acl_delete.field_value[10].value.u16 =
+                                       mh->match.acl.dp0;
+                               ml->acl_delete.field_value[10].mask_range.u16 =
+                                       mh->match.acl.dp1;
+                       }
+               return 0;
+
+       case TABLE_ARRAY:
+               ml->array.pos = mh->match.array.pos;
+               return 0;
+
+       case TABLE_HASH:
+               memcpy(ml->hash, mh->match.hash.key, sizeof(ml->hash));
+               return 0;
+
+       case TABLE_LPM:
+               if (mh->match.lpm.ip_version) {
+                       ml->lpm_ipv4.ip = mh->match.lpm.ipv4;
+                       ml->lpm_ipv4.depth = mh->match.lpm.depth;
+               } else {
+                       memcpy(ml->lpm_ipv6.ip,
+                               mh->match.lpm.ipv6, sizeof(ml->lpm_ipv6.ip));
+                       ml->lpm_ipv6.depth = mh->match.lpm.depth;
+               }
+
+               return 0;
+
+       default:
+               return -1;
+       }
+}
+
+static struct pipeline_msg_rsp *
+pipeline_msg_handle_table_rule_add(struct pipeline_data *p,
+       struct pipeline_msg_req *req)
+{
+       union table_rule_match_low_level match_ll;
+       struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
+       struct table_rule_match *match = &req->table_rule_add.match;
+       struct table_rule_action *action = &req->table_rule_add.action;
+       struct rte_pipeline_table_entry *data_in, *data_out;
+       uint32_t table_id = req->id;
+       int key_found, status;
+       struct rte_table_action *a = p->table_data[table_id].a;
+
+       /* Apply actions */
+       memset(p->buffer, 0, sizeof(p->buffer));
+       data_in = (struct rte_pipeline_table_entry *) p->buffer;
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_FWD)) {
+               status = rte_table_action_apply(a,
+                       data_in,
+                       RTE_TABLE_ACTION_FWD,
+                       &action->fwd);
+
+               if (status) {
+                       rsp->status = -1;
+                       return rsp;
+               }
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_MTR)) {
+               status = rte_table_action_apply(a,
+                       data_in,
+                       RTE_TABLE_ACTION_MTR,
+                       &action->mtr);
+
+               if (status) {
+                       rsp->status = -1;
+                       return rsp;
+               }
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_TM)) {
+               status = rte_table_action_apply(a,
+                       data_in,
+                       RTE_TABLE_ACTION_TM,
+                       &action->tm);
+
+               if (status) {
+                       rsp->status = -1;
+                       return rsp;
+               }
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_ENCAP)) {
+               status = rte_table_action_apply(a,
+                       data_in,
+                       RTE_TABLE_ACTION_ENCAP,
+                       &action->encap);
+
+               if (status) {
+                       rsp->status = -1;
+                       return rsp;
+               }
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_NAT)) {
+               status = rte_table_action_apply(a,
+                       data_in,
+                       RTE_TABLE_ACTION_NAT,
+                       &action->nat);
+
+               if (status) {
+                       rsp->status = -1;
+                       return rsp;
+               }
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_TTL)) {
+               status = rte_table_action_apply(a,
+                       data_in,
+                       RTE_TABLE_ACTION_TTL,
+                       &action->ttl);
+
+               if (status) {
+                       rsp->status = -1;
+                       return rsp;
+               }
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_STATS)) {
+               status = rte_table_action_apply(a,
+                       data_in,
+                       RTE_TABLE_ACTION_STATS,
+                       &action->stats);
+
+               if (status) {
+                       rsp->status = -1;
+                       return rsp;
+               }
+       }
+
+       if (action->action_mask & (1LLU << RTE_TABLE_ACTION_TIME)) {
+               status = rte_table_action_apply(a,
+                       data_in,
+                       RTE_TABLE_ACTION_TIME,
+                       &action->time);
+
+               if (status) {
+                       rsp->status = -1;
+                       return rsp;
+               }
+       }
+
+       /* Add rule (match, action) to table */
+       status = match_convert(match, &match_ll, 1);
+       if (status) {
+               rsp->status = -1;
+               return rsp;
+       }
+
+       status = rte_pipeline_table_entry_add(p->p,
+               table_id,
+               &match_ll,
+               data_in,
+               &key_found,
+               &data_out);
+       if (status) {
+               rsp->status = -1;
+               return rsp;
+       }
+
+       /* Write response */
+       rsp->status = 0;
+       rsp->table_rule_add.data = data_out;
+
+       return rsp;
+}
+
+static struct pipeline_msg_rsp *
+pipeline_msg_handle_table_rule_add_default(struct pipeline_data *p,
+       struct pipeline_msg_req *req)
+{
+       struct pipeline_msg_rsp *rsp = (struct pipeline_msg_rsp *) req;
+       struct table_rule_action *action = &req->table_rule_add_default.action;
+       struct rte_pipeline_table_entry *data_in, *data_out;
+       uint32_t table_id = req->id;
+       int status;
+
+       /* Apply actions */
+       memset(p->buffer, 0, sizeof(p->buffer));
+       data_in = (struct rte_pipeline_table_entry *) p->buffer;
+
+       data_in->action = action->fwd.action;
+       if (action->fwd.action == RTE_PIPELINE_ACTION_PORT)
+               data_in->port_id = action->fwd.id;
+       if (action->fwd.action == RTE_PIPELINE_ACTION_TABLE)
+               data_in->table_id = action->fwd.id;
+
+       /* Add default rule to table */
+       status = rte_pipeline_table_default_entry_add(p->p,
+               table_id,
+               data_in,
+               &data_out);
+       if (status) {
+               rsp->status = -1;
+               return rsp;
+       }
+
+       /* Write response */
+       rsp->status = 0;
+       rsp->table_rule_add_default.data = data_out;
+
+       return rsp;
+}
+
 static void
 pipeline_msg_handle(struct pipeline_data *p)
 {
@@ -940,6 +1684,13 @@ pipeline_msg_handle(struct pipeline_data *p)
                        rsp = pipeline_msg_handle_table_stats_read(p, req);
                        break;
 
+               case PIPELINE_REQ_TABLE_RULE_ADD:
+                       rsp = pipeline_msg_handle_table_rule_add(p, req);
+                       break;
+
+               case PIPELINE_REQ_TABLE_RULE_ADD_DEFAULT:
+                       rsp = pipeline_msg_handle_table_rule_add_default(p,     req);
+                       break;
 
                default:
                        rsp = (struct pipeline_msg_rsp *) req;