session: fix session cli maybe parse wrong args if executed in files

Type: fix

Signed-off-by: Xiaoming Jiang <jiangxiaoming@outlook.com>
Change-Id: Id19a52df4f237cf5d85d305fdc279ab7df2d6f4b
This commit is contained in:
Xiaoming Jiang
2022-05-02 15:07:31 +00:00
committed by Florin Coras
parent 0530d09f9e
commit da052b62bd
3 changed files with 69 additions and 29 deletions

View File

@ -159,6 +159,46 @@ done:
return match; return match;
} }
/* Get current command args */
uword
unformat_vlib_cli_args (unformat_input_t *i, va_list *va)
{
unformat_input_t *result = va_arg (*va, unformat_input_t *);
u8 *line;
uword last_c;
u32 index = i->index;
if (unformat_is_eof (i))
{
unformat_init (result, 0, 0);
return 0;
}
/* try to find last non-space character */
do
{
ASSERT (index > 0);
last_c = i->buffer[--index];
}
while (last_c == ' ');
if (last_c == '\t' || last_c == '\n' || last_c == '\r' || last_c == '\f' ||
last_c == '}')
{
/* current command has no args */
unformat_init (result, 0, 0);
return 0;
}
if (!unformat_user (i, unformat_line, &line))
{
unformat_init (result, 0, 0);
return 0;
}
unformat_init_vector (result, line);
return 1;
}
/* Looks for string based sub-input formatted { SUB-INPUT }. */ /* Looks for string based sub-input formatted { SUB-INPUT }. */
uword uword
unformat_vlib_cli_sub_input (unformat_input_t * i, va_list * args) unformat_vlib_cli_sub_input (unformat_input_t * i, va_list * args)

View File

