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 4E63548961; Fri, 17 Oct 2025 15:56:34 +0200 (CEST) Received: from mails.dpdk.org (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 35EEA42DA6; Fri, 17 Oct 2025 15:56:30 +0200 (CEST) Received: from mgamail.intel.com (mgamail.intel.com [192.198.163.11]) by mails.dpdk.org (Postfix) with ESMTP id 0003240269 for ; Fri, 17 Oct 2025 15:56:27 +0200 (CEST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=intel.com; i=@intel.com; q=dns/txt; s=Intel; t=1760709388; x=1792245388; h=from:to:cc:subject:date:message-id:in-reply-to: references:mime-version:content-transfer-encoding; bh=iCX+VNmx9VxsQ60tVx6KHPII4U4JwJwGjTJDB4I9OWw=; b=e0RGlyvJMKP/H2eZbKtvbQewDLt1vWLTV/alpHuaSZwhK/tzZiXKL5PT 6Hv5tdW1EDLRmU5fpcjfgjQB5xrWrxqLxLvvTD7mbcLAmA5bRIYjrOGSN MCrPYrXqKojvDca1F8aSsZNUcQ+Ifjcs9YIOZk8xMDU+1VeKK+JkbiNNQ iQuFd4H2Q/+lynaEofsnjYC3ULuhga0QQvNyJaYno4NDHKG3cd4R6ZQWS ZmpKoQuj7lI5SKEeJ+SBRafVrhkcyz2Dal/fpWFM5Sk7Zu4fGL7Mm3isM BobIER+f50SdghiEcfzApYfR043DFwBBoz0TqKMMziPaP/QfKJpia6vkF Q==; X-CSE-ConnectionGUID: olUq9+x4T76iZhTzdsuIzw== X-CSE-MsgGUID: bTF2lu/SRPS5nm02bP3GoA== X-IronPort-AV: E=McAfee;i="6800,10657,11585"; a="73522788" X-IronPort-AV: E=Sophos;i="6.19,236,1754982000"; d="scan'208";a="73522788" Received: from orviesa006.jf.intel.com ([10.64.159.146]) by fmvoesa105.fm.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 17 Oct 2025 06:56:27 -0700 X-CSE-ConnectionGUID: DZdMsFZ+RL6VtesKArWb1g== X-CSE-MsgGUID: TyEwU3qtRc+42o0vCQzb8Q== X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="6.19,236,1754982000"; d="scan'208";a="181878245" Received: from silpixa00401385.ir.intel.com ([10.20.224.226]) by orviesa006.jf.intel.com with ESMTP; 17 Oct 2025 06:56:27 -0700 From: Bruce Richardson To: dev@dpdk.org Cc: Bruce Richardson Subject: [PATCH 1/2] usertools/dpdk-telemetry: correct script formatting Date: Fri, 17 Oct 2025 14:56:21 +0100 Message-ID: <20251017135622.1152341-2-bruce.richardson@intel.com> X-Mailer: git-send-email 2.48.1 In-Reply-To: <20251017135622.1152341-1-bruce.richardson@intel.com> References: <20251017135622.1152341-1-bruce.richardson@intel.com> 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 Auto-format the dpdk-telemetry script using "black" tool, to ensure it meets default DPDK python formatting style. Signed-off-by: Bruce Richardson --- usertools/dpdk-telemetry.py | 90 +++++++++++++++++++++---------------- 1 file changed, 51 insertions(+), 39 deletions(-) diff --git a/usertools/dpdk-telemetry.py b/usertools/dpdk-telemetry.py index b025f86731..d428a3b707 100755 --- a/usertools/dpdk-telemetry.py +++ b/usertools/dpdk-telemetry.py @@ -18,13 +18,13 @@ # global vars TELEMETRY_VERSION = "v2" -SOCKET_NAME = 'dpdk_telemetry.{}'.format(TELEMETRY_VERSION) -DEFAULT_PREFIX = 'rte' +SOCKET_NAME = "dpdk_telemetry.{}".format(TELEMETRY_VERSION) +DEFAULT_PREFIX = "rte" CMDS = [] def read_socket(sock, buf_len, echo=True, pretty=False): - """ Read data from socket and return it in JSON format """ + """Read data from socket and return it in JSON format""" reply = sock.recv(buf_len).decode() try: ret = json.loads(reply) @@ -39,11 +39,11 @@ def read_socket(sock, buf_len, echo=True, pretty=False): def get_app_name(pid): - """ return the app name for a given PID, for printing """ - proc_cmdline = os.path.join('/proc', str(pid), 'cmdline') + """return the app name for a given PID, for printing""" + proc_cmdline = os.path.join("/proc", str(pid), "cmdline") try: with open(proc_cmdline) as f: - argv0 = f.read(1024).split('\0')[0] + argv0 = f.read(1024).split("\0")[0] return os.path.basename(argv0) except IOError as e: # ignore file not found errors @@ -53,41 +53,40 @@ def get_app_name(pid): def find_sockets(path): - """ Find any possible sockets to connect to and return them """ - return glob.glob(os.path.join(path, SOCKET_NAME + '*')) + """Find any possible sockets to connect to and return them""" + return glob.glob(os.path.join(path, SOCKET_NAME + "*")) def print_socket_options(prefix, paths): - """ Given a set of socket paths, give the commands needed to connect """ + """Given a set of socket paths, give the commands needed to connect""" cmd = sys.argv[0] if prefix != DEFAULT_PREFIX: cmd += " -f " + prefix for s in sorted(paths): sock_name = os.path.basename(s) if sock_name.endswith(TELEMETRY_VERSION): - print("- {} # Connect with '{}'".format(os.path.basename(s), - cmd)) + print("- {} # Connect with '{}'".format(os.path.basename(s), cmd)) else: - print("- {} # Connect with '{} -i {}'".format(os.path.basename(s), - cmd, - s.split(':')[-1])) + print( + "- {} # Connect with '{} -i {}'".format(os.path.basename(s), cmd, s.split(":")[-1]) + ) def get_dpdk_runtime_dir(fp): - """ Using the same logic as in DPDK's EAL, get the DPDK runtime directory - based on the file-prefix and user """ - run_dir = os.environ.get('RUNTIME_DIRECTORY') + """Using the same logic as in DPDK's EAL, get the DPDK runtime directory + based on the file-prefix and user""" + run_dir = os.environ.get("RUNTIME_DIRECTORY") if not run_dir: - if (os.getuid() == 0): - run_dir = '/var/run' + if os.getuid() == 0: + run_dir = "/var/run" else: - run_dir = os.environ.get('XDG_RUNTIME_DIR', '/tmp') - return os.path.join(run_dir, 'dpdk', fp) + run_dir = os.environ.get("XDG_RUNTIME_DIR", "/tmp") + return os.path.join(run_dir, "dpdk", fp) def list_fp(): - """ List all available file-prefixes to user """ - path = get_dpdk_runtime_dir('') + """List all available file-prefixes to user""" + path = get_dpdk_runtime_dir("") sockets = glob.glob(os.path.join(path, "*", SOCKET_NAME + "*")) prefixes = [] if not sockets: @@ -98,18 +97,17 @@ def list_fp(): prefixes.append(os.path.relpath(os.path.dirname(s), start=path)) for p in sorted(set(prefixes)): print(p) - print_socket_options(p, glob.glob(os.path.join(path, p, - SOCKET_NAME + "*"))) + print_socket_options(p, glob.glob(os.path.join(path, p, SOCKET_NAME + "*"))) def handle_socket(args, path): - """ Connect to socket and handle user input """ - prompt = '' # this evaluates to false in conditions + """Connect to socket and handle user input""" + prompt = "" # this evaluates to false in conditions sock = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET) global CMDS if os.isatty(sys.stdin.fileno()): - prompt = '--> ' + prompt = "--> " print("Connecting to " + path) try: sock.connect(path) @@ -142,7 +140,7 @@ def handle_socket(args, path): try: text = input(prompt).strip() while text != "quit": - if text.startswith('/'): + if text.startswith("/"): sock.send(text.encode()) read_socket(sock, output_buf_len, pretty=prompt) text = input(prompt).strip() @@ -153,8 +151,8 @@ def handle_socket(args, path): def readline_complete(text, state): - """ Find any matching commands from the list based on user input """ - all_cmds = ['quit'] + CMDS + """Find any matching commands from the list based on user input""" + all_cmds = ["quit"] + CMDS if text: matches = [c for c in all_cmds if c.startswith(text)] else: @@ -163,17 +161,31 @@ def readline_complete(text, state): if __name__ == "__main__": - readline.parse_and_bind('tab: complete') + readline.parse_and_bind("tab: complete") readline.set_completer(readline_complete) - readline.set_completer_delims(readline.get_completer_delims().replace('/', '')) + readline.set_completer_delims(readline.get_completer_delims().replace("/", "")) parser = argparse.ArgumentParser() - parser.add_argument('-f', '--file-prefix', default=DEFAULT_PREFIX, - help='Provide file-prefix for DPDK runtime directory') - parser.add_argument('-i', '--instance', default='0', type=int, - help='Provide instance number for DPDK application') - parser.add_argument('-l', '--list', action="store_true", default=False, - help='List all possible file-prefixes and exit') + parser.add_argument( + "-f", + "--file-prefix", + default=DEFAULT_PREFIX, + help="Provide file-prefix for DPDK runtime directory", + ) + parser.add_argument( + "-i", + "--instance", + default="0", + type=int, + help="Provide instance number for DPDK application", + ) + parser.add_argument( + "-l", + "--list", + action="store_true", + default=False, + help="List all possible file-prefixes and exit", + ) args = parser.parse_args() if args.list: list_fp() -- 2.48.1