#define SESSION_INVALID_INDEX ((u32)~0)
#define SESSION_INVALID_HANDLE ((u64)~0)
-#define QUIC_ECHO_DBG 0
-#define DBG(_fmt, _args...) \
- if (QUIC_ECHO_DBG) \
- clib_warning (_fmt, ##_args)
-
#define CHECK(expected, result, _fmt, _args...) \
if (expected != result) \
ECHO_FAIL ("expected %d, got %d : " _fmt, expected, result, ##_args);
echo_main_t *em = &echo_main; \
em->has_failed = 1; \
em->time_to_stop = 1; \
- clib_warning ("ECHO-ERROR: "_fmt, ##_args); \
+ if (em->log_lvl > 1) \
+ clib_warning ("ECHO-ERROR: "_fmt, ##_args); \
+ }
+
+#define ECHO_LOG(lvl, _fmt,_args...) \
+ { \
+ echo_main_t *em = &echo_main; \
+ if (em->log_lvl > lvl) \
+ clib_warning (_fmt, ##_args); \
}
typedef struct
data_source_t data_source;
u8 send_quic_disconnects; /* actively send disconnect */
u8 send_stream_disconnects; /* actively send disconnect */
+ u8 output_json;
+ u8 log_lvl;
u8 *appns_id;
u64 appns_flags;
u64 rx_total;
/* Event based timing : start & end depend on CLI specified events */
- u8 first_sconnect_sent; /* Sent the first Stream session connect ? */
+ u8 events_sent;
f64 start_time;
f64 end_time;
u8 timing_start_event;
dmp->_vl_msg_id = ntohs (VL_API_DISCONNECT_SESSION);
dmp->client_index = em->my_client_index;
dmp->handle = s->vpp_session_handle;
- DBG ("Disconnect session 0x%lx", dmp->handle);
+ ECHO_LOG (1, "Disconnect session 0x%lx", dmp->handle);
vl_msg_api_send_shmem (em->vl_input_queue, (u8 *) & dmp);
}
f64 timeout;
timeout = clib_time_now (&em->clib_time) + TIMEOUT;
uword *segment_present;
- DBG ("Waiting for segment 0x%lx...", segment_handle);
+ ECHO_LOG (1, "Waiting for segment 0x%lx...", segment_handle);
while (clib_time_now (&em->clib_time) < timeout)
{
clib_spinlock_lock (&em->segment_handles_lock);
if (em->time_to_stop == 1)
return 0;
}
- DBG ("timeout wait_for_segment_allocation (0x%lx)", segment_handle);
+ ECHO_LOG (1, "timeout wait_for_segment_allocation (0x%lx)", segment_handle);
return -1;
}
static void
quic_echo_notify_event (echo_main_t * em, echo_test_evt_t e)
{
+ if (em->events_sent & e)
+ return;
if (em->timing_start_event == e)
em->start_time = clib_time_now (&em->clib_time);
else if (em->timing_end_event == e)
em->end_time = clib_time_now (&em->clib_time);
+ em->events_sent |= e;
}
static void
session_print_stats (echo_main_t * em, echo_session_t * session)
{
f64 deltat = clib_time_now (&em->clib_time) - session->start;
- fformat (stdout, "Session 0x%x done in %.6fs RX[%.4f] TX[%.4f] Gbit/s\n",
- session->vpp_session_handle, deltat,
- (session->bytes_received * 8.0) / deltat / 1e9,
- (session->bytes_sent * 8.0) / deltat / 1e9);
+ ECHO_LOG (0, "Session 0x%x done in %.6fs RX[%.4f] TX[%.4f] Gbit/s\n",
+ session->vpp_session_handle, deltat,
+ (session->bytes_received * 8.0) / deltat / 1e9,
+ (session->bytes_sent * 8.0) / deltat / 1e9);
+}
+
+static void
+echo_event_didnt_happen (u8 e)
+{
+ echo_main_t *em = &echo_main;
+ u8 *s = format (0, "%U", echo_format_timing_event, e);
+ ECHO_LOG (0, "Expected event %s to happend, which did not", s);
+ em->has_failed = 1;
+}
+
+static void
+print_global_json_stats (echo_main_t * em)
+{
+ if (!(em->events_sent & em->timing_start_event))
+ return echo_event_didnt_happen (em->timing_start_event);
+ if (!(em->events_sent & em->timing_end_event))
+ return echo_event_didnt_happen (em->timing_end_event);
+ f64 deltat = em->end_time - em->start_time;
+ u8 *start_evt =
+ format (0, "%U", echo_format_timing_event, em->timing_start_event);
+ u8 *end_evt =
+ format (0, "%U", echo_format_timing_event, em->timing_end_event);
+ fformat (stdout, "{\n");
+ fformat (stdout, "\"time\": \"%.9f\",\n", deltat);
+ fformat (stdout, "\"start_evt\": \"%s\",\n", start_evt);
+ fformat (stdout, "\"end_evt\": \"%s\",\n", end_evt);
+ fformat (stdout, "\"rx_data\": %lld,\n", em->rx_total);
+ fformat (stdout, "\"tx_rx\": %lld,\n", em->tx_total);
+ fformat (stdout, "}\n");
}
static void
print_global_stats (echo_main_t * em)
{
+ u8 *s;
+ if (!(em->events_sent & em->timing_start_event))
+ return echo_event_didnt_happen (em->timing_start_event);
+ if (!(em->events_sent & em->timing_end_event))
+ return echo_event_didnt_happen (em->timing_end_event);
f64 deltat = em->end_time - em->start_time;
- u8 *s = format (0, "%U:%U",
- echo_format_timing_event, em->timing_start_event,
- echo_format_timing_event, em->timing_end_event);
+ s = format (0, "%U:%U",
+ echo_format_timing_event, em->timing_start_event,
+ echo_format_timing_event, em->timing_end_event);
fformat (stdout, "Timing %s\n", s);
fformat (stdout, "-------- TX --------\n");
- fformat (stdout, "%lld bytes (%lld mbytes, %lld gbytes) in %.2f seconds\n",
+ fformat (stdout, "%lld bytes (%lld mbytes, %lld gbytes) in %.6f seconds\n",
em->tx_total, em->tx_total / (1ULL << 20),
em->tx_total / (1ULL << 30), deltat);
fformat (stdout, "%.4f Gbit/second\n", (em->tx_total * 8.0) / deltat / 1e9);
fformat (stdout, "-------- RX --------\n");
- fformat (stdout, "%lld bytes (%lld mbytes, %lld gbytes) in %.2f seconds\n",
+ fformat (stdout, "%lld bytes (%lld mbytes, %lld gbytes) in %.6f seconds\n",
em->rx_total, em->rx_total / (1ULL << 20),
em->rx_total / (1ULL << 30), deltat);
fformat (stdout, "%.4f Gbit/second\n", (em->rx_total * 8.0) / deltat / 1e9);
{
/* Free session */
s = pool_elt_at_index (em->sessions, *session_index);
- DBG ("Freeing session 0x%lx", s->vpp_session_handle);
+ ECHO_LOG (1, "Freeing session 0x%lx", s->vpp_session_handle);
pool_put (em->sessions, s);
clib_memset (s, 0xfe, sizeof (*s));
}
else if (s->session_type == QUIC_SESSION_TYPE_STREAM)
clib_atomic_sub_fetch (&em->n_clients_connected, 1);
- DBG ("Cleanup sessions (still %uQ %uS)", em->n_quic_clients_connected,
- em->n_clients_connected);
+ ECHO_LOG (1, "Cleanup sessions (still %uQ %uS)",
+ em->n_quic_clients_connected, em->n_clients_connected);
hash_unset (em->session_index_by_vpp_handles, s->vpp_session_handle);
s->session_state = QUIC_SESSION_STATE_CLOSED;
}
echo_cleanup_session (em, s); /* We can clean Q/Lsessions right away */
}
+static void
+echo_initiate_qsession_close_no_stream (echo_main_t * em)
+{
+ ECHO_LOG (1, "Closing Qsessions");
+ /* Close Quic session without streams */
+ echo_session_t *s;
+
+ /* *INDENT-OFF* */
+ pool_foreach (s, em->sessions,
+ ({
+ if (s->session_type == QUIC_SESSION_TYPE_QUIC && s->accepted_session_count == 0)
+ {
+ ECHO_LOG (1,"ACTIVE close 0x%lx", s->vpp_session_handle);
+ if (em->send_quic_disconnects == ECHO_CLOSE_F_ACTIVE)
+ echo_disconnect_session (em, s);
+ else if (em->send_quic_disconnects == ECHO_CLOSE_F_NONE)
+ echo_cleanup_session (em, s);
+ }
+ }));
+ /* *INDENT-ON* */
+}
+
static void
test_recv_bytes (echo_main_t * em, echo_session_t * s, u8 * rx_buf,
u32 n_read)
expected = (s->bytes_received + i) & 0xff;
if (rx_buf[i] == expected || em->max_test_msg > 0)
continue;
- clib_warning ("Session 0x%lx byte %lld was 0x%x expected 0x%x",
- s->vpp_session_handle, s->bytes_received + i, rx_buf[i],
- expected);
+ ECHO_LOG (0, "Session 0x%lx byte %lld was 0x%x expected 0x%x",
+ s->vpp_session_handle, s->bytes_received + i, rx_buf[i],
+ expected);
em->max_test_msg--;
if (em->max_test_msg == 0)
- clib_warning ("Too many errors, hiding next ones");
+ ECHO_LOG (0, "Too many errors, hiding next ones");
if (em->test_return_packets == RETURN_PACKETS_ASSERT)
ECHO_FAIL ("test-bytes errored");
}
return;
}
- /* check idle clients */
- if (n_sent || n_read)
- s->idle_cycles = 0;
- else if (s->idle_cycles++ == 1e7)
+ if (em->log_lvl > 1)
{
- s->idle_cycles = 0;
- DBG ("Idle client TX:%dB RX:%dB", s->bytes_to_send,
- s->bytes_to_receive);
- DBG ("Idle FIFOs TX:%dB RX:%dB", svm_fifo_max_dequeue (s->tx_fifo),
- svm_fifo_max_dequeue (s->rx_fifo));
+ /* check idle clients */
+ if (n_sent || n_read)
+ s->idle_cycles = 0;
+ else if (s->idle_cycles++ == 1e7)
+ {
+ s->idle_cycles = 0;
+ ECHO_LOG (1, "Idle client TX:%dB RX:%dB", s->bytes_to_send,
+ s->bytes_to_receive);
+ ECHO_LOG (1, "Idle FIFOs TX:%dB RX:%dB",
+ svm_fifo_max_dequeue (s->tx_fifo),
+ svm_fifo_max_dequeue (s->rx_fifo));
+ }
}
}
echo_thread_handle_closing (echo_main_t * em, echo_session_t * s)
{
- DBG ("[%lu/%lu] -> S(%x) -> [%lu/%lu]",
- s->bytes_received, s->bytes_received + s->bytes_to_receive,
- s->session_index, s->bytes_sent, s->bytes_sent + s->bytes_to_send);
+ ECHO_LOG (1, "[%lu/%lu] -> S(%x) -> [%lu/%lu]",
+ s->bytes_received, s->bytes_received + s->bytes_to_receive,
+ s->session_index, s->bytes_sent,
+ s->bytes_sent + s->bytes_to_send);
clib_atomic_fetch_add (&em->tx_total, s->bytes_sent);
clib_atomic_fetch_add (&em->rx_total, s->bytes_received);
{
first_idx = n * (nc / n);
thread_sessions = (nc + 1) % n == 0 ? n : (nc + 1) % n;
- DBG ("Start thread %u [%u -> %u]", nc / n, first_idx,
- first_idx + thread_sessions - 1);
+ ECHO_LOG (1, "Start thread %u [%u -> %u]", nc / n, first_idx,
+ first_idx + thread_sessions - 1);
return pthread_create (&em->client_thread_handles[nc / n],
NULL /*attr */ , echo_thread_fn,
(void *) ((u64) first_idx << 32 | (u64)
clib_net_to_host_u32 (mp->retval));
return;
}
-
- clib_warning ("listening on %U:%u", format_ip46_address, mp->lcl_ip,
- mp->lcl_is_ip4 ? IP46_TYPE_IP4 : IP46_TYPE_IP6,
- clib_net_to_host_u16 (mp->lcl_port));
+ ECHO_LOG (0, "listening on %U:%u", format_ip46_address, mp->lcl_ip,
+ mp->lcl_is_ip4 ? IP46_TYPE_IP4 : IP46_TYPE_IP6,
+ clib_net_to_host_u16 (mp->lcl_port));
/* Allocate local session and set it up */
listen_session = echo_session_alloc (em);
clib_atomic_fetch_add (&listen_session->accepted_session_count, 1);
/* Add it to lookup table */
- DBG ("Accepted session 0x%lx -> 0x%lx", mp->handle, mp->listener_handle);
+ ECHO_LOG (1, "Accepted session 0x%lx -> 0x%lx", mp->handle,
+ mp->listener_handle);
hash_set (em->session_index_by_vpp_handles, mp->handle,
session->session_index);
if (listen_session->session_type == QUIC_SESSION_TYPE_LISTEN)
{
+ quic_echo_notify_event (em, ECHO_EVT_FIRST_QCONNECT);
session->session_type = QUIC_SESSION_TYPE_QUIC;
if (em->cb_vft.quic_accepted_cb)
em->cb_vft.quic_accepted_cb (mp, session->session_index);
else if (em->i_am_master)
{
session->session_type = QUIC_SESSION_TYPE_STREAM;
+ quic_echo_notify_event (em, ECHO_EVT_FIRST_SCONNECT);
if (em->cb_vft.server_stream_accepted_cb)
em->cb_vft.server_stream_accepted_cb (mp, session->session_index);
clib_atomic_fetch_add (&em->n_clients_connected, 1);
else
{
session->session_type = QUIC_SESSION_TYPE_STREAM;
+ quic_echo_notify_event (em, ECHO_EVT_FIRST_SCONNECT);
if (em->cb_vft.client_stream_accepted_cb)
em->cb_vft.client_stream_accepted_cb (mp, session->session_index);
clib_atomic_fetch_add (&em->n_clients_connected, 1);
}
- if (em->n_clients_connected == em->n_clients * em->n_stream_clients)
+ if (em->n_clients_connected == em->n_clients * em->n_stream_clients
+ && em->n_clients_connected != 0)
{
- DBG ("App is ready");
+ ECHO_LOG (1, "App is ready");
em->state = STATE_READY;
quic_echo_notify_event (em, ECHO_EVT_LAST_SCONNECTED);
}
if (em->n_quic_clients_connected == em->n_clients)
- quic_echo_notify_event (em, ECHO_EVT_LAST_QCONNECTED);
+ {
+ quic_echo_notify_event (em, ECHO_EVT_LAST_QCONNECTED);
+ if (em->n_stream_clients == 0)
+ {
+ em->state = STATE_READY;
+ echo_initiate_qsession_close_no_stream (em);
+ }
+ }
}
static void
session->listener_index = listen_session->session_index;
}
- DBG ("Connected session 0x%lx -> 0x%lx", mp->handle,
- listener_index !=
- SESSION_INVALID_INDEX ? listen_session->vpp_session_handle : (u64) ~
- 0);
+ ECHO_LOG (1, "Connected session 0x%lx -> 0x%lx", mp->handle,
+ listener_index !=
+ SESSION_INVALID_INDEX ? listen_session->vpp_session_handle : (u64)
+ ~ 0);
hash_set (em->session_index_by_vpp_handles, mp->handle,
session->session_index);
clib_atomic_fetch_add (&em->n_clients_connected, 1);
}
- if (em->n_clients_connected == em->n_clients * em->n_stream_clients)
+ if (em->n_clients_connected == em->n_clients * em->n_stream_clients
+ && em->n_clients_connected != 0)
{
- DBG ("App is ready");
+ ECHO_LOG (1, "App is ready");
em->state = STATE_READY;
quic_echo_notify_event (em, ECHO_EVT_LAST_SCONNECTED);
}
if (em->n_quic_clients_connected == em->n_clients)
- quic_echo_notify_event (em, ECHO_EVT_LAST_QCONNECTED);
+ {
+ quic_echo_notify_event (em, ECHO_EVT_LAST_QCONNECTED);
+ if (em->n_stream_clients == 0)
+ {
+ em->state = STATE_READY;
+ echo_initiate_qsession_close_no_stream (em);
+ }
+ }
}
/*
u8 *uri = format (0, "QUIC://session/%lu", mp->handle);
u64 i;
- if (!em->first_sconnect_sent)
- {
- em->first_sconnect_sent = 1;
- quic_echo_notify_event (em, ECHO_EVT_FIRST_SCONNECT);
- }
+ quic_echo_notify_event (em, ECHO_EVT_FIRST_SCONNECT);
for (i = 0; i < em->n_stream_clients; i++)
echo_send_connect (em, uri, session_index);
- clib_warning ("Qsession 0x%llx connected to %U:%d",
- mp->handle, format_ip46_address, &mp->lcl.ip,
- mp->lcl.is_ip4, clib_net_to_host_u16 (mp->lcl.port));
+ ECHO_LOG (0, "Qsession 0x%llx connected to %U:%d",
+ mp->handle, format_ip46_address, &mp->lcl.ip,
+ mp->lcl.is_ip4, clib_net_to_host_u16 (mp->lcl.port));
}
static void
echo_on_accept_connect (session_accepted_msg_t * mp, u32 session_index)
{
echo_main_t *em = &echo_main;
- DBG ("Accept on QSession 0x%lx %u", mp->handle);
+ ECHO_LOG (1, "Accept on QSession 0x%lx %u", mp->handle);
u8 *uri = format (0, "QUIC://session/%lu", mp->handle);
u32 i;
- if (!em->first_sconnect_sent)
- {
- em->first_sconnect_sent = 1;
- quic_echo_notify_event (em, ECHO_EVT_FIRST_SCONNECT);
- }
+ quic_echo_notify_event (em, ECHO_EVT_FIRST_SCONNECT);
for (i = 0; i < em->n_stream_clients; i++)
echo_send_connect (em, uri, session_index);
}
{
u8 *ip_str;
ip_str = format (0, "%U", format_ip46_address, &mp->rmt.ip, mp->rmt.is_ip4);
- clib_warning ("Accepted session from: %s:%d", ip_str,
- clib_net_to_host_u16 (mp->rmt.port));
+ ECHO_LOG (0, "Accepted session from: %s:%d", ip_str,
+ clib_net_to_host_u16 (mp->rmt.port));
}
echo_session_t *s;
uword *p;
int rv = 0;
- DBG ("passive close session 0x%lx", mp->handle);
+ ECHO_LOG (1, "passive close session 0x%lx", mp->handle);
p = hash_get (em->session_index_by_vpp_handles, mp->handle);
if (!p)
{
uword *p;
int rv = 0;
- DBG ("Reset session 0x%lx", mp->handle);
+ ECHO_LOG (1, "Reset session 0x%lx", mp->handle);
p = hash_get (em->session_index_by_vpp_handles, mp->handle);
if (!p)
case SESSION_IO_EVT_RX:
break;
default:
- clib_warning ("unhandled event %u", e->event_type);
+ ECHO_LOG (0, "unhandled event %u", e->event_type);
}
}
handle_mq_event (e);
svm_msg_q_free_msg (em->our_event_queue, &msg);
}
- DBG ("timeout waiting for %U", format_quic_echo_state, state);
+ ECHO_LOG (1, "timeout waiting for %U", format_quic_echo_state, state);
return -1;
}
svm_msg_q_msg_t msg;
session_event_t *e;
- DBG ("Waiting for data on %u clients", em->n_clients_connected);
+ ECHO_LOG (1, "Waiting for data on %u clients", em->n_clients_connected);
while (em->n_clients_connected | em->n_quic_clients_connected)
{
int rc = svm_msg_q_sub (em->our_event_queue, &msg, SVM_Q_TIMEDWAIT, 1);
u32 n_fds = 0;
u64 segment_handle;
segment_handle = clib_net_to_host_u64 (mp->segment_handle);
- DBG ("Attached returned app %u", htons (mp->app_index));
+ ECHO_LOG (1, "Attached returned app %u", htons (mp->app_index));
if (mp->retval)
{
clib_spinlock_lock (&em->segment_handles_lock);
hash_set (em->shared_segment_handles, segment_handle, 1);
clib_spinlock_unlock (&em->segment_handles_lock);
- DBG ("Mapped segment 0x%lx", segment_handle);
+ ECHO_LOG (1, "Mapped segment 0x%lx", segment_handle);
em->state = STATE_ATTACHED;
}
clib_spinlock_lock (&em->segment_handles_lock);
hash_unset (em->shared_segment_handles, segment_handle);
clib_spinlock_unlock (&em->segment_handles_lock);
- DBG ("Unmaped segment 0x%lx", segment_handle);
+ ECHO_LOG (1, "Unmaped segment 0x%lx", segment_handle);
}
static void
clib_spinlock_lock (&em->segment_handles_lock);
hash_set (em->shared_segment_handles, segment_handle, 1);
clib_spinlock_unlock (&em->segment_handles_lock);
- DBG ("Mapped segment 0x%lx", segment_handle);
+ ECHO_LOG (1, "Mapped segment 0x%lx", segment_handle);
}
static void
return;
}
- DBG ("Got disonnected reply for session 0x%lx", mp->handle);
+ ECHO_LOG (1, "Got disonnected reply for session 0x%lx", mp->handle);
p = hash_get (em->session_index_by_vpp_handles, mp->handle);
if (!p)
{
/* retry connect */
if (mp->context == SESSION_INVALID_INDEX)
{
- DBG ("Retrying connect %s", em->uri);
+ ECHO_LOG (1, "Retrying connect %s", em->uri);
echo_send_connect (em, em->uri, SESSION_INVALID_INDEX);
}
else
{
session = pool_elt_at_index (em->sessions, mp->context);
uri = format (0, "QUIC://session/%lu", session->vpp_session_handle);
- DBG ("Retrying connect %s", uri);
+ ECHO_LOG (1, "Retrying connect %s", uri);
echo_send_connect (em, uri, mp->context);
}
}
print_usage_and_exit (void)
{
fprintf (stderr,
- "quic_echo [socket-name SOCKET] [client|server] [uri URI] [OPTIONS]\n"
+ "Usage: quic_echo [socket-name SOCKET] [client|server] [uri URI] [OPTIONS]\n"
+ "Generates traffic and assert correct teardown of the QUIC hoststack\n"
"\n"
" socket-name PATH Specify the binary socket path to connect to VPP\n"
" use-svm-api Use SVM API to connect to VPP\n"
" global-scope global-scope option\n"
" secret SECRET set namespace secret\n"
" chroot prefix PATH Use PATH as memory root path\n"
- " quic-setup OPT OPT=serverstream : Client open N connections. On each one server opens M streams\n"
- " by default : Client open N connections. On each one client opens M streams\n"
- " sclose=[Y|N|W] When a stream is done (RX & TX), send close[Y] wait for close[W] or pass[N]\n"
- " qclose=[Y|N|W] When a connection is done (RX & TX), send close[Y] wait for close[W] or pass[N]\n"
+ " quic-setup OPT OPT=serverstream : Client open N connections. \n"
+ " On each one server opens M streams\n"
+ " OPT=default : Client open N connections.\n"
+ " On each one client opens M streams\n"
+ " sclose=[Y|N|W] When a stream is done, pass[N] send[Y] or wait[W] for close\n"
+ " qclose=[Y|N|W] When a connection is done pass[N] send[Y] or wait[W] for close\n"
"\n"
- " nclients N[/M] Open N QUIC connections, each one with M streams (M defaults to 1)\n"
- " nthreads N Use N busy loop threads for data [in addition to main & msg queue]\n"
- " TX=1337[Kb|Mb|GB] Send 1337 [K|M|G]bytes, use TX=RX to reflect the data\n"
- " RX=1337[Kb|Mb|GB] Expect 1337 [K|M|G]bytes\n"
+ " time START:END Time between evts START & END, events being :\n"
+ " start - Start of the app\n"
+ " qconnect - first Connection connect sent\n"
+ " qconnected - last Connection connected\n"
+ " sconnect - first Stream connect sent\n"
+ " sconnected - last Stream got connected\n"
+ " lastbyte - Last expected byte received\n"
+ " exit - Exiting of the app\n"
+ " json Output global stats in json\n"
+ " log=N Set the log level to [0: no output, 1:errors, 2:log]\n"
"\n"
- "Default config is :\n"
- "server nclients 1/1 RX=64Kb TX=RX\n"
- "client nclients 1/1 RX=64Kb TX=64Kb\n");
+ " nclients N[/M] Open N QUIC connections, each one with M streams (M defaults to 1)\n"
+ " nthreads N Use N busy loop threads for data [in addition to main & msg queue]\n"
+ " TX=1337[Kb|Mb|GB] Send 1337 [K|M|G]bytes, use TX=RX to reflect the data\n"
+ " RX=1337[Kb|Mb|GB] Expect 1337 [K|M|G]bytes\n"
+ "\n"
+ "Default configuration is :\n"
+ " server nclients 1/1 RX=64Kb TX=RX\n"
+ " client nclients 1/1 RX=64Kb TX=64Kb\n");
exit (1);
}
;
else if (unformat (a, "RX=%U", unformat_data, &em->bytes_to_receive))
;
+ else if (unformat (a, "json"))
+ em->output_json = 1;
+ else if (unformat (a, "log=%d", &em->log_lvl))
+ ;
else
if (unformat
(a, "sclose=%U", unformat_close, &em->send_stream_disconnects))
if (connect_to_vpp (app_name) < 0)
{
svm_region_exit ();
- fformat (stderr, "ECHO-ERROR: Couldn't connect to vpe, exiting...\n");
+ ECHO_FAIL ("ECHO-ERROR: Couldn't connect to vpe, exiting...\n");
exit (1);
}
application_send_attach (em);
if (wait_for_state_change (em, STATE_ATTACHED, TIMEOUT))
{
- fformat (stderr, "ECHO-ERROR: Couldn't attach to vpp, exiting...\n");
+ ECHO_FAIL ("ECHO-ERROR: Couldn't attach to vpp, exiting...\n");
exit (1);
}
if (em->i_am_master)
else
clients_run (em);
quic_echo_notify_event (em, ECHO_EVT_EXIT);
- print_global_stats (em);
+ if (em->output_json)
+ print_global_json_stats (em);
+ else
+ print_global_stats (em);
echo_free_sessions (em);
echo_assert_test_suceeded (em);
application_detach (em);
if (wait_for_state_change (em, STATE_DETACHED, TIMEOUT))
{
- fformat (stderr, "ECHO-ERROR: Couldn't detach from vpp, exiting...\n");
+ ECHO_FAIL ("ECHO-ERROR: Couldn't detach from vpp, exiting...\n");
exit (1);
}
if (em->use_sock_api)
vl_socket_client_disconnect ();
else
vl_client_disconnect_from_vlib ();
- fformat (stdout, "Test complete !\n");
+ ECHO_LOG (0, "Test complete !\n");
exit (em->has_failed);
}
Code Review / vpp.git / commitdiff