summaryrefslogtreecommitdiffstats
path: root/src/vnet/session-apps
diff options
context:
space:
mode:
Diffstat (limited to 'src/vnet/session-apps')
-rw-r--r--src/vnet/session-apps/echo_client.c36
-rw-r--r--src/vnet/session-apps/echo_client.h1
2 files changed, 25 insertions, 12 deletions
diff --git a/src/vnet/session-apps/echo_client.c b/src/vnet/session-apps/echo_client.c
index bcb2edf3792..edc6a2a3990 100644
--- a/src/vnet/session-apps/echo_client.c
+++ b/src/vnet/session-apps/echo_client.c
@@ -365,29 +365,38 @@ quic_echo_clients_qsession_connected_callback (u32 app_index, u32 api_context,
session_t * s, u8 is_fail)
{
echo_client_main_t *ecm = &echo_client_main;
- vnet_connect_args_t a;
+ vnet_connect_args_t *a = 0;
int rv;
u8 thread_index = vlib_get_thread_index ();
session_endpoint_cfg_t sep = SESSION_ENDPOINT_CFG_NULL;
+ u32 stream_n;
DBG ("QUIC Connection handle %d", session_handle (s));
- a.uri = (char *) ecm->connect_uri;
- parse_uri (a.uri, &sep);
+ vec_validate (a, 1);
+ a->uri = (char *) ecm->connect_uri;
+ parse_uri (a->uri, &sep);
sep.transport_opts = session_handle (s);
- sep.port = 0;
- clib_memset (&a, 0, sizeof (a));
- a.app_index = ecm->app_index;
- a.api_context = -1 - api_context;
- clib_memcpy (&a.sep_ext, &sep, sizeof (sep));
+ sep.port = 0; /* QUIC: create a stream flag */
- if ((rv = vnet_connect (&a)))
+ for (stream_n = 0; stream_n < ecm->quic_streams; stream_n++)
{
- clib_error ("Session opening failed: %d", rv);
- return -1;
+ clib_memset (a, 0, sizeof (a));
+ a->app_index = ecm->app_index;
+ a->api_context = -1 - api_context;
+ clib_memcpy (&a->sep_ext, &sep, sizeof (sep));
+
+ DBG ("QUIC opening stream %d", stream_n);
+ if ((rv = vnet_connect (a)))
+ {
+ clib_error ("Stream session %d opening failed: %d", stream_n, rv);
+ return -1;
+ }
+ DBG ("QUIC stream %d connected", stream_n);
}
vec_add1 (ecm->quic_session_index_by_thread[thread_index],
session_handle (s));
+ vec_free (a);
return 0;
}
@@ -751,6 +760,7 @@ echo_clients_command_fn (vlib_main_t * vm,
session_endpoint_cfg_t sep = SESSION_ENDPOINT_CFG_NULL;
int rv;
+ ecm->quic_streams = 1;
ecm->bytes_to_send = 8192;
ecm->no_return = 0;
ecm->fifo_size = 64 << 10;
@@ -775,6 +785,8 @@ echo_clients_command_fn (vlib_main_t * vm,
;
else if (unformat (input, "nclients %d", &n_clients))
;
+ else if (unformat (input, "quic-streams %d", &ecm->quic_streams))
+ ;
else if (unformat (input, "mbytes %lld", &tmp))
ecm->bytes_to_send = tmp << 20;
else if (unformat (input, "gbytes %lld", &tmp))
@@ -841,7 +853,7 @@ echo_clients_command_fn (vlib_main_t * vm,
ecm->ready_connections = 0;
- ecm->expected_connections = n_clients;
+ ecm->expected_connections = n_clients * ecm->quic_streams;
ecm->rx_total = 0;
ecm->tx_total = 0;
diff --git a/src/vnet/session-apps/echo_client.h b/src/vnet/session-apps/echo_client.h
index 68a5921f753..34cf0bd4764 100644
--- a/src/vnet/session-apps/echo_client.h
+++ b/src/vnet/session-apps/echo_client.h
@@ -65,6 +65,7 @@ typedef struct
u32 tls_engine; /**< TLS engine mbedtls/openssl */
u8 is_dgram;
u32 no_copy; /**< Don't memcpy data to tx fifo */
+ u32 quic_streams; /**< QUIC streams per connection */
/*
* Test state variables