From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id CA73BA0507; Wed, 6 Apr 2022 17:06:33 +0200 (CEST) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 7AE8D428BB; Wed, 6 Apr 2022 17:05:03 +0200 (CEST) Received: from lb.pantheon.sk (lb.pantheon.sk [46.229.239.20]) by mails.dpdk.org (Postfix) with ESMTP id E981E4288C for ; Wed, 6 Apr 2022 17:04:58 +0200 (CEST) Received: from localhost (localhost [127.0.0.1]) by lb.pantheon.sk (Postfix) with ESMTP id 451A01AB919; Wed, 6 Apr 2022 17:04:58 +0200 (CEST) X-Virus-Scanned: amavisd-new at siecit.sk Received: from lb.pantheon.sk ([127.0.0.1]) by localhost (lb.pantheon.sk [127.0.0.1]) (amavisd-new, port 10024) with ESMTP id modLOzLPVECF; Wed, 6 Apr 2022 17:04:57 +0200 (CEST) Received: from entguard.lab.pantheon.local (unknown [46.229.239.141]) by lb.pantheon.sk (Postfix) with ESMTP id 35B351B1F41; Wed, 6 Apr 2022 17:04:47 +0200 (CEST) From: =?UTF-8?q?Juraj=20Linke=C5=A1?= To: thomas@monjalon.net, david.marchand@redhat.com, Honnappa.Nagarahalli@arm.com, ohilyard@iol.unh.edu, lijuan.tu@intel.com Cc: dev@dpdk.org, =?UTF-8?q?Juraj=20Linke=C5=A1?= Subject: [RFC PATCH v1 12/18] dts: merge DTS framework/ixia_network/__init__.py to DPDK Date: Wed, 6 Apr 2022 15:04:34 +0000 Message-Id: <20220406150440.2914464-13-juraj.linkes@pantheon.tech> X-Mailer: git-send-email 2.25.1 In-Reply-To: <20220406150440.2914464-1-juraj.linkes@pantheon.tech> References: <20220406150440.2914464-1-juraj.linkes@pantheon.tech> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org --- dts/framework/ixia_network/__init__.py | 183 +++++++++++++++++++++++++ 1 file changed, 183 insertions(+) create mode 100644 dts/framework/ixia_network/__init__.py diff --git a/dts/framework/ixia_network/__init__.py b/dts/framework/ixia_network/__init__.py new file mode 100644 index 0000000000..98f4bcff2e --- /dev/null +++ b/dts/framework/ixia_network/__init__.py @@ -0,0 +1,183 @@ +# BSD LICENSE +# +# Copyright(c) 2010-2021 Intel Corporation. All rights reserved. +# All rights reserved. +# +# Redistribution and use in source and binary forms, with or without +# modification, are permitted provided that the following conditions +# are met: +# +# * Redistributions of source code must retain the above copyright +# notice, this list of conditions and the following disclaimer. +# * Redistributions in binary form must reproduce the above copyright +# notice, this list of conditions and the following disclaimer in +# the documentation and/or other materials provided with the +# distribution. +# * Neither the name of Intel Corporation nor the names of its +# contributors may be used to endorse or promote products derived +# from this software without specific prior written permission. +# +# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. +""" +ixNetwork package +""" +import os +import time +import traceback +from pprint import pformat + +from .ixnet import IxnetTrafficGenerator +from .ixnet_config import IxiaNetworkConfig + +__all__ = [ + "IxNetwork", +] + + +class IxNetwork(IxnetTrafficGenerator): + """ + ixNetwork performance measurement class. + """ + + def __init__(self, name, config, logger): + self.NAME = name + self.logger = logger + ixiaRef = self.NAME + if ixiaRef not in config: + return + _config = config.get(ixiaRef, {}) + self.ixiaVersion = _config.get("Version") + self.ports = _config.get("Ports") + ixia_ip = _config.get("IP") + rest_server_ip = _config.get("ixnet_api_server_ip") + self.max_retry = int(_config.get("max_retry") or "5") # times + self.logger.debug(locals()) + rest_config = IxiaNetworkConfig( + ixia_ip, + rest_server_ip, + "11009", + [[ixia_ip, p.get("card"), p.get("port")] for p in self.ports], + ) + super(IxNetwork, self).__init__(rest_config, logger) + self._traffic_list = [] + self._result = None + + @property + def OUTPUT_DIR(self): + # get dts output folder path + if self.logger.log_path.startswith(os.sep): + output_path = self.logger.log_path + else: + cur_path = os.sep.join(os.path.realpath(__file__).split(os.sep)[:-2]) + output_path = os.path.join(cur_path, self.logger.log_path) + if not os.path.exists(output_path): + os.makedirs(output_path) + + return output_path + + def get_ports(self): + """ + get ixNetwork ports for dts `ports_info` + """ + plist = [] + for p in self.ports: + plist.append( + { + "type": "ixia", + "pci": "IXIA:%d.%d" % (p["card"], p["port"]), + } + ) + return plist + + def send_ping6(self, pci, mac, ipv6): + return "64 bytes from" + + def disconnect(self): + """quit from ixNetwork api server""" + self.tear_down() + msg = "close ixNetwork session done !" + self.logger.info(msg) + + def prepare_ixia_network_stream(self, traffic_list): + self._traffic_list = [] + for txPort, rxPort, pcapFile, option in traffic_list: + stream = self.configure_streams(pcapFile, option.get("fields_config")) + tx_p = self.tg_vports[txPort] + rx_p = self.tg_vports[rxPort] + self._traffic_list.append((tx_p, rx_p, stream)) + + def start(self, options): + """start ixNetwork measurement""" + test_mode = options.get("method") + options["traffic_list"] = self._traffic_list + self.logger.debug(pformat(options)) + if test_mode == "rfc2544_dichotomy": + cnt = 0 + while cnt < self.max_retry: + try: + result = self.send_rfc2544_throughput(options) + if result: + break + except Exception as e: + msg = "failed to run rfc2544".format(cnt) + self.logger.error(msg) + self.logger.error(traceback.format_exc()) + cnt += 1 + msg = "No.{} rerun ixNetwork rfc2544".format(cnt) + self.logger.warning(msg) + time.sleep(10) + else: + result = [] + else: + msg = "not support measurement {}".format(test_mode) + self.logger.error(msg) + self._result = None + return None + self.logger.info("measure <{}> completed".format(test_mode)) + self.logger.info(result) + self._result = result + return result + + def get_rfc2544_stat(self, port_list): + """ + Get RX/TX packet statistics. + """ + if not self._result: + return [0] * 3 + + result = self._result + _ixnet_stats = {} + for item in result: + port_id = int(item.get("Trial")) - 1 + _ixnet_stats[port_id] = dict(item) + port_stat = _ixnet_stats.get(0, {}) + rx_packets = float(port_stat.get("Agg Rx Count (frames)") or "0.0") + tx_packets = float(port_stat.get("Agg Tx Count (frames)") or "0.0") + rx_pps = float(port_stat.get("Agg Rx Throughput (fps)") or "0.0") + return tx_packets, rx_packets, rx_pps + + def get_stats(self, ports, mode): + """ + get statistics of custom mode + """ + methods = { + "rfc2544": self.get_rfc2544_stat, + } + if mode not in list(methods.keys()): + msg = "not support mode <{0}>".format(mode) + raise Exception(msg) + # get custom mode stat + func = methods.get(mode) + stats = func(ports) + + return stats -- 2.20.1