From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mga01.intel.com (mga01.intel.com [192.55.52.88]) by dpdk.org (Postfix) with ESMTP id 057CA7E18 for ; Fri, 26 Sep 2014 07:58:08 +0200 (CEST) Received: from fmsmga003.fm.intel.com ([10.253.24.29]) by fmsmga101.fm.intel.com with ESMTP; 25 Sep 2014 23:04:29 -0700 X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="4.97,862,1389772800"; d="scan'208";a="391863789" Received: from shvmail01.sh.intel.com ([10.239.29.42]) by FMSMGA003.fm.intel.com with ESMTP; 25 Sep 2014 22:58:27 -0700 Received: from shecgisg004.sh.intel.com (shecgisg004.sh.intel.com [10.239.29.89]) by shvmail01.sh.intel.com with ESMTP id s8Q64QUX029457; Fri, 26 Sep 2014 14:04:26 +0800 Received: from shecgisg004.sh.intel.com (localhost [127.0.0.1]) by shecgisg004.sh.intel.com (8.13.6/8.13.6/SuSE Linux 0.8) with ESMTP id s8Q64OTA013061; Fri, 26 Sep 2014 14:04:26 +0800 Received: (from wujingji@localhost) by shecgisg004.sh.intel.com (8.13.6/8.13.6/Submit) id s8Q64OND013057; Fri, 26 Sep 2014 14:04:24 +0800 From: Jingjing Wu To: dev@dpdk.org Date: Fri, 26 Sep 2014 14:03:38 +0800 Message-Id: <1411711418-12881-21-git-send-email-jingjing.wu@intel.com> X-Mailer: git-send-email 1.7.4.1 In-Reply-To: <1411711418-12881-1-git-send-email-jingjing.wu@intel.com> References: <1411711418-12881-1-git-send-email-jingjing.wu@intel.com> Subject: [dpdk-dev] [PATCH v3 20/20] app/test-pmd: add test command to configure flexible masks X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: patches and discussions about DPDK List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Fri, 26 Sep 2014 05:58:10 -0000 add test command to configure flexible masks for each flow type Signed-off-by: Jingjing Wu Acked-by: Chen Jing D(Mark) Acked-by: Helin Zhang --- app/test-pmd/cmdline.c | 173 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 173 insertions(+) diff --git a/app/test-pmd/cmdline.c b/app/test-pmd/cmdline.c index da77752..073b929 100644 --- a/app/test-pmd/cmdline.c +++ b/app/test-pmd/cmdline.c @@ -690,6 +690,11 @@ static void cmd_help_long_parsed(void *parsed_result, "flow_director_flex_payload (port_id)" " (l2|l3|l4) (config)\n" " configure flexible payload selection.\n\n" + + "flow_director_flex_mask (port_id)" + " flow (ether|ip4|tcp4|udp4|sctp4|ip6|tcp6|udp6|sctp6)" + " words_mask (words) (word_mask_list)" + " configure masks of flexible payload.\n\n" ); } } @@ -8046,6 +8051,173 @@ cmdline_parse_inst_t cmd_set_flow_director_flex_payload = { }, }; +/* *** deal with flow director mask on flexible payload *** */ +struct cmd_flow_director_flex_mask_result { + cmdline_fixed_string_t flow_director_flexmask; + uint8_t port_id; + cmdline_fixed_string_t flow; + cmdline_fixed_string_t flow_type; + cmdline_fixed_string_t words_mask; + uint8_t words; + cmdline_fixed_string_t word_mask_list; +}; + +static inline int +parse_word_masks_cfg(const char *q_arg, + struct rte_eth_fdir_flex_masks *masks) +{ + char s[256]; + const char *p, *p0 = q_arg; + char *end; + enum fieldnames { + FLD_OFFSET = 0, + FLD_MASK, + _NUM_FLD + }; + unsigned long int_fld[_NUM_FLD]; + char *str_fld[_NUM_FLD]; + int i; + unsigned size; + + masks->nb_field = 0; + p = strchr(p0, '('); + while (p != NULL) { + ++p; + p0 = strchr(p, ')'); + if (p0 == NULL) + return -1; + + size = p0 - p; + if (size >= sizeof(s)) + return -1; + + snprintf(s, sizeof(s), "%.*s", size, p); + if (rte_strsplit(s, sizeof(s), str_fld, _NUM_FLD, ',') != _NUM_FLD) + return -1; + for (i = 0; i < _NUM_FLD; i++) { + errno = 0; + int_fld[i] = strtoul(str_fld[i], &end, 0); + if (errno != 0 || end == str_fld[i] || int_fld[i] > UINT16_MAX) + return -1; + } + masks->field[masks->nb_field].offset = + (uint16_t)int_fld[FLD_OFFSET]; + masks->field[masks->nb_field].bitmask = + ~(uint16_t)int_fld[FLD_MASK]; + masks->nb_field++; + if (masks->nb_field > 2) { + printf("exceeded max number of fields: %hu\n", + masks->nb_field); + return -1; + } + p = strchr(p0, '('); + } + return 0; +} + +static void +cmd_flow_director_flex_mask_parsed(void *parsed_result, + __attribute__((unused)) struct cmdline *cl, + __attribute__((unused)) void *data) +{ + struct cmd_flow_director_flex_mask_result *res = parsed_result; + struct rte_eth_fdir_flex_masks *flex_masks; + struct rte_eth_fdir_cfg fdir_cfg; + int ret = 0; + int cfg_size = 2 * sizeof(struct rte_eth_flex_mask) + + offsetof(struct rte_eth_fdir_flex_masks, field); + + ret = rte_eth_dev_filter_supported(res->port_id, RTE_ETH_FILTER_FDIR); + if (ret < 0) { + printf("flow director is not supported on port %u.\n", + res->port_id); + return; + } + + memset(&fdir_cfg, 0, sizeof(struct rte_eth_fdir_cfg)); + + flex_masks = (struct rte_eth_fdir_flex_masks *)rte_zmalloc_socket("CLI", + cfg_size, CACHE_LINE_SIZE, rte_socket_id()); + + if (flex_masks == NULL) { + printf("fail to malloc memory to configure flexi masks\n"); + return; + } + + if (!strcmp(res->flow_type, "ip4")) + flex_masks->flow_type = RTE_ETH_FLOW_TYPE_IPV4_OTHER; + else if (!strcmp(res->flow_type, "udp4")) + flex_masks->flow_type = RTE_ETH_FLOW_TYPE_UDPV4; + else if (!strcmp(res->flow_type, "tcp4")) + flex_masks->flow_type = RTE_ETH_FLOW_TYPE_TCPV4; + else if (!strcmp(res->flow_type, "sctp4")) + flex_masks->flow_type = RTE_ETH_FLOW_TYPE_SCTPV4; + else if (!strcmp(res->flow_type, "ip6")) + flex_masks->flow_type = RTE_ETH_FLOW_TYPE_IPV6_OTHER; + else if (!strcmp(res->flow_type, "udp6")) + flex_masks->flow_type = RTE_ETH_FLOW_TYPE_UDPV6; + else if (!strcmp(res->flow_type, "tcp6")) + flex_masks->flow_type = RTE_ETH_FLOW_TYPE_TCPV6; + else if (!strcmp(res->flow_type, "sctp6")) + flex_masks->flow_type = RTE_ETH_FLOW_TYPE_SCTPV6; + + flex_masks->words_mask = res->words; + ret = parse_word_masks_cfg(res->word_mask_list, flex_masks); + if (ret < 0) { + printf("fdir flex masks error\n"); + rte_free(flex_masks); + return; + } + + fdir_cfg.cmd = RTE_ETH_FDIR_CFG_FLX_MASK; + fdir_cfg.cfg = flex_masks; + ret = rte_eth_dev_filter_ctrl(res->port_id, RTE_ETH_FILTER_FDIR, + RTE_ETH_FILTER_OP_SET, &fdir_cfg); + if (ret < 0) + printf("fdir flex mask setting error: (%s)\n", strerror(-ret)); + rte_free(flex_masks); +} + +cmdline_parse_token_string_t cmd_flow_director_flexmask = + TOKEN_STRING_INITIALIZER(struct cmd_flow_director_flex_mask_result, + flow_director_flexmask, + "flow_director_flex_mask"); +cmdline_parse_token_num_t cmd_flow_director_flexmask_port_id = + TOKEN_NUM_INITIALIZER(struct cmd_flow_director_flex_mask_result, + port_id, UINT8); +cmdline_parse_token_string_t cmd_flow_director_flexmask_flow = + TOKEN_STRING_INITIALIZER(struct cmd_flow_director_flex_mask_result, + flow, "flow"); +cmdline_parse_token_string_t cmd_flow_director_flexmask_flow_type = + TOKEN_STRING_INITIALIZER(struct cmd_flow_director_flex_mask_result, + flow_type, + "ip4#tcp4#udp4#sctp4#ip6#tcp6#udp6#sctp6"); +cmdline_parse_token_string_t cmd_flow_director_flexmask_words_mask = + TOKEN_STRING_INITIALIZER(struct cmd_flow_director_flex_mask_result, + words_mask, "words_mask"); +cmdline_parse_token_num_t cmd_flow_director_flexmask_words = + TOKEN_NUM_INITIALIZER(struct cmd_flow_director_flex_mask_result, + words, UINT8); +cmdline_parse_token_string_t cmd_flow_director_flexmask_word_mask_list = + TOKEN_STRING_INITIALIZER(struct cmd_flow_director_flex_mask_result, + word_mask_list, NULL); + +cmdline_parse_inst_t cmd_set_flow_director_flex_mask = { + .f = cmd_flow_director_flex_mask_parsed, + .data = NULL, + .help_str = "set flow director's flex masks on NIC", + .tokens = { + (void *)&cmd_flow_director_flexmask, + (void *)&cmd_flow_director_flexmask_port_id, + (void *)&cmd_flow_director_flexmask_flow, + (void *)&cmd_flow_director_flexmask_flow_type, + (void *)&cmd_flow_director_flexmask_words_mask, + (void *)&cmd_flow_director_flexmask_words, + (void *)&cmd_flow_director_flexmask_word_mask_list, + NULL, + }, +}; + /* ******************************************************************************** */ /* list of instructions */ @@ -8177,6 +8349,7 @@ cmdline_parse_ctx_t main_ctx[] = { (cmdline_parse_inst_t *)&cmd_add_del_sctp_flow_director, (cmdline_parse_inst_t *)&cmd_flush_flow_director, (cmdline_parse_inst_t *)&cmd_set_flow_director_flex_payload, + (cmdline_parse_inst_t *)&cmd_set_flow_director_flex_mask, NULL, }; -- 1.8.1.4