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 8E7EBA034C; Tue, 18 Jan 2022 16:34:57 +0100 (CET) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 724E842730; Tue, 18 Jan 2022 16:34:57 +0100 (CET) Received: from NAM10-DM6-obe.outbound.protection.outlook.com (mail-dm6nam10on2074.outbound.protection.outlook.com [40.107.93.74]) by mails.dpdk.org (Postfix) with ESMTP id BFF714068E for ; Tue, 18 Jan 2022 16:34:55 +0100 (CET) ARC-Seal: i=1; a=rsa-sha256; s=arcselector9901; d=microsoft.com; cv=none; b=QCEpj91suEN9Vwn4ik42106UiENVB4zBAQ00+Ns4BsmoIImX2FYNszuU1pDwjXh4N7G3Fci8v5f1dBRZyIPAz5z/QD886LvfVTOG0VduFEED9hOZ4u5Zi9loZYCxH0l6zGLyIluxlaN/gcvCP8uMMd/Qr2g94IBd6bU7RweO4Q13xP10fG99Yw56HYplZdnAhotMabeydHaF+/mwa+UehtSHRGvgPK22vaHZWBUuPn6fDggjMa2wmLTLpBRCF3lpSvbi539p6QHpcBTfPJ2pxHa33SL0sdWStE38w/6CR/ExDwgiKVbY6cRs/HPDnnBN/fAXgrEV5qylVqpbNBsnMg== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=microsoft.com; s=arcselector9901; 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=HEJFW/CJbrHu63nLaTb4wpYNYP1ZTksevilSaOQxkb4=; b=klFEsoS+2VSefw+3H3nsg9G558Vg3ARIBXi9UMgP1Rhp2EC4gQKaEMD8vV5zEeJ4IWtcr7iZcXhK7Xh8c2z6Og5IplQRWRdv0MA6GAcCmdixAGfxZ9vCkDgKz7AsI5XCFhktNRELuVQy9lhjOOcEemGQNQqsoJ6A/bCa18gYwR8bJNHJD2B/yUmJW5Sp7tQCkxisUaW/oqnPh0dZrUtwl2bsXCpEyLshvagGJB0FraAtDfpLx4CrkO/MNj3GkhQsq1SSC8lSAhsjDYvV1DWk5KSM0Y+uo65cI7dm+mQxVWvyXvkRy9LARFBKMEdTOazDl2AFY632XFMhCxKVGYLhCg== ARC-Authentication-Results: i=1; mx.microsoft.com 1; spf=pass (sender ip is 12.22.5.234) smtp.rcpttodomain=intel.com smtp.mailfrom=nvidia.com; dmarc=pass (p=reject sp=reject pct=100) action=none header.from=nvidia.com; dkim=none (message not signed); arc=none DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=Nvidia.com; s=selector2; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck; bh=HEJFW/CJbrHu63nLaTb4wpYNYP1ZTksevilSaOQxkb4=; b=MaBkHhXLBeAp1w2osvvDjOIrNYgJzJPYbHVc5/yXr+PQ9caGQWqdR0ulIuc0WSWEw9cAea7/niP1ec5TC80oWJ1toyRPli7qo5fZNyqN3AkOdUkl2OKP6ICNgRTAW1EzR3ptKShcSQLP+6fryNasH8iZZuhOU3zZN+ZCYeRol6YLEgsXSdYjz3tHBnoTEVMMpvkU8YzDsHdG+hmVd/UCXMbvOABgvoyLIInHli3Xvvu60DtSQ/BEa2Y6NAZH5Kw2j74dfm5Zydyp0TuFiGIYOFIV0mm4q8JDzDYVQHaTcWcWYXOwq9eVZBd/+o3hsx5sxeCknDGr4dldh5U702lpGQ== Received: from CH2PR12MB3926.namprd12.prod.outlook.com (2603:10b6:610:27::30) by DM6PR12MB3433.namprd12.prod.outlook.com (2603:10b6:5:38::14) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.4888.11; Tue, 18 Jan 2022 15:34:53 +0000 Received: from DM6PR12CA0004.namprd12.prod.outlook.com (2603:10b6:5:1c0::17) by CH2PR12MB3926.namprd12.prod.outlook.com (2603:10b6:610:27::30) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.4888.11; Tue, 18 Jan 2022 15:34:50 +0000 Received: from DM6NAM11FT042.eop-nam11.prod.protection.outlook.com (2603:10b6:5:1c0:cafe::96) by DM6PR12CA0004.outlook.office365.com (2603:10b6:5:1c0::17) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.4888.10 via Frontend Transport; Tue, 18 Jan 2022 15:34:50 +0000 X-MS-Exchange-Authentication-Results: spf=pass (sender IP is 12.22.5.234) smtp.mailfrom=nvidia.com; dkim=none (message not signed) header.d=none;dmarc=pass action=none header.from=nvidia.com; Received-SPF: Pass (protection.outlook.com: domain of nvidia.com designates 12.22.5.234 as permitted sender) receiver=protection.outlook.com; client-ip=12.22.5.234; helo=mail.nvidia.com; Received: from mail.nvidia.com (12.22.5.234) by DM6NAM11FT042.mail.protection.outlook.com (10.13.173.165) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384) id 15.20.4888.9 via Frontend Transport; Tue, 18 Jan 2022 15:34:50 +0000 Received: from rnnvmail201.nvidia.com (10.129.68.8) by DRHQMAIL101.nvidia.com (10.27.9.10) with Microsoft SMTP Server (TLS) id 15.0.1497.18; Tue, 18 Jan 2022 15:34:50 +0000 Received: from nvidia.com (10.126.230.35) by rnnvmail201.nvidia.com (10.129.68.8) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384) id 15.2.986.9; Tue, 18 Jan 2022 07:34:47 -0800 From: Alexander Kozyrev To: CC: , , , , , , , , Subject: [v2,06/10] app/testpmd: implement rte flow table Date: Tue, 18 Jan 2022 17:34:34 +0200 Message-ID: <20220118153434.3947731-1-akozyrev@nvidia.com> X-Mailer: git-send-email 2.18.2 In-Reply-To: <20220118153027.3947448-1-akozyrev@nvidia.com> References: <20220118153027.3947448-1-akozyrev@nvidia.com> MIME-Version: 1.0 Content-Type: text/plain X-Originating-IP: [10.126.230.35] X-ClientProxiedBy: HQMAIL107.nvidia.com (172.20.187.13) To rnnvmail201.nvidia.com (10.129.68.8) X-EOPAttributedMessage: 0 X-MS-PublicTrafficType: Email X-MS-Office365-Filtering-Correlation-Id: d867b07e-801b-4934-d857-08d9da98112e X-MS-TrafficTypeDiagnostic: CH2PR12MB3926:EE_|DM6PR12MB3433:EE_ X-LD-Processed: 43083d15-7273-40c1-b7db-39efd9ccc17a,ExtAddr,ExtAddr X-Microsoft-Antispam-PRVS: X-MS-Oob-TLC-OOBClassifiers: OLM:6430; X-MS-Exchange-SenderADCheck: 1 X-MS-Exchange-AntiSpam-Relay: 0 X-Microsoft-Antispam: BCL:0; X-Microsoft-Antispam-Message-Info: tEVpu3MusraxsCEIoY8ioVo4yWU+nGdMjCU9AP+gPMlXfMMslXYPx6IpEvw91knU6ElDUCSL/+mti8YtE1Z7osaEFle0Cp1hz7fvAYAS0+3QrO1eWU3BsnnVpE4PhTfOq+2shEwVoaK3mVmx6zTFeJLhLEoI/GpZ3OsvIkvhaRsQKGGrpDmYHqKoRN65Pg1EM/LTR8TwtRR7ISBye5W7vb7EQJah5HWMD0NYaxYuhT5p+5tfuG5W4tvLE4zGk82DbJQu6w4YYakoGaHzDUgetBjRi0dGPwuXsWtKFYzCFMm9ZVYAW8vVAGJOjhAaeFTk3sEPVZG2KWQO8ifNyBS1zClfTjWycDG/XBSCfYOMwPZqpslax/IuWFO52Dtg2mxu1q5wxp2clK56GhxnbRDIOM2jt7KrhdqE1XBjjv+ilLdkB9vSKWhmzGn4M9JFTpyGFXFmJlm+Y/soIj9sUfiItBtWkPeGA/L+sFAiQSJZhvhcNShBKrWhtcwuQ0RoJtU7v/8Vr/Qym0LhJzkgGXg5Jf+cxYKNDGiK3CZ7Cn3LQGqKCLKg66H81Wn8lR6LbLj14YWODSSy0z5UrW9rwBP3SR3nVQNb8sjoDyG5Id2mEn3TsKOiVGV5XpbI725HLrEYwS+xzpDakIMP7/54IEXnED46KYwAP4efRcyyoMjwfKBaXEWA4Xo0ScnmQN61vpHIMAZU2Lx2vknfDOfd8GEbJlt3iZkkv2vVjyGZ74pIn/IA8OcgnVe2tdp6nqX1+ipCwdxZdhXzyPsSMSjZpmZyFFW8v0ganLnhind3DRi4ID8= X-Forefront-Antispam-Report: CIP:12.22.5.234; CTRY:US; LANG:en; SCL:1; SRV:; IPV:CAL; SFV:NSPM; H:mail.nvidia.com; PTR:InfoNoRecords; CAT:NONE; SFS:(4636009)(36840700001)(46966006)(40470700002)(5660300002)(336012)(82310400004)(2906002)(70586007)(6286002)(316002)(6916009)(70206006)(55016003)(186003)(16526019)(6666004)(426003)(26005)(1076003)(54906003)(30864003)(2616005)(86362001)(81166007)(36756003)(356005)(508600001)(8676002)(8936002)(7696005)(40460700001)(47076005)(83380400001)(4326008)(36860700001)(36900700001); DIR:OUT; SFP:1101; X-OriginatorOrg: Nvidia.com X-MS-Exchange-CrossTenant-OriginalArrivalTime: 18 Jan 2022 15:34:50.5927 (UTC) X-MS-Exchange-CrossTenant-Network-Message-Id: d867b07e-801b-4934-d857-08d9da98112e X-MS-Exchange-CrossTenant-Id: 43083d15-7273-40c1-b7db-39efd9ccc17a X-MS-Exchange-CrossTenant-OriginalAttributedTenantConnectingIp: TenantId=43083d15-7273-40c1-b7db-39efd9ccc17a; Ip=[12.22.5.234]; Helo=[mail.nvidia.com] X-MS-Exchange-CrossTenant-FromEntityHeader: HybridOnPrem X-MS-Exchange-CrossTenant-AuthSource: DM6NAM11FT042.eop-nam11.prod.protection.outlook.com X-MS-Exchange-CrossTenant-AuthAs: Anonymous X-MS-Exchange-Transport-CrossTenantHeadersStamped: DM6PR12MB3433 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 Add testpmd support for the rte_flow_table API. Provide the command line interface for the flow table creation/destruction. Usage example: testpmd> flow table 0 create table_id 6 group 9 priority 4 ingress mode 1 rules_number 64 item_template 2 action_template 4 testpmd> flow table 0 destroy table 6 Signed-off-by: Alexander Kozyrev --- app/test-pmd/cmdline_flow.c | 315 ++++++++++++++++++++ app/test-pmd/config.c | 168 +++++++++++ app/test-pmd/testpmd.h | 15 + doc/guides/testpmd_app_ug/testpmd_funcs.rst | 53 ++++ 4 files changed, 551 insertions(+) diff --git a/app/test-pmd/cmdline_flow.c b/app/test-pmd/cmdline_flow.c index fb27a97855..4dc2a2aaeb 100644 --- a/app/test-pmd/cmdline_flow.c +++ b/app/test-pmd/cmdline_flow.c @@ -58,6 +58,7 @@ enum index { COMMON_FLEX_TOKEN, COMMON_ITEM_TEMPLATE_ID, COMMON_ACTION_TEMPLATE_ID, + COMMON_TABLE_ID, /* TOP-level command. */ ADD, @@ -77,6 +78,7 @@ enum index { CONFIGURE, ITEM_TEMPLATE, ACTION_TEMPLATE, + TABLE, INDIRECT_ACTION, VALIDATE, CREATE, @@ -111,6 +113,20 @@ enum index { ACTION_TEMPLATE_SPEC, ACTION_TEMPLATE_MASK, + /* Table arguments. */ + TABLE_CREATE, + TABLE_DESTROY, + TABLE_CREATE_ID, + TABLE_DESTROY_ID, + TABLE_GROUP, + TABLE_PRIORITY, + TABLE_INGRESS, + TABLE_EGRESS, + TABLE_TRANSFER, + TABLE_RULES_NUMBER, + TABLE_ITEM_TEMPLATE, + TABLE_ACTION_TEMPLATE, + /* Tunnel arguments. */ TUNNEL_CREATE, TUNNEL_CREATE_TYPE, @@ -882,6 +898,18 @@ struct buffer { uint32_t *template_id; uint32_t template_id_n; } templ_destroy; /**< Template destroy arguments. */ + struct { + uint32_t id; + struct rte_flow_table_attr attr; + uint32_t *item_id; + uint32_t item_id_n; + uint32_t *action_id; + uint32_t action_id_n; + } table; /**< Table arguments. */ + struct { + uint32_t *table_id; + uint32_t table_id_n; + } table_destroy; /**< Template destroy arguments. */ struct { uint32_t *action_id; uint32_t action_id_n; @@ -1013,6 +1041,32 @@ static const enum index next_at_destroy_attr[] = { ZERO, }; +static const enum index next_table_subcmd[] = { + TABLE_CREATE, + TABLE_DESTROY, + ZERO, +}; + +static const enum index next_table_attr[] = { + TABLE_CREATE_ID, + TABLE_GROUP, + TABLE_PRIORITY, + TABLE_INGRESS, + TABLE_EGRESS, + TABLE_TRANSFER, + TABLE_RULES_NUMBER, + TABLE_ITEM_TEMPLATE, + TABLE_ACTION_TEMPLATE, + END, + ZERO, +}; + +static const enum index next_table_destroy_attr[] = { + TABLE_DESTROY_ID, + END, + ZERO, +}; + static const enum index next_ia_create_attr[] = { INDIRECT_ACTION_CREATE_ID, INDIRECT_ACTION_INGRESS, @@ -2057,6 +2111,11 @@ static int parse_template(struct context *, const struct token *, static int parse_template_destroy(struct context *, const struct token *, const char *, unsigned int, void *, unsigned int); +static int parse_table(struct context *, const struct token *, + const char *, unsigned int, void *, unsigned int); +static int parse_table_destroy(struct context *, const struct token *, + const char *, unsigned int, + void *, unsigned int); static int parse_tunnel(struct context *, const struct token *, const char *, unsigned int, void *, unsigned int); @@ -2130,6 +2189,8 @@ static int comp_item_template_id(struct context *, const struct token *, unsigned int, char *, unsigned int); static int comp_action_template_id(struct context *, const struct token *, unsigned int, char *, unsigned int); +static int comp_table_id(struct context *, const struct token *, + unsigned int, char *, unsigned int); /** Token definitions. */ static const struct token token_list[] = { @@ -2294,6 +2355,13 @@ static const struct token token_list[] = { .call = parse_int, .comp = comp_action_template_id, }, + [COMMON_TABLE_ID] = { + .name = "{table_id}", + .type = "TABLE_ID", + .help = "table id", + .call = parse_int, + .comp = comp_table_id, + }, /* Top-level command. */ [FLOW] = { .name = "flow", @@ -2303,6 +2371,7 @@ static const struct token token_list[] = { (CONFIGURE, ITEM_TEMPLATE, ACTION_TEMPLATE, + TABLE, INDIRECT_ACTION, VALIDATE, CREATE, @@ -2474,6 +2543,104 @@ static const struct token token_list[] = { .call = parse_template, }, /* Top-level command. */ + [TABLE] = { + .name = "table", + .type = "{command} {port_id} [{arg} [...]]", + .help = "manage tables", + .next = NEXT(next_table_subcmd, NEXT_ENTRY(COMMON_PORT_ID)), + .args = ARGS(ARGS_ENTRY(struct buffer, port)), + .call = parse_table, + }, + /* Sub-level commands. */ + [TABLE_CREATE] = { + .name = "create", + .help = "create table", + .next = NEXT(next_table_attr), + .call = parse_table, + }, + [TABLE_DESTROY] = { + .name = "destroy", + .help = "destroy table", + .next = NEXT(NEXT_ENTRY(TABLE_DESTROY_ID)), + .args = ARGS(ARGS_ENTRY(struct buffer, port)), + .call = parse_table_destroy, + }, + /* Table arguments. */ + [TABLE_CREATE_ID] = { + .name = "table_id", + .help = "specify table id to create", + .next = NEXT(next_table_attr, + NEXT_ENTRY(COMMON_TABLE_ID)), + .args = ARGS(ARGS_ENTRY(struct buffer, args.table.id)), + }, + [TABLE_DESTROY_ID] = { + .name = "table", + .help = "specify table id to destroy", + .next = NEXT(next_table_destroy_attr, + NEXT_ENTRY(COMMON_TABLE_ID)), + .args = ARGS(ARGS_ENTRY_PTR(struct buffer, + args.table_destroy.table_id)), + .call = parse_table_destroy, + }, + [TABLE_GROUP] = { + .name = "group", + .help = "specify a group", + .next = NEXT(next_table_attr, NEXT_ENTRY(COMMON_GROUP_ID)), + .args = ARGS(ARGS_ENTRY(struct buffer, + args.table.attr.flow_attr.group)), + }, + [TABLE_PRIORITY] = { + .name = "priority", + .help = "specify a priority level", + .next = NEXT(next_table_attr, NEXT_ENTRY(COMMON_PRIORITY_LEVEL)), + .args = ARGS(ARGS_ENTRY(struct buffer, + args.table.attr.flow_attr.priority)), + }, + [TABLE_EGRESS] = { + .name = "egress", + .help = "affect rule to egress", + .next = NEXT(next_table_attr), + .call = parse_table, + }, + [TABLE_INGRESS] = { + .name = "ingress", + .help = "affect rule to ingress", + .next = NEXT(next_table_attr), + .call = parse_table, + }, + [TABLE_TRANSFER] = { + .name = "transfer", + .help = "affect rule to transfer", + .next = NEXT(next_table_attr), + .call = parse_table, + }, + [TABLE_RULES_NUMBER] = { + .name = "rules_number", + .help = "number of rules in table", + .next = NEXT(next_table_attr, + NEXT_ENTRY(COMMON_UNSIGNED)), + .args = ARGS(ARGS_ENTRY(struct buffer, + args.table.attr.nb_flows)), + }, + [TABLE_ITEM_TEMPLATE] = { + .name = "item_template", + .help = "specify item template id", + .next = NEXT(next_table_attr, + NEXT_ENTRY(COMMON_ITEM_TEMPLATE_ID)), + .args = ARGS(ARGS_ENTRY_PTR(struct buffer, + args.table.item_id)), + .call = parse_table, + }, + [TABLE_ACTION_TEMPLATE] = { + .name = "action_template", + .help = "specify action template id", + .next = NEXT(next_table_attr, + NEXT_ENTRY(COMMON_ACTION_TEMPLATE_ID)), + .args = ARGS(ARGS_ENTRY_PTR(struct buffer, + args.table.action_id)), + .call = parse_table, + }, + /* Top-level command. */ [INDIRECT_ACTION] = { .name = "indirect_action", .type = "{command} {port_id} [{arg} [...]]", @@ -7874,6 +8041,119 @@ parse_template_destroy(struct context *ctx, const struct token *token, return len; } +/** Parse tokens for indirect action commands. */ +static int +parse_table(struct context *ctx, const struct token *token, + const char *str, unsigned int len, + void *buf, unsigned int size) +{ + struct buffer *out = buf; + uint32_t *template_id; + + /* Token name must match. */ + if (parse_default(ctx, token, str, len, NULL, 0) < 0) + return -1; + /* Nothing else to do if there is no buffer. */ + if (!out) + return len; + if (!out->command) { + if (ctx->curr != TABLE) + return -1; + if (sizeof(*out) > size) + return -1; + out->command = ctx->curr; + ctx->objdata = 0; + ctx->object = out; + ctx->objmask = NULL; + return len; + } + switch (ctx->curr) { + case TABLE_CREATE: + out->command = ctx->curr; + ctx->objdata = 0; + ctx->object = out; + ctx->objmask = NULL; + out->args.table.id = UINT32_MAX; + return len; + case TABLE_ITEM_TEMPLATE: + out->args.table.item_id = + (void *)RTE_ALIGN_CEIL((uintptr_t)(out + 1), + sizeof(double)); + template_id = out->args.table.item_id + + out->args.table.item_id_n++; + if ((uint8_t *)template_id > (uint8_t *)out + size) + return -1; + ctx->objdata = 0; + ctx->object = template_id; + ctx->objmask = NULL; + return len; + case TABLE_ACTION_TEMPLATE: + out->args.table.action_id = + (void *)RTE_ALIGN_CEIL((uintptr_t) + (out->args.table.item_id + + out->args.table.item_id_n), + sizeof(double)); + template_id = out->args.table.action_id + + out->args.table.action_id_n++; + if ((uint8_t *)template_id > (uint8_t *)out + size) + return -1; + ctx->objdata = 0; + ctx->object = template_id; + ctx->objmask = NULL; + return len; + case TABLE_INGRESS: + out->args.table.attr.flow_attr.ingress = 1; + return len; + case TABLE_EGRESS: + out->args.table.attr.flow_attr.egress = 1; + return len; + case TABLE_TRANSFER: + out->args.table.attr.flow_attr.transfer = 1; + return len; + default: + return -1; + } +} + +/** Parse tokens for indirect action destroy command. */ +static int +parse_table_destroy(struct context *ctx, const struct token *token, + const char *str, unsigned int len, + void *buf, unsigned int size) +{ + struct buffer *out = buf; + uint32_t *table_id; + + /* Token name must match. */ + if (parse_default(ctx, token, str, len, NULL, 0) < 0) + return -1; + /* Nothing else to do if there is no buffer. */ + if (!out) + return len; + if (!out->command || out->command == TABLE) { + if (ctx->curr != TABLE_DESTROY) + return -1; + if (sizeof(*out) > size) + return -1; + out->command = ctx->curr; + ctx->objdata = 0; + ctx->object = out; + ctx->objmask = NULL; + out->args.table_destroy.table_id = + (void *)RTE_ALIGN_CEIL((uintptr_t)(out + 1), + sizeof(double)); + return len; + } + table_id = out->args.table_destroy.table_id + + out->args.table_destroy.table_id_n++; + if ((uint8_t *)table_id > (uint8_t *)out + size) + return -1; + ctx->objdata = 0; + ctx->object = table_id; + ctx->objmask = NULL; + return len; +} + static int parse_flex(struct context *ctx, const struct token *token, const char *str, unsigned int len, @@ -8889,6 +9169,30 @@ comp_action_template_id(struct context *ctx, const struct token *token, return i; } +/** Complete available table IDs. */ +static int +comp_table_id(struct context *ctx, const struct token *token, + unsigned int ent, char *buf, unsigned int size) +{ + unsigned int i = 0; + struct rte_port *port; + struct port_table *pt; + + (void)token; + if (port_id_is_invalid(ctx->port, DISABLED_WARN) || + ctx->port == (portid_t)RTE_PORT_ALL) + return -1; + port = &ports[ctx->port]; + for (pt = port->table_list; pt != NULL; pt = pt->next) { + if (buf && i == ent) + return snprintf(buf, size, "%u", pt->id); + ++i; + } + if (buf) + return -1; + return i; +} + /** Internal context. */ static struct context cmd_flow_context; @@ -9170,6 +9474,17 @@ cmd_flow_parsed(const struct buffer *in) in->args.templ_destroy.template_id_n, in->args.templ_destroy.template_id); break; + case TABLE_CREATE: + port_flow_table_create(in->port, in->args.table.id, + &in->args.table.attr, in->args.table.item_id_n, + in->args.table.item_id, in->args.table.action_id_n, + in->args.table.action_id); + break; + case TABLE_DESTROY: + port_flow_table_destroy(in->port, + in->args.table_destroy.table_id_n, + in->args.table_destroy.table_id); + break; case INDIRECT_ACTION_CREATE: port_action_handle_create( in->port, in->args.vc.attr.group, diff --git a/app/test-pmd/config.c b/app/test-pmd/config.c index 80678d851f..07582fa552 100644 --- a/app/test-pmd/config.c +++ b/app/test-pmd/config.c @@ -1638,6 +1638,49 @@ template_alloc(uint32_t id, struct port_template **template, return 0; } +static int +table_alloc(uint32_t id, struct port_table **table, + struct port_table **list) +{ + struct port_table *lst = *list; + struct port_table **ppt; + struct port_table *pt = NULL; + + *table = NULL; + if (id == UINT32_MAX) { + /* taking first available ID */ + if (lst) { + if (lst->id == UINT32_MAX - 1) { + printf("Highest table ID is already" + " assigned, delete it first\n"); + return -ENOMEM; + } + id = lst->id + 1; + } else { + id = 0; + } + } + pt = calloc(1, sizeof(*pt)); + if (!pt) { + printf("Allocation of table failed\n"); + return -ENOMEM; + } + ppt = list; + while (*ppt && (*ppt)->id > id) + ppt = &(*ppt)->next; + if (*ppt && (*ppt)->id == id) { + printf("Table #%u is already assigned," + " delete it first\n", id); + free(pt); + return -EINVAL; + } + pt->next = *ppt; + pt->id = id; + *ppt = pt; + *table = pt; + return 0; +} + /** Configure flow management resources. */ int port_flow_configure(portid_t port_id, @@ -2243,6 +2286,131 @@ port_flow_action_template_destroy(portid_t port_id, uint32_t n, return ret; } +/** Create table */ +int +port_flow_table_create(portid_t port_id, uint32_t id, + const struct rte_flow_table_attr *table_attr, + uint32_t nb_item_templates, uint32_t *item_templates, + uint32_t nb_action_templates, uint32_t *action_templates) +{ + struct rte_port *port; + struct port_table *pt; + struct port_template *temp = NULL; + int ret; + uint32_t i; + struct rte_flow_error error; + struct rte_flow_item_template + *flow_item_templates[nb_item_templates]; + struct rte_flow_action_template + *flow_action_templates[nb_action_templates]; + + if (port_id_is_invalid(port_id, ENABLED_WARN) || + port_id == (portid_t)RTE_PORT_ALL) + return -EINVAL; + port = &ports[port_id]; + for (i = 0; i < nb_item_templates; ++i) { + bool found = false; + temp = port->item_templ_list; + while (temp) { + if (item_templates[i] == temp->id) { + flow_item_templates[i] = temp->template.itempl; + found = true; + break; + } + temp = temp->next; + } + if (!found) { + printf("Item template #%u is invalid\n", + item_templates[i]); + return -EINVAL; + } + } + for (i = 0; i < nb_action_templates; ++i) { + bool found = false; + temp = port->action_templ_list; + while (temp) { + if (action_templates[i] == temp->id) { + flow_action_templates[i] = + temp->template.atempl; + found = true; + break; + } + temp = temp->next; + } + if (!found) { + printf("Action template #%u is invalid\n", + action_templates[i]); + return -EINVAL; + } + } + ret = table_alloc(id, &pt, &port->table_list); + if (ret) + return ret; + /* Poisoning to make sure PMDs update it in case of error. */ + memset(&error, 0x22, sizeof(error)); + pt->table = rte_flow_table_create(port_id, table_attr, + flow_item_templates, nb_item_templates, + flow_action_templates, nb_action_templates, + &error); + + if (!pt->table) { + uint32_t destroy_id = pt->id; + port_flow_table_destroy(port_id, 1, &destroy_id); + return port_flow_complain(&error); + } + printf("Table #%u created\n", pt->id); + return 0; +} + +/** Destroy table */ +int +port_flow_table_destroy(portid_t port_id, + uint32_t n, const uint32_t *table) +{ + struct rte_port *port; + struct port_table **tmp; + uint32_t c = 0; + int ret = 0; + + if (port_id_is_invalid(port_id, ENABLED_WARN) || + port_id == (portid_t)RTE_PORT_ALL) + return -EINVAL; + port = &ports[port_id]; + tmp = &port->table_list; + while (*tmp) { + uint32_t i; + + for (i = 0; i != n; ++i) { + struct rte_flow_error error; + struct port_table *pt = *tmp; + + if (table[i] != pt->id) + continue; + /* + * Poisoning to make sure PMDs update it in case + * of error. + */ + memset(&error, 0x33, sizeof(error)); + + if (pt->table && + rte_flow_table_destroy(port_id, + pt->table, + &error)) { + ret = port_flow_complain(&error); + continue; + } + *tmp = pt->next; + printf("Table #%u destroyed\n", pt->id); + free(pt); + break; + } + if (i == n) + tmp = &(*tmp)->next; + ++c; + } + return ret; +} + /** Create flow rule. */ int port_flow_create(portid_t port_id, diff --git a/app/test-pmd/testpmd.h b/app/test-pmd/testpmd.h index 4befa6d7a4..b8655b9987 100644 --- a/app/test-pmd/testpmd.h +++ b/app/test-pmd/testpmd.h @@ -177,6 +177,14 @@ struct port_template { } template; /**< PMD opaque template object */ }; +/** Descriptor for a flow table. */ +struct port_table { + struct port_table *next; /**< Next table in list. */ + struct port_table *tmp; /**< Temporary linking. */ + uint32_t id; /**< Table ID. */ + struct rte_flow_table *table; /**< PMD opaque template object */ +}; + /** Descriptor for a single flow. */ struct port_flow { struct port_flow *next; /**< Next flow in list. */ @@ -259,6 +267,7 @@ struct rte_port { uint8_t slave_flag; /**< bonding slave port */ struct port_template *item_templ_list; /**< Item templates. */ struct port_template *action_templ_list; /**< Action templates. */ + struct port_table *table_list; /**< Flow tables. */ struct port_flow *flow_list; /**< Associated flows. */ struct port_indirect_action *actions_list; /**< Associated indirect actions. */ @@ -912,6 +921,12 @@ int port_flow_action_template_create(portid_t port_id, uint32_t id, const struct rte_flow_action *masks); int port_flow_action_template_destroy(portid_t port_id, uint32_t n, const uint32_t *template); +int port_flow_table_create(portid_t port_id, uint32_t id, + const struct rte_flow_table_attr *table_attr, + uint32_t nb_item_templates, uint32_t *item_templates, + uint32_t nb_action_templates, uint32_t *action_templates); +int port_flow_table_destroy(portid_t port_id, + uint32_t n, const uint32_t *table); int port_flow_validate(portid_t port_id, const struct rte_flow_attr *attr, const struct rte_flow_item *pattern, diff --git a/doc/guides/testpmd_app_ug/testpmd_funcs.rst b/doc/guides/testpmd_app_ug/testpmd_funcs.rst index d23cfa6572..f8a87564be 100644 --- a/doc/guides/testpmd_app_ug/testpmd_funcs.rst +++ b/doc/guides/testpmd_app_ug/testpmd_funcs.rst @@ -3335,6 +3335,19 @@ following sections. flow action_template {port_id} destroy action_template {id} [...] +- Create a table:: + + flow table {port_id} create + [table_id {id}] + [group {group_id}] [priority {level}] [ingress] [egress] [transfer] + rules_number {number} + item_template {item_template_id} + action_template {action_template_id} + +- Destroy a table:: + + flow table {port_id} destroy table {id} [...] + - Check whether a flow rule can be created:: flow validate {port_id} @@ -3495,6 +3508,46 @@ The usual error message is shown when an item template cannot be destroyed:: Caught error type [...] ([...]): [...] +Creating flow table +~~~~~~~~~~~~~~~~~~~ + +``flow table create`` creates the specified flow table. +It is bound to ``rte_flow_table_create()``:: + + flow table {port_id} create + [table_id {id}] [group {group_id}] + [priority {level}] [ingress] [egress] [transfer] + rules_number {number} + item_template {item_template_id} + action_template {action_template_id} + +If successful, it will show:: + + Table #[...] created + +Otherwise it will show an error message of the form:: + + Caught error type [...] ([...]): [...] + +Destroying flow table +~~~~~~~~~~~~~~~~~~~~~ + +``flow table destroy`` destroys one or more flow tables +from their table ID (as returned by ``flow table create``), +this command calls ``rte_flow_table_destroy()`` as many +times as necessary:: + + flow table {port_id} destroy table {id} [...] + +If successful, it will show:: + + Table #[...] destroyed + +It does not report anything for table IDs that do not exist. +The usual error message is shown when a table cannot be destroyed:: + + Caught error type [...] ([...]): [...] + Creating a tunnel stub for offload ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ -- 2.18.2