@ -204,6 +204,7 @@ clib_error_t *vlib_cli_register (struct vlib_main_t *vm,
clib_error_t *vlib_cli_register_parse_rule (struct vlib_main_t *vm, clib_error_t *vlib_cli_register_parse_rule (struct vlib_main_t *vm,
vlib_cli_parse_rule_t * c); vlib_cli_parse_rule_t * c);
uword unformat_vlib_cli_args (unformat_input_t *i, va_list *va);
uword unformat_vlib_cli_sub_input (unformat_input_t * i, va_list * args); uword unformat_vlib_cli_sub_input (unformat_input_t * i, va_list * args);
/* Return an vector of strings consisting of possible auto-completions /* Return an vector of strings consisting of possible auto-completions

View File

@ -487,7 +487,7 @@ show_session_command_fn (vlib_main_t * vm, unformat_input_t * input,
{ {
u8 one_session = 0, do_listeners = 0, sst, do_elog = 0, do_filter = 0; u8 one_session = 0, do_listeners = 0, sst, do_elog = 0, do_filter = 0;
u32 track_index, thread_index = 0, start = 0, end = ~0, session_index; u32 track_index, thread_index = 0, start = 0, end = ~0, session_index;
unformat_input_t _line_input, *line_input = &_line_input; unformat_input_t _cli_args, *cli_args = &_cli_args;
transport_proto_t transport_proto = TRANSPORT_PROTO_INVALID; transport_proto_t transport_proto = TRANSPORT_PROTO_INVALID;
session_state_t state = SESSION_N_STATES, *states = 0; session_state_t state = SESSION_N_STATES, *states = 0;
session_main_t *smm = &session_main; session_main_t *smm = &session_main;
@ -501,26 +501,26 @@ show_session_command_fn (vlib_main_t * vm, unformat_input_t * input,
session_cli_return_if_not_enabled (); session_cli_return_if_not_enabled ();
if (!unformat_user (input, unformat_line_input, line_input)) if (!unformat_user (input, unformat_vlib_cli_args, cli_args))
{ {
session_cli_show_all_sessions (vm, 0); session_cli_show_all_sessions (vm, 0);
return 0; return 0;
} }
while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT) while (unformat_check_input (cli_args) != UNFORMAT_END_OF_INPUT)
{ {
if (unformat (line_input, "verbose %d", &verbose)) if (unformat (cli_args, "verbose %d", &verbose))
; ;
else if (unformat (line_input, "verbose")) else if (unformat (cli_args, "verbose"))
verbose = 1; verbose = 1;
else if (unformat (line_input, "listeners %U", unformat_transport_proto, else if (unformat (cli_args, "listeners %U", unformat_transport_proto,
&transport_proto)) &transport_proto))
do_listeners = 1; do_listeners = 1;
else if (unformat (line_input, "%U", unformat_session, &s)) else if (unformat (cli_args, "%U", unformat_session, &s))
{ {
one_session = 1; one_session = 1;
} }
else if (unformat (line_input, "thread %u index %u", &thread_index, else if (unformat (cli_args, "thread %u index %u", &thread_index,
&session_index)) &session_index))
{ {
s = session_get_if_valid (session_index, thread_index); s = session_get_if_valid (session_index, thread_index);
@ -531,17 +531,16 @@ show_session_command_fn (vlib_main_t * vm, unformat_input_t * input,
} }
one_session = 1; one_session = 1;
} }
else if (unformat (line_input, "thread %u", &thread_index)) else if (unformat (cli_args, "thread %u", &thread_index))
{ {
do_filter = 1; do_filter = 1;
} }
else else if (unformat (cli_args, "state %U", unformat_session_state, &state))
if (unformat (line_input, "state %U", unformat_session_state, &state))
{ {
vec_add1 (states, state); vec_add1 (states, state);
do_filter = 1; do_filter = 1;
} }
else if (unformat (line_input, "proto %U index %u", else if (unformat (cli_args, "proto %U index %u",
unformat_transport_proto, &transport_proto, unformat_transport_proto, &transport_proto,
&transport_index)) &transport_index))
{ {
@ -564,34 +563,34 @@ show_session_command_fn (vlib_main_t * vm, unformat_input_t * input,
} }
one_session = 1; one_session = 1;
} }
else if (unformat (line_input, "proto %U", unformat_transport_proto, else if (unformat (cli_args, "proto %U", unformat_transport_proto,
&transport_proto)) &transport_proto))
do_filter = 1; do_filter = 1;
else if (unformat (line_input, "range %u %u", &start, &end)) else if (unformat (cli_args, "range %u %u", &start, &end))
do_filter = 1; do_filter = 1;
else if (unformat (line_input, "range %u", &start)) else if (unformat (cli_args, "range %u", &start))
{ {
end = start + 50; end = start + 50;
do_filter = 1; do_filter = 1;
} }
else if (unformat (line_input, "elog")) else if (unformat (cli_args, "elog"))
do_elog = 1; do_elog = 1;
else if (unformat (line_input, "protos")) else if (unformat (cli_args, "protos"))
{ {
vlib_cli_output (vm, "%U", format_transport_protos); vlib_cli_output (vm, "%U", format_transport_protos);
goto done; goto done;
} }
else if (unformat (line_input, "states")) else if (unformat (cli_args, "states"))
{ {
session_cli_print_session_states (vm); session_cli_print_session_states (vm);
goto done; goto done;
} }
else if (unformat (line_input, "events")) else if (unformat (cli_args, "events"))
do_events = 1; do_events = 1;
else else
{ {
error = clib_error_return (0, "unknown input `%U'", error = clib_error_return (0, "unknown input `%U'",
format_unformat_error, line_input); format_unformat_error, cli_args);
goto done; goto done;
} }
} }
@ -660,7 +659,7 @@ show_session_command_fn (vlib_main_t * vm, unformat_input_t * input,
session_cli_show_all_sessions (vm, verbose); session_cli_show_all_sessions (vm, verbose);
done: done:
unformat_free (line_input); unformat_free (cli_args);
vec_free (states); vec_free (states);
return error; return error;
} }
@ -850,29 +849,29 @@ static clib_error_t *
session_enable_disable_fn (vlib_main_t * vm, unformat_input_t * input, session_enable_disable_fn (vlib_main_t * vm, unformat_input_t * input,
vlib_cli_command_t * cmd) vlib_cli_command_t * cmd)
{ {
unformat_input_t _line_input, *line_input = &_line_input; unformat_input_t _cli_args, *cli_args = &_cli_args;
u8 is_en = 1; u8 is_en = 1;
clib_error_t *error; clib_error_t *error;
if (!unformat_user (input, unformat_line_input, line_input)) if (!unformat_user (input, unformat_vlib_cli_args, cli_args))
return clib_error_return (0, "expected enable | disable"); return clib_error_return (0, "expected enable | disable");
while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT) while (unformat_check_input (cli_args) != UNFORMAT_END_OF_INPUT)
{ {
if (unformat (line_input, "enable")) if (unformat (cli_args, "enable"))
is_en = 1; is_en = 1;
else if (unformat (line_input, "disable")) else if (unformat (cli_args, "disable"))
is_en = 0; is_en = 0;
else else
{ {
error = clib_error_return (0, "unknown input `%U'", error = clib_error_return (0, "unknown input `%U'",
format_unformat_error, line_input); format_unformat_error, cli_args);
unformat_free (line_input); unformat_free (cli_args);
return error; return error;
} }
} }
unformat_free (line_input); unformat_free (cli_args);
return vnet_session_enable_disable (vm, is_en); return vnet_session_enable_disable (vm, is_en);
} }