examples/tep_term: add encap/decap configuration
authorJijiang Liu <jijiang.liu@intel.com>
Mon, 22 Jun 2015 16:41:05 +0000 (00:41 +0800)
committerThomas Monjalon <thomas.monjalon@6wind.com>
Tue, 23 Jun 2015 09:36:15 +0000 (11:36 +0200)
Add the encapsulation and decapsulation options.

The two flags are enabled by default.

Sometimes we want to know the performance influence of
the encapsulation and decapsulation operations, and
I think we should add the two configuration options.

Signed-off-by: Jijiang Liu <jijiang.liu@intel.com>
examples/tep_termination/main.c
examples/tep_termination/vxlan_setup.c
examples/tep_termination/vxlan_setup.h

index 6c7f44f..bd77617 100644 (file)
 #define CMD_LINE_OPT_TX_CHECKSUM "tx-checksum"
 #define CMD_LINE_OPT_TSO_SEGSZ "tso-segsz"
 #define CMD_LINE_OPT_FILTER_TYPE "filter-type"
+#define CMD_LINE_OPT_ENCAP "encap"
+#define CMD_LINE_OPT_DECAP "decap"
 #define CMD_LINE_OPT_RX_RETRY "rx-retry"
 #define CMD_LINE_OPT_RX_RETRY_DELAY "rx-retry-delay"
 #define CMD_LINE_OPT_RX_RETRY_NUM "rx-retry-num"
@@ -149,6 +151,12 @@ uint8_t tx_checksum = 0;
 /* TCP segment size */
 uint16_t tso_segsz = 0;
 
+/* enable/disable decapsulation */
+uint8_t rx_decap = 1;
+
+/* enable/disable encapsulation */
+uint8_t tx_encap = 1;
+
 /* RX filter type for tunneling packet */
 uint8_t filter_idx = 1;
 
@@ -270,6 +278,8 @@ tep_termination_usage(const char *prgname)
        "               --nb-devices[1-64]: The number of virtIO device\n"
        "               --tx-checksum [0|1]: inner Tx checksum offload\n"
        "               --tso-segsz [0-N]: TCP segment size\n"
+       "               --decap [0|1]: tunneling packet decapsulation\n"
+       "               --encap [0|1]: tunneling packet encapsulation\n"
        "               --filter-type[1-3]: filter type for tunneling packet\n"
        "                   1: Inner MAC and tenent ID\n"
        "                   2: Inner MAC and VLAN, and tenent ID\n"
@@ -301,6 +311,8 @@ tep_termination_parse_args(int argc, char **argv)
                {CMD_LINE_OPT_UDP_PORT, required_argument, NULL, 0},
                {CMD_LINE_OPT_TX_CHECKSUM, required_argument, NULL, 0},
                {CMD_LINE_OPT_TSO_SEGSZ, required_argument, NULL, 0},
+               {CMD_LINE_OPT_DECAP, required_argument, NULL, 0},
+               {CMD_LINE_OPT_ENCAP, required_argument, NULL, 0},
                {CMD_LINE_OPT_FILTER_TYPE, required_argument, NULL, 0},
                {CMD_LINE_OPT_RX_RETRY, required_argument, NULL, 0},
                {CMD_LINE_OPT_RX_RETRY_DELAY, required_argument, NULL, 0},
@@ -433,6 +445,34 @@ tep_termination_parse_args(int argc, char **argv)
                                        filter_idx = ret - 1;
                        }
 
+                       /* Enable/disable encapsulation on RX. */
+                       if (!strncmp(long_option[option_index].name,
+                               CMD_LINE_OPT_DECAP,
+                               sizeof(CMD_LINE_OPT_DECAP))) {
+                               ret = parse_num_opt(optarg, 1);
+                               if (ret == -1) {
+                                       RTE_LOG(INFO, VHOST_CONFIG,
+                                               "Invalid argument for decap [0|1]\n");
+                                       tep_termination_usage(prgname);
+                                       return -1;
+                               } else
+                                       rx_decap = ret;
+                       }
+
+                       /* Enable/disable encapsulation on TX. */
+                       if (!strncmp(long_option[option_index].name,
+                               CMD_LINE_OPT_ENCAP,
+                               sizeof(CMD_LINE_OPT_ENCAP))) {
+                               ret = parse_num_opt(optarg, 1);
+                               if (ret == -1) {
+                                       RTE_LOG(INFO, VHOST_CONFIG,
+                                               "Invalid argument for encap [0|1]\n");
+                                       tep_termination_usage(prgname);
+                                       return -1;
+                               } else
+                                       tx_encap = ret;
+                       }
+
                        /* Enable/disable stats. */
                        if (!strncmp(long_option[option_index].name,
                                CMD_LINE_OPT_STATS,
index 2341f9e..51ad133 100644 (file)
@@ -218,13 +218,20 @@ vxlan_port_init(uint8_t port, struct rte_mempool *mbuf_pool)
 static int
 vxlan_rx_process(struct rte_mbuf *pkt)
 {
-       return decapsulation(pkt);
+       int ret = 0;
+
+       if (rx_decap)
+               ret = decapsulation(pkt);
+
+       return ret;
 }
 
 static void
 vxlan_tx_process(uint8_t queue_id, struct rte_mbuf *pkt)
 {
-       encapsulation(pkt, queue_id);
+       if (tx_encap)
+               encapsulation(pkt, queue_id);
+
        return;
 }
 
index 189d491..1846540 100644 (file)
@@ -41,6 +41,8 @@ extern uint8_t ports[RTE_MAX_ETHPORTS];
 extern struct ether_addr ports_eth_addr[RTE_MAX_ETHPORTS];
 extern uint32_t enable_stats;
 extern struct device_statistics dev_statistics[MAX_DEVICES];
+extern uint8_t rx_decap;
+extern uint8_t tx_encap;
 
 typedef int (*ol_port_configure_t)(uint8_t port,
                                   struct rte_mempool *mbuf_pool);