ethdev: add send queue flow matching item
Checks
Commit Message
From: Kiran Kumar K <kirankumark@marvell.com>
Adding support for send queue flow matching item.
This item is valid only for egress rules.
An example use case would be that application can
set different vlan insert rules with different PCP values
based on tx queue number.
Signed-off-by: Kiran Kumar K <kirankumark@marvell.com>
---
app/test-pmd/cmdline_flow.c | 28 +++++++++++++++++++
doc/guides/prog_guide/rte_flow.rst | 7 +++++
doc/guides/rel_notes/release_23_07.rst | 31 ++-------------------
doc/guides/testpmd_app_ug/testpmd_funcs.rst | 4 +++
lib/ethdev/rte_flow.c | 1 +
lib/ethdev/rte_flow.h | 26 +++++++++++++++++
6 files changed, 68 insertions(+), 29 deletions(-)
Comments
On Thu, Apr 20, 2023 at 10:59 AM <kirankumark@marvell.com> wrote:
>
> From: Kiran Kumar K <kirankumark@marvell.com>
>
> Adding support for send queue flow matching item.
To be consistent, use Tx queue every where.(git commit subject too)
> This item is valid only for egress rules.
> An example use case would be that application can
> set different vlan insert rules with different PCP values
> based on tx queue number.
>
> Signed-off-by: Kiran Kumar K <kirankumark@marvell.com>
> ---
> app/test-pmd/cmdline_flow.c | 28 +++++++++++++++++++
> doc/guides/prog_guide/rte_flow.rst | 7 +++++
> doc/guides/rel_notes/release_23_07.rst | 31 ++-------------------
> doc/guides/testpmd_app_ug/testpmd_funcs.rst | 4 +++
> lib/ethdev/rte_flow.c | 1 +
> lib/ethdev/rte_flow.h | 26 +++++++++++++++++
> 6 files changed, 68 insertions(+), 29 deletions(-)
>
> diff --git a/app/test-pmd/cmdline_flow.c b/app/test-pmd/cmdline_flow.c
> index 58939ec321..a68a6080a8 100644
> --- a/app/test-pmd/cmdline_flow.c
> +++ b/app/test-pmd/cmdline_flow.c
> @@ -496,6 +496,8 @@ enum index {
> ITEM_QUOTA_STATE_NAME,
> ITEM_AGGR_AFFINITY,
> ITEM_AGGR_AFFINITY_VALUE,
> + ITEM_TX_QUEUE,
> + ITEM_TX_QUEUE_VALUE,
>
> /* Validate/create actions. */
> ACTIONS,
> @@ -1452,6 +1454,7 @@ static const enum index next_item[] = {
> ITEM_METER,
> ITEM_QUOTA,
> ITEM_AGGR_AFFINITY,
> + ITEM_TX_QUEUE,
> END_SET,
> ZERO,
> };
> @@ -1953,6 +1956,12 @@ static const enum index item_aggr_affinity[] = {
> ZERO,
> };
>
> +static const enum index item_tx_queue[] = {
> + ITEM_TX_QUEUE_VALUE,
> + ITEM_NEXT,
> + ZERO,
> +};
> +
> static const enum index next_action[] = {
> ACTION_END,
> ACTION_VOID,
> @@ -6945,6 +6954,22 @@ static const struct token token_list[] = {
> .args = ARGS(ARGS_ENTRY(struct rte_flow_item_aggr_affinity,
> affinity)),
> },
> + [ITEM_TX_QUEUE] = {
> + .name = "tx_queue",
> + .help = "match on the tx queue of send packet",
> + .priv = PRIV_ITEM(TX_QUEUE,
> + sizeof(struct rte_flow_item_tx_queue)),
> + .next = NEXT(item_tx_queue),
> + .call = parse_vc,
> + },
> + [ITEM_TX_QUEUE_VALUE] = {
> + .name = "tx_queue_value",
> + .help = "tx queue value",
> + .next = NEXT(item_tx_queue, NEXT_ENTRY(COMMON_UNSIGNED),
> + item_param),
> + .args = ARGS(ARGS_ENTRY(struct rte_flow_item_tx_queue,
> + tx_queue)),
> + },
> };
>
> /** Remove and return last entry from argument stack. */
> @@ -11849,6 +11874,9 @@ flow_item_default_mask(const struct rte_flow_item *item)
> case RTE_FLOW_ITEM_TYPE_AGGR_AFFINITY:
> mask = &rte_flow_item_aggr_affinity_mask;
> break;
> + case RTE_FLOW_ITEM_TYPE_TX_QUEUE:
> + mask = &rte_flow_item_tx_queue_mask;
> + break;
> default:
> break;
> }
> diff --git a/doc/guides/prog_guide/rte_flow.rst b/doc/guides/prog_guide/rte_flow.rst
> index 32fc45516a..7154b56330 100644
> --- a/doc/guides/prog_guide/rte_flow.rst
> +++ b/doc/guides/prog_guide/rte_flow.rst
> @@ -1486,6 +1486,13 @@ This item is meant to use the same structure as `Item: PORT_REPRESENTOR`_.
>
> See also `Action: REPRESENTED_PORT`_.
>
> +Item: ``TX_QUEUE``
> +^^^^^^^^^^^^^^^^^^^^^^^
> +
> +Matches on the tx queue of send packet .
tx -> Tx
> +
> +- ``tx_queue``: Tx queue.
> +
> Item: ``AGGR_AFFINITY``
> ^^^^^^^^^^^^^^^^^^^^^^^
>
> diff --git a/doc/guides/rel_notes/release_23_07.rst b/doc/guides/rel_notes/release_23_07.rst
> index a9b1293689..631cbd2b58 100644
> --- a/doc/guides/rel_notes/release_23_07.rst
> +++ b/doc/guides/rel_notes/release_23_07.rst
> @@ -24,36 +24,9 @@ DPDK Release 23.07
> New Features
> ------------
>
> -.. This section should contain new features added in this release.
> - Sample format:
> +* **Added flow matching of tx queue.**
Same as below. Right?
>
> - * **Add a title in the past tense with a full stop.**
> -
> - Add a short 1-2 sentence description in the past tense.
> - The description should be enough to allow someone scanning
> - the release notes to understand the new feature.
> -
> - If the feature adds a lot of sub-features you can use a bullet list
> - like this:
> -
> - * Added feature foo to do something.
> - * Enhanced feature bar to do something else.
> -
> - Refer to the previous release notes for examples.
> -
> - Suggested order in release notes items:
> - * Core libs (EAL, mempool, ring, mbuf, buses)
> - * Device abstraction libs and PMDs (ordered alphabetically by vendor name)
> - - ethdev (lib, PMDs)
> - - cryptodev (lib, PMDs)
> - - eventdev (lib, PMDs)
> - - etc
> - * Other libs
> - * Apps, Examples, Tools (if significant)
> -
> - This section is a comment. Do not overwrite or remove it.
> - Also, make sure to start the actual text at the margin.
> - =======================================================
No need to remove this section comment.
> + Added ``RTE_FLOW_ITEM_TYPE_TX_QUEUE`` to match tx queue of send packet.
Added ``RTE_FLOW_ITEM_TYPE_TX_QUEUE`` rte_flow pattern to match Tx
queue of send packet.
>
>
> Removed Items
> diff --git a/doc/guides/testpmd_app_ug/testpmd_funcs.rst b/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> index 8f23847859..29f7dd4428 100644
> --- a/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> +++ b/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> @@ -3779,6 +3779,10 @@ This section lists supported pattern items and their attributes, if any.
>
> - ``affinity {value}``: aggregated port (starts from 1).
>
> +- ``tx_queue``: match tx queue of send packet.
> +
> + - ``tx_queue {value}``: send queue value (starts from 0).
> +
> - ``send_to_kernel``: send packets to kernel.
>
>
> diff --git a/lib/ethdev/rte_flow.c b/lib/ethdev/rte_flow.c
> index 69e6e749f7..f0d7f868fa 100644
> --- a/lib/ethdev/rte_flow.c
> +++ b/lib/ethdev/rte_flow.c
> @@ -164,6 +164,7 @@ static const struct rte_flow_desc_data rte_flow_desc_item[] = {
> MK_FLOW_ITEM(IPV6_ROUTING_EXT, sizeof(struct rte_flow_item_ipv6_routing_ext)),
> MK_FLOW_ITEM(QUOTA, sizeof(struct rte_flow_item_quota)),
> MK_FLOW_ITEM(AGGR_AFFINITY, sizeof(struct rte_flow_item_aggr_affinity)),
> + MK_FLOW_ITEM(TX_QUEUE, sizeof(struct rte_flow_item_tx_queue)),
> };
>
> /** Generate flow_action[] entry. */
> diff --git a/lib/ethdev/rte_flow.h b/lib/ethdev/rte_flow.h
> index 713ba8b65c..e75876c371 100644
> --- a/lib/ethdev/rte_flow.h
> +++ b/lib/ethdev/rte_flow.h
> @@ -672,8 +672,34 @@ enum rte_flow_item_type {
> * @see struct rte_flow_item_aggr_affinity.
> */
> RTE_FLOW_ITEM_TYPE_AGGR_AFFINITY,
> + /**
> + * Match Send Queue number.
Tx queue
> + * This is valid only for egress rules.
> + *
> + * @see struct rte_flow_item_tx_queue
> + */
> + RTE_FLOW_ITEM_TYPE_TX_QUEUE,
> };
>
> +/**
> + * RTE_FLOW_ITEM_TYPE_TX_QUEUE
> + *
> + * Send queue number
Tx
> + *
> + * @see struct rte_flow_item_tx_queue
> + */
> +struct rte_flow_item_tx_queue {
> + /** Send queue number that packet is being transmitted */
Tx
> + uint16_t tx_queue;
> +};
> +
> +/** Default mask for RTE_FLOW_ITEM_TX_QUEUE. */
> +#ifndef __cplusplus
> +static const struct rte_flow_item_tx_queue rte_flow_item_tx_queue_mask = {
> + .tx_queue = RTE_BE16(0xffff),
> +};
> +#endif
> +
> /**
> * @warning
> * @b EXPERIMENTAL: this API may change without prior notice.
> --
> 2.34.1
>
Hi all,
I'd like to test this feature somehow but this patch just implements the API... Will there
be some PMD support soon? I could see that mlx5 implements some internal hidden RTE Flow
item SC already that matches this behaviour... It would be great to make it available
via this TX_QUEUE feature. Any plans for this (Ori)?
Jan
On Thu, 20 Apr 2023 10:59:01 +0530
<kirankumark@marvell.com> wrote:
> From: Kiran Kumar K <kirankumark@marvell.com>
>
> Adding support for send queue flow matching item.
> This item is valid only for egress rules.
> An example use case would be that application can
> set different vlan insert rules with different PCP values
> based on tx queue number.
>
> Signed-off-by: Kiran Kumar K <kirankumark@marvell.com>
> ---
> app/test-pmd/cmdline_flow.c | 28 +++++++++++++++++++
> doc/guides/prog_guide/rte_flow.rst | 7 +++++
> doc/guides/rel_notes/release_23_07.rst | 31 ++-------------------
> doc/guides/testpmd_app_ug/testpmd_funcs.rst | 4 +++
> lib/ethdev/rte_flow.c | 1 +
> lib/ethdev/rte_flow.h | 26 +++++++++++++++++
> 6 files changed, 68 insertions(+), 29 deletions(-)
>
> diff --git a/app/test-pmd/cmdline_flow.c b/app/test-pmd/cmdline_flow.c
> index 58939ec321..a68a6080a8 100644
> --- a/app/test-pmd/cmdline_flow.c
> +++ b/app/test-pmd/cmdline_flow.c
> @@ -496,6 +496,8 @@ enum index {
> ITEM_QUOTA_STATE_NAME,
> ITEM_AGGR_AFFINITY,
> ITEM_AGGR_AFFINITY_VALUE,
> + ITEM_TX_QUEUE,
> + ITEM_TX_QUEUE_VALUE,
>
> /* Validate/create actions. */
> ACTIONS,
> @@ -1452,6 +1454,7 @@ static const enum index next_item[] = {
> ITEM_METER,
> ITEM_QUOTA,
> ITEM_AGGR_AFFINITY,
> + ITEM_TX_QUEUE,
> END_SET,
> ZERO,
> };
> @@ -1953,6 +1956,12 @@ static const enum index item_aggr_affinity[] = {
> ZERO,
> };
>
> +static const enum index item_tx_queue[] = {
> + ITEM_TX_QUEUE_VALUE,
> + ITEM_NEXT,
> + ZERO,
> +};
> +
> static const enum index next_action[] = {
> ACTION_END,
> ACTION_VOID,
> @@ -6945,6 +6954,22 @@ static const struct token token_list[] = {
> .args = ARGS(ARGS_ENTRY(struct rte_flow_item_aggr_affinity,
> affinity)),
> },
> + [ITEM_TX_QUEUE] = {
> + .name = "tx_queue",
> + .help = "match on the tx queue of send packet",
> + .priv = PRIV_ITEM(TX_QUEUE,
> + sizeof(struct rte_flow_item_tx_queue)),
> + .next = NEXT(item_tx_queue),
> + .call = parse_vc,
> + },
> + [ITEM_TX_QUEUE_VALUE] = {
> + .name = "tx_queue_value",
> + .help = "tx queue value",
> + .next = NEXT(item_tx_queue, NEXT_ENTRY(COMMON_UNSIGNED),
> + item_param),
> + .args = ARGS(ARGS_ENTRY(struct rte_flow_item_tx_queue,
> + tx_queue)),
> + },
> };
>
> /** Remove and return last entry from argument stack. */
> @@ -11849,6 +11874,9 @@ flow_item_default_mask(const struct rte_flow_item *item)
> case RTE_FLOW_ITEM_TYPE_AGGR_AFFINITY:
> mask = &rte_flow_item_aggr_affinity_mask;
> break;
> + case RTE_FLOW_ITEM_TYPE_TX_QUEUE:
> + mask = &rte_flow_item_tx_queue_mask;
> + break;
> default:
> break;
> }
> diff --git a/doc/guides/prog_guide/rte_flow.rst b/doc/guides/prog_guide/rte_flow.rst
> index 32fc45516a..7154b56330 100644
> --- a/doc/guides/prog_guide/rte_flow.rst
> +++ b/doc/guides/prog_guide/rte_flow.rst
> @@ -1486,6 +1486,13 @@ This item is meant to use the same structure as `Item: PORT_REPRESENTOR`_.
>
> See also `Action: REPRESENTED_PORT`_.
>
> +Item: ``TX_QUEUE``
> +^^^^^^^^^^^^^^^^^^^^^^^
> +
> +Matches on the tx queue of send packet .
> +
> +- ``tx_queue``: Tx queue.
> +
> Item: ``AGGR_AFFINITY``
> ^^^^^^^^^^^^^^^^^^^^^^^
>
> diff --git a/doc/guides/rel_notes/release_23_07.rst b/doc/guides/rel_notes/release_23_07.rst
> index a9b1293689..631cbd2b58 100644
> --- a/doc/guides/rel_notes/release_23_07.rst
> +++ b/doc/guides/rel_notes/release_23_07.rst
> @@ -24,36 +24,9 @@ DPDK Release 23.07
> New Features
> ------------
>
> -.. This section should contain new features added in this release.
> - Sample format:
> +* **Added flow matching of tx queue.**
>
> - * **Add a title in the past tense with a full stop.**
> -
> - Add a short 1-2 sentence description in the past tense.
> - The description should be enough to allow someone scanning
> - the release notes to understand the new feature.
> -
> - If the feature adds a lot of sub-features you can use a bullet list
> - like this:
> -
> - * Added feature foo to do something.
> - * Enhanced feature bar to do something else.
> -
> - Refer to the previous release notes for examples.
> -
> - Suggested order in release notes items:
> - * Core libs (EAL, mempool, ring, mbuf, buses)
> - * Device abstraction libs and PMDs (ordered alphabetically by vendor name)
> - - ethdev (lib, PMDs)
> - - cryptodev (lib, PMDs)
> - - eventdev (lib, PMDs)
> - - etc
> - * Other libs
> - * Apps, Examples, Tools (if significant)
> -
> - This section is a comment. Do not overwrite or remove it.
> - Also, make sure to start the actual text at the margin.
> - =======================================================
> + Added ``RTE_FLOW_ITEM_TYPE_TX_QUEUE`` to match tx queue of send packet.
>
>
> Removed Items
> diff --git a/doc/guides/testpmd_app_ug/testpmd_funcs.rst b/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> index 8f23847859..29f7dd4428 100644
> --- a/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> +++ b/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> @@ -3779,6 +3779,10 @@ This section lists supported pattern items and their attributes, if any.
>
> - ``affinity {value}``: aggregated port (starts from 1).
>
> +- ``tx_queue``: match tx queue of send packet.
> +
> + - ``tx_queue {value}``: send queue value (starts from 0).
> +
> - ``send_to_kernel``: send packets to kernel.
>
>
> diff --git a/lib/ethdev/rte_flow.c b/lib/ethdev/rte_flow.c
> index 69e6e749f7..f0d7f868fa 100644
> --- a/lib/ethdev/rte_flow.c
> +++ b/lib/ethdev/rte_flow.c
> @@ -164,6 +164,7 @@ static const struct rte_flow_desc_data rte_flow_desc_item[] = {
> MK_FLOW_ITEM(IPV6_ROUTING_EXT, sizeof(struct rte_flow_item_ipv6_routing_ext)),
> MK_FLOW_ITEM(QUOTA, sizeof(struct rte_flow_item_quota)),
> MK_FLOW_ITEM(AGGR_AFFINITY, sizeof(struct rte_flow_item_aggr_affinity)),
> + MK_FLOW_ITEM(TX_QUEUE, sizeof(struct rte_flow_item_tx_queue)),
> };
>
> /** Generate flow_action[] entry. */
> diff --git a/lib/ethdev/rte_flow.h b/lib/ethdev/rte_flow.h
> index 713ba8b65c..e75876c371 100644
> --- a/lib/ethdev/rte_flow.h
> +++ b/lib/ethdev/rte_flow.h
> @@ -672,8 +672,34 @@ enum rte_flow_item_type {
> * @see struct rte_flow_item_aggr_affinity.
> */
> RTE_FLOW_ITEM_TYPE_AGGR_AFFINITY,
> + /**
> + * Match Send Queue number.
> + * This is valid only for egress rules.
> + *
> + * @see struct rte_flow_item_tx_queue
> + */
> + RTE_FLOW_ITEM_TYPE_TX_QUEUE,
> };
>
> +/**
> + * RTE_FLOW_ITEM_TYPE_TX_QUEUE
> + *
> + * Send queue number
> + *
> + * @see struct rte_flow_item_tx_queue
> + */
> +struct rte_flow_item_tx_queue {
> + /** Send queue number that packet is being transmitted */
> + uint16_t tx_queue;
> +};
> +
> +/** Default mask for RTE_FLOW_ITEM_TX_QUEUE. */
> +#ifndef __cplusplus
> +static const struct rte_flow_item_tx_queue rte_flow_item_tx_queue_mask = {
> + .tx_queue = RTE_BE16(0xffff),
> +};
> +#endif
> +
> /**
> * @warning
> * @b EXPERIMENTAL: this API may change without prior notice.
I think we will move to support this but I can't give you time line
> -----Original Message-----
> From: Jan Viktorin <viktorin@cesnet.cz>
> Sent: Friday, May 12, 2023 2:24 PM
> To: kirankumark@marvell.com; Ori Kam <orika@nvidia.com>
> Cc: Aman Singh <aman.deep.singh@intel.com>; Yuying Zhang
> <yuying.zhang@intel.com>; NBU-Contact-Thomas Monjalon (EXTERNAL)
> <thomas@monjalon.net>; Ferruh Yigit <ferruh.yigit@amd.com>; Andrew
> Rybchenko <andrew.rybchenko@oktetlabs.ru>; dev@dpdk.org
> Subject: Re: [dpdk-dev][PATCH] ethdev: add send queue flow matching item
>
> Hi all,
>
> I'd like to test this feature somehow but this patch just implements the API...
> Will there
> be some PMD support soon? I could see that mlx5 implements some internal
> hidden RTE Flow
> item SC already that matches this behaviour... It would be great to make it
> available
> via this TX_QUEUE feature. Any plans for this (Ori)?
>
> Jan
>
> On Thu, 20 Apr 2023 10:59:01 +0530
> <kirankumark@marvell.com> wrote:
>
> > From: Kiran Kumar K <kirankumark@marvell.com>
> >
> > Adding support for send queue flow matching item.
> > This item is valid only for egress rules.
> > An example use case would be that application can
> > set different vlan insert rules with different PCP values
> > based on tx queue number.
> >
> > Signed-off-by: Kiran Kumar K <kirankumark@marvell.com>
> > ---
> > app/test-pmd/cmdline_flow.c | 28 +++++++++++++++++++
> > doc/guides/prog_guide/rte_flow.rst | 7 +++++
> > doc/guides/rel_notes/release_23_07.rst | 31 ++-------------------
> > doc/guides/testpmd_app_ug/testpmd_funcs.rst | 4 +++
> > lib/ethdev/rte_flow.c | 1 +
> > lib/ethdev/rte_flow.h | 26 +++++++++++++++++
> > 6 files changed, 68 insertions(+), 29 deletions(-)
> >
> > diff --git a/app/test-pmd/cmdline_flow.c b/app/test-pmd/cmdline_flow.c
> > index 58939ec321..a68a6080a8 100644
> > --- a/app/test-pmd/cmdline_flow.c
> > +++ b/app/test-pmd/cmdline_flow.c
> > @@ -496,6 +496,8 @@ enum index {
> > ITEM_QUOTA_STATE_NAME,
> > ITEM_AGGR_AFFINITY,
> > ITEM_AGGR_AFFINITY_VALUE,
> > + ITEM_TX_QUEUE,
> > + ITEM_TX_QUEUE_VALUE,
> >
> > /* Validate/create actions. */
> > ACTIONS,
> > @@ -1452,6 +1454,7 @@ static const enum index next_item[] = {
> > ITEM_METER,
> > ITEM_QUOTA,
> > ITEM_AGGR_AFFINITY,
> > + ITEM_TX_QUEUE,
> > END_SET,
> > ZERO,
> > };
> > @@ -1953,6 +1956,12 @@ static const enum index item_aggr_affinity[] = {
> > ZERO,
> > };
> >
> > +static const enum index item_tx_queue[] = {
> > + ITEM_TX_QUEUE_VALUE,
> > + ITEM_NEXT,
> > + ZERO,
> > +};
> > +
> > static const enum index next_action[] = {
> > ACTION_END,
> > ACTION_VOID,
> > @@ -6945,6 +6954,22 @@ static const struct token token_list[] = {
> > .args = ARGS(ARGS_ENTRY(struct
> rte_flow_item_aggr_affinity,
> > affinity)),
> > },
> > + [ITEM_TX_QUEUE] = {
> > + .name = "tx_queue",
> > + .help = "match on the tx queue of send packet",
> > + .priv = PRIV_ITEM(TX_QUEUE,
> > + sizeof(struct rte_flow_item_tx_queue)),
> > + .next = NEXT(item_tx_queue),
> > + .call = parse_vc,
> > + },
> > + [ITEM_TX_QUEUE_VALUE] = {
> > + .name = "tx_queue_value",
> > + .help = "tx queue value",
> > + .next = NEXT(item_tx_queue,
> NEXT_ENTRY(COMMON_UNSIGNED),
> > + item_param),
> > + .args = ARGS(ARGS_ENTRY(struct rte_flow_item_tx_queue,
> > + tx_queue)),
> > + },
> > };
> >
> > /** Remove and return last entry from argument stack. */
> > @@ -11849,6 +11874,9 @@ flow_item_default_mask(const struct
> rte_flow_item *item)
> > case RTE_FLOW_ITEM_TYPE_AGGR_AFFINITY:
> > mask = &rte_flow_item_aggr_affinity_mask;
> > break;
> > + case RTE_FLOW_ITEM_TYPE_TX_QUEUE:
> > + mask = &rte_flow_item_tx_queue_mask;
> > + break;
> > default:
> > break;
> > }
> > diff --git a/doc/guides/prog_guide/rte_flow.rst
> b/doc/guides/prog_guide/rte_flow.rst
> > index 32fc45516a..7154b56330 100644
> > --- a/doc/guides/prog_guide/rte_flow.rst
> > +++ b/doc/guides/prog_guide/rte_flow.rst
> > @@ -1486,6 +1486,13 @@ This item is meant to use the same structure as
> `Item: PORT_REPRESENTOR`_.
> >
> > See also `Action: REPRESENTED_PORT`_.
> >
> > +Item: ``TX_QUEUE``
> > +^^^^^^^^^^^^^^^^^^^^^^^
> > +
> > +Matches on the tx queue of send packet .
> > +
> > +- ``tx_queue``: Tx queue.
> > +
> > Item: ``AGGR_AFFINITY``
> > ^^^^^^^^^^^^^^^^^^^^^^^
> >
> > diff --git a/doc/guides/rel_notes/release_23_07.rst
> b/doc/guides/rel_notes/release_23_07.rst
> > index a9b1293689..631cbd2b58 100644
> > --- a/doc/guides/rel_notes/release_23_07.rst
> > +++ b/doc/guides/rel_notes/release_23_07.rst
> > @@ -24,36 +24,9 @@ DPDK Release 23.07
> > New Features
> > ------------
> >
> > -.. This section should contain new features added in this release.
> > - Sample format:
> > +* **Added flow matching of tx queue.**
> >
> > - * **Add a title in the past tense with a full stop.**
> > -
> > - Add a short 1-2 sentence description in the past tense.
> > - The description should be enough to allow someone scanning
> > - the release notes to understand the new feature.
> > -
> > - If the feature adds a lot of sub-features you can use a bullet list
> > - like this:
> > -
> > - * Added feature foo to do something.
> > - * Enhanced feature bar to do something else.
> > -
> > - Refer to the previous release notes for examples.
> > -
> > - Suggested order in release notes items:
> > - * Core libs (EAL, mempool, ring, mbuf, buses)
> > - * Device abstraction libs and PMDs (ordered alphabetically by vendor
> name)
> > - - ethdev (lib, PMDs)
> > - - cryptodev (lib, PMDs)
> > - - eventdev (lib, PMDs)
> > - - etc
> > - * Other libs
> > - * Apps, Examples, Tools (if significant)
> > -
> > - This section is a comment. Do not overwrite or remove it.
> > - Also, make sure to start the actual text at the margin.
> > - =======================================================
> > + Added ``RTE_FLOW_ITEM_TYPE_TX_QUEUE`` to match tx queue of send
> packet.
> >
> >
> > Removed Items
> > diff --git a/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> b/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> > index 8f23847859..29f7dd4428 100644
> > --- a/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> > +++ b/doc/guides/testpmd_app_ug/testpmd_funcs.rst
> > @@ -3779,6 +3779,10 @@ This section lists supported pattern items and
> their attributes, if any.
> >
> > - ``affinity {value}``: aggregated port (starts from 1).
> >
> > +- ``tx_queue``: match tx queue of send packet.
> > +
> > + - ``tx_queue {value}``: send queue value (starts from 0).
> > +
> > - ``send_to_kernel``: send packets to kernel.
> >
> >
> > diff --git a/lib/ethdev/rte_flow.c b/lib/ethdev/rte_flow.c
> > index 69e6e749f7..f0d7f868fa 100644
> > --- a/lib/ethdev/rte_flow.c
> > +++ b/lib/ethdev/rte_flow.c
> > @@ -164,6 +164,7 @@ static const struct rte_flow_desc_data
> rte_flow_desc_item[] = {
> > MK_FLOW_ITEM(IPV6_ROUTING_EXT, sizeof(struct
> rte_flow_item_ipv6_routing_ext)),
> > MK_FLOW_ITEM(QUOTA, sizeof(struct rte_flow_item_quota)),
> > MK_FLOW_ITEM(AGGR_AFFINITY, sizeof(struct
> rte_flow_item_aggr_affinity)),
> > + MK_FLOW_ITEM(TX_QUEUE, sizeof(struct rte_flow_item_tx_queue)),
> > };
> >
> > /** Generate flow_action[] entry. */
> > diff --git a/lib/ethdev/rte_flow.h b/lib/ethdev/rte_flow.h
> > index 713ba8b65c..e75876c371 100644
> > --- a/lib/ethdev/rte_flow.h
> > +++ b/lib/ethdev/rte_flow.h
> > @@ -672,8 +672,34 @@ enum rte_flow_item_type {
> > * @see struct rte_flow_item_aggr_affinity.
> > */
> > RTE_FLOW_ITEM_TYPE_AGGR_AFFINITY,
> > + /**
> > + * Match Send Queue number.
> > + * This is valid only for egress rules.
> > + *
> > + * @see struct rte_flow_item_tx_queue
> > + */
> > + RTE_FLOW_ITEM_TYPE_TX_QUEUE,
> > };
> >
> > +/**
> > + * RTE_FLOW_ITEM_TYPE_TX_QUEUE
> > + *
> > + * Send queue number
> > + *
> > + * @see struct rte_flow_item_tx_queue
> > + */
> > +struct rte_flow_item_tx_queue {
> > + /** Send queue number that packet is being transmitted */
> > + uint16_t tx_queue;
> > +};
> > +
> > +/** Default mask for RTE_FLOW_ITEM_TX_QUEUE. */
> > +#ifndef __cplusplus
> > +static const struct rte_flow_item_tx_queue
> rte_flow_item_tx_queue_mask = {
> > + .tx_queue = RTE_BE16(0xffff),
> > +};
> > +#endif
> > +
> > /**
> > * @warning
> > * @b EXPERIMENTAL: this API may change without prior notice.
@@ -496,6 +496,8 @@ enum index {
ITEM_QUOTA_STATE_NAME,
ITEM_AGGR_AFFINITY,
ITEM_AGGR_AFFINITY_VALUE,
+ ITEM_TX_QUEUE,
+ ITEM_TX_QUEUE_VALUE,
/* Validate/create actions. */
ACTIONS,
@@ -1452,6 +1454,7 @@ static const enum index next_item[] = {
ITEM_METER,
ITEM_QUOTA,
ITEM_AGGR_AFFINITY,
+ ITEM_TX_QUEUE,
END_SET,
ZERO,
};
@@ -1953,6 +1956,12 @@ static const enum index item_aggr_affinity[] = {
ZERO,
};
+static const enum index item_tx_queue[] = {
+ ITEM_TX_QUEUE_VALUE,
+ ITEM_NEXT,
+ ZERO,
+};
+
static const enum index next_action[] = {
ACTION_END,
ACTION_VOID,
@@ -6945,6 +6954,22 @@ static const struct token token_list[] = {
.args = ARGS(ARGS_ENTRY(struct rte_flow_item_aggr_affinity,
affinity)),
},
+ [ITEM_TX_QUEUE] = {
+ .name = "tx_queue",
+ .help = "match on the tx queue of send packet",
+ .priv = PRIV_ITEM(TX_QUEUE,
+ sizeof(struct rte_flow_item_tx_queue)),
+ .next = NEXT(item_tx_queue),
+ .call = parse_vc,
+ },
+ [ITEM_TX_QUEUE_VALUE] = {
+ .name = "tx_queue_value",
+ .help = "tx queue value",
+ .next = NEXT(item_tx_queue, NEXT_ENTRY(COMMON_UNSIGNED),
+ item_param),
+ .args = ARGS(ARGS_ENTRY(struct rte_flow_item_tx_queue,
+ tx_queue)),
+ },
};
/** Remove and return last entry from argument stack. */
@@ -11849,6 +11874,9 @@ flow_item_default_mask(const struct rte_flow_item *item)
case RTE_FLOW_ITEM_TYPE_AGGR_AFFINITY:
mask = &rte_flow_item_aggr_affinity_mask;
break;
+ case RTE_FLOW_ITEM_TYPE_TX_QUEUE:
+ mask = &rte_flow_item_tx_queue_mask;
+ break;
default:
break;
}
@@ -1486,6 +1486,13 @@ This item is meant to use the same structure as `Item: PORT_REPRESENTOR`_.
See also `Action: REPRESENTED_PORT`_.
+Item: ``TX_QUEUE``
+^^^^^^^^^^^^^^^^^^^^^^^
+
+Matches on the tx queue of send packet .
+
+- ``tx_queue``: Tx queue.
+
Item: ``AGGR_AFFINITY``
^^^^^^^^^^^^^^^^^^^^^^^
@@ -24,36 +24,9 @@ DPDK Release 23.07
New Features
------------
-.. This section should contain new features added in this release.
- Sample format:
+* **Added flow matching of tx queue.**
- * **Add a title in the past tense with a full stop.**
-
- Add a short 1-2 sentence description in the past tense.
- The description should be enough to allow someone scanning
- the release notes to understand the new feature.
-
- If the feature adds a lot of sub-features you can use a bullet list
- like this:
-
- * Added feature foo to do something.
- * Enhanced feature bar to do something else.
-
- Refer to the previous release notes for examples.
-
- Suggested order in release notes items:
- * Core libs (EAL, mempool, ring, mbuf, buses)
- * Device abstraction libs and PMDs (ordered alphabetically by vendor name)
- - ethdev (lib, PMDs)
- - cryptodev (lib, PMDs)
- - eventdev (lib, PMDs)
- - etc
- * Other libs
- * Apps, Examples, Tools (if significant)
-
- This section is a comment. Do not overwrite or remove it.
- Also, make sure to start the actual text at the margin.
- =======================================================
+ Added ``RTE_FLOW_ITEM_TYPE_TX_QUEUE`` to match tx queue of send packet.
Removed Items
@@ -3779,6 +3779,10 @@ This section lists supported pattern items and their attributes, if any.
- ``affinity {value}``: aggregated port (starts from 1).
+- ``tx_queue``: match tx queue of send packet.
+
+ - ``tx_queue {value}``: send queue value (starts from 0).
+
- ``send_to_kernel``: send packets to kernel.
@@ -164,6 +164,7 @@ static const struct rte_flow_desc_data rte_flow_desc_item[] = {
MK_FLOW_ITEM(IPV6_ROUTING_EXT, sizeof(struct rte_flow_item_ipv6_routing_ext)),
MK_FLOW_ITEM(QUOTA, sizeof(struct rte_flow_item_quota)),
MK_FLOW_ITEM(AGGR_AFFINITY, sizeof(struct rte_flow_item_aggr_affinity)),
+ MK_FLOW_ITEM(TX_QUEUE, sizeof(struct rte_flow_item_tx_queue)),
};
/** Generate flow_action[] entry. */
@@ -672,8 +672,34 @@ enum rte_flow_item_type {
* @see struct rte_flow_item_aggr_affinity.
*/
RTE_FLOW_ITEM_TYPE_AGGR_AFFINITY,
+ /**
+ * Match Send Queue number.
+ * This is valid only for egress rules.
+ *
+ * @see struct rte_flow_item_tx_queue
+ */
+ RTE_FLOW_ITEM_TYPE_TX_QUEUE,
};
+/**
+ * RTE_FLOW_ITEM_TYPE_TX_QUEUE
+ *
+ * Send queue number
+ *
+ * @see struct rte_flow_item_tx_queue
+ */
+struct rte_flow_item_tx_queue {
+ /** Send queue number that packet is being transmitted */
+ uint16_t tx_queue;
+};
+
+/** Default mask for RTE_FLOW_ITEM_TX_QUEUE. */
+#ifndef __cplusplus
+static const struct rte_flow_item_tx_queue rte_flow_item_tx_queue_mask = {
+ .tx_queue = RTE_BE16(0xffff),
+};
+#endif
+
/**
* @warning
* @b EXPERIMENTAL: this API may change without prior notice.