Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/129306/?format=api
{ "id": 129306, "url": "http://patchwork.dpdk.org/api/patches/129306/?format=api", "web_url": "http://patchwork.dpdk.org/project/dpdk/patch/20230705153125.4657-4-viacheslavo@nvidia.com/", "project": { "id": 1, "url": "http://patchwork.dpdk.org/api/projects/1/?format=api", "name": "DPDK", "link_name": "dpdk", "list_id": "dev.dpdk.org", "list_email": "dev@dpdk.org", "web_url": "http://core.dpdk.org", "scm_url": "git://dpdk.org/dpdk", "webscm_url": "http://git.dpdk.org/dpdk", "list_archive_url": "https://inbox.dpdk.org/dev", "list_archive_url_format": "https://inbox.dpdk.org/dev/{}", "commit_url_format": "" }, "msgid": "<20230705153125.4657-4-viacheslavo@nvidia.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20230705153125.4657-4-viacheslavo@nvidia.com", "date": "2023-07-05T15:31:24", "name": "[v5,3/4] net/mlx5: add Tx datapath trace analyzing script", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "5ac7b30bee2b580c4f4ce36bf5b68fec7b12c142", "submitter": { "id": 1926, "url": "http://patchwork.dpdk.org/api/people/1926/?format=api", "name": "Slava Ovsiienko", "email": "viacheslavo@nvidia.com" }, "delegate": { "id": 3268, "url": "http://patchwork.dpdk.org/api/users/3268/?format=api", "username": "rasland", "first_name": "Raslan", "last_name": "Darawsheh", "email": "rasland@nvidia.com" }, "mbox": "http://patchwork.dpdk.org/project/dpdk/patch/20230705153125.4657-4-viacheslavo@nvidia.com/mbox/", "series": [ { "id": 28841, "url": "http://patchwork.dpdk.org/api/series/28841/?format=api", "web_url": "http://patchwork.dpdk.org/project/dpdk/list/?series=28841", "date": "2023-07-05T15:31:22", "name": "net/mlx5: introduce Tx datapath tracing", "version": 5, "mbox": "http://patchwork.dpdk.org/series/28841/mbox/" } ], "comments": "http://patchwork.dpdk.org/api/patches/129306/comments/", "check": "success", "checks": "http://patchwork.dpdk.org/api/patches/129306/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dev-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 3FA5E42DD9;\n\tWed, 5 Jul 2023 17:32:22 +0200 (CEST)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 82D6842D44;\n\tWed, 5 Jul 2023 17:32:05 +0200 (CEST)", "from NAM11-CO1-obe.outbound.protection.outlook.com\n (mail-co1nam11on2064.outbound.protection.outlook.com [40.107.220.64])\n by mails.dpdk.org (Postfix) with ESMTP id 8795C42D2F\n for <dev@dpdk.org>; Wed, 5 Jul 2023 17:32:01 +0200 (CEST)", "from SJ0PR03CA0089.namprd03.prod.outlook.com (2603:10b6:a03:331::34)\n by PH7PR12MB6693.namprd12.prod.outlook.com (2603:10b6:510:1b0::6)\n with Microsoft SMTP Server (version=TLS1_2,\n cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.6565.17; Wed, 5 Jul\n 2023 15:31:59 +0000", "from DM6NAM11FT098.eop-nam11.prod.protection.outlook.com\n (2603:10b6:a03:331:cafe::79) by SJ0PR03CA0089.outlook.office365.com\n (2603:10b6:a03:331::34) with Microsoft SMTP Server (version=TLS1_2,\n cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.6565.18 via Frontend\n Transport; Wed, 5 Jul 2023 15:31:59 +0000", "from mail.nvidia.com (216.228.117.161) by\n DM6NAM11FT098.mail.protection.outlook.com (10.13.173.61) with Microsoft SMTP\n Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id\n 15.20.6521.45 via Frontend Transport; Wed, 5 Jul 2023 15:31:58 +0000", "from rnnvmail201.nvidia.com (10.129.68.8) by mail.nvidia.com\n (10.129.200.67) with Microsoft SMTP Server (version=TLS1_2,\n cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.2.986.5; Wed, 5 Jul 2023\n 08:31:44 -0700", "from nvidia.com (10.126.230.35) by rnnvmail201.nvidia.com\n (10.129.68.8) with Microsoft SMTP Server (version=TLS1_2,\n cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.2.986.37; Wed, 5 Jul 2023\n 08:31:43 -0700" ], "ARC-Seal": "i=1; a=rsa-sha256; s=arcselector9901; d=microsoft.com; cv=none;\n b=eGRZ0pBjN4LyHfHPlBxFQuoI/eNAIuLoNanLZgRJwhJ1WMCWywpFUZolQS6yQCoPOv0/GUjl3jeZH65Agrpsa4EW5I9L3NAg6p1hCJtJBtwWq7wXkJDxPX7Jd7XQ1/LqukJ1GAOjMLuRKfvvFU+KV/JcR50YewsgwnGQGVGUtQ5cJYyUoTczDM8zUqUzbuYmJHOfkFLLz0wnANOBJoc+d1DvZft4dQg5mwqSzdApa0TETyV0fF3J/+d96wCek3TS6uiJbnPJ7CcZ9Cq7cooaAqNJOurr7oHGCuNmCvTNyimP0gUvuU+YfQh7RDwwdPJwGvKTxzx4K0QBQzLUZYV7jQ==", "ARC-Message-Signature": "i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com;\n s=arcselector9901;\n h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-AntiSpam-MessageData-ChunkCount:X-MS-Exchange-AntiSpam-MessageData-0:X-MS-Exchange-AntiSpam-MessageData-1;\n bh=/DsapU1Z/lqzk/PAxwff7QOfmmrMm5Xv0ofwjQ6zr/I=;\n b=XMJoXZyCLPEQqTTMvL9IY3gufedEGula4dA202DeKg1j+ocrDmGgfTivRaPvmoUCIYgC1KIOK5qlnD1HzNG34ji3zffBDgHaj4GfM7KszcfmcgLOYQFpCbsrf/k5ZiYJtCCO5W8VhyJgb2AMXGFbOQJNCR8kZPU4Rr9l15KqL1zYzhTstnlaAddT9hoGzVsiNNiOp7SSEC1yyLIjMb/dPbDc7TS8ZQ1zW9fam2OUBRguAlQaxpWFcugV0bay29IU9VksUUHlYN/fp8qHzQWF9BBuxNGGKT6ZbhkejL1uofjCy7Q04SMMRj3zPmlJ1kL2tjoWPEESJaeydIBJOFw8Uw==", "ARC-Authentication-Results": "i=1; mx.microsoft.com 1; spf=pass (sender ip is\n 216.228.117.161) smtp.rcpttodomain=dpdk.org smtp.mailfrom=nvidia.com;\n dmarc=pass (p=reject sp=reject pct=100) action=none header.from=nvidia.com;\n dkim=none (message not signed); arc=none", "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/relaxed; d=Nvidia.com;\n s=selector2;\n h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck;\n bh=/DsapU1Z/lqzk/PAxwff7QOfmmrMm5Xv0ofwjQ6zr/I=;\n b=sJXjQf3L4dAHYjzCsl2UHJEokATAY+dhULdsfCEtVW4p/ekylsYjC3MA5e4JYeo2Y6kQbZ9hrTgcY7HvCEOw5L/pOi6su4r2up1BYenMdedSh4VMZQYiEdgpaUw83bt329O3ryxy9+bpuaDFXhJz5yab+d6X/vML9JTUSq7elQ7OV1ChHABRAZG6jTCIEI7UTAzjqc+gRyr+rV1DnmNDbBldzeCzGoxYQHQUQ8h55VprWcLG7CJXSaD8/mG10Lyi9HpciKycP6lTm8hEzwszhvObVV/9kNQSShPICSZh9Jc0+zQ/xticzVZug1YJhAoRuhamzB3XcRCc+4HtSqqa6w==", "X-MS-Exchange-Authentication-Results": "spf=pass (sender IP is 216.228.117.161)\n smtp.mailfrom=nvidia.com;\n dkim=none (message not signed)\n header.d=none;dmarc=pass action=none header.from=nvidia.com;", "Received-SPF": "Pass (protection.outlook.com: domain of nvidia.com designates\n 216.228.117.161 as permitted sender) receiver=protection.outlook.com;\n client-ip=216.228.117.161; helo=mail.nvidia.com; pr=C", "From": "Viacheslav Ovsiienko <viacheslavo@nvidia.com>", "To": "<dev@dpdk.org>", "CC": "<jerinj@marvell.com>, <rasland@nvidia.com>", "Subject": "[PATCH v5 3/4] net/mlx5: add Tx datapath trace analyzing script", "Date": "Wed, 5 Jul 2023 18:31:24 +0300", "Message-ID": "<20230705153125.4657-4-viacheslavo@nvidia.com>", "X-Mailer": "git-send-email 2.18.1", "In-Reply-To": "<20230705153125.4657-1-viacheslavo@nvidia.com>", "References": "<20230420100803.494-1-viacheslavo@nvidia.com>\n <20230705153125.4657-1-viacheslavo@nvidia.com>", "MIME-Version": "1.0", "Content-Type": "text/plain", "X-Originating-IP": "[10.126.230.35]", "X-ClientProxiedBy": "rnnvmail201.nvidia.com (10.129.68.8) To\n rnnvmail201.nvidia.com (10.129.68.8)", "X-EOPAttributedMessage": "0", "X-MS-PublicTrafficType": "Email", "X-MS-TrafficTypeDiagnostic": "DM6NAM11FT098:EE_|PH7PR12MB6693:EE_", "X-MS-Office365-Filtering-Correlation-Id": "3148950a-f6c4-4076-4b4c-08db7d6cf8f3", "X-MS-Exchange-SenderADCheck": "1", "X-MS-Exchange-AntiSpam-Relay": "0", "X-Microsoft-Antispam": "BCL:0;", "X-Microsoft-Antispam-Message-Info": "\n gkTz3uz2Xm1HH/N/Yr2Khejl6ptYhjlsKePmN9xlkEzl4nCKlNCajD4XItM+V9lMSsusqwGISon8a2O0NmuaBwyUIMeUb40YZqzAzK8+UL+UuM4Za2YWdpd9y/JlZ8s8Zskx9+GMey3oa5CQw7czsuNLRCModjh64Zr4N2qQnnmhMle6L1F8i88bAfgfzIcj94KuF7rGU0o50wb3UJjHNxE0HKAmm5QKCw68nQtrJfkXZRFDBSpCFE0TFsZxTaK+k2ldZq6fydiVafHPR56LW6UCuIs4FxeyDG2dROo1VTo9qJ77ASRbFqtJ60X0jXdcLU2ZEkwnRnpruAAGggt9pbxgU5twtu47/BBtWkwVj5YMam4QfHB8hy9EZcyHvA+doUm9VokNpSSp78yXvpozs4oCYnMub6II0aaJ3xwaqXEplZ5Y18BS0UvgKhbAof0QBOkdzO/n/wmtllCBRq1mizZ22Kv5yrA4YAxWCJaHWKCcTohXlWbYD/RuZ8tgIsfMcz9eYd3XuCo1XCEJMMga78r65FnVOk2F9vusAepdNJTKk2Y0Bs54FVu0lB2lgSaPU6fDoPQQqF4wfCgjWEfdpfKnCrVweMuUA6n7Satj7iXEJB8Jhco+33uxR+2flFVwRyA2jvZ1RPCnqx5tQR0C+kvvlGDuxfJFQudQI0rkrXjP7fohOQXdApQ0o0p4GjQ+aLPTKMlEMJNCgQbBNRtIaSXqJlPB8E/OgLgLoEGUSojRQ6LixjSF8kM0XMeUS+3F", "X-Forefront-Antispam-Report": "CIP:216.228.117.161; CTRY:US; LANG:en; SCL:1;\n SRV:;\n IPV:NLI; SFV:NSPM; H:mail.nvidia.com; PTR:dc6edge2.nvidia.com; CAT:NONE;\n SFS:(13230028)(4636009)(136003)(346002)(376002)(39860400002)(396003)(451199021)(36840700001)(40470700004)(46966006)(5660300002)(36860700001)(8936002)(8676002)(41300700001)(316002)(47076005)(2906002)(336012)(426003)(83380400001)(2616005)(82740400003)(55016003)(6286002)(40480700001)(16526019)(70206006)(6916009)(4326008)(1076003)(356005)(7636003)(70586007)(40460700003)(82310400005)(86362001)(186003)(54906003)(26005)(107886003)(478600001)(6666004)(7696005)(36756003);\n DIR:OUT; SFP:1101;", "X-OriginatorOrg": "Nvidia.com", "X-MS-Exchange-CrossTenant-OriginalArrivalTime": "05 Jul 2023 15:31:58.8128 (UTC)", "X-MS-Exchange-CrossTenant-Network-Message-Id": "\n 3148950a-f6c4-4076-4b4c-08db7d6cf8f3", "X-MS-Exchange-CrossTenant-Id": "43083d15-7273-40c1-b7db-39efd9ccc17a", "X-MS-Exchange-CrossTenant-OriginalAttributedTenantConnectingIp": "\n TenantId=43083d15-7273-40c1-b7db-39efd9ccc17a; Ip=[216.228.117.161];\n Helo=[mail.nvidia.com]", "X-MS-Exchange-CrossTenant-AuthSource": "\n DM6NAM11FT098.eop-nam11.prod.protection.outlook.com", "X-MS-Exchange-CrossTenant-AuthAs": "Anonymous", "X-MS-Exchange-CrossTenant-FromEntityHeader": "HybridOnPrem", "X-MS-Exchange-Transport-CrossTenantHeadersStamped": "PH7PR12MB6693", "X-BeenThere": "dev@dpdk.org", "X-Mailman-Version": "2.1.29", "Precedence": "list", "List-Id": "DPDK patches and discussions <dev.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dev>,\n <mailto:dev-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dev/>", "List-Post": "<mailto:dev@dpdk.org>", "List-Help": "<mailto:dev-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dev>,\n <mailto:dev-request@dpdk.org?subject=subscribe>", "Errors-To": "dev-bounces@dpdk.org" }, "content": "The Python script is intended to analyze mlx5 PMD\ndatapath traces and report:\n - tx_burst routine timings\n - how packets are pushed to WQEs\n - how packet sending is completed with timings\n\nSigned-off-by: Viacheslav Ovsiienko <viacheslavo@nvidia.com>\n---\n drivers/net/mlx5/tools/mlx5_trace.py | 307 +++++++++++++++++++++++++++\n 1 file changed, 307 insertions(+)\n create mode 100755 drivers/net/mlx5/tools/mlx5_trace.py", "diff": "diff --git a/drivers/net/mlx5/tools/mlx5_trace.py b/drivers/net/mlx5/tools/mlx5_trace.py\nnew file mode 100755\nindex 0000000000..8c1fd0a350\n--- /dev/null\n+++ b/drivers/net/mlx5/tools/mlx5_trace.py\n@@ -0,0 +1,307 @@\n+#!/usr/bin/env python3\n+# SPDX-License-Identifier: BSD-3-Clause\n+# Copyright (c) 2023 NVIDIA Corporation & Affiliates\n+\n+\"\"\"\n+Analyzing the mlx5 PMD datapath tracings\n+\"\"\"\n+import sys\n+import argparse\n+import bt2\n+\n+PFX_TX = \"pmd.net.mlx5.tx.\"\n+PFX_TX_LEN = len(PFX_TX)\n+\n+\n+class MlxQueue:\n+ \"\"\"Queue container object\"\"\"\n+\n+ def __init__(self):\n+ self.done_burst = [] # completed bursts\n+ self.wait_burst = [] # waiting for completion\n+ self.pq_id = 0\n+\n+ def log(self):\n+ \"\"\"Log all queue bursts\"\"\"\n+ for txb in self.done_burst:\n+ txb.log()\n+\n+\n+class MlxMbuf:\n+ \"\"\"Packet mbufs container object\"\"\"\n+\n+ def __init__(self):\n+ self.wqe = 0 # wqe id\n+ self.ptr = None # first packet mbuf pointer\n+ self.len = 0 # packet data length\n+ self.nseg = 0 # number of segments\n+\n+ def log(self):\n+ \"\"\"Log mbuf\"\"\"\n+ out_txt = \" %X: %u\" % (self.ptr, self.len)\n+ if self.nseg != 1:\n+ out_txt += \" (%d segs)\" % self.nseg\n+ print(out_txt)\n+\n+\n+class MlxWqe:\n+ \"\"\"WQE container object\"\"\"\n+\n+ def __init__(self):\n+ self.mbuf = [] # list of mbufs in WQE\n+ self.wait_ts = 0 # preceding wait/push timestamp\n+ self.comp_ts = 0 # send/recv completion timestamp\n+ self.opcode = 0\n+\n+ def log(self):\n+ \"\"\"Log WQE\"\"\"\n+ wqe_id = (self.opcode >> 8) & 0xFFFF\n+ wqe_op = self.opcode & 0xFF\n+ out_txt = \" %04X: \" % wqe_id\n+ if wqe_op == 0xF:\n+ out_txt += \"WAIT\"\n+ elif wqe_op == 0x29:\n+ out_txt += \"EMPW\"\n+ elif wqe_op == 0xE:\n+ out_txt += \"TSO \"\n+ elif wqe_op == 0xA:\n+ out_txt += \"SEND\"\n+ else:\n+ out_txt += \"0x%02X\" % wqe_op\n+ if self.comp_ts != 0:\n+ out_txt += \" (%d, %d)\" % (self.wait_ts, self.comp_ts - self.wait_ts)\n+ else:\n+ out_txt += \" (%d)\" % self.wait_ts\n+ print(out_txt)\n+ for mbuf in self.mbuf:\n+ mbuf.log()\n+\n+ def comp(self, wqe_id, wqe_ts):\n+ \"\"\"Return 0 if WQE in not completedLog WQE\"\"\"\n+ if self.comp_ts != 0:\n+ return 1\n+ cur_id = (self.opcode >> 8) & 0xFFFF\n+ if cur_id > wqe_id:\n+ cur_id -= wqe_id\n+ if cur_id <= 0x8000:\n+ return 0\n+ else:\n+ cur_id = wqe_id - cur_id\n+ if cur_id >= 0x8000:\n+ return 0\n+ self.comp_ts = wqe_ts\n+ return 1\n+\n+\n+class MlxBurst:\n+ \"\"\"Packet burst container object\"\"\"\n+\n+ def __init__(self):\n+ self.wqes = [] # issued burst WQEs\n+ self.done = 0 # number of sent/recv packets\n+ self.req = 0 # requested number of packets\n+ self.call_ts = 0 # burst routine invocation\n+ self.done_ts = 0 # burst routine done\n+ self.queue = None\n+\n+ def log(self):\n+ \"\"\"Log burst\"\"\"\n+ port = self.queue.pq_id >> 16\n+ queue = self.queue.pq_id & 0xFFFF\n+ if self.req == 0:\n+ print(\n+ \"%u: tx(p=%u, q=%u, %u/%u pkts (incomplete)\"\n+ % (self.call_ts, port, queue, self.done, self.req)\n+ )\n+ else:\n+ print(\n+ \"%u: tx(p=%u, q=%u, %u/%u pkts in %u\"\n+ % (\n+ self.call_ts,\n+ port,\n+ queue,\n+ self.done,\n+ self.req,\n+ self.done_ts - self.call_ts,\n+ )\n+ )\n+ for wqe in self.wqes:\n+ wqe.log()\n+\n+ def comp(self, wqe_id, wqe_ts):\n+ \"\"\"Return 0 if not all of WQEs in burst completed\"\"\"\n+ wlen = len(self.wqes)\n+ if wlen == 0:\n+ return 0\n+ for wqe in self.wqes:\n+ if wqe.comp(wqe_id, wqe_ts) == 0:\n+ return 0\n+ return 1\n+\n+\n+class MlxTrace:\n+ \"\"\"Trace representing object\"\"\"\n+\n+ def __init__(self):\n+ self.tx_blst = {} # current Tx bursts per CPU\n+ self.tx_qlst = {} # active Tx queues per port/queue\n+ self.tx_wlst = {} # wait timestamp list per CPU\n+\n+ def run(self, msg_it):\n+ \"\"\"Run over gathered tracing data and build database\"\"\"\n+ for msg in msg_it:\n+ if not isinstance(msg, bt2._EventMessageConst):\n+ continue\n+ event = msg.event\n+ if event.name.startswith(PFX_TX):\n+ do_tx(msg, self)\n+ # Handling of other log event cathegories can be added here\n+\n+ def log(self):\n+ \"\"\"Log gathered trace database\"\"\"\n+ for pq_id in self.tx_qlst:\n+ queue = self.tx_qlst.get(pq_id)\n+ queue.log()\n+\n+\n+def do_tx_entry(msg, trace):\n+ \"\"\"Handle entry Tx busrt\"\"\"\n+ event = msg.event\n+ cpu_id = event[\"cpu_id\"]\n+ burst = trace.tx_blst.get(cpu_id)\n+ if burst is not None:\n+ # continue existing burst after WAIT\n+ return\n+ # allocate the new burst and append to the queue\n+ burst = MlxBurst()\n+ burst.call_ts = msg.default_clock_snapshot.ns_from_origin\n+ trace.tx_blst[cpu_id] = burst\n+ pq_id = event[\"port_id\"] << 16 | event[\"queue_id\"]\n+ queue = trace.tx_qlst.get(pq_id)\n+ if queue is None:\n+ # queue does not exist - allocate the new one\n+ queue = MlxQueue()\n+ queue.pq_id = pq_id\n+ trace.tx_qlst[pq_id] = queue\n+ burst.queue = queue\n+ queue.wait_burst.append(burst)\n+\n+\n+def do_tx_exit(msg, trace):\n+ \"\"\"Handle exit Tx busrt\"\"\"\n+ event = msg.event\n+ cpu_id = event[\"cpu_id\"]\n+ burst = trace.tx_blst.get(cpu_id)\n+ if burst is None:\n+ return\n+ burst.done_ts = msg.default_clock_snapshot.ns_from_origin\n+ burst.req = event[\"nb_req\"]\n+ burst.done = event[\"nb_sent\"]\n+ trace.tx_blst.pop(cpu_id)\n+\n+\n+def do_tx_wqe(msg, trace):\n+ \"\"\"Handle WQE record\"\"\"\n+ event = msg.event\n+ cpu_id = event[\"cpu_id\"]\n+ burst = trace.tx_blst.get(cpu_id)\n+ if burst is None:\n+ return\n+ wqe = MlxWqe()\n+ wqe.wait_ts = trace.tx_wlst.get(cpu_id)\n+ if wqe.wait_ts is None:\n+ wqe.wait_ts = msg.default_clock_snapshot.ns_from_origin\n+ wqe.opcode = event[\"opcode\"]\n+ burst.wqes.append(wqe)\n+\n+\n+def do_tx_wait(msg, trace):\n+ \"\"\"Handle WAIT record\"\"\"\n+ event = msg.event\n+ cpu_id = event[\"cpu_id\"]\n+ trace.tx_wlst[cpu_id] = event[\"ts\"]\n+\n+\n+def do_tx_push(msg, trace):\n+ \"\"\"Handle WQE push event\"\"\"\n+ event = msg.event\n+ cpu_id = event[\"cpu_id\"]\n+ burst = trace.tx_blst.get(cpu_id)\n+ if burst is None:\n+ return\n+ if not burst.wqes:\n+ return\n+ wqe = burst.wqes[-1]\n+ mbuf = MlxMbuf()\n+ mbuf.wqe = event[\"wqe_id\"]\n+ mbuf.ptr = event[\"mbuf\"]\n+ mbuf.len = event[\"mbuf_pkt_len\"]\n+ mbuf.nseg = event[\"mbuf_nb_segs\"]\n+ wqe.mbuf.append(mbuf)\n+\n+\n+def do_tx_complete(msg, trace):\n+ \"\"\"Handle send completion event\"\"\"\n+ event = msg.event\n+ pq_id = event[\"port_id\"] << 16 | event[\"queue_id\"]\n+ queue = trace.tx_qlst.get(pq_id)\n+ if queue is None:\n+ return\n+ qlen = len(queue.wait_burst)\n+ if qlen == 0:\n+ return\n+ wqe_id = event[\"wqe_id\"]\n+ wqe_ts = event[\"ts\"]\n+ rmv = 0\n+ while rmv < qlen:\n+ burst = queue.wait_burst[rmv]\n+ if burst.comp(wqe_id, wqe_ts) == 0:\n+ break\n+ rmv += 1\n+ # mode completed burst to done list\n+ if rmv != 0:\n+ idx = 0\n+ while idx < rmv:\n+ queue.done_burst.append(burst)\n+ idx += 1\n+ del queue.wait_burst[0:rmv]\n+\n+\n+def do_tx(msg, trace):\n+ \"\"\"Handle Tx related records\"\"\"\n+ name = msg.event.name[PFX_TX_LEN:]\n+ if name == \"entry\":\n+ do_tx_entry(msg, trace)\n+ elif name == \"exit\":\n+ do_tx_exit(msg, trace)\n+ elif name == \"wqe\":\n+ do_tx_wqe(msg, trace)\n+ elif name == \"wait\":\n+ do_tx_wait(msg, trace)\n+ elif name == \"push\":\n+ do_tx_push(msg, trace)\n+ elif name == \"complete\":\n+ do_tx_complete(msg, trace)\n+ else:\n+ print(\"Error: unrecognized Tx event name: %s\" % msg.event.name, file=sys.stderr)\n+ raise ValueError()\n+\n+\n+def main() -> int:\n+ \"\"\"Script entry point\"\"\"\n+ try:\n+ parser = argparse.ArgumentParser()\n+ parser.add_argument(\"path\", nargs=1, type=str, help=\"input trace folder\")\n+ args = parser.parse_args()\n+\n+ mlx_tr = MlxTrace()\n+ msg_it = bt2.TraceCollectionMessageIterator(args.path)\n+ mlx_tr.run(msg_it)\n+ mlx_tr.log()\n+ return 0\n+ except ValueError:\n+ return -1\n+\n+\n+if __name__ == \"__main__\":\n+ sys.exit(main())\n", "prefixes": [ "v5", "3/4" ] }