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 00324A00C2; Mon, 26 Sep 2022 16:18:15 +0200 (CEST) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 1C6F342B8A; Mon, 26 Sep 2022 16:17:31 +0200 (CEST) Received: from lb.pantheon.sk (lb.pantheon.sk [46.229.239.20]) by mails.dpdk.org (Postfix) with ESMTP id 5283242B72 for ; Mon, 26 Sep 2022 16:17:26 +0200 (CEST) Received: from localhost (localhost [127.0.0.1]) by lb.pantheon.sk (Postfix) with ESMTP id 8AA961FF592; Mon, 26 Sep 2022 16:17:25 +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 t9lM8niKpglE; Mon, 26 Sep 2022 16:17:24 +0200 (CEST) Received: from entguard.lab.pantheon.local (unknown [46.229.239.141]) by lb.pantheon.sk (Postfix) with ESMTP id E3BC1243CFD; Mon, 26 Sep 2022 16:17:18 +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, kda@semihalf.com, bruce.richardson@intel.com Cc: dev@dpdk.org, =?UTF-8?q?Juraj=20Linke=C5=A1?= Subject: [PATCH v5 08/10] dts: add dts workflow module Date: Mon, 26 Sep 2022 14:17:11 +0000 Message-Id: <20220926141713.2415010-9-juraj.linkes@pantheon.tech> X-Mailer: git-send-email 2.25.1 In-Reply-To: <20220926141713.2415010-1-juraj.linkes@pantheon.tech> References: <20220926141713.2415010-1-juraj.linkes@pantheon.tech> MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 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 The module implements methods needed to run DTS. It handles the creation of objects and eventually the whole DTS workflow, such as running node setups, test gathering, setup and execution and various cleanups. Signed-off-by: Owen Hilyard Signed-off-by: Juraj Linkeš --- dts/framework/dts.py | 69 ++++++++++++++++++++++++++++++++++++++++++ dts/framework/utils.py | 18 +++++++++++ 2 files changed, 87 insertions(+) create mode 100644 dts/framework/dts.py diff --git a/dts/framework/dts.py b/dts/framework/dts.py new file mode 100644 index 0000000000..6b3ec069f6 --- /dev/null +++ b/dts/framework/dts.py @@ -0,0 +1,69 @@ +# SPDX-License-Identifier: BSD-3-Clause +# Copyright(c) 2010-2019 Intel Corporation +# Copyright(c) 2022 PANTHEON.tech s.r.o. +# Copyright(c) 2022 University of New Hampshire +# + +import sys +import traceback +from typing import Iterable, Optional + +from framework import logger +from framework.testbed_model.node import Node + +from .config import CONFIGURATION +from .logger import getLogger +from .utils import check_dts_python_version + +log_handler: Optional[logger.DTSLOG] = None + + +def run_all() -> None: + """ + Main process of DTS, it will run all test suites in the config file. + """ + + global log_handler + + # check the python version of the server that run dts + check_dts_python_version() + + log_handler = getLogger("dts") + + nodes = {} + # This try/finally block means "Run the try block, if there is an exception, + # run the finally block before passing it upward. If there is not an exception, + # run the finally block after the try block is finished." This helps avoid the + # problem of python's interpreter exit context, which essentially prevents you + # from making certain system calls. This makes cleaning up resources difficult, + # since most of the resources in DTS are network-based, which is restricted. + try: + # for all Execution sections + for execution in CONFIGURATION.executions: + sut_config = execution.system_under_test + if sut_config.name not in nodes: + node = Node(sut_config) + nodes[sut_config.name] = node + out = node.send_command("echo Hello World") + + except Exception as e: + # sys.exit() doesn't produce a stack trace, need to print it explicitly + traceback.print_exc() + raise e + + finally: + quit_execution(nodes.values()) + + +def quit_execution(sut_nodes: Iterable[Node]) -> None: + """ + Close session to SUT and TG before quit. + Return exit status when failure occurred. + """ + for sut_node in sut_nodes: + # close all session + sut_node.node_exit() + + if log_handler is not None: + log_handler.info("DTS ended") + sys.exit(0) diff --git a/dts/framework/utils.py b/dts/framework/utils.py index 26b784ebb5..2a174831d0 100644 --- a/dts/framework/utils.py +++ b/dts/framework/utils.py @@ -4,6 +4,8 @@ # Copyright(c) 2022 University of New Hampshire # +import sys + def RED(text: str) -> str: return f"\u001B[31;1m{str(text)}\u001B[0m" @@ -11,3 +13,19 @@ def RED(text: str) -> str: def GREEN(text: str) -> str: return f"\u001B[32;1m{str(text)}\u001B[0m" + + +def check_dts_python_version() -> None: + if sys.version_info.major < 3 or ( + sys.version_info.major == 3 and sys.version_info.minor < 10 + ): + print( + RED( + ( + "WARNING: DTS execution node's python version is lower than" + "python 3.10, is deprecated and will not work in future releases." + ) + ), + file=sys.stderr, + ) + print(RED("Please use Python >= 3.10 instead"), file=sys.stderr) -- 2.30.2