Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/87184/?format=api
{ "id": 87184, "url": "https://patches.dpdk.org/api/patches/87184/?format=api", "web_url": "https://patches.dpdk.org/project/dts/patch/20210125084414.8503-9-yufengx.mo@intel.com/", "project": { "id": 3, "url": "https://patches.dpdk.org/api/projects/3/?format=api", "name": "DTS", "link_name": "dts", "list_id": "dts.dpdk.org", "list_email": "dts@dpdk.org", "web_url": "", "scm_url": "git://dpdk.org/tools/dts", "webscm_url": "http://git.dpdk.org/tools/dts/", "list_archive_url": "https://inbox.dpdk.org/dts", "list_archive_url_format": "https://inbox.dpdk.org/dts/{}", "commit_url_format": "" }, "msgid": "<20210125084414.8503-9-yufengx.mo@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dts/20210125084414.8503-9-yufengx.mo@intel.com", "date": "2021-01-25T08:43:55", "name": "[V1,08/27] framework/pktgen: enable ixNetwork", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": false, "hash": "4b55c16350dd2e78776a6e49e6585dc718ff6945", "submitter": { "id": 1342, "url": "https://patches.dpdk.org/api/people/1342/?format=api", "name": "Yufen.Mo", "email": "yufengx.mo@intel.com" }, "delegate": { "id": 23642, "url": "https://patches.dpdk.org/api/users/23642/?format=api", "username": "lijuantu", "first_name": "LIjuan", "last_name": "Tu", "email": "lijuan.tu@intel.com" }, "mbox": "https://patches.dpdk.org/project/dts/patch/20210125084414.8503-9-yufengx.mo@intel.com/mbox/", "series": [ { "id": 14926, "url": "https://patches.dpdk.org/api/series/14926/?format=api", "web_url": "https://patches.dpdk.org/project/dts/list/?series=14926", "date": "2021-01-25T08:43:47", "name": "dts: enable IxNetwork and enhance perf testing", "version": 1, "mbox": "https://patches.dpdk.org/series/14926/mbox/" } ], "comments": "https://patches.dpdk.org/api/patches/87184/comments/", "check": "pending", "checks": "https://patches.dpdk.org/api/patches/87184/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dts-bounces@dpdk.org>", "X-Original-To": "patchwork@inbox.dpdk.org", "Delivered-To": "patchwork@inbox.dpdk.org", "Received": [ "from mails.dpdk.org (mails.dpdk.org [217.70.189.124])\n\tby inbox.dpdk.org (Postfix) with ESMTP id 164AEA052A;\n\tMon, 25 Jan 2021 09:51:40 +0100 (CET)", "from [217.70.189.124] (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 0C72D140DEA;\n\tMon, 25 Jan 2021 09:51:40 +0100 (CET)", "from mga06.intel.com (mga06.intel.com [134.134.136.31])\n by mails.dpdk.org (Postfix) with ESMTP id 941B7140DE5\n for <dts@dpdk.org>; Mon, 25 Jan 2021 09:51:38 +0100 (CET)", "from fmsmga001.fm.intel.com ([10.253.24.23])\n by orsmga104.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 25 Jan 2021 00:51:37 -0800", "from dpdk-moyufen06.sh.intel.com ([10.67.116.208])\n by fmsmga001.fm.intel.com with ESMTP; 25 Jan 2021 00:51:35 -0800" ], "IronPort-SDR": [ "\n gU2mBpwADoH1fWp1dgxcmtO+G7xXlGuYc3+gb1623aIcN7byz0vQBxn7V/StbildMkPH9Chwin\n bu5vMisT767g==", "\n RQd6o4TFbNnpmlTqnIV+XsQM+Wg67Hm58t9C/YvkK8Orju6nDsEx6e5WQRi5sWQWkijjjlNXjB\n wFCUwWecvwhA==" ], "X-IronPort-AV": [ "E=McAfee;i=\"6000,8403,9874\"; a=\"241224409\"", "E=Sophos;i=\"5.79,373,1602572400\"; d=\"scan'208\";a=\"241224409\"", "E=Sophos;i=\"5.79,373,1602572400\"; d=\"scan'208\";a=\"471978407\"" ], "X-ExtLoop1": "1", "From": "yufengmx <yufengx.mo@intel.com>", "To": "dts@dpdk.org,\n\tlijuan.tu@intel.com", "Cc": "yufengmx <yufengx.mo@intel.com>", "Date": "Mon, 25 Jan 2021 16:43:55 +0800", "Message-Id": "<20210125084414.8503-9-yufengx.mo@intel.com>", "X-Mailer": "git-send-email 2.21.0", "In-Reply-To": "<20210125084414.8503-1-yufengx.mo@intel.com>", "References": "<20210125084414.8503-1-yufengx.mo@intel.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "Subject": "[dts] [PATCH V1 08/27] framework/pktgen: enable ixNetwork", "X-BeenThere": "dts@dpdk.org", "X-Mailman-Version": "2.1.29", "Precedence": "list", "List-Id": "test suite reviews and discussions <dts.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dts>,\n <mailto:dts-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dts/>", "List-Post": "<mailto:dts@dpdk.org>", "List-Help": "<mailto:dts-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dts>,\n <mailto:dts-request@dpdk.org?subject=subscribe>", "Errors-To": "dts-bounces@dpdk.org", "Sender": "\"dts\" <dts-bounces@dpdk.org>" }, "content": "create ixia_network package.\n\nSigned-off-by: yufengmx <yufengx.mo@intel.com>\n---\n framework/ixia_network/__init__.py | 182 +++++++++++++++++++++++++++++\n 1 file changed, 182 insertions(+)\n create mode 100644 framework/ixia_network/__init__.py", "diff": "diff --git a/framework/ixia_network/__init__.py b/framework/ixia_network/__init__.py\nnew file mode 100644\nindex 00000000..086fb5af\n--- /dev/null\n+++ b/framework/ixia_network/__init__.py\n@@ -0,0 +1,182 @@\n+# BSD LICENSE\n+#\n+# Copyright(c) 2010-2021 Intel Corporation. All rights reserved.\n+# All rights reserved.\n+#\n+# Redistribution and use in source and binary forms, with or without\n+# modification, are permitted provided that the following conditions\n+# are met:\n+#\n+# * Redistributions of source code must retain the above copyright\n+# notice, this list of conditions and the following disclaimer.\n+# * Redistributions in binary form must reproduce the above copyright\n+# notice, this list of conditions and the following disclaimer in\n+# the documentation and/or other materials provided with the\n+# distribution.\n+# * Neither the name of Intel Corporation nor the names of its\n+# contributors may be used to endorse or promote products derived\n+# from this software without specific prior written permission.\n+#\n+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS\n+# \"AS IS\" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT\n+# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR\n+# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT\n+# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,\n+# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT\n+# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,\n+# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY\n+# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT\n+# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE\n+# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.\n+\"\"\"\n+ixNetwork package\n+\"\"\"\n+import os\n+import time\n+import traceback\n+from pprint import pformat\n+\n+from .ixnet import IxnetTrafficGenerator\n+from .ixnet_config import IxiaNetworkConfig\n+\n+__all__ = [\n+ \"IxNetwork\",\n+]\n+\n+\n+class IxNetwork(IxnetTrafficGenerator):\n+ \"\"\"\n+ ixNetwork performance measurement class.\n+ \"\"\"\n+\n+ def __init__(self, name, config, logger):\n+ self.NAME = name\n+ self.logger = logger\n+ ixiaRef = self.NAME\n+ if ixiaRef not in config:\n+ return\n+ _config = config.get(ixiaRef, {})\n+ self.ixiaVersion = _config.get(\"Version\")\n+ self.ports = _config.get(\"Ports\")\n+ ixia_ip = _config.get(\"IP\")\n+ rest_server_ip = _config.get(\"ixnet_api_server_ip\")\n+ self.max_retry = int(_config.get(\"max_retry\") or '5') # times\n+ self.logger.debug(locals())\n+ rest_config = IxiaNetworkConfig(\n+ ixia_ip,\n+ rest_server_ip,\n+ '11009',\n+ [[ixia_ip, p.get('card'), p.get('port')] for p in self.ports],\n+ )\n+ super(IxNetwork, self).__init__(rest_config, logger)\n+ self._traffic_list = []\n+ self._result = None\n+\n+ @property\n+ def OUTPUT_DIR(self):\n+ # get dts output folder path\n+ if self.logger.log_path.startswith(os.sep):\n+ output_path = self.logger.log_path\n+ else:\n+ cur_path = os.sep.join(\n+ os.path.realpath(__file__).split(os.sep)[:-2])\n+ output_path = os.path.join(cur_path, self.logger.log_path)\n+ if not os.path.exists(output_path):\n+ os.makedirs(output_path)\n+\n+ return output_path\n+\n+ def get_ports(self):\n+ \"\"\"\n+ get ixNetwork ports for dts `ports_info`\n+ \"\"\"\n+ plist = []\n+ for p in self.ports:\n+ plist.append({\n+ 'type': 'ixia',\n+ 'pci': 'IXIA:%d.%d' % (p['card'], p['port']),\n+ })\n+ return plist\n+\n+ def send_ping6(self, pci, mac, ipv6):\n+ return '64 bytes from'\n+\n+ def disconnect(self):\n+ ''' quit from ixNetwork api server '''\n+ self.tear_down()\n+ msg = 'close ixNetwork session done !'\n+ self.logger.info(msg)\n+\n+ def prepare_ixia_network_stream(self, traffic_list):\n+ self._traffic_list = []\n+ for txPort, rxPort, pcapFile, option in traffic_list:\n+ stream = self.configure_streams(pcapFile, option.get('fields_config'))\n+ tx_p = self.tg_vports[txPort]\n+ rx_p = self.tg_vports[rxPort]\n+ self._traffic_list.append((tx_p, rx_p, stream))\n+\n+ def start(self, options):\n+ ''' start ixNetwork measurement '''\n+ test_mode = options.get('method')\n+ options['traffic_list'] = self._traffic_list\n+ self.logger.debug(pformat(options))\n+ if test_mode == 'rfc2544_dichotomy':\n+ cnt = 0\n+ while cnt < self.max_retry:\n+ try:\n+ result = self.send_rfc2544_throughput(options)\n+ if result:\n+ break\n+ except Exception as e:\n+ msg = \"failed to run rfc2544\".format(cnt)\n+ self.logger.error(msg)\n+ self.logger.error(traceback.format_exc())\n+ cnt += 1\n+ msg = \"No.{} rerun ixNetwork rfc2544\".format(cnt)\n+ self.logger.warning(msg)\n+ time.sleep(10)\n+ else:\n+ result = []\n+ else:\n+ msg = \"not support measurement {}\".format(test_mode)\n+ self.logger.error(msg)\n+ self._result = None\n+ return None\n+ self.logger.info('measure <{}> completed'.format(test_mode))\n+ self.logger.info(result)\n+ self._result = result\n+ return result\n+\n+ def get_rfc2544_stat(self, port_list):\n+ \"\"\"\n+ Get RX/TX packet statistics.\n+ \"\"\"\n+ if not self._result:\n+ return [0] * 3\n+\n+ result = self._result\n+ _ixnet_stats = {}\n+ for item in result:\n+ port_id = int(item.get('Trial')) - 1\n+ _ixnet_stats[port_id] = dict(item)\n+ port_stat = _ixnet_stats.get(0, {})\n+ rx_packets = float(port_stat.get('Agg Rx Count (frames)') or '0.0')\n+ tx_packets = float(port_stat.get('Agg Tx Count (frames)') or '0.0')\n+ rx_pps = float(port_stat.get('Agg Rx Throughput (fps)') or '0.0')\n+ return tx_packets, rx_packets, rx_pps\n+\n+ def get_stats(self, ports, mode):\n+ '''\n+ get statistics of custom mode\n+ '''\n+ methods = {\n+ 'rfc2544': self.get_rfc2544_stat,\n+ }\n+ if mode not in list(methods.keys()):\n+ msg = \"not support mode <{0}>\".format(mode)\n+ raise Exception(msg)\n+ # get custom mode stat\n+ func = methods.get(mode)\n+ stats = func(ports)\n+\n+ return stats\n", "prefixes": [ "V1", "08/27" ] }