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 A97D046EF7; Wed, 24 Sep 2025 16:42:57 +0200 (CEST) Received: from mails.dpdk.org (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 7FF9D40DCA; Wed, 24 Sep 2025 16:42:14 +0200 (CEST) Received: from egress-ip11b.ess.de.barracuda.com (egress-ip11b.ess.de.barracuda.com [18.185.115.215]) by mails.dpdk.org (Postfix) with ESMTP id 3EEE840A6D for ; Wed, 24 Sep 2025 16:42:04 +0200 (CEST) Received: from AS8PR04CU009.outbound.protection.outlook.com (mail-westeuropeazon11021092.outbound.protection.outlook.com [52.101.70.92]) by mx-outbound22-32.eu-central-1b.ess.aws.cudaops.com (version=TLSv1.2 cipher=ECDHE-RSA-AES256-GCM-SHA384 bits=256 verify=NO); Wed, 24 Sep 2025 14:42:01 +0000 ARC-Seal: i=1; a=rsa-sha256; s=arcselector10001; d=microsoft.com; cv=none; b=Q3S1wN9z0FTu/DPrq064Cb1T/skBRN10SLfIi25Z6MaTqQpHhN8WtKPPKxI2TB55NFPuPbxSVpyu1kDmFjhOsn6B4BrWI7P2UIuAFNtyj8Ro7DXhKMKeEc7BxeElGe076p0xPv3NTZweAz0rD2M2wa9RNXlCO6c3FHvkP/BeQm1g7FY6EYk5fv20McY0moU5Fg9a1RNQRGG3nzsfYxqCB0rvkdW9E9sSz3BQuvM/o5RefK5d/+SAEHCYFss3JUnPKXfJmGT0Q9aQKDwY4GBpI7tkXWYHeVVBc9EoPfxbjfe6AKASM6SiDDQqAuXRbkozfuhTqcy2bDgWz6vZBIFrww== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com; s=arcselector10001; 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; bh=BO6OUAEr4TkJS+jCwxt6Swrvhs3gascSHLxN19sRxxM=; b=b6We0UaFbJyYLreR+JwM5ePzz9ldsJip/gk5R/hekdNg+9SKjgXFVyxDRh+mJioojumJBkkhuCkw5+sCwjld9OBn5Qpp5LZowNn0AusNaS8YVj+CKHqtDFpt8Pz7QrdguZi6mCqArir1oy+PXtBugj6z6pKPbpukzqZFs08BwQG7+EWbRbFVk8CycmvUWHvRShzyMb8k6o0CX8i3rIdZNrMOoYm4MuEUbWZdPXbH3sc8QRR8NOn7hvU0QiM+rd9JDxK9OSCpfESN7DaIHTdUBv8nkUOzuuKS4SC6GtRyk6iCU8p8sfD1kvJQ0/wqxY2UCOPFJvS+qEAEwnSwfphBEw== ARC-Authentication-Results: i=1; mx.microsoft.com 1; spf=fail (sender ip is 178.72.21.4) smtp.rcpttodomain=dpdk.org smtp.mailfrom=napatech.com; dmarc=fail (p=reject sp=reject pct=100) action=oreject header.from=napatech.com; dkim=none (message not signed); arc=none (0) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=napatech.com; s=selector1; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck; bh=BO6OUAEr4TkJS+jCwxt6Swrvhs3gascSHLxN19sRxxM=; b=afIUyj+qMZF2kbVyu1lHhjiH9XPfP7cd06DQT6dA5WlgtwLH6GelEoN22l3zX9P9c0+zaN/+ci/i/INZXx4G7EsA52XRvPHPgJaue18Ercor9BeEMh1Wny3v9OHz05AGuKp9YmBLZe9DOHpBWpKCaFB2sPR0Mf+veRzSu38wf8g= Received: from CWLP123CA0240.GBRP123.PROD.OUTLOOK.COM (2603:10a6:400:19f::13) by AM9P190MB1315.EURP190.PROD.OUTLOOK.COM (2603:10a6:20b:26d::13) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.9160.9; Wed, 24 Sep 2025 14:42:00 +0000 Received: from AM4PEPF00027A69.eurprd04.prod.outlook.com (2603:10a6:400:19f:cafe::6f) by CWLP123CA0240.outlook.office365.com (2603:10a6:400:19f::13) with Microsoft SMTP Server (version=TLS1_3, cipher=TLS_AES_256_GCM_SHA384) id 15.20.9137.21 via Frontend Transport; Wed, 24 Sep 2025 14:42:00 +0000 X-MS-Exchange-Authentication-Results: spf=fail (sender IP is 178.72.21.4) smtp.mailfrom=napatech.com; dkim=none (message not signed) header.d=none;dmarc=fail action=oreject header.from=napatech.com; Received-SPF: Fail (protection.outlook.com: domain of napatech.com does not designate 178.72.21.4 as permitted sender) receiver=protection.outlook.com; client-ip=178.72.21.4; helo=localhost.localdomain; Received: from localhost.localdomain (178.72.21.4) by AM4PEPF00027A69.mail.protection.outlook.com (10.167.16.87) with Microsoft SMTP Server id 15.20.9160.9 via Frontend Transport; Wed, 24 Sep 2025 14:42:00 +0000 From: Serhii Iliushyk To: dev@dpdk.org Cc: mko-plv@napatech.com, sil-plv@napatech.com, ckm@napatech.com, stephen@networkplumber.org Subject: [PATCH v1 05/24] net/ntnic: migrate adapter mon thread to service Date: Wed, 24 Sep 2025 16:41:28 +0200 Message-ID: <20250924144152.53203-6-sil-plv@napatech.com> X-Mailer: git-send-email 2.45.0 In-Reply-To: <20250924144152.53203-1-sil-plv@napatech.com> References: <20250908141740.1312268-2-sil-plv@napatech.com> <20250924144152.53203-1-sil-plv@napatech.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-EOPAttributedMessage: 0 X-MS-PublicTrafficType: Email X-MS-TrafficTypeDiagnostic: AM4PEPF00027A69:EE_|AM9P190MB1315:EE_ Content-Type: text/plain X-MS-Office365-Filtering-Correlation-Id: 3262b1e5-d633-41f9-3a6f-08ddfb788521 X-MS-Exchange-SenderADCheck: 1 X-MS-Exchange-AntiSpam-Relay: 0 X-Microsoft-Antispam: BCL:0; ARA:13230040|82310400026|376014|1800799024|36860700013; X-Microsoft-Antispam-Message-Info: =?us-ascii?Q?orDULblemgJhGzWzEoXZvJGzRDWiZpxwzuqjM+rv5mkgXOAUbgy/Y2/jvAjO?= =?us-ascii?Q?wYMyttzGhGDvDv+KFZeX+dlO9gHk6qD5qYdgc5CaoLcWJKB4aLrJAv8MiLVA?= =?us-ascii?Q?Tqu6EmO99SlTiPC40bNnwV27Je3UmA5BAsFzZfcXjPvVBLMDw2CSkLMPVjFi?= =?us-ascii?Q?b807TIm/ruSGLDtDeZjK6z1zXe0QvGpOBqBWtq4SJ7QxjE813SvkEbau9Tth?= =?us-ascii?Q?/oBA/tsLmBbVyPY7ED+MdVVBHMFoP2WPvpd4oayjrwYTdgxCo5jDkR6YNGr2?= =?us-ascii?Q?UkUANDiLk2wSr+r3WWnP6tjTUvWU9QtiRdHv9msL4bepcgiUc6U5+l0rwB5p?= =?us-ascii?Q?SFlPnzUIQkAIZFLdqCkvFHCKMhsFnvaqr7NJQq94oDzlSGzp18/XFc8xyHRR?= =?us-ascii?Q?B5ygzrxwmsoiEYMw+NZV2fRWwCGdHlkL0wuowSALd0PRLpssO5gauo5gyjF7?= =?us-ascii?Q?4ATg3Qbfa8/wWLn9emW1g3copwfYjlmIMhJl9O/VTh9icv2uy27lVqu4jVMY?= =?us-ascii?Q?z47xzMuu4t+ZkF8zp6GgmuG8AG/Lb3Y1gBr45pIG7wMX/DephppFrQ1AyGAr?= =?us-ascii?Q?PxwXGeqWZpmoAlpwT7C69wkoThvRZqtSSLzZtesxC6AYqRPF/Txu+u2g7AWD?= =?us-ascii?Q?rhykaG0ZsTkn4Fctk3V0B3VpSIn74F6FOLUZ2Pzt/zDzD5FXFinwNgEOl4uT?= =?us-ascii?Q?3+uZTrGY40/E6kVb540aNoWDFMrC6OIH7TpLKmouFXFxLD/jH/vvzwFUSVPD?= =?us-ascii?Q?cBw/skEUFYT2Kt4QuEh+tE9gXllaU+sqj38vsdBP2AXYWo4dLF8MLg86K6EN?= =?us-ascii?Q?+aFSF2h0dgEH0ug73uzhXe38CDYJ3LEp5Xl4HSPheTRAktT8rvLzUaMJOoj2?= =?us-ascii?Q?KYEwsna/Bsu9taSEPMv8L6Mt4Qntt66/Y4GynISDYvlZbt7gvLiOySINurTU?= =?us-ascii?Q?JZfxtpGyl++SsOqFDqWJRjcDIsJSn6ezFdq2cF8H4/q5uNJiEl4JMbPjEst6?= =?us-ascii?Q?zTY7WLfggaQogPa7ZvxdJEkBniGzbmXHiTonntu+x6ocZR3yeNi1v6FZ3tNL?= =?us-ascii?Q?61bfvP8Ym/xf28tRhiRDJ0NP6/YHYsobIY4RmiCQjmxvO9Xi0gLGcpFvRMol?= =?us-ascii?Q?L3+TdfzMF4i6EIyQ9nOosTg0wcCjhEdUPOLHAIvw2QZL9ZOPZt57y5lBVKvG?= =?us-ascii?Q?tq1sjoRPb2zBqB0E2iiGE/4RKwtbAfbF6Dug7iOQ5WHlzkenqrZ6jIS2ndNc?= =?us-ascii?Q?3JaEsRrA55Z6bEo3sxymtEYVSl8DzT8Z6AXP8yapVYDqY7BKCO26ZZKZdQ+C?= =?us-ascii?Q?RWZnGSif+SEKpQI4gDSktJGMs0ucQNuW8GBg3eX1dgpq80k7Gzu1XDaz5ndG?= =?us-ascii?Q?J4SxSgqJ2jZcVWJctRK+e825rRSLuuCFaZY1+vAoojpYapvTE1fuj7UTgalZ?= =?us-ascii?Q?OyRcqzcBMepxGXovCaoJY1moqzrE2QKyAYHt6x542WOmE3SsGnAB55OJHLr8?= =?us-ascii?Q?eFCnYI1D1K5mL1WHfSCZCYVhzdQf/uQUtOcJ?= X-Forefront-Antispam-Report: CIP:178.72.21.4; CTRY:DK; LANG:en; SCL:1; SRV:; IPV:NLI; SFV:NSPM; H:localhost.localdomain; PTR:InfoDomainNonexistent; CAT:NONE; SFS:(13230040)(82310400026)(376014)(1800799024)(36860700013); DIR:OUT; SFP:1102; X-MS-Exchange-AntiSpam-ExternalHop-MessageData-ChunkCount: 1 X-MS-Exchange-AntiSpam-ExternalHop-MessageData-0: WZB+M5Z33vikHODQLFA+69AWTtXD7C2ov1yCjsphyyXEHaCbP2b+aUVtpzSMkCRYspta6hOWar0HVApIbszP4dD7Kb5B8xfZo1UN783WjjeqGyfFJiKwuGyLLs0E2bBN0J1WOc4/bi3JLYrGGa/EtArprQm1GZTq5I8cD5aQfwotF+Z5LgI0yD0gAYaU22eTuzVYGtGnL+r8zkiO8UhuK5ManNoXTPWUoxIhsOSxQSLuzF77TJoqd2Vez7Br3oeLiM5Evdpo/gZupmf+xwn9L2Ha7uKKTBBGD78stojkJcE1J7TZih9vjbo3mx/kOk/Cwj8nDOEWjiTLTGGeeklePTadbQjEuflc8asjUZzTguWy5KIj6z8D8mlkX5AjcnOvxAUKJnBIlWuDv0HWV+JyARB4M3AguxtaqImZRNkFyFFfIzkT8UIDyPTbPPUzk6MrdBh8g+J3Aok7D5ZEE4ndmRMDVwjOBg6yv3EHyyixKAm10OVwAHAQB6WPqjoXku1OWeLMKWXGxVa+m5zVGXfMlHOVBFIVIVzB9qp3otX+p2PSFPrEnX4tkZx1Z32H+5tH2U1u7Km9iNik7FfyeHw+4CJ3oq9nUAlsNW+5K/j6uL4AjzpAexgy3/lW75RnoV6noZoNjivgqdhpm8u7A3ymaw== X-OriginatorOrg: napatech.com X-MS-Exchange-CrossTenant-OriginalArrivalTime: 24 Sep 2025 14:42:00.3658 (UTC) X-MS-Exchange-CrossTenant-Network-Message-Id: 3262b1e5-d633-41f9-3a6f-08ddfb788521 X-MS-Exchange-CrossTenant-Id: c4540d0b-728a-4233-9da5-9ea30c7ec3ed X-MS-Exchange-CrossTenant-OriginalAttributedTenantConnectingIp: TenantId=c4540d0b-728a-4233-9da5-9ea30c7ec3ed; Ip=[178.72.21.4]; Helo=[localhost.localdomain] X-MS-Exchange-CrossTenant-AuthSource: AM4PEPF00027A69.eurprd04.prod.outlook.com X-MS-Exchange-CrossTenant-AuthAs: Anonymous X-MS-Exchange-CrossTenant-FromEntityHeader: HybridOnPrem X-MS-Exchange-Transport-CrossTenantHeadersStamped: AM9P190MB1315 X-BESS-ID: 1758724921-305664-7614-7974-1 X-BESS-VER: 2019.1_20250904.2304 X-BESS-Apparent-Source-IP: 52.101.70.92 X-BESS-Parts: H4sIAAAAAAACA4uuVkqtKFGyUioBkjpK+cVKVkaWRhaWQGYGUNTCyMTczMw4Nd XE0MTQ0tzEJNHIODkpzdAgJSktxcjCQqk2FgBeFZrMQgAAAA== X-BESS-Outbound-Spam-Score: 0.50 X-BESS-Outbound-Spam-Report: Code version 3.2, rules version 3.2.2.267723 [from cloudscan22-209.eu-central-1b.ess.aws.cudaops.com] Rule breakdown below pts rule name description ---- ---------------------- -------------------------------- 0.50 BSF_RULE7568M META: Custom Rule 7568M 0.00 BSF_BESS_OUTBOUND META: BESS Outbound X-BESS-Outbound-Spam-Status: SCORE=0.50 using account:ESS113687 scores of KILL_LEVEL=7.0 tests=BSF_RULE7568M, BSF_BESS_OUTBOUND X-BESS-BRTS-Status: 1 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 adapter monitor service is responsible for link state management. Signed-off-by: Serhii Iliushyk --- drivers/net/ntnic/adapter/nt4ga_adapter.c | 25 +- .../net/ntnic/include/common_adapter_defs.h | 15 - drivers/net/ntnic/include/nt4ga_adapter.h | 3 - drivers/net/ntnic/include/ntnic_stat.h | 2 +- drivers/net/ntnic/include/ntos_drv.h | 2 +- .../link_mgmt/link_100g/nt4ga_link_100g.c | 303 +++++++++-------- .../link_agx_100g/nt4ga_agx_link_100g.c | 306 ++++++++++-------- drivers/net/ntnic/ntutil/nt_service.c | 6 + drivers/net/ntnic/rte_pmd_ntnic.h | 1 + 9 files changed, 334 insertions(+), 329 deletions(-) delete mode 100644 drivers/net/ntnic/include/common_adapter_defs.h diff --git a/drivers/net/ntnic/adapter/nt4ga_adapter.c b/drivers/net/ntnic/adapter/nt4ga_adapter.c index 526ecc8089..363874c85f 100644 --- a/drivers/net/ntnic/adapter/nt4ga_adapter.c +++ b/drivers/net/ntnic/adapter/nt4ga_adapter.c @@ -5,6 +5,7 @@ #include +#include "nt_service.h" #include "ntlog.h" #include "nthw_fpga.h" #include "ntnic_mod_reg.h" @@ -12,28 +13,6 @@ /* * Global variables shared by NT adapter types */ -rte_thread_t monitor_tasks[NUM_ADAPTER_MAX]; -volatile int monitor_task_is_running[NUM_ADAPTER_MAX]; - -/* - * Signal-handler to stop all monitor threads - */ -static void stop_monitor_tasks(int signum) -{ - const size_t N = ARRAY_SIZE(monitor_task_is_running); - size_t i; - - /* Stop all monitor tasks */ - for (i = 0; i < N; i++) { - const int is_running = monitor_task_is_running[i]; - monitor_task_is_running[i] = 0; - - if (signum == -1 && is_running != 0) { - rte_thread_join(monitor_tasks[i], NULL); - memset(&monitor_tasks[i], 0, sizeof(monitor_tasks[0])); - } - } -} static int nt4ga_adapter_show_info(struct adapter_info_s *p_adapter_info, FILE *pfh) { @@ -255,7 +234,7 @@ static int nt4ga_adapter_deinit(struct adapter_info_s *p_adapter_info) int i; int res = -1; - stop_monitor_tasks(-1); + nthw_service_del(RTE_NTNIC_SERVICE_ADAPTER_MON); /* Nt4ga Deinit Filter */ nt4ga_filter_t *p_filter = &p_adapter_info->nt4ga_filter; diff --git a/drivers/net/ntnic/include/common_adapter_defs.h b/drivers/net/ntnic/include/common_adapter_defs.h deleted file mode 100644 index 6ed9121f0f..0000000000 --- a/drivers/net/ntnic/include/common_adapter_defs.h +++ /dev/null @@ -1,15 +0,0 @@ -/* - * SPDX-License-Identifier: BSD-3-Clause - * Copyright(c) 2023 Napatech A/S - */ - -#ifndef _COMMON_ADAPTER_DEFS_H_ -#define _COMMON_ADAPTER_DEFS_H_ - -/* - * Declarations shared by NT adapter types. - */ -#define NUM_ADAPTER_MAX (8) -#define NUM_ADAPTER_PORTS_MAX (128) - -#endif /* _COMMON_ADAPTER_DEFS_H_ */ diff --git a/drivers/net/ntnic/include/nt4ga_adapter.h b/drivers/net/ntnic/include/nt4ga_adapter.h index 7396b8ab65..6c701b601f 100644 --- a/drivers/net/ntnic/include/nt4ga_adapter.h +++ b/drivers/net/ntnic/include/nt4ga_adapter.h @@ -47,8 +47,5 @@ typedef struct adapter_info_s { int n_tx_host_buffers; } adapter_info_t; -extern rte_thread_t monitor_tasks[NUM_ADAPTER_MAX]; -extern volatile int monitor_task_is_running[NUM_ADAPTER_MAX]; - #endif /* _NT4GA_ADAPTER_H_ */ diff --git a/drivers/net/ntnic/include/ntnic_stat.h b/drivers/net/ntnic/include/ntnic_stat.h index 1b53f6c347..928c629fb2 100644 --- a/drivers/net/ntnic/include/ntnic_stat.h +++ b/drivers/net/ntnic/include/ntnic_stat.h @@ -6,7 +6,7 @@ #ifndef NTNIC_STAT_H_ #define NTNIC_STAT_H_ -#include "common_adapter_defs.h" +#include "ntos_drv.h" #include "nthw_rmc.h" #include "nthw_rpf.h" #include "nthw_fpga_model.h" diff --git a/drivers/net/ntnic/include/ntos_drv.h b/drivers/net/ntnic/include/ntos_drv.h index e6e46f8cc1..f353a5eca8 100644 --- a/drivers/net/ntnic/include/ntos_drv.h +++ b/drivers/net/ntnic/include/ntos_drv.h @@ -20,7 +20,7 @@ #define NUM_MAC_ADDRS_PER_PORT (16U) #define NUM_MULTICAST_ADDRS_PER_PORT (16U) -#define NUM_ADAPTER_MAX (8) +#define NUM_ADAPTER_MAX (1) #define NUM_ADAPTER_PORTS_MAX (2) diff --git a/drivers/net/ntnic/link_mgmt/link_100g/nt4ga_link_100g.c b/drivers/net/ntnic/link_mgmt/link_100g/nt4ga_link_100g.c index adb187d322..21e95d84bd 100644 --- a/drivers/net/ntnic/link_mgmt/link_100g/nt4ga_link_100g.c +++ b/drivers/net/ntnic/link_mgmt/link_100g/nt4ga_link_100g.c @@ -9,6 +9,7 @@ #include "ntlog.h" #include "i2c_nim.h" #include "ntnic_mod_reg.h" +#include "nt_service.h" /* * Swap tx/rx polarity @@ -478,170 +479,178 @@ static int _port_init(adapter_info_t *drv, nthw_fpga_t *fpga, int port) */ static int _common_ptp_nim_state_machine(void *data) { - adapter_info_t *drv = (adapter_info_t *)data; - fpga_info_t *fpga_info = &drv->fpga_info; - nt4ga_link_t *link_info = &drv->nt4ga_link; - nthw_fpga_t *fpga = fpga_info->mp_fpga; - const int adapter_no = drv->adapter_no; - const int nb_ports = fpga_info->n_phy_ports; - uint32_t last_lpbk_mode[NUM_ADAPTER_PORTS_MAX]; + static adapter_info_t *drv; + static nt4ga_link_t *link_info; + static nthw_fpga_t *fpga; + static int nb_ports; + static nim_i2c_ctx_t *nim_ctx; + static link_state_t *link_state; + static nthw_mac_pcs_t *mac_pcs; + static nthw_gpio_phy_t *gpio_phy; + static uint32_t last_lpbk_mode[NUM_ADAPTER_PORTS_MAX]; + + struct nt_service *adapter_mon_srv = nthw_service_get_info(RTE_NTNIC_SERVICE_ADAPTER_MON); + RTE_ASSERT(adapter_mon_srv != NULL); + + if (!NT_SERVICE_GET_STATE(adapter_mon_srv)) { + drv = (adapter_info_t *)data; + RTE_ASSERT(drv != NULL); + + fpga_info_t *fpga_info = &drv->fpga_info; + int adapter_no = drv->adapter_no; + + link_info = &drv->nt4ga_link; + fpga = fpga_info->mp_fpga; + nb_ports = fpga_info->n_phy_ports; + + if (!fpga) { + NT_LOG(ERR, NTNIC, "%s: fpga is NULL", drv->mp_adapter_id_str); + return -1; + } - nim_i2c_ctx_t *nim_ctx; - link_state_t *link_state; - nthw_mac_pcs_t *mac_pcs; - nthw_gpio_phy_t *gpio_phy; + RTE_ASSERT(adapter_no >= 0 && adapter_no < NUM_ADAPTER_MAX); + nim_ctx = link_info->u.var100g.nim_ctx; + link_state = link_info->link_state; + mac_pcs = link_info->u.var100g.mac_pcs100g; + gpio_phy = link_info->u.var100g.gpio_phy; - if (!fpga) { - NT_LOG(ERR, NTNIC, "%s: fpga is NULL", drv->mp_adapter_id_str); - goto NT4GA_LINK_100G_MON_EXIT; - } + memset(last_lpbk_mode, 0, sizeof(last_lpbk_mode)); - RTE_ASSERT(adapter_no >= 0 && adapter_no < NUM_ADAPTER_MAX); - nim_ctx = link_info->u.var100g.nim_ctx; - link_state = link_info->link_state; - mac_pcs = link_info->u.var100g.mac_pcs100g; - gpio_phy = link_info->u.var100g.gpio_phy; + NT_LOG(DBG, NTNIC, "%s: link state machine running...", drv->mp_adapter_id_str); - monitor_task_is_running[adapter_no] = 1; - memset(last_lpbk_mode, 0, sizeof(last_lpbk_mode)); + NT_LOG(INF, NTNIC, "Adapter monitor service started on lcore %i", rte_lcore_id()); + adapter_mon_srv->lcore = rte_lcore_id(); + NT_SERVICE_SET_STATE(adapter_mon_srv, true); + return 0; + } - if (monitor_task_is_running[adapter_no]) - NT_LOG(DBG, NTNIC, "%s: link state machine running...", drv->mp_adapter_id_str); + int i; + static bool reported_link[NUM_ADAPTER_PORTS_MAX] = { false }; - while (monitor_task_is_running[adapter_no]) { - int i; - static bool reported_link[NUM_ADAPTER_PORTS_MAX] = { false }; + for (i = 0; i < nb_ports; i++) { + link_state_t new_link_state; + const bool is_port_disabled = link_info->port_action[i].port_disable; + const bool was_port_disabled = link_state[i].link_disabled; + const bool disable_port = is_port_disabled && !was_port_disabled; + const bool enable_port = !is_port_disabled && was_port_disabled; - for (i = 0; i < nb_ports; i++) { - link_state_t new_link_state; - const bool is_port_disabled = link_info->port_action[i].port_disable; - const bool was_port_disabled = link_state[i].link_disabled; - const bool disable_port = is_port_disabled && !was_port_disabled; - const bool enable_port = !is_port_disabled && was_port_disabled; + if (!rte_service_runstate_get(adapter_mon_srv->id)) /* stop quickly */ + break; - if (!monitor_task_is_running[adapter_no]) /* stop quickly */ - break; + /* Has the administrative port state changed? */ + RTE_ASSERT(!(disable_port && enable_port)); + + if (disable_port) { + memset(&link_state[i], 0, sizeof(link_state[i])); + link_info->link_info[i].link_speed = NT_LINK_SPEED_UNKNOWN; + link_state[i].link_disabled = true; + reported_link[i] = false; + /* Turn off laser and LED, etc. */ + (void)_create_nim(drv, i, false); + NT_LOG(DBG, NTNIC, "%s: Port %i is disabled", + drv->mp_port_id_str[i], i); + continue; + } - /* Has the administrative port state changed? */ - RTE_ASSERT(!(disable_port && enable_port)); - - if (disable_port) { - memset(&link_state[i], 0, sizeof(link_state[i])); - link_info->link_info[i].link_speed = NT_LINK_SPEED_UNKNOWN; - link_state[i].link_disabled = true; - reported_link[i] = false; - /* Turn off laser and LED, etc. */ - (void)_create_nim(drv, i, false); - NT_LOG(DBG, NTNIC, "%s: Port %i is disabled", - drv->mp_port_id_str[i], i); - continue; - } + if (enable_port) { + link_state[i].link_disabled = false; + NT_LOG(DBG, NTNIC, "%s: Port %i is enabled", + drv->mp_port_id_str[i], i); + } - if (enable_port) { - link_state[i].link_disabled = false; - NT_LOG(DBG, NTNIC, "%s: Port %i is enabled", - drv->mp_port_id_str[i], i); + if (is_port_disabled) + continue; + + if (link_info->port_action[i].port_lpbk_mode != last_lpbk_mode[i]) { + /* Loopback mode has changed. Do something */ + if (!_nim_is_present(&gpio_phy[i], (uint8_t)i)) { + /* + * If there is no Nim present, we need to initialize the + * port anyway + */ + _port_init(drv, fpga, i); } - if (is_port_disabled) - continue; + NT_LOG(INF, NTNIC, "%s: Loopback mode changed=%u", + drv->mp_port_id_str[i], + link_info->port_action[i].port_lpbk_mode); + _set_loopback(drv, + &mac_pcs[i], + i, + link_info->port_action[i].port_lpbk_mode, + last_lpbk_mode[i]); - if (link_info->port_action[i].port_lpbk_mode != last_lpbk_mode[i]) { - /* Loopback mode has changed. Do something */ - if (!_nim_is_present(&gpio_phy[i], (uint8_t)i)) { - /* - * If there is no Nim present, we need to initialize the - * port anyway - */ - _port_init(drv, fpga, i); - } - - NT_LOG(INF, NTNIC, "%s: Loopback mode changed=%u", - drv->mp_port_id_str[i], - link_info->port_action[i].port_lpbk_mode); - _set_loopback(drv, - &mac_pcs[i], - i, - link_info->port_action[i].port_lpbk_mode, - last_lpbk_mode[i]); - - if (link_info->port_action[i].port_lpbk_mode == 1) - link_state[i].link_up = true; - - last_lpbk_mode[i] = link_info->port_action[i].port_lpbk_mode; - continue; - } + if (link_info->port_action[i].port_lpbk_mode == 1) + link_state[i].link_up = true; - (void)_link_state_build(drv, &mac_pcs[i], &gpio_phy[i], i, &new_link_state, - is_port_disabled); + last_lpbk_mode[i] = link_info->port_action[i].port_lpbk_mode; + continue; + } - if (!new_link_state.nim_present) { - if (link_state[i].nim_present) { - NT_LOG(INF, NTNIC, "%s: NIM module removed", - drv->mp_port_id_str[i]); - } + (void)_link_state_build(drv, &mac_pcs[i], &gpio_phy[i], i, &new_link_state, + is_port_disabled); - link_state[i] = new_link_state; - continue; + if (!new_link_state.nim_present) { + if (link_state[i].nim_present) { + NT_LOG(INF, NTNIC, "%s: NIM module removed", + drv->mp_port_id_str[i]); } - /* NIM module is present */ - if (new_link_state.lh_nim_absent || !link_state[i].nim_present) { - sfp_nim_state_t new_state; + link_state[i] = new_link_state; + continue; + } - NT_LOG(DBG, NTNIC, "%s: NIM module inserted", - drv->mp_port_id_str[i]); + /* NIM module is present */ + if (new_link_state.lh_nim_absent || !link_state[i].nim_present) { + sfp_nim_state_t new_state; + + NT_LOG(DBG, NTNIC, "%s: NIM module inserted", + drv->mp_port_id_str[i]); - if (_port_init(drv, fpga, i)) { - NT_LOG(ERR, NTNIC, - "%s: Failed to initialize NIM module", - drv->mp_port_id_str[i]); - continue; - } - - if (nthw_nim_state_build(&nim_ctx[i], &new_state)) { - NT_LOG(ERR, NTNIC, "%s: Cannot read basic NIM data", - drv->mp_port_id_str[i]); - continue; - } - - RTE_ASSERT(new_state.br); /* Cannot be zero if NIM is present */ - NT_LOG(DBG, NTNIC, - "%s: NIM id = %u (%s), br = %u, vendor = '%s', pn = '%s', sn='%s'", - drv->mp_port_id_str[i], nim_ctx->nim_id, - nthw_nim_id_to_text(nim_ctx->nim_id), - (unsigned int)new_state.br, nim_ctx->vendor_name, - nim_ctx->prod_no, nim_ctx->serial_no); - - (void)_link_state_build(drv, &mac_pcs[i], &gpio_phy[i], i, - &link_state[i], is_port_disabled); - - NT_LOG(DBG, NTNIC, "%s: NIM module initialized", + if (_port_init(drv, fpga, i)) { + NT_LOG(ERR, NTNIC, + "%s: Failed to initialize NIM module", drv->mp_port_id_str[i]); continue; } - if (reported_link[i] != new_link_state.link_up) { - NT_LOG(INF, NTNIC, "%s: link is %s", drv->mp_port_id_str[i], - (new_link_state.link_up ? "up" : "down")); - link_info->link_info[i].link_speed = - (new_link_state.link_up ? NT_LINK_SPEED_100G - : NT_LINK_SPEED_UNKNOWN); - link_state[i].link_up = new_link_state.link_up; - reported_link[i] = new_link_state.link_up; + if (nthw_nim_state_build(&nim_ctx[i], &new_state)) { + NT_LOG(ERR, NTNIC, "%s: Cannot read basic NIM data", + drv->mp_port_id_str[i]); + continue; } - check_link_state(drv, &mac_pcs[i]); - } /* end-for */ + RTE_ASSERT(new_state.br); /* Cannot be zero if NIM is present */ + NT_LOG(DBG, NTNIC, + "%s: NIM id = %u (%s), br = %u, vendor = '%s', pn = '%s', sn='%s'", + drv->mp_port_id_str[i], nim_ctx->nim_id, + nthw_nim_id_to_text(nim_ctx->nim_id), + (unsigned int)new_state.br, nim_ctx->vendor_name, + nim_ctx->prod_no, nim_ctx->serial_no); - if (monitor_task_is_running[adapter_no]) - nt_os_wait_usec(5 * 100000U); /* 5 x 0.1s = 0.5s */ - } + (void)_link_state_build(drv, &mac_pcs[i], &gpio_phy[i], i, + &link_state[i], is_port_disabled); -NT4GA_LINK_100G_MON_EXIT: + NT_LOG(DBG, NTNIC, "%s: NIM module initialized", + drv->mp_port_id_str[i]); + continue; + } - NT_LOG(DBG, NTNIC, "%s: Stopped NT4GA 100 Gbps link monitoring thread.", - drv->mp_adapter_id_str); + if (reported_link[i] != new_link_state.link_up) { + NT_LOG(INF, NTNIC, "%s: link is %s", drv->mp_port_id_str[i], + (new_link_state.link_up ? "up" : "down")); + link_info->link_info[i].link_speed = + (new_link_state.link_up ? NT_LINK_SPEED_100G + : NT_LINK_SPEED_UNKNOWN); + link_state[i].link_up = new_link_state.link_up; + reported_link[i] = new_link_state.link_up; + } + + check_link_state(drv, &mac_pcs[i]); + } /* end-for */ + + if (rte_service_runstate_get(adapter_mon_srv->id)) + nt_os_wait_usec(5 * 100000U); /* 5 x 0.1s = 0.5s */ return 0; } @@ -649,11 +658,9 @@ static int _common_ptp_nim_state_machine(void *data) /* * Userland NIM state machine */ -static uint32_t nt4ga_link_100g_mon(void *data) +static int nt4ga_link_100g_mon(void *data) { - (void)_common_ptp_nim_state_machine(data); - - return 0; + return _common_ptp_nim_state_machine(data); } /* @@ -710,11 +717,21 @@ static int nt4ga_link_100g_ports_init(struct adapter_info_s *p_adapter_info, nth } } - /* Create state-machine thread */ + /* Create state-machine service */ if (res == 0) { - if (!monitor_task_is_running[adapter_no]) { - res = rte_thread_create(&monitor_tasks[adapter_no], NULL, - nt4ga_link_100g_mon, p_adapter_info); + struct rte_service_spec adapter_monitor_service = { + .name = "ntnic-adapter-monitor", + .callback = nt4ga_link_100g_mon, + .socket_id = SOCKET_ID_ANY, + .capabilities = RTE_SERVICE_CAP_MT_SAFE, + .callback_userdata = p_adapter_info, + }; + + res = nthw_service_add(&adapter_monitor_service, RTE_NTNIC_SERVICE_ADAPTER_MON); + if (res) { + NT_LOG(ERR, NTNIC, "%s: Failed to create adapter monitor service", + p_adapter_info->mp_adapter_id_str); + return res; } } diff --git a/drivers/net/ntnic/link_mgmt/link_agx_100g/nt4ga_agx_link_100g.c b/drivers/net/ntnic/link_mgmt/link_agx_100g/nt4ga_agx_link_100g.c index 75a7504510..c8b7912e26 100644 --- a/drivers/net/ntnic/link_mgmt/link_agx_100g/nt4ga_agx_link_100g.c +++ b/drivers/net/ntnic/link_mgmt/link_agx_100g/nt4ga_agx_link_100g.c @@ -13,6 +13,7 @@ #include "nim_defines.h" #include "nthw_gfg.h" #include "nthw_phy_tile.h" +#include "nt_service.h" typedef enum { LOOPBACK_HOST_NONE, @@ -768,179 +769,186 @@ static int _port_init(adapter_info_t *p_info, nthw_fpga_t *fpga, int port) /* * Link state machine */ -static void *_common_ptp_nim_state_machine(void *data) +static int _common_ptp_nim_state_machine(void *data) { - adapter_info_t *drv = (adapter_info_t *)data; - fpga_info_t *fpga_info = &drv->fpga_info; - nt4ga_link_t *link_info = &drv->nt4ga_link; - nthw_fpga_t *fpga = fpga_info->mp_fpga; - const int adapter_no = drv->adapter_no; - const int nb_ports = fpga_info->n_phy_ports; - uint32_t last_lpbk_mode[NUM_ADAPTER_PORTS_MAX]; - /* link_state_t new_link_state; */ - - link_state_t *link_state = link_info->link_state; - nim_i2c_ctx_t *nim_ctx = link_info->u.var_a100g.nim_ctx; + static adapter_info_t *drv; + static nt4ga_link_t *link_info; + static nthw_fpga_t *fpga; + static int nb_ports; + static link_state_t *link_state; + static nim_i2c_ctx_t *nim_ctx; + static uint32_t last_lpbk_mode[NUM_ADAPTER_PORTS_MAX]; + + struct nt_service *adapter_mon_srv = nthw_service_get_info(RTE_NTNIC_SERVICE_ADAPTER_MON); + RTE_ASSERT(adapter_mon_srv != NULL); + + if (!NT_SERVICE_GET_STATE(adapter_mon_srv)) { + drv = (adapter_info_t *)data; + RTE_ASSERT(drv != NULL); + + fpga_info_t *fpga_info = &drv->fpga_info; + link_info = &drv->nt4ga_link; + fpga = fpga_info->mp_fpga; + int adapter_no = drv->adapter_no; + + nb_ports = fpga_info->n_phy_ports; + link_state = link_info->link_state; + nim_ctx = link_info->u.var_a100g.nim_ctx; + + if (!fpga) { + NT_LOG(ERR, NTNIC, "%s: fpga is NULL", drv->mp_adapter_id_str); + return -1; + } - if (!fpga) { - NT_LOG(ERR, NTNIC, "%s: fpga is NULL", drv->mp_adapter_id_str); - goto NT4GA_LINK_100G_MON_EXIT; - } + RTE_ASSERT(adapter_no >= 0 && adapter_no < NUM_ADAPTER_MAX); - RTE_ASSERT(adapter_no >= 0 && adapter_no < NUM_ADAPTER_MAX); + memset(last_lpbk_mode, 0, sizeof(last_lpbk_mode)); - monitor_task_is_running[adapter_no] = 1; - memset(last_lpbk_mode, 0, sizeof(last_lpbk_mode)); + /* Initialize link state */ + for (int i = 0; i < nb_ports; i++) { + link_state[i].link_disabled = true; + link_state[i].nim_present = false; + link_state[i].lh_nim_absent = true; + link_state[i].link_up = false; + link_state[i].link_state = NT_LINK_STATE_UNKNOWN; + link_state[i].link_state_latched = NT_LINK_STATE_UNKNOWN; + } - /* Initialize link state */ - for (int i = 0; i < nb_ports; i++) { - link_state[i].link_disabled = true; - link_state[i].nim_present = false; - link_state[i].lh_nim_absent = true; - link_state[i].link_up = false; - link_state[i].link_state = NT_LINK_STATE_UNKNOWN; - link_state[i].link_state_latched = NT_LINK_STATE_UNKNOWN; + NT_LOG(INF, NTNIC, "Adapter monitor service started on lcore %i", rte_lcore_id()); + adapter_mon_srv->lcore = rte_lcore_id(); + NT_SERVICE_SET_STATE(adapter_mon_srv, true); + return 0; } - if (monitor_task_is_running[adapter_no]) - NT_LOG(DBG, NTNIC, "%s: link state machine running...", drv->mp_adapter_id_str); + int i; + static bool reported_link[NUM_ADAPTER_PORTS_MAX] = { false }; - while (monitor_task_is_running[adapter_no]) { - int i; - static bool reported_link[NUM_ADAPTER_PORTS_MAX] = { false }; + for (i = 0; i < nb_ports; i++) { + const bool is_port_disabled = link_info->port_action[i].port_disable; + const bool was_port_disabled = link_state[i].link_disabled; + const bool disable_port = is_port_disabled && !was_port_disabled; + const bool enable_port = !is_port_disabled && was_port_disabled; - for (i = 0; i < nb_ports; i++) { - const bool is_port_disabled = link_info->port_action[i].port_disable; - const bool was_port_disabled = link_state[i].link_disabled; - const bool disable_port = is_port_disabled && !was_port_disabled; - const bool enable_port = !is_port_disabled && was_port_disabled; - - if (!monitor_task_is_running[adapter_no]) - break; - - /* - * Has the administrative port state changed? - */ - RTE_ASSERT(!(disable_port && enable_port)); - - if (disable_port) { - memset(&link_state[i], 0, sizeof(link_state[i])); - link_state[i].link_disabled = true; - link_state[i].lh_nim_absent = true; - reported_link[i] = false; - port_disable(drv, i); - NT_LOG(INF, NTNIC, "%s: Port %i is disabled", - drv->mp_port_id_str[i], i); - continue; - } + if (!rte_service_runstate_get(adapter_mon_srv->id)) + break; - if (enable_port) { - link_state[i].link_disabled = false; - NT_LOG(DBG, NTNIC, "%s: Port %i is enabled", - drv->mp_port_id_str[i], i); - } + /* + * Has the administrative port state changed? + */ + RTE_ASSERT(!(disable_port && enable_port)); + + if (disable_port) { + memset(&link_state[i], 0, sizeof(link_state[i])); + link_state[i].link_disabled = true; + link_state[i].lh_nim_absent = true; + reported_link[i] = false; + port_disable(drv, i); + NT_LOG(INF, NTNIC, "%s: Port %i is disabled", + drv->mp_port_id_str[i], i); + continue; + } - if (is_port_disabled) - continue; + if (enable_port) { + link_state[i].link_disabled = false; + NT_LOG(DBG, NTNIC, "%s: Port %i is enabled", + drv->mp_port_id_str[i], i); + } - if (link_info->port_action[i].port_lpbk_mode != last_lpbk_mode[i]) { - /* Loopback mode has changed. Do something */ - if (!nim_is_present(&nim_ctx[i], i)) { - /* - * If there is no Nim present, we need to initialize the - * port anyway - */ - _port_init(drv, fpga, i); - } - - set_loopback(drv, - i, - link_info->port_action[i].port_lpbk_mode, - last_lpbk_mode[i]); - - if (link_info->port_action[i].port_lpbk_mode == 1) - link_state[i].link_up = true; - - last_lpbk_mode[i] = link_info->port_action[i].port_lpbk_mode; - continue; + if (is_port_disabled) + continue; + + if (link_info->port_action[i].port_lpbk_mode != last_lpbk_mode[i]) { + /* Loopback mode has changed. Do something */ + if (!nim_is_present(&nim_ctx[i], i)) { + /* + * If there is no Nim present, we need to initialize the + * port anyway + */ + _port_init(drv, fpga, i); } - get_link_state(drv, nim_ctx, &link_state[i], i); - link_state[i].link_disabled = is_port_disabled; + set_loopback(drv, + i, + link_info->port_action[i].port_lpbk_mode, + last_lpbk_mode[i]); - if (!link_state[i].nim_present) { - if (!link_state[i].lh_nim_absent) { - NT_LOG(INF, NTNIC, "%s: NIM module removed", - drv->mp_port_id_str[i]); - reported_link[i] = false; - link_state[i].link_up = false; - link_state[i].lh_nim_absent = true; + if (link_info->port_action[i].port_lpbk_mode == 1) + link_state[i].link_up = true; - } else { - NT_LOG(DBG, NTNIC, "%s: No NIM module, skip", - drv->mp_port_id_str[i]); - } + last_lpbk_mode[i] = link_info->port_action[i].port_lpbk_mode; + continue; + } - continue; - } + get_link_state(drv, nim_ctx, &link_state[i], i); + link_state[i].link_disabled = is_port_disabled; - /* - * NIM module is present - */ - if (link_state[i].lh_nim_absent && link_state[i].nim_present) { - sfp_nim_state_t new_state; - NT_LOG(INF, NTNIC, "%s: NIM module inserted", + if (!link_state[i].nim_present) { + if (!link_state[i].lh_nim_absent) { + NT_LOG(INF, NTNIC, "%s: NIM module removed", drv->mp_port_id_str[i]); + reported_link[i] = false; + link_state[i].link_up = false; + link_state[i].lh_nim_absent = true; - if (_port_init(drv, fpga, i)) { - NT_LOG(ERR, NTNIC, - "%s: Failed to initialize NIM module", - drv->mp_port_id_str[i]); - continue; - } + } else { + NT_LOG(DBG, NTNIC, "%s: No NIM module, skip", + drv->mp_port_id_str[i]); + } - if (nthw_nim_state_build(&nim_ctx[i], &new_state)) { - NT_LOG(ERR, NTNIC, "%s: Cannot read basic NIM data", - drv->mp_port_id_str[i]); - continue; - } + continue; + } - RTE_ASSERT(new_state.br); /* Cannot be zero if NIM is present */ - NT_LOG(DBG, NTNIC, - "%s: NIM id = %u (%s), br = %u, vendor = '%s', pn = '%s', sn='%s'", - drv->mp_port_id_str[i], nim_ctx[i].nim_id, - nthw_nim_id_to_text(nim_ctx[i].nim_id), - (unsigned int)new_state.br, nim_ctx[i].vendor_name, - nim_ctx[i].prod_no, nim_ctx[i].serial_no); - link_state[i].lh_nim_absent = false; - NT_LOG(DBG, NTNIC, "%s: NIM module initialized", + /* + * NIM module is present + */ + if (link_state[i].lh_nim_absent && link_state[i].nim_present) { + sfp_nim_state_t new_state; + NT_LOG(INF, NTNIC, "%s: NIM module inserted", + drv->mp_port_id_str[i]); + + if (_port_init(drv, fpga, i)) { + NT_LOG(ERR, NTNIC, + "%s: Failed to initialize NIM module", drv->mp_port_id_str[i]); continue; } - if (reported_link[i] != link_state[i].link_up) { - NT_LOG(INF, NTNIC, "%s: link is %s", drv->mp_port_id_str[i], - (link_state[i].link_up ? "up" : "down")); - reported_link[i] = link_state[i].link_up; - set_link_state(drv, nim_ctx, &link_state[i], i); + if (nthw_nim_state_build(&nim_ctx[i], &new_state)) { + NT_LOG(ERR, NTNIC, "%s: Cannot read basic NIM data", + drv->mp_port_id_str[i]); + continue; } + + RTE_ASSERT(new_state.br); /* Cannot be zero if NIM is present */ + NT_LOG(DBG, NTNIC, + "%s: NIM id = %u (%s), br = %u, vendor = '%s', pn = '%s', sn='%s'", + drv->mp_port_id_str[i], nim_ctx[i].nim_id, + nthw_nim_id_to_text(nim_ctx[i].nim_id), + (unsigned int)new_state.br, nim_ctx[i].vendor_name, + nim_ctx[i].prod_no, nim_ctx[i].serial_no); + link_state[i].lh_nim_absent = false; + NT_LOG(DBG, NTNIC, "%s: NIM module initialized", + drv->mp_port_id_str[i]); + continue; } - if (monitor_task_is_running[adapter_no]) - nt_os_wait_usec(5 * 100000U); /* 5 x 0.1s = 0.5s */ + if (reported_link[i] != link_state[i].link_up) { + NT_LOG(INF, NTNIC, "%s: link is %s", drv->mp_port_id_str[i], + (link_state[i].link_up ? "up" : "down")); + reported_link[i] = link_state[i].link_up; + set_link_state(drv, nim_ctx, &link_state[i], i); + } } -NT4GA_LINK_100G_MON_EXIT: - NT_LOG(DBG, NTNIC, "%s: Stopped NT4GA 100 Gbps link monitoring thread.", - drv->mp_adapter_id_str); - return NULL; + if (rte_service_runstate_get(adapter_mon_srv->id)) + nt_os_wait_usec(5 * 100000U); /* 5 x 0.1s = 0.5s */ + + return 0; } -static uint32_t nt4ga_agx_link_100g_mon(void *data) +static int nt4ga_agx_link_100g_mon(void *data) { - (void)_common_ptp_nim_state_machine(data); - - return 0; + return _common_ptp_nim_state_machine(data); } /* @@ -1009,12 +1017,24 @@ int nt4ga_agx_link_100g_ports_init(struct adapter_info_s *p_adapter_info, nthw_f } /* - * Create state-machine thread + * Create state-machine service */ - if (!monitor_task_is_running[adapter_no]) { - res = rte_thread_create(&monitor_tasks[adapter_no], NULL, - nt4ga_agx_link_100g_mon, p_adapter_info); + if (res == 0) { + struct rte_service_spec adapter_monitor_service = { + .name = "ntnic-adapter_agx-monitor", + .callback = nt4ga_agx_link_100g_mon, + .socket_id = SOCKET_ID_ANY, + .capabilities = RTE_SERVICE_CAP_MT_SAFE, + .callback_userdata = p_adapter_info, + }; + + res = nthw_service_add(&adapter_monitor_service, RTE_NTNIC_SERVICE_ADAPTER_MON); + if (res) { + NT_LOG(ERR, NTNIC, "%s: Failed to create adapter monitor service", + p_adapter_info->mp_adapter_id_str); + return res; + } } return res; diff --git a/drivers/net/ntnic/ntutil/nt_service.c b/drivers/net/ntnic/ntutil/nt_service.c index 9f22ee2bba..c39771acc2 100644 --- a/drivers/net/ntnic/ntutil/nt_service.c +++ b/drivers/net/ntnic/ntutil/nt_service.c @@ -36,6 +36,12 @@ static struct nt_service g_nt_services[RTE_NTNIC_SERVICE_MAX] = { .lcore = RTE_MAX_LCORE, .initialized = false, }, + [RTE_NTNIC_SERVICE_ADAPTER_MON] = { + .tag = RTE_NTNIC_SERVICE_ADAPTER_MON, + .id = NT_SERVICE_UNKNOWN_ID, + .lcore = RTE_MAX_LCORE, + .initialized = false, + }, }; inline struct nt_service *nthw_service_get_info(const enum rte_ntnic_service_tag tag) diff --git a/drivers/net/ntnic/rte_pmd_ntnic.h b/drivers/net/ntnic/rte_pmd_ntnic.h index 1a68cb8e37..08e7958acd 100644 --- a/drivers/net/ntnic/rte_pmd_ntnic.h +++ b/drivers/net/ntnic/rte_pmd_ntnic.h @@ -45,6 +45,7 @@ enum rte_ntnic_service_tag { RTE_NTNIC_SERVICE_STAT = 1, RTE_NTNIC_SERVICE_PORT_0_EVENT = 2, RTE_NTNIC_SERVICE_PORT_1_EVENT = 3, + RTE_NTNIC_SERVICE_ADAPTER_MON = 4, RTE_NTNIC_SERVICE_MAX }; -- 2.45.0