@@ -1778,14 +1778,14 @@ cmd_pipeline_commit(char **tokens,
status = rte_swx_ctl_pipeline_commit(ctl, 1);
if (status)
snprintf(out, out_size, "Commit failed. "
- "Use \"commit\" to retry or \"abort\" to discard the pending work.\n");
+ "Use \"commit\" to retry or \"cancel\" to discard the pending work.\n");
}
-static const char cmd_pipeline_abort_help[] =
-"pipeline <pipeline_name> abort\n";
+static const char cmd_pipeline_cancel_help[] =
+"pipeline <pipeline_name> cancel\n";
static void
-cmd_pipeline_abort(char **tokens,
+cmd_pipeline_cancel(char **tokens,
uint32_t n_tokens,
char *out,
size_t out_size,
@@ -1806,7 +1806,7 @@ cmd_pipeline_abort(char **tokens,
return;
}
- rte_swx_ctl_pipeline_abort(ctl);
+ rte_swx_ctl_pipeline_cancel(ctl);
}
static const char cmd_pipeline_regrd_help[] =
@@ -3474,8 +3474,8 @@ cmd_help(char **tokens,
"\tpipeline selector group member delete\n"
"\tpipeline selector show\n"
"\tpipeline learner default\n"
+ "\tpipeline cancel\n"
"\tpipeline commit\n"
- "\tpipeline abort\n"
"\tpipeline regrd\n"
"\tpipeline regwr\n"
"\tpipeline meter profile add\n"
@@ -3648,9 +3648,9 @@ cmd_help(char **tokens,
if ((strcmp(tokens[0], "pipeline") == 0) &&
(n_tokens == 2) &&
- (strcmp(tokens[1], "abort") == 0)) {
+ (strcmp(tokens[1], "cancel") == 0)) {
snprintf(out, out_size, "\n%s\n",
- cmd_pipeline_abort_help);
+ cmd_pipeline_cancel_help);
return;
}
@@ -3934,8 +3934,8 @@ cli_process(char *in, char *out, size_t out_size, void *obj)
}
if ((n_tokens >= 3) &&
- (strcmp(tokens[2], "abort") == 0)) {
- cmd_pipeline_abort(tokens, n_tokens, out,
+ (strcmp(tokens[2], "cancel") == 0)) {
+ cmd_pipeline_cancel(tokens, n_tokens, out,
out_size, obj);
return;
}
@@ -2063,7 +2063,7 @@ table_rollback(struct rte_swx_ctl_pipeline *ctl, uint32_t table_id)
* failed commit operation to remove ALL the pending work for ALL the tables.
*/
static void
-table_abort(struct rte_swx_ctl_pipeline *ctl, uint32_t table_id)
+table_cancel(struct rte_swx_ctl_pipeline *ctl, uint32_t table_id)
{
struct table *table = &ctl->tables[table_id];
@@ -2366,7 +2366,7 @@ selector_rollback(struct rte_swx_ctl_pipeline *ctl, uint32_t selector_id)
}
static void
-selector_abort(struct rte_swx_ctl_pipeline *ctl, uint32_t selector_id)
+selector_cancel(struct rte_swx_ctl_pipeline *ctl, uint32_t selector_id)
{
struct selector *s = &ctl->selectors[selector_id];
uint32_t group_id;
@@ -2545,7 +2545,7 @@ learner_rollfwd_finalize(struct rte_swx_ctl_pipeline *ctl, uint32_t learner_id)
}
static void
-learner_abort(struct rte_swx_ctl_pipeline *ctl, uint32_t learner_id)
+learner_cancel(struct rte_swx_ctl_pipeline *ctl, uint32_t learner_id)
{
struct learner *l = &ctl->learners[learner_id];
@@ -2554,7 +2554,8 @@ learner_abort(struct rte_swx_ctl_pipeline *ctl, uint32_t learner_id)
}
int
-rte_swx_ctl_pipeline_commit(struct rte_swx_ctl_pipeline *ctl, int abort_on_fail)
+rte_swx_ctl_pipeline_commit(struct rte_swx_ctl_pipeline *ctl,
+ int cancel_on_fail)
{
struct rte_swx_table_state *ts;
int status = 0;
@@ -2622,25 +2623,25 @@ rte_swx_ctl_pipeline_commit(struct rte_swx_ctl_pipeline *ctl, int abort_on_fail)
rollback:
for (i = 0; i < ctl->info.n_tables; i++) {
table_rollback(ctl, i);
- if (abort_on_fail)
- table_abort(ctl, i);
+ if (cancel_on_fail)
+ table_cancel(ctl, i);
}
for (i = 0; i < ctl->info.n_selectors; i++) {
selector_rollback(ctl, i);
- if (abort_on_fail)
- selector_abort(ctl, i);
+ if (cancel_on_fail)
+ selector_cancel(ctl, i);
}
- if (abort_on_fail)
+ if (cancel_on_fail)
for (i = 0; i < ctl->info.n_learners; i++)
- learner_abort(ctl, i);
+ learner_cancel(ctl, i);
return status;
}
void
-rte_swx_ctl_pipeline_abort(struct rte_swx_ctl_pipeline *ctl)
+rte_swx_ctl_pipeline_cancel(struct rte_swx_ctl_pipeline *ctl)
{
uint32_t i;
@@ -2648,13 +2649,13 @@ rte_swx_ctl_pipeline_abort(struct rte_swx_ctl_pipeline *ctl)
return;
for (i = 0; i < ctl->info.n_tables; i++)
- table_abort(ctl, i);
+ table_cancel(ctl, i);
for (i = 0; i < ctl->info.n_selectors; i++)
- selector_abort(ctl, i);
+ selector_cancel(ctl, i);
for (i = 0; i < ctl->info.n_learners; i++)
- learner_abort(ctl, i);
+ learner_cancel(ctl, i);
}
static int
@@ -1045,7 +1045,7 @@ rte_swx_ctl_pipeline_learner_default_entry_add(struct rte_swx_ctl_pipeline *ctl,
*
* @param[in] ctl
* Pipeline control handle.
- * @param[in] abort_on_fail
+ * @param[in] revert_on_fail
* When non-zero (false), all the scheduled work is discarded after a failed
* commit. Otherwise, the scheduled work is still kept pending for the next
* commit.
@@ -1056,10 +1056,10 @@ rte_swx_ctl_pipeline_learner_default_entry_add(struct rte_swx_ctl_pipeline *ctl,
__rte_experimental
int
rte_swx_ctl_pipeline_commit(struct rte_swx_ctl_pipeline *ctl,
- int abort_on_fail);
+ int revert_on_fail);
/**
- * Pipeline abort
+ * Pipeline cancel
*
* Discard all the scheduled table work.
*
@@ -1068,7 +1068,7 @@ rte_swx_ctl_pipeline_commit(struct rte_swx_ctl_pipeline *ctl,
*/
__rte_experimental
void
-rte_swx_ctl_pipeline_abort(struct rte_swx_ctl_pipeline *ctl);
+rte_swx_ctl_pipeline_cancel(struct rte_swx_ctl_pipeline *ctl);
/**
* Pipeline table entry read
@@ -62,7 +62,7 @@ EXPERIMENTAL {
# added in 20.11
rte_swx_ctl_action_arg_info_get;
rte_swx_ctl_action_info_get;
- rte_swx_ctl_pipeline_abort;
+ rte_swx_ctl_pipeline_cancel;
rte_swx_ctl_pipeline_commit;
rte_swx_ctl_pipeline_create;
rte_swx_ctl_pipeline_free;