Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/97037/?format=api
{ "id": 97037, "url": "http://patchwork.dpdk.org/api/patches/97037/?format=api", "web_url": "http://patchwork.dpdk.org/project/dpdk/patch/20210818090755.2419483-2-dkozlyuk@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": "<20210818090755.2419483-2-dkozlyuk@nvidia.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20210818090755.2419483-2-dkozlyuk@nvidia.com", "date": "2021-08-18T09:07:52", "name": "[1/4] mempool: add event callbacks", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "e42fb00fe8485592aeef9b071cfe80dc5455fb92", "submitter": { "id": 2248, "url": "http://patchwork.dpdk.org/api/people/2248/?format=api", "name": "Dmitry Kozlyuk", "email": "dkozlyuk@nvidia.com" }, "delegate": { "id": 1, "url": "http://patchwork.dpdk.org/api/users/1/?format=api", "username": "tmonjalo", "first_name": "Thomas", "last_name": "Monjalon", "email": "thomas@monjalon.net" }, "mbox": "http://patchwork.dpdk.org/project/dpdk/patch/20210818090755.2419483-2-dkozlyuk@nvidia.com/mbox/", "series": [ { "id": 18324, "url": "http://patchwork.dpdk.org/api/series/18324/?format=api", "web_url": "http://patchwork.dpdk.org/project/dpdk/list/?series=18324", "date": "2021-08-18T09:07:51", "name": "net/mlx5: implicit mempool registration", "version": 1, "mbox": "http://patchwork.dpdk.org/series/18324/mbox/" } ], "comments": "http://patchwork.dpdk.org/api/patches/97037/comments/", "check": "success", "checks": "http://patchwork.dpdk.org/api/patches/97037/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 AE45FA0C47;\n\tWed, 18 Aug 2021 11:08:25 +0200 (CEST)", "from [217.70.189.124] (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 7BE9F411C1;\n\tWed, 18 Aug 2021 11:08:21 +0200 (CEST)", "from NAM12-BN8-obe.outbound.protection.outlook.com\n (mail-bn8nam12on2078.outbound.protection.outlook.com [40.107.237.78])\n by mails.dpdk.org (Postfix) with ESMTP id 0FDDA41194\n for <dev@dpdk.org>; Wed, 18 Aug 2021 11:08:20 +0200 (CEST)", "from MWHPR21CA0053.namprd21.prod.outlook.com (2603:10b6:300:db::15)\n by MN2PR12MB4784.namprd12.prod.outlook.com (2603:10b6:208:39::19)\n with Microsoft SMTP Server (version=TLS1_2,\n cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.4415.19; Wed, 18 Aug\n 2021 09:08:18 +0000", "from CO1NAM11FT061.eop-nam11.prod.protection.outlook.com\n (2603:10b6:300:db:cafe::a3) by MWHPR21CA0053.outlook.office365.com\n (2603:10b6:300:db::15) with Microsoft SMTP Server (version=TLS1_2,\n cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.4457.0 via Frontend\n Transport; Wed, 18 Aug 2021 09:08:18 +0000", "from mail.nvidia.com (216.228.112.35) by\n CO1NAM11FT061.mail.protection.outlook.com (10.13.175.200) with Microsoft SMTP\n Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384) id\n 15.20.4415.16 via Frontend Transport; Wed, 18 Aug 2021 09:08:17 +0000", "from DRHQMAIL107.nvidia.com (10.27.9.16) by HQMAIL111.nvidia.com\n (172.20.187.18) with Microsoft SMTP Server (TLS) id 15.0.1497.2; Wed, 18 Aug\n 2021 09:08:17 +0000", "from nvidia.com (172.20.187.5) by DRHQMAIL107.nvidia.com\n (10.27.9.16) with Microsoft SMTP Server (TLS) id 15.0.1497.2; Wed, 18 Aug\n 2021 09:08:14 +0000" ], "ARC-Seal": "i=1; a=rsa-sha256; s=arcselector9901; d=microsoft.com; cv=none;\n b=Oh9Rh2sYXxLvRVHUNWsBvZiNcEsKwSS5Hh1TtD4poXtOeznzavx8XMRJtI/plujHT3BLacBTIMEheGPIJd2FESiMRDv3BqalLgdJ/9YvZGOQsYsl3/P5Ky2korT96uWZJ3PqF71nUW5mbR8ZVrcbjOI4jipkTtW/7QprF3MwVKTsp5MrCxaoQKVLQR3WSuANQlDy1t9dEOMFn1fV/5dOq8eYJMoznywYwhOXpkB7WseWbSMh2nyl97JflN6MdhuHAssi+Zjao5I2X5lqYuWqsCHDV+b/xOdAfJtC3t6VyRi52XoKawtTg+pG8xUobUdYhyo3l296qk3B6N7hfiz+oA==", "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-SenderADCheck;\n bh=lxDH73fiZolxR1kEoPyesFulrSlFeu9b3KKOO24UJ+w=;\n b=ZDwKpMn7ekjda2G9zic8B9cQc+M+iUTrNcOlj9z8f89iETI2tfrGds5WU6RAiJks8SJcj9Kz2FHOETzgaTDTtGB9X3SRhv1rPi6iYrv5YKEr5yhXrtHt4I/k3Tu7m4A3kGW49R5fyTNuE4giM90dkdNDpDxbTH4GMulI5huZP9yCaiqhHoCp1d3iHgofvS4kuIRSa/ox1vYUJ72joX1FfilUQDzql2G6pV2umxBqURk9yw7vwqBf6sAEwJhfpPmb+40UnT8DTXHjCiecjd5IYhKg0AksBUkW4DHeJdRH/yl7BNUac25/UPTitTOIcwFenZOYrN25P9CbW1x1pRrldQ==", "ARC-Authentication-Results": "i=1; mx.microsoft.com 1; spf=pass (sender ip is\n 216.228.112.35) smtp.rcpttodomain=dpdk.org smtp.mailfrom=nvidia.com;\n dmarc=pass (p=quarantine sp=none 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=lxDH73fiZolxR1kEoPyesFulrSlFeu9b3KKOO24UJ+w=;\n b=DadFHYP49Fi6cDri9cqQ7RaCg8xCPpj/nYtNFLZNjSoJbtqcK9k8BDuU5N9d/c1rxIH+1IICJ/4nWuW5GlHX0FoCjUl/oTak4HeptFRY3WV+27RKEsEKwF+3xfx4NZAqHGRiZRwyyDbSGtszL5o12nhF2Y7eJloffmlsnRfgmmUtMsKXVtN939rMkU4flY4Z0LXms/9Sp8BrDnmVwbdCB6evha8yx9czYZqFdVfqmrnpZ5QjssxWA4pOsfjFu0xzMboCm+9R5eOIfRtfrPJuXi+pqMT7haNMgQl8z+AjTjo1jm+lG+Soctit6PPa7qSTtE7CYdPGM1288Hn6GrxyHQ==", "X-MS-Exchange-Authentication-Results": "spf=pass (sender IP is 216.228.112.35)\n smtp.mailfrom=nvidia.com; dpdk.org; dkim=none (message not signed)\n header.d=none;dpdk.org; dmarc=pass action=none header.from=nvidia.com;", "Received-SPF": "Pass (protection.outlook.com: domain of nvidia.com designates\n 216.228.112.35 as permitted sender) receiver=protection.outlook.com;\n client-ip=216.228.112.35; helo=mail.nvidia.com;", "From": "Dmitry Kozlyuk <dkozlyuk@nvidia.com>", "To": "<dev@dpdk.org>", "CC": "Matan Azrad <matan@nvidia.com>, Olivier Matz <olivier.matz@6wind.com>,\n Andrew Rybchenko <andrew.rybchenko@oktetlabs.ru>, Ray Kinsella\n <mdr@ashroe.eu>, Anatoly Burakov <anatoly.burakov@intel.com>", "Date": "Wed, 18 Aug 2021 12:07:52 +0300", "Message-ID": "<20210818090755.2419483-2-dkozlyuk@nvidia.com>", "X-Mailer": "git-send-email 2.25.1", "In-Reply-To": "<20210818090755.2419483-1-dkozlyuk@nvidia.com>", "References": "<20210818090755.2419483-1-dkozlyuk@nvidia.com>", "MIME-Version": "1.0", "Content-Transfer-Encoding": "8bit", "Content-Type": "text/plain", "X-Originating-IP": "[172.20.187.5]", "X-ClientProxiedBy": "HQMAIL111.nvidia.com (172.20.187.18) To\n DRHQMAIL107.nvidia.com (10.27.9.16)", "X-EOPAttributedMessage": "0", "X-MS-PublicTrafficType": "Email", "X-MS-Office365-Filtering-Correlation-Id": "5940ae01-d6d3-42e2-034e-08d96227b7e5", "X-MS-TrafficTypeDiagnostic": "MN2PR12MB4784:", "X-Microsoft-Antispam-PRVS": "\n <MN2PR12MB4784A71CCEF0854E822B8C5EB9FF9@MN2PR12MB4784.namprd12.prod.outlook.com>", "X-MS-Oob-TLC-OOBClassifiers": "OLM:9508;", "X-MS-Exchange-SenderADCheck": "1", "X-MS-Exchange-AntiSpam-Relay": "0", "X-Microsoft-Antispam": "BCL:0;", "X-Microsoft-Antispam-Message-Info": "\n yrETf2vSw9/McHvwfqDvT1IqFpMAnDCTHPkFuQZPXcoBZ1gHENUQnR2KJ6IvHRvzdMRpO7Y3jaDLXuSeRwXD5jgoGs3bxsPMWUB+OQtelNjvsccjWmYjf5bcxEKii/jd6lQl6yQtGViQH1dSB7o5wEnLrWCTXEGbgdUlROvnzcU4pCEHTtPk6copY8KdbT1dtwLS8qCtwOLjr3N2iGaeEp2FrdMd4uIeUL6m7v4Co247u0AkUIz6QsAbSFy7SEmgGzO8R2Nea4+memLEzAo5cEKhzqhKMaFSVb8eDWnl7ZDX+Luyt1PJHys8Olh8duh1eQ0SaKprtJQbsnhd1ub7KKXpM8jKP31RSq78NEU+y0Q3bT0Xe57ZC0l3DmX85x/zQqNz6q8oBpTHh7m+hNtOoAnLtnHPxgOPfttqy/tFGYgvUys6k8TmLQjvXTyC7g/J72ZWWEkUCsuxIM2u3G4EuyCid08pZQrzOEix0/nZ3CJeRmDxLKsq0grFnrY5JNhdTDZkTX2sBiLjSKOB1uM/ipqR4c0OFbTOrbV9dTl7oDrSApbwuznlfRdGPdzc5BfKGScjnja266W7ELe7xvOu1Un/9imssDumLsdTmK2qTXauXzjWUMosLDRNJ4fvev6R0oTO/mYSUv9lwPfIbRyrsw4VeVeGK9dvjUALi5IgZAYyxWpPinKT9BcUIhWdzGLVUlH3Zle1jjpJaqyAxbB5wA==", "X-Forefront-Antispam-Report": "CIP:216.228.112.35; CTRY:US; LANG:en; SCL:1;\n SRV:;\n IPV:NLI; SFV:NSPM; H:mail.nvidia.com; PTR:schybrid02.nvidia.com; CAT:NONE;\n SFS:(4636009)(396003)(376002)(346002)(136003)(39860400002)(46966006)(36840700001)(83380400001)(1076003)(7636003)(316002)(55016002)(478600001)(2906002)(86362001)(6916009)(356005)(54906003)(16526019)(82740400003)(36756003)(6666004)(4326008)(47076005)(8676002)(70206006)(7696005)(70586007)(26005)(186003)(2616005)(6286002)(8936002)(82310400003)(336012)(5660300002)(426003)(36860700001);\n DIR:OUT; SFP:1101;", "X-OriginatorOrg": "Nvidia.com", "X-MS-Exchange-CrossTenant-OriginalArrivalTime": "18 Aug 2021 09:08:17.7022 (UTC)", "X-MS-Exchange-CrossTenant-Network-Message-Id": "\n 5940ae01-d6d3-42e2-034e-08d96227b7e5", "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.112.35];\n Helo=[mail.nvidia.com]", "X-MS-Exchange-CrossTenant-AuthSource": "\n CO1NAM11FT061.eop-nam11.prod.protection.outlook.com", "X-MS-Exchange-CrossTenant-AuthAs": "Anonymous", "X-MS-Exchange-CrossTenant-FromEntityHeader": "HybridOnPrem", "X-MS-Exchange-Transport-CrossTenantHeadersStamped": "MN2PR12MB4784", "Subject": "[dpdk-dev] [PATCH 1/4] mempool: add event callbacks", "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", "Sender": "\"dev\" <dev-bounces@dpdk.org>" }, "content": "Performance of MLX5 PMD of different classes can benefit if PMD knows\nwhich memory it will need to handle in advance, before the first mbuf\nis sent to the PMD. It is impractical, however, to consider\nall allocated memory for this purpose. Most often mbuf memory comes\nfrom mempools that can come and go. PMD can enumerate existing mempools\non device start, but it also needs to track mempool creation\nand destruction after the forwarding starts but before an mbuf\nfrom the new mempool is sent to the device.\n\nAdd an internal API to register callback for mempool lify cycle events,\ncurrently RTE_MEMPOOL_EVENT_CREATE and RTE_MEMPOOL_EVENT_DESTROY:\n* rte_mempool_event_callback_register()\n* rte_mempool_event_callback_unregister()\n\nSigned-off-by: Dmitry Kozlyuk <dkozlyuk@nvidia.com>\nAcked-by: Matan Azrad <matan@nvidia.com>\n---\n lib/mempool/rte_mempool.c | 153 ++++++++++++++++++++++++++++++++++++--\n lib/mempool/rte_mempool.h | 56 ++++++++++++++\n lib/mempool/version.map | 8 ++\n 3 files changed, 212 insertions(+), 5 deletions(-)", "diff": "diff --git a/lib/mempool/rte_mempool.c b/lib/mempool/rte_mempool.c\nindex 59a588425b..0ec56ad278 100644\n--- a/lib/mempool/rte_mempool.c\n+++ b/lib/mempool/rte_mempool.c\n@@ -42,6 +42,18 @@ static struct rte_tailq_elem rte_mempool_tailq = {\n };\n EAL_REGISTER_TAILQ(rte_mempool_tailq)\n \n+TAILQ_HEAD(mempool_callback_list, rte_tailq_entry);\n+\n+static struct rte_tailq_elem callback_tailq = {\n+\t.name = \"RTE_MEMPOOL_CALLBACK\",\n+};\n+EAL_REGISTER_TAILQ(callback_tailq)\n+\n+/* Invoke all registered mempool event callbacks. */\n+static void\n+mempool_event_callback_invoke(enum rte_mempool_event event,\n+\t\t\t struct rte_mempool *mp);\n+\n #define CACHE_FLUSHTHRESH_MULTIPLIER 1.5\n #define CALC_CACHE_FLUSHTHRESH(c)\t\\\n \t((typeof(c))((c) * CACHE_FLUSHTHRESH_MULTIPLIER))\n@@ -722,6 +734,7 @@ rte_mempool_free(struct rte_mempool *mp)\n \t}\n \trte_mcfg_tailq_write_unlock();\n \n+\tmempool_event_callback_invoke(RTE_MEMPOOL_EVENT_DESTROY, mp);\n \trte_mempool_trace_free(mp);\n \trte_mempool_free_memchunks(mp);\n \trte_mempool_ops_free(mp);\n@@ -778,10 +791,10 @@ rte_mempool_cache_free(struct rte_mempool_cache *cache)\n }\n \n /* create an empty mempool */\n-struct rte_mempool *\n-rte_mempool_create_empty(const char *name, unsigned n, unsigned elt_size,\n-\tunsigned cache_size, unsigned private_data_size,\n-\tint socket_id, unsigned flags)\n+static struct rte_mempool *\n+mempool_create_empty(const char *name, unsigned int n,\n+\tunsigned int elt_size, unsigned int cache_size,\n+\tunsigned int private_data_size, int socket_id, unsigned int flags)\n {\n \tchar mz_name[RTE_MEMZONE_NAMESIZE];\n \tstruct rte_mempool_list *mempool_list;\n@@ -915,6 +928,19 @@ rte_mempool_create_empty(const char *name, unsigned n, unsigned elt_size,\n \treturn NULL;\n }\n \n+struct rte_mempool *\n+rte_mempool_create_empty(const char *name, unsigned int n,\n+\tunsigned int elt_size, unsigned int cache_size,\n+\tunsigned int private_data_size, int socket_id, unsigned int flags)\n+{\n+\tstruct rte_mempool *mp;\n+\n+\tmp = mempool_create_empty(name, n, elt_size, cache_size,\n+\t\tprivate_data_size, socket_id, flags);\n+\tmempool_event_callback_invoke(RTE_MEMPOOL_EVENT_CREATE, mp);\n+\treturn mp;\n+}\n+\n /* create the mempool */\n struct rte_mempool *\n rte_mempool_create(const char *name, unsigned n, unsigned elt_size,\n@@ -926,7 +952,7 @@ rte_mempool_create(const char *name, unsigned n, unsigned elt_size,\n \tint ret;\n \tstruct rte_mempool *mp;\n \n-\tmp = rte_mempool_create_empty(name, n, elt_size, cache_size,\n+\tmp = mempool_create_empty(name, n, elt_size, cache_size,\n \t\tprivate_data_size, socket_id, flags);\n \tif (mp == NULL)\n \t\treturn NULL;\n@@ -958,6 +984,8 @@ rte_mempool_create(const char *name, unsigned n, unsigned elt_size,\n \tif (obj_init)\n \t\trte_mempool_obj_iter(mp, obj_init, obj_init_arg);\n \n+\tmempool_event_callback_invoke(RTE_MEMPOOL_EVENT_CREATE, mp);\n+\n \trte_mempool_trace_create(name, n, elt_size, cache_size,\n \t\tprivate_data_size, mp_init, mp_init_arg, obj_init,\n \t\tobj_init_arg, flags, mp);\n@@ -1343,3 +1371,118 @@ void rte_mempool_walk(void (*func)(struct rte_mempool *, void *),\n \n \trte_mcfg_mempool_read_unlock();\n }\n+\n+struct mempool_callback {\n+\trte_mempool_event_callback *func;\n+\tvoid *arg;\n+};\n+\n+static void\n+mempool_event_callback_invoke(enum rte_mempool_event event,\n+\t\t\t struct rte_mempool *mp)\n+{\n+\tstruct mempool_callback_list *list;\n+\tstruct rte_tailq_entry *te;\n+\tvoid *tmp_te;\n+\n+\trte_mcfg_tailq_read_lock();\n+\tlist = RTE_TAILQ_CAST(callback_tailq.head, mempool_callback_list);\n+\tTAILQ_FOREACH_SAFE(te, list, next, tmp_te) {\n+\t\tstruct mempool_callback *cb = te->data;\n+\t\trte_mcfg_tailq_read_unlock();\n+\t\tcb->func(event, mp, cb->arg);\n+\t\trte_mcfg_tailq_read_lock();\n+\t}\n+\trte_mcfg_tailq_read_unlock();\n+}\n+\n+int\n+rte_mempool_event_callback_register(rte_mempool_event_callback *func,\n+\t\t\t\t void *arg)\n+{\n+\tstruct mempool_callback_list *list;\n+\tstruct rte_tailq_entry *te = NULL;\n+\tstruct mempool_callback *cb;\n+\tvoid *tmp_te;\n+\tint ret;\n+\n+\trte_mcfg_mempool_read_lock();\n+\trte_mcfg_tailq_write_lock();\n+\n+\tlist = RTE_TAILQ_CAST(callback_tailq.head, mempool_callback_list);\n+\tTAILQ_FOREACH_SAFE(te, list, next, tmp_te) {\n+\t\tstruct mempool_callback *cb =\n+\t\t\t\t\t(struct mempool_callback *)te->data;\n+\t\tif (cb->func == func && cb->arg == arg) {\n+\t\t\tret = -EEXIST;\n+\t\t\tgoto exit;\n+\t\t}\n+\t}\n+\n+\tte = rte_zmalloc(\"MEMPOOL_TAILQ_ENTRY\", sizeof(*te), 0);\n+\tif (te == NULL) {\n+\t\tRTE_LOG(ERR, MEMPOOL,\n+\t\t\t\"Cannot allocate event callback tailq entry!\\n\");\n+\t\tret = -ENOMEM;\n+\t\tgoto exit;\n+\t}\n+\n+\tcb = rte_malloc(\"MEMPOOL_EVENT_CALLBACK\", sizeof(*cb), 0);\n+\tif (cb == NULL) {\n+\t\tRTE_LOG(ERR, MEMPOOL,\n+\t\t\t\"Cannot allocate event callback!\\n\");\n+\t\trte_free(te);\n+\t\tret = -ENOMEM;\n+\t\tgoto exit;\n+\t}\n+\n+\tcb->func = func;\n+\tcb->arg = arg;\n+\tte->data = cb;\n+\tTAILQ_INSERT_TAIL(list, te, next);\n+\tret = 0;\n+\n+exit:\n+\trte_mcfg_tailq_write_unlock();\n+\trte_mcfg_mempool_read_unlock();\n+\trte_errno = -ret;\n+\treturn ret;\n+}\n+\n+int\n+rte_mempool_event_callback_unregister(rte_mempool_event_callback *func,\n+\t\t\t\t void *arg)\n+{\n+\tstruct mempool_callback_list *list;\n+\tstruct rte_tailq_entry *te = NULL;\n+\tstruct mempool_callback *cb;\n+\tint ret;\n+\n+\tif (rte_eal_process_type() != RTE_PROC_PRIMARY) {\n+\t\trte_errno = EPERM;\n+\t\treturn -1;\n+\t}\n+\n+\trte_mcfg_mempool_read_lock();\n+\trte_mcfg_tailq_write_lock();\n+\tret = -ENOENT;\n+\tlist = RTE_TAILQ_CAST(callback_tailq.head, mempool_callback_list);\n+\tTAILQ_FOREACH(te, list, next) {\n+\t\tcb = (struct mempool_callback *)te->data;\n+\t\tif (cb->func == func && cb->arg == arg)\n+\t\t\tbreak;\n+\t}\n+\tif (te != NULL) {\n+\t\tTAILQ_REMOVE(list, te, next);\n+\t\tret = 0;\n+\t}\n+\trte_mcfg_tailq_write_unlock();\n+\trte_mcfg_mempool_read_unlock();\n+\n+\tif (ret == 0) {\n+\t\trte_free(te);\n+\t\trte_free(cb);\n+\t}\n+\trte_errno = -ret;\n+\treturn ret;\n+}\ndiff --git a/lib/mempool/rte_mempool.h b/lib/mempool/rte_mempool.h\nindex 4235d6f0bf..1e9b8f0229 100644\n--- a/lib/mempool/rte_mempool.h\n+++ b/lib/mempool/rte_mempool.h\n@@ -1775,6 +1775,62 @@ void rte_mempool_walk(void (*func)(struct rte_mempool *, void *arg),\n int\n rte_mempool_get_page_size(struct rte_mempool *mp, size_t *pg_sz);\n \n+/**\n+ * Mempool event type.\n+ * @internal\n+ */\n+enum rte_mempool_event {\n+\t/** Occurs after a successful mempool creation. */\n+\tRTE_MEMPOOL_EVENT_CREATE = 0,\n+\t/** Occurs before destruction of a mempool begins. */\n+\tRTE_MEMPOOL_EVENT_DESTROY = 1,\n+};\n+\n+/**\n+ * @internal\n+ * Mempool event callback.\n+ */\n+typedef void (rte_mempool_event_callback)(\n+\t\tenum rte_mempool_event event,\n+\t\tstruct rte_mempool *mp,\n+\t\tvoid *arg);\n+\n+/**\n+ * @internal\n+ * Register a callback invoked on mempool life cycle event.\n+ * Callbacks will be invoked in the process that creates the mempool.\n+ *\n+ * @param cb\n+ * Callback function.\n+ * @param cb_arg\n+ * User data.\n+ *\n+ * @return\n+ * 0 on success, negative on failure and rte_errno is set.\n+ */\n+__rte_internal\n+int\n+rte_mempool_event_callback_register(rte_mempool_event_callback *cb,\n+\t\t\t\t void *cb_arg);\n+\n+/**\n+ * @internal\n+ * Unregister a callback added with rte_mempool_event_callback_register().\n+ * @p cb and @p arg must exactly match registration parameters.\n+ *\n+ * @param cb\n+ * Callback function.\n+ * @param cb_arg\n+ * User data.\n+ *\n+ * @return\n+ * 0 on success, negative on failure and rte_errno is set.\n+ */\n+__rte_internal\n+int\n+rte_mempool_event_callback_unregister(rte_mempool_event_callback *cb,\n+\t\t\t\t void *cb_arg);\n+\n #ifdef __cplusplus\n }\n #endif\ndiff --git a/lib/mempool/version.map b/lib/mempool/version.map\nindex 9f77da6fff..1b7d7c5456 100644\n--- a/lib/mempool/version.map\n+++ b/lib/mempool/version.map\n@@ -64,3 +64,11 @@ EXPERIMENTAL {\n \t__rte_mempool_trace_ops_free;\n \t__rte_mempool_trace_set_ops_byname;\n };\n+\n+INTERNAL {\n+\tglobal:\n+\n+\t# added in 21.11\n+\trte_mempool_event_callback_register;\n+\trte_mempool_event_callback_unregister;\n+};\n", "prefixes": [ "1/4" ] }