@@ -10,8 +10,8 @@
#include "l3fwd.h"
#include "l3fwd_route.h"
-static struct em_rule *em_route_base_v4;
-static struct em_rule *em_route_base_v6;
+struct em_rule *em_route_base_v4;
+struct em_rule *em_route_base_v6;
enum {
CB_FLD_DST_ADDR,
@@ -56,6 +56,15 @@
#define L3FWD_HASH_ENTRIES (1024*1024*1)
#endif
+/* Select Longest-Prefix, Exact match, Forwarding Information Base or Access Control. */
+enum L3FWD_LOOKUP_MODE {
+ L3FWD_LOOKUP_DEFAULT,
+ L3FWD_LOOKUP_LPM,
+ L3FWD_LOOKUP_EM,
+ L3FWD_LOOKUP_FIB,
+ L3FWD_LOOKUP_ACL
+};
+
struct parm_cfg {
const char *rule_ipv4_name;
const char *rule_ipv6_name;
@@ -101,6 +110,9 @@ extern struct rte_ether_addr ports_eth_addr[RTE_MAX_ETHPORTS];
/* mask of enabled ports */
extern uint32_t enabled_port_mask;
+/* Skip or exit on invalid route */
+extern bool exit_on_failure;
+
/* Used only in exact match mode. */
extern int ipv6; /**< ipv6 is false by default. */
extern uint32_t hash_entry_number;
@@ -218,6 +230,10 @@ init_mem(uint16_t portid, unsigned int nb_mbuf);
int config_port_max_pkt_len(struct rte_eth_conf *conf,
struct rte_eth_dev_info *dev_info);
+int
+l3fwd_validate_routes_port(enum L3FWD_LOOKUP_MODE mode, uint32_t i,
+ bool is_ipv4);
+
/* Function pointers for ACL, LPM, EM or FIB functionality. */
void
setup_acl(const int socketid);
@@ -384,9 +384,14 @@ populate_ipv4_flow_into_table(const struct rte_hash *h)
struct in_addr src;
struct in_addr dst;
- if ((1 << em_route_base_v4[i].if_out &
- enabled_port_mask) == 0)
- continue;
+ ret = l3fwd_validate_routes_port(L3FWD_LOOKUP_EM, i, true);
+ if (ret) {
+ if (exit_on_failure)
+ rte_exit(EXIT_FAILURE, "IDX: %d: Port ID %d in IPv4 rule is not"
+ " enabled\n", i, em_route_base_v4[i].if_out);
+ else
+ continue;
+ }
entry = &em_route_base_v4[i];
convert_ipv4_5tuple(&(entry->v4_key), &newkey);
@@ -436,9 +441,14 @@ populate_ipv6_flow_into_table(const struct rte_hash *h)
struct em_rule *entry;
union ipv6_5tuple_host newkey;
- if ((1 << em_route_base_v6[i].if_out &
- enabled_port_mask) == 0)
- continue;
+ ret = l3fwd_validate_routes_port(L3FWD_LOOKUP_EM, i, false);
+ if (ret) {
+ if (exit_on_failure)
+ rte_exit(EXIT_FAILURE, "IDX %d: Port ID %d given in IPv6 rule is not"
+ " enabled\n", i, em_route_base_v6[i].if_out);
+ else
+ continue;
+ }
entry = &em_route_base_v6[i];
convert_ipv6_5tuple(&(entry->v6_key), &newkey);
@@ -670,10 +670,15 @@ setup_fib(const int socketid)
for (i = 0; i < route_num_v4; i++) {
struct in_addr in;
- /* Skip unused ports. */
- if ((1 << route_base_v4[i].if_out &
- enabled_port_mask) == 0)
- continue;
+ /* Check for valid ports */
+ ret = l3fwd_validate_routes_port(L3FWD_LOOKUP_FIB, i, true);
+ if (ret) {
+ if (exit_on_failure)
+ rte_exit(EXIT_FAILURE, "IDX %d: Port ID %d in IPv4 rule is not"
+ " enabled\n", i, route_base_v4[i].if_out);
+ else
+ continue;
+ }
rte_eth_dev_info_get(route_base_v4[i].if_out,
&dev_info);
@@ -724,10 +729,15 @@ setup_fib(const int socketid)
/* Populate the fib IPv6 table. */
for (i = 0; i < route_num_v6; i++) {
- /* Skip unused ports. */
- if ((1 << route_base_v6[i].if_out &
- enabled_port_mask) == 0)
- continue;
+ /* Check for valid ports. */
+ ret = l3fwd_validate_routes_port(L3FWD_LOOKUP_FIB, i, false);
+ if (ret) {
+ if (exit_on_failure)
+ rte_exit(EXIT_FAILURE, "IDX %d: Port ID %d given in IPv6 rule is not"
+ " enabled\n", i, route_base_v6[i].if_out);
+ else
+ continue;
+ }
rte_eth_dev_info_get(route_base_v6[i].if_out,
&dev_info);
@@ -583,10 +583,15 @@ setup_lpm(const int socketid)
for (i = 0; i < route_num_v4; i++) {
struct in_addr in;
- /* skip unused ports */
- if ((1 << route_base_v4[i].if_out &
- enabled_port_mask) == 0)
- continue;
+ /* Check for valid ports */
+ ret = l3fwd_validate_routes_port(L3FWD_LOOKUP_LPM, i, true);
+ if (ret) {
+ if (exit_on_failure)
+ rte_exit(EXIT_FAILURE, "IDX: %d: Port ID %d in IPv4 rule is not"
+ " enabled\n", i, route_base_v4[i].if_out);
+ else
+ continue;
+ }
rte_eth_dev_info_get(route_base_v4[i].if_out,
&dev_info);
@@ -627,10 +632,15 @@ setup_lpm(const int socketid)
/* populate the LPM table */
for (i = 0; i < route_num_v6; i++) {
- /* skip unused ports */
- if ((1 << route_base_v6[i].if_out &
- enabled_port_mask) == 0)
- continue;
+ /* Check for valid ports */
+ ret = l3fwd_validate_routes_port(L3FWD_LOOKUP_LPM, i, false);
+ if (ret) {
+ if (exit_on_failure)
+ rte_exit(EXIT_FAILURE, "IDX %d Port ID %d given in IPv6 rule is not"
+ " enabled\n", i, route_base_v6[i].if_out);
+ else
+ continue;
+ }
rte_eth_dev_info_get(route_base_v6[i].if_out,
&dev_info);
@@ -82,6 +82,8 @@ struct em_rule {
extern struct lpm_route_rule *route_base_v4;
extern struct lpm_route_rule *route_base_v6;
+extern struct em_rule *em_route_base_v4;
+extern struct em_rule *em_route_base_v6;
extern int route_num_v4;
extern int route_num_v6;
@@ -59,14 +59,6 @@ uint16_t nb_txd = TX_DESC_DEFAULT;
/**< Ports set in promiscuous mode off by default. */
static int promiscuous_on;
-/* Select Longest-Prefix, Exact match, Forwarding Information Base or Access Control. */
-enum L3FWD_LOOKUP_MODE {
- L3FWD_LOOKUP_DEFAULT,
- L3FWD_LOOKUP_LPM,
- L3FWD_LOOKUP_EM,
- L3FWD_LOOKUP_FIB,
- L3FWD_LOOKUP_ACL
-};
static enum L3FWD_LOOKUP_MODE lookup_mode;
/* Global variables. */
@@ -88,7 +80,8 @@ xmm_t val_eth[RTE_MAX_ETHPORTS];
/* mask of enabled ports */
uint32_t enabled_port_mask;
-
+bool exit_on_failure; /**< Skip the route rule with invalid or */
+ /**< disabled port ID */
/* Used only in exact match mode. */
int ipv6; /**< ipv6 is false by default. */
@@ -267,6 +260,43 @@ l3fwd_set_alg(const char *optarg)
parm_config.alg = parse_acl_alg(optarg);
}
+/* This function will work only after read_config_files step */
+int
+l3fwd_validate_routes_port(enum L3FWD_LOOKUP_MODE mode, uint32_t i,
+ bool is_ipv4)
+{
+ uint32_t max_port_count = (sizeof(enabled_port_mask) * CHAR_BIT);
+
+ if (mode == L3FWD_LOOKUP_LPM ||
+ mode == L3FWD_LOOKUP_FIB) {
+ if (is_ipv4) {
+ if (route_base_v4[i].if_out >= max_port_count ||
+ ((1 << route_base_v4[i].if_out &
+ enabled_port_mask) == 0))
+ return -1;
+ } else {
+ if (route_base_v6[i].if_out >= max_port_count ||
+ ((1 << route_base_v6[i].if_out &
+ enabled_port_mask) == 0))
+ return -1;
+ }
+ } else if (mode == L3FWD_LOOKUP_EM) {
+ if (is_ipv4) {
+ if (em_route_base_v4[i].if_out >= max_port_count ||
+ ((1 << em_route_base_v4[i].if_out &
+ enabled_port_mask) == 0))
+ return -1;
+ } else {
+ if (em_route_base_v6[i].if_out >= max_port_count ||
+ ((1 << em_route_base_v6[i].if_out &
+ enabled_port_mask) == 0))
+ return -1;
+ }
+ }
+
+ return 0;
+}
+
/*
* Setup lookup methods for forwarding.
* Currently exact-match, longest-prefix-match and forwarding information
@@ -402,6 +432,7 @@ print_usage(const char *prgname)
" [--parse-ptype]"
" [--per-port-pool]"
" [--mode]"
+ " [--exit-on-failure]"
#ifdef RTE_LIB_EVENTDEV
" [--eventq-sched]"
" [--event-vector [--event-vector-size SIZE] [--event-vector-tmo NS]]"
@@ -428,6 +459,8 @@ print_usage(const char *prgname)
" --per-port-pool: Use separate buffer pool per port\n"
" --mode: Packet transfer mode for I/O, poll or eventdev\n"
" Default mode = poll\n"
+ " --exit-on-failure: Exit on invalid/disabled port ID given in route rule\n"
+ " Default action is skip the rule\n"
#ifdef RTE_LIB_EVENTDEV
" --eventq-sched: Event queue synchronization method\n"
" ordered, atomic or parallel.\n"
@@ -689,6 +722,7 @@ static const char short_options[] =
#define CMD_LINE_OPT_RELAX_RX_OFFLOAD "relax-rx-offload"
#define CMD_LINE_OPT_PER_PORT_POOL "per-port-pool"
#define CMD_LINE_OPT_MODE "mode"
+#define CMD_LINE_OPT_EXIT_ON_FAILURE "exit-on-failure"
#define CMD_LINE_OPT_EVENTQ_SYNC "eventq-sched"
#define CMD_LINE_OPT_EVENT_ETH_RX_QUEUES "event-eth-rxqs"
#define CMD_LINE_OPT_LOOKUP "lookup"
@@ -726,7 +760,8 @@ enum {
CMD_LINE_OPT_LOOKUP_NUM,
CMD_LINE_OPT_ENABLE_VECTOR_NUM,
CMD_LINE_OPT_VECTOR_SIZE_NUM,
- CMD_LINE_OPT_VECTOR_TMO_NS_NUM
+ CMD_LINE_OPT_VECTOR_TMO_NS_NUM,
+ CMD_LINE_OPT_EXIT_ON_FAILURE_NUM
};
static const struct option lgopts[] = {
@@ -743,6 +778,7 @@ static const struct option lgopts[] = {
{CMD_LINE_OPT_DISABLE_RSS, 0, 0, CMD_LINE_OPT_DISABLE_RSS_NUM},
{CMD_LINE_OPT_PER_PORT_POOL, 0, 0, CMD_LINE_OPT_PARSE_PER_PORT_POOL},
{CMD_LINE_OPT_MODE, 1, 0, CMD_LINE_OPT_MODE_NUM},
+ {CMD_LINE_OPT_EXIT_ON_FAILURE, 0, 0, CMD_LINE_OPT_EXIT_ON_FAILURE_NUM},
{CMD_LINE_OPT_EVENTQ_SYNC, 1, 0, CMD_LINE_OPT_EVENTQ_SYNC_NUM},
{CMD_LINE_OPT_EVENT_ETH_RX_QUEUES, 1, 0,
CMD_LINE_OPT_EVENT_ETH_RX_QUEUES_NUM},
@@ -885,6 +921,10 @@ parse_args(int argc, char **argv)
parse_mode(optarg);
break;
+ case CMD_LINE_OPT_EXIT_ON_FAILURE_NUM:
+ exit_on_failure = true;
+ break;
+
#ifdef RTE_LIB_EVENTDEV
case CMD_LINE_OPT_EVENTQ_SYNC_NUM:
parse_eventq_sched(optarg);