Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/137396/?format=api
{ "id": 137396, "url": "http://patches.dpdk.org/api/patches/137396/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/20240227191550.137687-24-hkalra@marvell.com/", "project": { "id": 1, "url": "http://patches.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": "<20240227191550.137687-24-hkalra@marvell.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20240227191550.137687-24-hkalra@marvell.com", "date": "2024-02-27T19:15:50", "name": "[v4,23/23] net/cnxk: other flow operations", "commit_ref": null, "pull_url": null, "state": "changes-requested", "archived": true, "hash": "5293e929eb5c71efdc0b5086c1a2a8e0e24bc824", "submitter": { "id": 1182, "url": "http://patches.dpdk.org/api/people/1182/?format=api", "name": "Harman Kalra", "email": "hkalra@marvell.com" }, "delegate": { "id": 310, "url": "http://patches.dpdk.org/api/users/310/?format=api", "username": "jerin", "first_name": "Jerin", "last_name": "Jacob", "email": "jerinj@marvell.com" }, "mbox": "http://patches.dpdk.org/project/dpdk/patch/20240227191550.137687-24-hkalra@marvell.com/mbox/", "series": [ { "id": 31259, "url": "http://patches.dpdk.org/api/series/31259/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=31259", "date": "2024-02-27T19:15:27", "name": "net/cnxk: support for port representors", "version": 4, "mbox": "http://patches.dpdk.org/series/31259/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/137396/comments/", "check": "warning", "checks": "http://patches.dpdk.org/api/patches/137396/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 A269F43C06;\n\tTue, 27 Feb 2024 20:19:03 +0100 (CET)", "from mails.dpdk.org (localhost [127.0.0.1])\n\tby mails.dpdk.org (Postfix) with ESMTP id 35F5842FC5;\n\tTue, 27 Feb 2024 20:17:42 +0100 (CET)", "from mx0b-0016f401.pphosted.com (mx0b-0016f401.pphosted.com\n [67.231.156.173])\n by mails.dpdk.org (Postfix) with ESMTP id 07BF842EC7\n for <dev@dpdk.org>; Tue, 27 Feb 2024 20:17:14 +0100 (CET)", "from pps.filterd (m0045851.ppops.net [127.0.0.1])\n by mx0b-0016f401.pphosted.com (8.17.1.24/8.17.1.24) with ESMTP id\n 41RFgq5E005654 for <dev@dpdk.org>; Tue, 27 Feb 2024 11:17:14 -0800", "from dc6wp-exch02.marvell.com ([4.21.29.225])\n by mx0b-0016f401.pphosted.com (PPS) with ESMTPS id 3whjm694rb-1\n (version=TLSv1.2 cipher=ECDHE-RSA-AES256-GCM-SHA384 bits=256 verify=NOT)\n for <dev@dpdk.org>; Tue, 27 Feb 2024 11:17:14 -0800 (PST)", "from DC6WP-EXCH02.marvell.com (10.76.176.209) by\n DC6WP-EXCH02.marvell.com (10.76.176.209) with Microsoft SMTP Server\n (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id\n 15.2.1258.12; Tue, 27 Feb 2024 11:17:13 -0800", "from maili.marvell.com (10.69.176.80) by DC6WP-EXCH02.marvell.com\n (10.76.176.209) with Microsoft SMTP Server id 15.2.1258.12 via Frontend\n Transport; Tue, 27 Feb 2024 11:17:13 -0800", "from localhost.localdomain (unknown [10.29.52.211])\n by maili.marvell.com (Postfix) with ESMTP id 10C103F719D;\n Tue, 27 Feb 2024 11:17:10 -0800 (PST)" ], "DKIM-Signature": "v=1; a=rsa-sha256; c=relaxed/relaxed; d=marvell.com; h=\n from:to:cc:subject:date:message-id:in-reply-to:references\n :mime-version:content-type; s=pfpt0220; bh=58HMGRWtVEfmn97fgpfmA\n fQks8itEfDhNPhItl+oTSU=; b=V8X/0RZ1M4liBIyB7zNCB8kiO0TSulodDo8DX\n SHN4wZCIu6KGobf9CW16aSNvvZkE6oDtDmGY0i7R3NPCUrJSd6+E4x5FGbvgiJwc\n Ysi4SDhIAxEHYhtwou1tmNjZAyRAN0lO50ZHRWFxBFIYoiIZHDcY+fEcLgv20hY5\n KlhXNHJczaUX2oV+BqYMFGnDEpHXWu9z/A1dPEJRZ5yzR5vFFu0wgYgjm8HH6t/W\n /uGccnuBqYu+zbpkociZmcCzCq0QT2n1AcMdInEheClgpZz/qrxqOSKcyr11/3bp\n lIImeVN9WNJNnK3oSjy+fLiZnmAt9ZsnbjCb3cU5NQXQCNyCQ==", "From": "Harman Kalra <hkalra@marvell.com>", "To": "Nithin Dabilpuram <ndabilpuram@marvell.com>, Kiran Kumar K\n <kirankumark@marvell.com>, Sunil Kumar Kori <skori@marvell.com>, Satha Rao\n <skoteshwar@marvell.com>, Harman Kalra <hkalra@marvell.com>", "CC": "<dev@dpdk.org>", "Subject": "[PATCH v4 23/23] net/cnxk: other flow operations", "Date": "Wed, 28 Feb 2024 00:45:50 +0530", "Message-ID": "<20240227191550.137687-24-hkalra@marvell.com>", "X-Mailer": "git-send-email 2.18.0", "In-Reply-To": "<20240227191550.137687-1-hkalra@marvell.com>", "References": "<20230811163419.165790-1-hkalra@marvell.com>\n <20240227191550.137687-1-hkalra@marvell.com>", "MIME-Version": "1.0", "Content-Type": "text/plain", "X-Proofpoint-ORIG-GUID": "WF6f3aAFS52cBZ815ynM5Q3b3Zwna7Ib", "X-Proofpoint-GUID": "WF6f3aAFS52cBZ815ynM5Q3b3Zwna7Ib", "X-Proofpoint-Virus-Version": "vendor=baseguard\n engine=ICAP:2.0.272,Aquarius:18.0.1011,Hydra:6.0.619,FMLib:17.11.176.26\n definitions=2024-02-27_06,2024-02-27_01,2023-05-22_02", "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": "Implementing other flow operations - validate, destroy, query,\nflush, dump for representor ports\n\nSigned-off-by: Harman Kalra <hkalra@marvell.com>\n---\n drivers/net/cnxk/cnxk_rep_flow.c | 414 +++++++++++++++++++++++++++++++\n drivers/net/cnxk/cnxk_rep_msg.h | 32 +++\n 2 files changed, 446 insertions(+)", "diff": "diff --git a/drivers/net/cnxk/cnxk_rep_flow.c b/drivers/net/cnxk/cnxk_rep_flow.c\nindex 2613be5b9e..d26f5aa12c 100644\n--- a/drivers/net/cnxk/cnxk_rep_flow.c\n+++ b/drivers/net/cnxk/cnxk_rep_flow.c\n@@ -267,6 +267,222 @@ populate_action_data(void *buffer, uint32_t *length, const struct rte_flow_actio\n \t*length = len;\n }\n \n+static int\n+process_flow_destroy(struct cnxk_rep_dev *rep_dev, void *flow, cnxk_rep_msg_ack_data_t *adata)\n+{\n+\tcnxk_rep_msg_flow_destroy_meta_t msg_fd_meta;\n+\tuint32_t len = 0, rc;\n+\tvoid *buffer;\n+\tsize_t size;\n+\n+\t/* If representor not representing any active VF, return 0 */\n+\tif (!rep_dev->is_vf_active)\n+\t\treturn 0;\n+\n+\tsize = MAX_BUFFER_SIZE;\n+\tbuffer = plt_zmalloc(size, 0);\n+\tif (!buffer) {\n+\t\tplt_err(\"Failed to allocate mem\");\n+\t\trc = -ENOMEM;\n+\t\tgoto fail;\n+\t}\n+\n+\tcnxk_rep_msg_populate_header(buffer, &len);\n+\n+\tmsg_fd_meta.portid = rep_dev->rep_id;\n+\tmsg_fd_meta.flow = (uint64_t)flow;\n+\tplt_rep_dbg(\"Flow Destroy: flow 0x%\" PRIu64 \", portid %d\", msg_fd_meta.flow,\n+\t\t msg_fd_meta.portid);\n+\tcnxk_rep_msg_populate_command_meta(buffer, &len, &msg_fd_meta,\n+\t\t\t\t\t sizeof(cnxk_rep_msg_flow_destroy_meta_t),\n+\t\t\t\t\t CNXK_REP_MSG_FLOW_DESTROY);\n+\tcnxk_rep_msg_populate_msg_end(buffer, &len);\n+\n+\trc = cnxk_rep_msg_send_process(rep_dev, buffer, len, adata);\n+\tif (rc) {\n+\t\tplt_err(\"Failed to process the message, err %d\", rc);\n+\t\tgoto fail;\n+\t}\n+\n+\treturn 0;\n+fail:\n+\treturn rc;\n+}\n+\n+static int\n+copy_flow_dump_file(FILE *target)\n+{\n+\tFILE *source = NULL;\n+\tint pos;\n+\tchar ch;\n+\n+\tsource = fopen(DEFAULT_DUMP_FILE_NAME, \"r\");\n+\tif (source == NULL) {\n+\t\tplt_err(\"Failed to read default dump file: %s, err %d\", DEFAULT_DUMP_FILE_NAME,\n+\t\t\terrno);\n+\t\treturn errno;\n+\t}\n+\n+\tfseek(source, 0L, SEEK_END);\n+\tpos = ftell(source);\n+\tfseek(source, 0L, SEEK_SET);\n+\twhile (pos--) {\n+\t\tch = fgetc(source);\n+\t\tfputc(ch, target);\n+\t}\n+\n+\tfclose(source);\n+\n+\t/* Remove the default file after reading */\n+\tremove(DEFAULT_DUMP_FILE_NAME);\n+\n+\treturn 0;\n+}\n+\n+static int\n+process_flow_dump(struct cnxk_rep_dev *rep_dev, struct rte_flow *flow, FILE *file,\n+\t\t cnxk_rep_msg_ack_data_t *adata)\n+{\n+\tcnxk_rep_msg_flow_dump_meta_t msg_fp_meta;\n+\tuint32_t len = 0, rc;\n+\tvoid *buffer;\n+\tsize_t size;\n+\n+\tsize = MAX_BUFFER_SIZE;\n+\tbuffer = plt_zmalloc(size, 0);\n+\tif (!buffer) {\n+\t\tplt_err(\"Failed to allocate mem\");\n+\t\trc = -ENOMEM;\n+\t\tgoto fail;\n+\t}\n+\n+\tcnxk_rep_msg_populate_header(buffer, &len);\n+\n+\tmsg_fp_meta.portid = rep_dev->rep_id;\n+\tmsg_fp_meta.flow = (uint64_t)flow;\n+\tmsg_fp_meta.is_stdout = (file == stdout) ? 1 : 0;\n+\n+\tplt_rep_dbg(\"Flow Dump: flow 0x%\" PRIu64 \", portid %d stdout %d\", msg_fp_meta.flow,\n+\t\t msg_fp_meta.portid, msg_fp_meta.is_stdout);\n+\tcnxk_rep_msg_populate_command_meta(buffer, &len, &msg_fp_meta,\n+\t\t\t\t\t sizeof(cnxk_rep_msg_flow_dump_meta_t),\n+\t\t\t\t\t CNXK_REP_MSG_FLOW_DUMP);\n+\tcnxk_rep_msg_populate_msg_end(buffer, &len);\n+\n+\trc = cnxk_rep_msg_send_process(rep_dev, buffer, len, adata);\n+\tif (rc) {\n+\t\tplt_err(\"Failed to process the message, err %d\", rc);\n+\t\tgoto fail;\n+\t}\n+\n+\t/* Copy contents from default file to user file */\n+\tif (file != stdout)\n+\t\tcopy_flow_dump_file(file);\n+\n+\treturn 0;\n+fail:\n+\treturn rc;\n+}\n+\n+static int\n+process_flow_flush(struct cnxk_rep_dev *rep_dev, cnxk_rep_msg_ack_data_t *adata)\n+{\n+\tcnxk_rep_msg_flow_flush_meta_t msg_ff_meta;\n+\tuint32_t len = 0, rc;\n+\tvoid *buffer;\n+\tsize_t size;\n+\n+\tsize = MAX_BUFFER_SIZE;\n+\tbuffer = plt_zmalloc(size, 0);\n+\tif (!buffer) {\n+\t\tplt_err(\"Failed to allocate mem\");\n+\t\trc = -ENOMEM;\n+\t\tgoto fail;\n+\t}\n+\n+\tcnxk_rep_msg_populate_header(buffer, &len);\n+\n+\tmsg_ff_meta.portid = rep_dev->rep_id;\n+\tplt_rep_dbg(\"Flow Flush: portid %d\", msg_ff_meta.portid);\n+\tcnxk_rep_msg_populate_command_meta(buffer, &len, &msg_ff_meta,\n+\t\t\t\t\t sizeof(cnxk_rep_msg_flow_flush_meta_t),\n+\t\t\t\t\t CNXK_REP_MSG_FLOW_FLUSH);\n+\tcnxk_rep_msg_populate_msg_end(buffer, &len);\n+\n+\trc = cnxk_rep_msg_send_process(rep_dev, buffer, len, adata);\n+\tif (rc) {\n+\t\tplt_err(\"Failed to process the message, err %d\", rc);\n+\t\tgoto fail;\n+\t}\n+\n+\treturn 0;\n+fail:\n+\treturn rc;\n+}\n+\n+static int\n+process_flow_query(struct cnxk_rep_dev *rep_dev, struct rte_flow *flow,\n+\t\t const struct rte_flow_action *action, void *data, cnxk_rep_msg_ack_data_t *adata)\n+{\n+\tcnxk_rep_msg_flow_query_meta_t *msg_fq_meta;\n+\tstruct rte_flow_query_count *query = data;\n+\tuint32_t len = 0, rc, sz, total_sz;\n+\tuint64_t action_data[BUFSIZ];\n+\tvoid *buffer;\n+\tsize_t size;\n+\n+\tsize = MAX_BUFFER_SIZE;\n+\tbuffer = plt_zmalloc(size, 0);\n+\tif (!buffer) {\n+\t\tplt_err(\"Failed to allocate mem\");\n+\t\trc = -ENOMEM;\n+\t\tgoto fail;\n+\t}\n+\n+\tcnxk_rep_msg_populate_header(buffer, &len);\n+\n+\tmemset(action_data, 0, BUFSIZ * sizeof(uint64_t));\n+\tsz = prepare_action_data(action, 1, action_data);\n+\ttotal_sz = sz + sizeof(cnxk_rep_msg_flow_query_meta_t);\n+\n+\tmsg_fq_meta = plt_zmalloc(total_sz, 0);\n+\tif (!msg_fq_meta) {\n+\t\tplt_err(\"Failed to allocate memory\");\n+\t\trc = -ENOMEM;\n+\t\tgoto fail;\n+\t}\n+\n+\tmsg_fq_meta->portid = rep_dev->rep_id;\n+\tmsg_fq_meta->reset = query->reset;\n+\t;\n+\tmsg_fq_meta->flow = (uint64_t)flow;\n+\t/* Populate the action data */\n+\trte_memcpy(msg_fq_meta->action_data, action_data, sz);\n+\tmsg_fq_meta->action_data_sz = sz;\n+\n+\tplt_rep_dbg(\"Flow query: flow 0x%\" PRIu64 \", portid %d, action type %d total sz %d \"\n+\t\t \"action sz %d\", msg_fq_meta->flow, msg_fq_meta->portid, action->type, total_sz,\n+\t\t sz);\n+\tcnxk_rep_msg_populate_command_meta(buffer, &len, msg_fq_meta, total_sz,\n+\t\t\t\t\t CNXK_REP_MSG_FLOW_QUERY);\n+\tcnxk_rep_msg_populate_msg_end(buffer, &len);\n+\n+\trc = cnxk_rep_msg_send_process(rep_dev, buffer, len, adata);\n+\tif (rc) {\n+\t\tplt_err(\"Failed to process the message, err %d\", rc);\n+\t\tgoto free;\n+\t}\n+\n+\trte_free(msg_fq_meta);\n+\n+\treturn 0;\n+\n+free:\n+\trte_free(msg_fq_meta);\n+fail:\n+\treturn rc;\n+}\n+\n static int\n process_flow_rule(struct cnxk_rep_dev *rep_dev, const struct rte_flow_attr *attr,\n \t\t const struct rte_flow_item pattern[], const struct rte_flow_action actions[],\n@@ -396,6 +612,204 @@ cnxk_rep_flow_create(struct rte_eth_dev *eth_dev, const struct rte_flow_attr *at\n \treturn NULL;\n }\n \n+static int\n+cnxk_rep_flow_validate(struct rte_eth_dev *eth_dev, const struct rte_flow_attr *attr,\n+\t\t const struct rte_flow_item pattern[], const struct rte_flow_action actions[],\n+\t\t struct rte_flow_error *error)\n+{\n+\tstruct cnxk_rep_dev *rep_dev = cnxk_rep_pmd_priv(eth_dev);\n+\tcnxk_rep_msg_ack_data_t adata;\n+\tint rc = 0;\n+\n+\t/* If representor not representing any active VF, return 0 */\n+\tif (!rep_dev->is_vf_active) {\n+\t\trte_flow_error_set(error, -EAGAIN, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Represented VF not active yet\");\n+\t\treturn 0;\n+\t}\n+\n+\tif (rep_dev->native_repte)\n+\t\treturn cnxk_flow_validate_common(eth_dev, attr, pattern, actions, error, true);\n+\n+\trc = process_flow_rule(rep_dev, attr, pattern, actions, &adata, CNXK_REP_MSG_FLOW_VALIDATE);\n+\tif (!rc || adata.u.sval < 0) {\n+\t\tif (adata.u.sval < 0) {\n+\t\t\trc = (int)adata.u.sval;\n+\t\t\trte_flow_error_set(error, adata.u.sval, RTE_FLOW_ERROR_TYPE_UNSPECIFIED,\n+\t\t\t\t\t NULL, \"Failed to validate flow\");\n+\t\t\tgoto fail;\n+\t\t}\n+\t} else {\n+\t\trte_flow_error_set(error, rc, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Failed to validate flow\");\n+\t}\n+\n+\tplt_rep_dbg(\"Flow %p validated successfully\", adata.u.data);\n+\n+fail:\n+\treturn rc;\n+}\n+\n+static int\n+cnxk_rep_flow_destroy(struct rte_eth_dev *eth_dev, struct rte_flow *flow,\n+\t\t struct rte_flow_error *error)\n+{\n+\tstruct cnxk_rep_dev *rep_dev = cnxk_rep_pmd_priv(eth_dev);\n+\tcnxk_rep_msg_ack_data_t adata;\n+\tint rc;\n+\n+\t/* If representor not representing any active VF, return 0 */\n+\tif (!rep_dev->is_vf_active) {\n+\t\trte_flow_error_set(error, -EAGAIN, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Represented VF not active yet\");\n+\t\treturn 0;\n+\t}\n+\n+\tif (rep_dev->native_repte)\n+\t\treturn cnxk_flow_destroy_common(eth_dev, (struct roc_npc_flow *)flow, error, true);\n+\n+\trc = process_flow_destroy(rep_dev, flow, &adata);\n+\tif (rc || adata.u.sval < 0) {\n+\t\tif (adata.u.sval < 0)\n+\t\t\trc = adata.u.sval;\n+\n+\t\trte_flow_error_set(error, rc, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Failed to destroy flow\");\n+\t\tgoto fail;\n+\t}\n+\n+\treturn 0;\n+fail:\n+\treturn rc;\n+}\n+\n+static int\n+cnxk_rep_flow_query(struct rte_eth_dev *eth_dev, struct rte_flow *flow,\n+\t\t const struct rte_flow_action *action, void *data, struct rte_flow_error *error)\n+{\n+\tstruct cnxk_rep_dev *rep_dev = cnxk_rep_pmd_priv(eth_dev);\n+\tcnxk_rep_msg_ack_data_t adata;\n+\tint rc;\n+\n+\t/* If representor not representing any active VF, return 0 */\n+\tif (!rep_dev->is_vf_active) {\n+\t\trte_flow_error_set(error, -EAGAIN, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Represented VF not active yet\");\n+\t\treturn 0;\n+\t}\n+\n+\tif (action->type != RTE_FLOW_ACTION_TYPE_COUNT) {\n+\t\trc = -ENOTSUP;\n+\t\trte_flow_error_set(error, rc, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Only COUNT is supported in query\");\n+\t\tgoto fail;\n+\t}\n+\n+\tif (rep_dev->native_repte)\n+\t\treturn cnxk_flow_query_common(eth_dev, flow, action, data, error, true);\n+\n+\trc = process_flow_query(rep_dev, flow, action, data, &adata);\n+\tif (rc || adata.u.sval < 0) {\n+\t\tif (adata.u.sval < 0)\n+\t\t\trc = adata.u.sval;\n+\n+\t\trte_flow_error_set(error, rc, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Failed to query the flow\");\n+\t\tgoto fail;\n+\t}\n+\n+\trte_memcpy(data, adata.u.data, adata.size);\n+\n+\treturn 0;\n+fail:\n+\treturn rc;\n+}\n+\n+static int\n+cnxk_rep_flow_flush(struct rte_eth_dev *eth_dev, struct rte_flow_error *error)\n+{\n+\tstruct cnxk_rep_dev *rep_dev = cnxk_rep_pmd_priv(eth_dev);\n+\tcnxk_rep_msg_ack_data_t adata;\n+\tint rc;\n+\n+\t/* If representor not representing any active VF, return 0 */\n+\tif (!rep_dev->is_vf_active) {\n+\t\trte_flow_error_set(error, -EAGAIN, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Represented VF not active yet\");\n+\t\treturn 0;\n+\t}\n+\n+\tif (rep_dev->native_repte)\n+\t\treturn cnxk_flow_flush_common(eth_dev, error, true);\n+\n+\trc = process_flow_flush(rep_dev, &adata);\n+\tif (rc || adata.u.sval < 0) {\n+\t\tif (adata.u.sval < 0)\n+\t\t\trc = adata.u.sval;\n+\n+\t\trte_flow_error_set(error, rc, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Failed to destroy flow\");\n+\t\tgoto fail;\n+\t}\n+\n+\treturn 0;\n+fail:\n+\treturn rc;\n+}\n+\n+static int\n+cnxk_rep_flow_dev_dump(struct rte_eth_dev *eth_dev, struct rte_flow *flow, FILE *file,\n+\t\t struct rte_flow_error *error)\n+{\n+\tstruct cnxk_rep_dev *rep_dev = cnxk_rep_pmd_priv(eth_dev);\n+\tcnxk_rep_msg_ack_data_t adata;\n+\tint rc;\n+\n+\t/* If representor not representing any active VF, return 0 */\n+\tif (!rep_dev->is_vf_active) {\n+\t\trte_flow_error_set(error, -EAGAIN, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Represented VF not active yet\");\n+\t\treturn 0;\n+\t}\n+\n+\tif (rep_dev->native_repte)\n+\t\treturn cnxk_flow_dev_dump_common(eth_dev, flow, file, error, true);\n+\n+\trc = process_flow_dump(rep_dev, flow, file, &adata);\n+\tif (rc || adata.u.sval < 0) {\n+\t\tif (adata.u.sval < 0)\n+\t\t\trc = adata.u.sval;\n+\n+\t\trte_flow_error_set(error, rc, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t\t \"Failed to destroy flow\");\n+\t\tgoto fail;\n+\t}\n+\n+\treturn 0;\n+fail:\n+\treturn rc;\n+}\n+\n+static int\n+cnxk_rep_flow_isolate(struct rte_eth_dev *eth_dev __rte_unused, int enable __rte_unused,\n+\t\t struct rte_flow_error *error)\n+{\n+\t/* If we support, we need to un-install the default mcam\n+\t * entry for this port.\n+\t */\n+\n+\trte_flow_error_set(error, ENOTSUP, RTE_FLOW_ERROR_TYPE_UNSPECIFIED, NULL,\n+\t\t\t \"Flow isolation not supported\");\n+\n+\treturn -rte_errno;\n+}\n+\n struct rte_flow_ops cnxk_rep_flow_ops = {\n+\t.validate = cnxk_rep_flow_validate,\n \t.create = cnxk_rep_flow_create,\n+\t.destroy = cnxk_rep_flow_destroy,\n+\t.query = cnxk_rep_flow_query,\n+\t.flush = cnxk_rep_flow_flush,\n+\t.isolate = cnxk_rep_flow_isolate,\n+\t.dev_dump = cnxk_rep_flow_dev_dump,\n };\ndiff --git a/drivers/net/cnxk/cnxk_rep_msg.h b/drivers/net/cnxk/cnxk_rep_msg.h\nindex d27a234e48..bfd9ce9c7b 100644\n--- a/drivers/net/cnxk/cnxk_rep_msg.h\n+++ b/drivers/net/cnxk/cnxk_rep_msg.h\n@@ -29,6 +29,11 @@ typedef enum CNXK_REP_MSG {\n \tCNXK_REP_MSG_ETH_STATS_CLEAR,\n \t/* Flow operation msgs */\n \tCNXK_REP_MSG_FLOW_CREATE,\n+\tCNXK_REP_MSG_FLOW_DESTROY,\n+\tCNXK_REP_MSG_FLOW_VALIDATE,\n+\tCNXK_REP_MSG_FLOW_FLUSH,\n+\tCNXK_REP_MSG_FLOW_DUMP,\n+\tCNXK_REP_MSG_FLOW_QUERY,\n \t/* End of messaging sequence */\n \tCNXK_REP_MSG_END,\n } cnxk_rep_msg_t;\n@@ -109,6 +114,33 @@ typedef struct cnxk_rep_msg_flow_create_meta {\n \tuint16_t nb_action;\n } __rte_packed cnxk_rep_msg_flow_create_meta_t;\n \n+/* Flow destroy msg meta */\n+typedef struct cnxk_rep_msg_flow_destroy_meta {\n+\tuint64_t flow;\n+\tuint16_t portid;\n+} __rte_packed cnxk_rep_msg_flow_destroy_meta_t;\n+\n+/* Flow flush msg meta */\n+typedef struct cnxk_rep_msg_flow_flush_meta {\n+\tuint16_t portid;\n+} __rte_packed cnxk_rep_msg_flow_flush_meta_t;\n+\n+/* Flow dump msg meta */\n+typedef struct cnxk_rep_msg_flow_dump_meta {\n+\tuint64_t flow;\n+\tuint16_t portid;\n+\tuint8_t is_stdout;\n+} __rte_packed cnxk_rep_msg_flow_dump_meta_t;\n+\n+/* Flow query msg meta */\n+typedef struct cnxk_rep_msg_flow_query_meta {\n+\tuint64_t flow;\n+\tuint16_t portid;\n+\tuint8_t reset;\n+\tuint32_t action_data_sz;\n+\tuint8_t action_data[];\n+} __rte_packed cnxk_rep_msg_flow_query_meta_t;\n+\n /* Type pattern meta */\n typedef struct cnxk_pattern_hdr {\n \tuint16_t type;\n", "prefixes": [ "v4", "23/23" ] }