X-Git-Url: https://gerrit.fd.io/r/gitweb?p=vpp.git;a=blobdiff_plain;f=src%2Fvnet%2Fpg%2Fcli.c;h=4526986d1ff802ad1669342a062f1886c3effca3;hp=a09107c50c53c548686d63d348cd95362983d294;hb=8feeaff56;hpb=671e60e65635b8d030bf303c88411192c747b59e diff --git a/src/vnet/pg/cli.c b/src/vnet/pg/cli.c index a09107c50c5..4526986d1ff 100644 --- a/src/vnet/pg/cli.c +++ b/src/vnet/pg/cli.c @@ -42,9 +42,9 @@ #include #include -#ifdef CLIB_UNIX +#include #include -#endif + /* Root of all packet generator cli commands. */ /* *INDENT-OFF* */ @@ -145,40 +145,66 @@ VLIB_CLI_COMMAND (disable_streams_cli, static) = { }; /* *INDENT-ON* */ +static u8 * +format_pg_edit_group (u8 * s, va_list * va) +{ + pg_edit_group_t *g = va_arg (*va, pg_edit_group_t *); + + s = + format (s, "hdr-size %d, offset %d, ", g->n_packet_bytes, + g->start_byte_offset); + if (g->edit_function) + { + u8 *function_name; + u8 *junk_after_name; + function_name = format (0, "%U%c", format_clib_elf_symbol_with_address, + g->edit_function, 0); + junk_after_name = function_name; + while (*junk_after_name && *junk_after_name != ' ') + junk_after_name++; + *junk_after_name = 0; + s = format (s, "edit-function %s, ", function_name); + vec_free (function_name); + } + + return s; +} + static u8 * format_pg_stream (u8 * s, va_list * va) { pg_stream_t *t = va_arg (*va, pg_stream_t *); - u8 *v; + int verbose = va_arg (*va, int); if (!t) - return format (s, "%=16s%=12s%=16s%s", + return format (s, "%-16s%=12s%=16s%s", "Name", "Enabled", "Count", "Parameters"); - s = format (s, "%-16v%=12s%16Ld", + s = format (s, "%-16v%=12s%=16Ld", t->name, pg_stream_is_enabled (t) ? "Yes" : "No", t->n_packets_generated); - v = 0; - - v = format (v, "limit %Ld, ", t->n_packets_limit); + int indent = format_get_indent (s); - v = format (v, "rate %.2e pps, ", t->rate_packets_per_second); - - v = format (v, "size %d%c%d, ", + s = format (s, "limit %Ld, ", t->n_packets_limit); + s = format (s, "rate %.2e pps, ", t->rate_packets_per_second); + s = format (s, "size %d%c%d, ", t->min_packet_bytes, t->packet_size_edit_type == PG_EDIT_RANDOM ? '+' : '-', t->max_packet_bytes); + s = format (s, "buffer-size %d, ", t->buffer_bytes); + s = format (s, "worker %d, ", t->worker_index); - v = format (v, "buffer-size %d, ", t->buffer_bytes); - - v = format (v, "worker %d, ", t->worker_index); - - if (v) + if (verbose) + { + pg_edit_group_t *g; + /* *INDENT-OFF* */ + vec_foreach (g, t->edit_groups) { - s = format (s, " %v", v); - vec_free (v); + s = format (s, "\n%U%U", format_white_space, indent, format_pg_edit_group, g); + } + /* *INDENT-ON* */ } return s; @@ -190,6 +216,15 @@ show_streams (vlib_main_t * vm, { pg_main_t *pg = &pg_main; pg_stream_t *s; + int verbose = 0; + + while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT) + { + if (unformat (input, "verbose")) + verbose = 1; + else + break; + } if (pool_elts (pg->streams) == 0) { @@ -197,10 +232,10 @@ show_streams (vlib_main_t * vm, goto done; } - vlib_cli_output (vm, "%U", format_pg_stream, 0); + vlib_cli_output (vm, "%U", format_pg_stream, 0, 0); /* *INDENT-OFF* */ pool_foreach (s, pg->streams, ({ - vlib_cli_output (vm, "%U", format_pg_stream, s); + vlib_cli_output (vm, "%U", format_pg_stream, s, verbose); })); /* *INDENT-ON* */ @@ -210,8 +245,8 @@ done: /* *INDENT-OFF* */ VLIB_CLI_COMMAND (show_streams_cli, static) = { - .path = "show packet-generator", - .short_help = "Show packet generator streams", + .path = "show packet-generator ", + .short_help = "show packet-generator [verbose]", .function = show_streams, }; /* *INDENT-ON* */ @@ -232,8 +267,6 @@ pg_pcap_read (pg_stream_t * s, char *file_name) s->min_packet_bytes = pm.min_packet_bytes; s->max_packet_bytes = pm.max_packet_bytes; s->buffer_bytes = pm.max_packet_bytes; - /* For PCAP buffers we never re-use buffers. */ - s->flags |= PG_STREAM_FLAGS_DISABLE_BUFFER_RECYCLE; if (s->n_packets_limit == 0) s->n_packets_limit = vec_len (pm.packets_read); @@ -277,10 +310,11 @@ validate_stream (pg_stream_t * s) if (s->max_packet_bytes < s->min_packet_bytes) return clib_error_create ("max-size < min-size"); - if (s->buffer_bytes >= 4096 || s->buffer_bytes == 0) - return - clib_error_create ("buffer-size must be positive and < 4096, given %d", - s->buffer_bytes); + u32 hdr_size = pg_edit_group_n_bytes (s, 0); + if (s->min_packet_bytes < hdr_size) + return clib_error_create ("min-size < total header size %d", hdr_size); + if (s->buffer_bytes == 0) + return clib_error_create ("buffer-size must be positive"); if (s->rate_packets_per_second < 0) return clib_error_create ("negative rate"); @@ -305,7 +339,7 @@ new_stream (vlib_main_t * vm, s.sw_if_index[VLIB_RX] = s.sw_if_index[VLIB_TX] = ~0; s.node_index = ~0; s.max_packet_bytes = s.min_packet_bytes = 64; - s.buffer_bytes = VLIB_BUFFER_DATA_SIZE; + s.buffer_bytes = vlib_buffer_get_default_data_size (vm); s.if_id = 0; pcap_file_name = 0; while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT) @@ -351,9 +385,6 @@ new_stream (vlib_main_t * vm, else if (unformat_user (input, unformat_pg_stream_parameter, &s)) ; - else if (unformat (input, "no-recycle")) - s.flags |= PG_STREAM_FLAGS_DISABLE_BUFFER_RECYCLE; - else { error = clib_error_create ("unknown input `%U'", @@ -362,10 +393,6 @@ new_stream (vlib_main_t * vm, } } - error = validate_stream (&s); - if (error) - return error; - if (!sub_input_given && !pcap_file_name) { error = clib_error_create ("no packet data given"); @@ -419,6 +446,10 @@ new_stream (vlib_main_t * vm, } } + error = validate_stream (&s); + if (error) + return error; + pg_stream_add (pg, &s); return 0; @@ -501,7 +532,10 @@ change_stream_parameters (vlib_main_t * vm, error = validate_stream (&s_new); if (!error) - s[0] = s_new; + { + s[0] = s_new; + pg_stream_change (pg, s); + } return error; }