app/testpmd: add async flow create/destroy operations
Add testpmd support for the rte_flow_q_create/rte_flow_q_destroy API.
Provide the command line interface for enqueueing flow
creation/destruction operations. Usage example:
testpmd> flow queue 0 create 0 postpone no
template_table 6 pattern_template 0 actions_template 0
pattern eth dst is 00:16:3e:31:15:c3 / end actions drop / end
testpmd> flow queue 0 destroy 0 postpone yes rule 0
Signed-off-by: Alexander Kozyrev <akozyrev@nvidia.com>
Acked-by: Ori Kam <orika@nvidia.com>
This commit is contained in:
Alexander Kozyrev
Ferruh Yigit
parent
c4b3887334
commit
ecdc927b99
@ -59,6 +59,7 @@ enum index {
|
||||
COMMON_PATTERN_TEMPLATE_ID,
|
||||
COMMON_ACTIONS_TEMPLATE_ID,
|
||||
COMMON_TABLE_ID,
|
||||
COMMON_QUEUE_ID,
|
||||
|
||||
/* TOP-level command. */
|
||||
ADD,
|
||||
@ -92,6 +93,7 @@ enum index {
|
||||
ISOLATE,
|
||||
TUNNEL,
|
||||
FLEX,
|
||||
QUEUE,
|
||||
|
||||
/* Flex arguments */
|
||||
FLEX_ITEM_INIT,
|
||||
@ -120,6 +122,22 @@ enum index {
|
||||
ACTIONS_TEMPLATE_SPEC,
|
||||
ACTIONS_TEMPLATE_MASK,
|
||||
|
||||
/* Queue arguments. */
|
||||
QUEUE_CREATE,
|
||||
QUEUE_DESTROY,
|
||||
|
||||
/* Queue create arguments. */
|
||||
QUEUE_CREATE_ID,
|
||||
QUEUE_CREATE_POSTPONE,
|
||||
QUEUE_TEMPLATE_TABLE,
|
||||
QUEUE_PATTERN_TEMPLATE,
|
||||
QUEUE_ACTIONS_TEMPLATE,
|
||||
QUEUE_SPEC,
|
||||
|
||||
/* Queue destroy arguments. */
|
||||
QUEUE_DESTROY_ID,
|
||||
QUEUE_DESTROY_POSTPONE,
|
||||
|
||||
/* Table arguments. */
|
||||
TABLE_CREATE,
|
||||
TABLE_DESTROY,
|
||||
@ -918,6 +936,8 @@ struct token {
|
||||
struct buffer {
|
||||
enum index command; /**< Flow command. */
|
||||
portid_t port; /**< Affected port ID. */
|
||||
queueid_t queue; /** Async queue ID. */
|
||||
bool postpone; /** Postpone async operation */
|
||||
union {
|
||||
struct {
|
||||
struct rte_flow_port_attr port_attr;
|
||||
@ -948,6 +968,7 @@ struct buffer {
|
||||
uint32_t action_id;
|
||||
} ia; /* Indirect action query arguments */
|
||||
struct {
|
||||
uint32_t table_id;
|
||||
uint32_t pat_templ_id;
|
||||
uint32_t act_templ_id;
|
||||
struct rte_flow_attr attr;
|
||||
@ -1103,6 +1124,18 @@ static const enum index next_table_destroy_attr[] = {
|
||||
ZERO,
|
||||
};
|
||||
|
||||
static const enum index next_queue_subcmd[] = {
|
||||
QUEUE_CREATE,
|
||||
QUEUE_DESTROY,
|
||||
ZERO,
|
||||
};
|
||||
|
||||
static const enum index next_queue_destroy_attr[] = {
|
||||
QUEUE_DESTROY_ID,
|
||||
END,
|
||||
ZERO,
|
||||
};
|
||||
|
||||
static const enum index next_ia_create_attr[] = {
|
||||
INDIRECT_ACTION_CREATE_ID,
|
||||
INDIRECT_ACTION_INGRESS,
|
||||
@ -2213,6 +2246,12 @@ static int parse_table(struct context *, const struct token *,
|
||||
static int parse_table_destroy(struct context *, const struct token *,
|
||||
const char *, unsigned int,
|
||||
void *, unsigned int);
|
||||
static int parse_qo(struct context *, const struct token *,
|
||||
const char *, unsigned int,
|
||||
void *, unsigned int);
|
||||
static int parse_qo_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);
|
||||
@ -2288,6 +2327,8 @@ static int comp_actions_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);
|
||||
static int comp_queue_id(struct context *, const struct token *,
|
||||
unsigned int, char *, unsigned int);
|
||||
|
||||
/** Token definitions. */
|
||||
static const struct token token_list[] = {
|
||||
@ -2459,6 +2500,13 @@ static const struct token token_list[] = {
|
||||
.call = parse_int,
|
||||
.comp = comp_table_id,
|
||||
},
|
||||
[COMMON_QUEUE_ID] = {
|
||||
.name = "{queue_id}",
|
||||
.type = "QUEUE_ID",
|
||||
.help = "queue id",
|
||||
.call = parse_int,
|
||||
.comp = comp_queue_id,
|
||||
},
|
||||
/* Top-level command. */
|
||||
[FLOW] = {
|
||||
.name = "flow",
|
||||
@ -2481,7 +2529,8 @@ static const struct token token_list[] = {
|
||||
QUERY,
|
||||
ISOLATE,
|
||||
TUNNEL,
|
||||
FLEX)),
|
||||
FLEX,
|
||||
QUEUE)),
|
||||
.call = parse_init,
|
||||
},
|
||||
/* Top-level command. */
|
||||
@ -2784,6 +2833,84 @@ static const struct token token_list[] = {
|
||||
.call = parse_table,
|
||||
},
|
||||
/* Top-level command. */
|
||||
[QUEUE] = {
|
||||
.name = "queue",
|
||||
.help = "queue a flow rule operation",
|
||||
.next = NEXT(next_queue_subcmd, NEXT_ENTRY(COMMON_PORT_ID)),
|
||||
.args = ARGS(ARGS_ENTRY(struct buffer, port)),
|
||||
.call = parse_qo,
|
||||
},
|
||||
/* Sub-level commands. */
|
||||
[QUEUE_CREATE] = {
|
||||
.name = "create",
|
||||
.help = "create a flow rule",
|
||||
.next = NEXT(NEXT_ENTRY(QUEUE_TEMPLATE_TABLE),
|
||||
NEXT_ENTRY(COMMON_QUEUE_ID)),
|
||||
.args = ARGS(ARGS_ENTRY(struct buffer, queue)),
|
||||
.call = parse_qo,
|
||||
},
|
||||
[QUEUE_DESTROY] = {
|
||||
.name = "destroy",
|
||||
.help = "destroy a flow rule",
|
||||
.next = NEXT(NEXT_ENTRY(QUEUE_DESTROY_ID),
|
||||
NEXT_ENTRY(COMMON_QUEUE_ID)),
|
||||
.args = ARGS(ARGS_ENTRY(struct buffer, queue)),
|
||||
.call = parse_qo_destroy,
|
||||
},
|
||||
/* Queue arguments. */
|
||||
[QUEUE_TEMPLATE_TABLE] = {
|
||||
.name = "template table",
|
||||
.help = "specify table id",
|
||||
.next = NEXT(NEXT_ENTRY(QUEUE_PATTERN_TEMPLATE),
|
||||
NEXT_ENTRY(COMMON_TABLE_ID)),
|
||||
.args = ARGS(ARGS_ENTRY(struct buffer,
|
||||
args.vc.table_id)),
|
||||
.call = parse_qo,
|
||||
},
|
||||
[QUEUE_PATTERN_TEMPLATE] = {
|
||||
.name = "pattern_template",
|
||||
.help = "specify pattern template index",
|
||||
.next = NEXT(NEXT_ENTRY(QUEUE_ACTIONS_TEMPLATE),
|
||||
NEXT_ENTRY(COMMON_UNSIGNED)),
|
||||
.args = ARGS(ARGS_ENTRY(struct buffer,
|
||||
args.vc.pat_templ_id)),
|
||||
.call = parse_qo,
|
||||
},
|
||||
[QUEUE_ACTIONS_TEMPLATE] = {
|
||||
.name = "actions_template",
|
||||
.help = "specify actions template index",
|
||||
.next = NEXT(NEXT_ENTRY(QUEUE_CREATE_POSTPONE),
|
||||
NEXT_ENTRY(COMMON_UNSIGNED)),
|
||||
.args = ARGS(ARGS_ENTRY(struct buffer,
|
||||
args.vc.act_templ_id)),
|
||||
.call = parse_qo,
|
||||
},
|
||||
[QUEUE_CREATE_POSTPONE] = {
|
||||
.name = "postpone",
|
||||
.help = "postpone create operation",
|
||||
.next = NEXT(NEXT_ENTRY(ITEM_PATTERN),
|
||||
NEXT_ENTRY(COMMON_BOOLEAN)),
|
||||
.args = ARGS(ARGS_ENTRY(struct buffer, postpone)),
|
||||
.call = parse_qo,
|
||||
},
|
||||
[QUEUE_DESTROY_POSTPONE] = {
|
||||
.name = "postpone",
|
||||
.help = "postpone destroy operation",
|
||||
.next = NEXT(NEXT_ENTRY(QUEUE_DESTROY_ID),
|
||||
NEXT_ENTRY(COMMON_BOOLEAN)),
|
||||
.args = ARGS(ARGS_ENTRY(struct buffer, postpone)),
|
||||
.call = parse_qo_destroy,
|
||||
},
|
||||
[QUEUE_DESTROY_ID] = {
|
||||
.name = "rule",
|
||||
.help = "specify rule id to destroy",
|
||||
.next = NEXT(next_queue_destroy_attr,
|
||||
NEXT_ENTRY(COMMON_UNSIGNED)),
|
||||
.args = ARGS(ARGS_ENTRY_PTR(struct buffer,
|
||||
args.destroy.rule)),
|
||||
.call = parse_qo_destroy,
|
||||
},
|
||||
/* Top-level command. */
|
||||
[INDIRECT_ACTION] = {
|
||||
.name = "indirect_action",
|
||||
.type = "{command} {port_id} [{arg} [...]]",
|
||||
@ -8503,6 +8630,111 @@ parse_table_destroy(struct context *ctx, const struct token *token,
|
||||
return len;
|
||||
}
|
||||
|
||||
/** Parse tokens for queue create commands. */
|
||||
static int
|
||||
parse_qo(struct context *ctx, const struct token *token,
|
||||
const char *str, unsigned int len,
|
||||
void *buf, unsigned int size)
|
||||
{
|
||||
struct buffer *out = buf;
|
||||
|
||||
/* 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 != QUEUE)
|
||||
return -1;
|
||||
if (sizeof(*out) > size)
|
||||
return -1;
|
||||
out->command = ctx->curr;
|
||||
ctx->objdata = 0;
|
||||
ctx->object = out;
|
||||
ctx->objmask = NULL;
|
||||
out->args.vc.data = (uint8_t *)out + size;
|
||||
return len;
|
||||
}
|
||||
switch (ctx->curr) {
|
||||
case QUEUE_CREATE:
|
||||
out->command = ctx->curr;
|
||||
ctx->objdata = 0;
|
||||
ctx->object = out;
|
||||
ctx->objmask = NULL;
|
||||
return len;
|
||||
case QUEUE_TEMPLATE_TABLE:
|
||||
case QUEUE_PATTERN_TEMPLATE:
|
||||
case QUEUE_ACTIONS_TEMPLATE:
|
||||
case QUEUE_CREATE_POSTPONE:
|
||||
return len;
|
||||
case ITEM_PATTERN:
|
||||
out->args.vc.pattern =
|
||||
(void *)RTE_ALIGN_CEIL((uintptr_t)(out + 1),
|
||||
sizeof(double));
|
||||
ctx->object = out->args.vc.pattern;
|
||||
ctx->objmask = NULL;
|
||||
return len;
|
||||
case ACTIONS:
|
||||
out->args.vc.actions =
|
||||
(void *)RTE_ALIGN_CEIL((uintptr_t)
|
||||
(out->args.vc.pattern +
|
||||
out->args.vc.pattern_n),
|
||||
sizeof(double));
|
||||
ctx->object = out->args.vc.actions;
|
||||
ctx->objmask = NULL;
|
||||
return len;
|
||||
default:
|
||||
return -1;
|
||||
}
|
||||
}
|
||||
|
||||
/** Parse tokens for queue destroy command. */
|
||||
static int
|
||||
parse_qo_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 *flow_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 == QUEUE) {
|
||||
if (ctx->curr != QUEUE_DESTROY)
|
||||
return -1;
|
||||
if (sizeof(*out) > size)
|
||||
return -1;
|
||||
out->command = ctx->curr;
|
||||
ctx->objdata = 0;
|
||||
ctx->object = out;
|
||||
ctx->objmask = NULL;
|
||||
out->args.destroy.rule =
|
||||
(void *)RTE_ALIGN_CEIL((uintptr_t)(out + 1),
|
||||
sizeof(double));
|
||||
return len;
|
||||
}
|
||||
switch (ctx->curr) {
|
||||
case QUEUE_DESTROY_ID:
|
||||
flow_id = out->args.destroy.rule
|
||||
+ out->args.destroy.rule_n++;
|
||||
if ((uint8_t *)flow_id > (uint8_t *)out + size)
|
||||
return -1;
|
||||
ctx->objdata = 0;
|
||||
ctx->object = flow_id;
|
||||
ctx->objmask = NULL;
|
||||
return len;
|
||||
case QUEUE_DESTROY_POSTPONE:
|
||||
return len;
|
||||
default:
|
||||
return -1;
|
||||
}
|
||||
}
|
||||
|
||||
static int
|
||||
parse_flex(struct context *ctx, const struct token *token,
|
||||
const char *str, unsigned int len,
|
||||
@ -9544,6 +9776,28 @@ comp_table_id(struct context *ctx, const struct token *token,
|
||||
return i;
|
||||
}
|
||||
|
||||
/** Complete available queue IDs. */
|
||||
static int
|
||||
comp_queue_id(struct context *ctx, const struct token *token,
|
||||
unsigned int ent, char *buf, unsigned int size)
|
||||
{
|
||||
unsigned int i = 0;
|
||||
struct rte_port *port;
|
||||
|
||||
(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 (i = 0; i < port->queue_nb; i++) {
|
||||
if (buf && i == ent)
|
||||
return snprintf(buf, size, "%u", i);
|
||||
}
|
||||
if (buf)
|
||||
return -1;
|
||||
return i;
|
||||
}
|
||||
|
||||
/** Internal context. */
|
||||
static struct context cmd_flow_context;
|
||||
|
||||
@ -9855,6 +10109,17 @@ cmd_flow_parsed(const struct buffer *in)
|
||||
in->args.table_destroy.table_id_n,
|
||||
in->args.table_destroy.table_id);
|
||||
break;
|
||||
case QUEUE_CREATE:
|
||||
port_queue_flow_create(in->port, in->queue, in->postpone,
|
||||
in->args.vc.table_id, in->args.vc.pat_templ_id,
|
||||
in->args.vc.act_templ_id, in->args.vc.pattern,
|
||||
in->args.vc.actions);
|
||||
break;
|
||||
case QUEUE_DESTROY:
|
||||
port_queue_flow_destroy(in->port, in->queue, in->postpone,
|
||||
in->args.destroy.rule_n,
|
||||
in->args.destroy.rule);
|
||||
break;
|
||||
case INDIRECT_ACTION_CREATE:
|
||||
port_action_handle_create(
|
||||
in->port, in->args.vc.attr.group,
|
||||
|
||||
@ -2460,6 +2460,172 @@ port_flow_template_table_destroy(portid_t port_id,
|
||||
return ret;
|
||||
}
|
||||
|
||||
/** Enqueue create flow rule operation. */
|
||||
int
|
||||
port_queue_flow_create(portid_t port_id, queueid_t queue_id,
|
||||
bool postpone, uint32_t table_id,
|
||||
uint32_t pattern_idx, uint32_t actions_idx,
|
||||
const struct rte_flow_item *pattern,
|
||||
const struct rte_flow_action *actions)
|
||||
{
|
||||
struct rte_flow_op_attr op_attr = { .postpone = postpone };
|
||||
struct rte_flow_op_result comp = { 0 };
|
||||
struct rte_flow *flow;
|
||||
struct rte_port *port;
|
||||
struct port_flow *pf;
|
||||
struct port_table *pt;
|
||||
uint32_t id = 0;
|
||||
bool found;
|
||||
int ret = 0;
|
||||
struct rte_flow_error error = { RTE_FLOW_ERROR_TYPE_NONE, NULL, NULL };
|
||||
struct rte_flow_action_age *age = age_action_get(actions);
|
||||
|
||||
port = &ports[port_id];
|
||||
if (port->flow_list) {
|
||||
if (port->flow_list->id == UINT32_MAX) {
|
||||
printf("Highest rule ID is already assigned,"
|
||||
" delete it first");
|
||||
return -ENOMEM;
|
||||
}
|
||||
id = port->flow_list->id + 1;
|
||||
}
|
||||
|
||||
if (queue_id >= port->queue_nb) {
|
||||
printf("Queue #%u is invalid\n", queue_id);
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
found = false;
|
||||
pt = port->table_list;
|
||||
while (pt) {
|
||||
if (table_id == pt->id) {
|
||||
found = true;
|
||||
break;
|
||||
}
|
||||
pt = pt->next;
|
||||
}
|
||||
if (!found) {
|
||||
printf("Table #%u is invalid\n", table_id);
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
if (pattern_idx >= pt->nb_pattern_templates) {
|
||||
printf("Pattern template index #%u is invalid,"
|
||||
" %u templates present in the table\n",
|
||||
pattern_idx, pt->nb_pattern_templates);
|
||||
return -EINVAL;
|
||||
}
|
||||
if (actions_idx >= pt->nb_actions_templates) {
|
||||
printf("Actions template index #%u is invalid,"
|
||||
" %u templates present in the table\n",
|
||||
actions_idx, pt->nb_actions_templates);
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
pf = port_flow_new(NULL, pattern, actions, &error);
|
||||
if (!pf)
|
||||
return port_flow_complain(&error);
|
||||
if (age) {
|
||||
pf->age_type = ACTION_AGE_CONTEXT_TYPE_FLOW;
|
||||
age->context = &pf->age_type;
|
||||
}
|
||||
/* Poisoning to make sure PMDs update it in case of error. */
|
||||
memset(&error, 0x11, sizeof(error));
|
||||
flow = rte_flow_async_create(port_id, queue_id, &op_attr, pt->table,
|
||||
pattern, pattern_idx, actions, actions_idx, NULL, &error);
|
||||
if (!flow) {
|
||||
uint32_t flow_id = pf->id;
|
||||
port_queue_flow_destroy(port_id, queue_id, true, 1, &flow_id);
|
||||
return port_flow_complain(&error);
|
||||
}
|
||||
|
||||
while (ret == 0) {
|
||||
/* Poisoning to make sure PMDs update it in case of error. */
|
||||
memset(&error, 0x22, sizeof(error));
|
||||
ret = rte_flow_pull(port_id, queue_id, &comp, 1, &error);
|
||||
if (ret < 0) {
|
||||
printf("Failed to pull queue\n");
|
||||
return -EINVAL;
|
||||
}
|
||||
}
|
||||
|
||||
pf->next = port->flow_list;
|
||||
pf->id = id;
|
||||
pf->flow = flow;
|
||||
port->flow_list = pf;
|
||||
printf("Flow rule #%u creation enqueued\n", pf->id);
|
||||
return 0;
|
||||
}
|
||||
|
||||
/** Enqueue number of destroy flow rules operations. */
|
||||
int
|
||||
port_queue_flow_destroy(portid_t port_id, queueid_t queue_id,
|
||||
bool postpone, uint32_t n, const uint32_t *rule)
|
||||
{
|
||||
struct rte_flow_op_attr op_attr = { .postpone = postpone };
|
||||
struct rte_flow_op_result comp = { 0 };
|
||||
struct rte_port *port;
|
||||
struct port_flow **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];
|
||||
|
||||
if (queue_id >= port->queue_nb) {
|
||||
printf("Queue #%u is invalid\n", queue_id);
|
||||
return -EINVAL;
|
||||
}
|
||||
|
||||
tmp = &port->flow_list;
|
||||
while (*tmp) {
|
||||
uint32_t i;
|
||||
|
||||
for (i = 0; i != n; ++i) {
|
||||
struct rte_flow_error error;
|
||||
struct port_flow *pf = *tmp;
|
||||
|
||||
if (rule[i] != pf->id)
|
||||
continue;
|
||||
/*
|
||||
* Poisoning to make sure PMD
|
||||
* update it in case of error.
|
||||
*/
|
||||
memset(&error, 0x33, sizeof(error));
|
||||
if (rte_flow_async_destroy(port_id, queue_id, &op_attr,
|
||||
pf->flow, NULL, &error)) {
|
||||
ret = port_flow_complain(&error);
|
||||
continue;
|
||||
}
|
||||
|
||||
while (ret == 0) {
|
||||
/*
|
||||
* Poisoning to make sure PMD
|
||||
* update it in case of error.
|
||||
*/
|
||||
memset(&error, 0x44, sizeof(error));
|
||||
ret = rte_flow_pull(port_id, queue_id,
|
||||
&comp, 1, &error);
|
||||
if (ret < 0) {
|
||||
printf("Failed to pull queue\n");
|
||||
return -EINVAL;
|
||||
}
|
||||
}
|
||||
|
||||
printf("Flow rule #%u destruction enqueued\n", pf->id);
|
||||
*tmp = pf->next;
|
||||
free(pf);
|
||||
break;
|
||||
}
|
||||
if (i == n)
|
||||
tmp = &(*tmp)->next;
|
||||
++c;
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
|
||||
/** Create flow rule. */
|
||||
int
|
||||
port_flow_create(portid_t port_id,
|
||||
|
||||
@ -933,6 +933,13 @@ int port_flow_template_table_create(portid_t port_id, uint32_t id,
|
||||
uint32_t nb_actions_templates, uint32_t *actions_templates);
|
||||
int port_flow_template_table_destroy(portid_t port_id,
|
||||
uint32_t n, const uint32_t *table);
|
||||
int port_queue_flow_create(portid_t port_id, queueid_t queue_id,
|
||||
bool postpone, uint32_t table_id,
|
||||
uint32_t pattern_idx, uint32_t actions_idx,
|
||||
const struct rte_flow_item *pattern,
|
||||
const struct rte_flow_action *actions);
|
||||
int port_queue_flow_destroy(portid_t port_id, queueid_t queue_id,
|
||||
bool postpone, uint32_t n, const uint32_t *rule);
|
||||
int port_flow_validate(portid_t port_id,
|
||||
const struct rte_flow_attr *attr,
|
||||
const struct rte_flow_item *pattern,
|
||||
|
||||
@ -3384,6 +3384,20 @@ following sections.
|
||||
pattern {item} [/ {item} [...]] / end
|
||||
actions {action} [/ {action} [...]] / end
|
||||
|
||||
- Enqueue creation of a flow rule::
|
||||
|
||||
flow queue {port_id} create {queue_id}
|
||||
[postpone {boolean}] template_table {table_id}
|
||||
pattern_template {pattern_template_index}
|
||||
actions_template {actions_template_index}
|
||||
pattern {item} [/ {item} [...]] / end
|
||||
actions {action} [/ {action} [...]] / end
|
||||
|
||||
- Enqueue destruction of specific flow rules::
|
||||
|
||||
flow queue {port_id} destroy {queue_id}
|
||||
[postpone {boolean}] rule {rule_id} [...]
|
||||
|
||||
- Create a flow rule::
|
||||
|
||||
flow create {port_id}
|
||||
@ -3708,6 +3722,30 @@ one.
|
||||
|
||||
**All unspecified object values are automatically initialized to 0.**
|
||||
|
||||
Enqueueing creation of flow rules
|
||||
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
||||
|
||||
``flow queue create`` adds creation operation of a flow rule to a queue.
|
||||
It is bound to ``rte_flow_async_create()``::
|
||||
|
||||
flow queue {port_id} create {queue_id}
|
||||
[postpone {boolean}] template_table {table_id}
|
||||
pattern_template {pattern_template_index}
|
||||
actions_template {actions_template_index}
|
||||
pattern {item} [/ {item} [...]] / end
|
||||
actions {action} [/ {action} [...]] / end
|
||||
|
||||
If successful, it will return a flow rule ID usable with other commands::
|
||||
|
||||
Flow rule #[...] creaion enqueued
|
||||
|
||||
Otherwise it will show an error message of the form::
|
||||
|
||||
Caught error type [...] ([...]): [...]
|
||||
|
||||
This command uses the same pattern items and actions as ``flow create``,
|
||||
their format is described in `Creating flow rules`_.
|
||||
|
||||
Attributes
|
||||
^^^^^^^^^^
|
||||
|
||||
@ -4430,6 +4468,25 @@ Non-existent rule IDs are ignored::
|
||||
Flow rule #0 destroyed
|
||||
testpmd>
|
||||
|
||||
Enqueueing destruction of flow rules
|
||||
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
||||
|
||||
``flow queue destroy`` adds destruction operations to destroy one or more rules
|
||||
from their rule ID (as returned by ``flow queue create``) to a queue,
|
||||
this command calls ``rte_flow_async_destroy()`` as many times as necessary::
|
||||
|
||||
flow queue {port_id} destroy {queue_id}
|
||||
[postpone {boolean}] rule {rule_id} [...]
|
||||
|
||||
If successful, it will show::
|
||||
|
||||
Flow rule #[...] destruction enqueued
|
||||
|
||||
It does not report anything for rule IDs that do not exist. The usual error
|
||||
message is shown when a rule cannot be destroyed::
|
||||
|
||||
Caught error type [...] ([...]): [...]
|
||||
|
||||
Querying flow rules
|
||||
~~~~~~~~~~~~~~~~~~~
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user