diff options
author | Nathan Skrzypczak <nathan.skrzypczak@gmail.com> | 2019-11-22 11:26:19 +0100 |
---|---|---|
committer | Dave Wallace <dwallacelf@gmail.com> | 2019-11-22 21:08:19 +0000 |
commit | b2fce36c8ebd19bd9a60b06988ce753d93e59d81 (patch) | |
tree | de175c7b7201eed8db53986d7224700e2616d1e5 /src/plugins/hs_apps/sapi/vpp_echo_proto_quic.c | |
parent | 952a7b8b74be7fd237e6c0ccfe423876aa7e7b3e (diff) |
hsa: Improve for mq-intensive
Type: feature
* Remove the retry mechanism in case of failed connect
* Limit the number of simultaneous connects (default
to mqsize / 2)
Change-Id: I7a0ed2e349ee3e8ca71639c2a2ec4cdf84f5c13e
Signed-off-by: Nathan Skrzypczak <nathan.skrzypczak@gmail.com>
Diffstat (limited to 'src/plugins/hs_apps/sapi/vpp_echo_proto_quic.c')
-rw-r--r-- | src/plugins/hs_apps/sapi/vpp_echo_proto_quic.c | 26 |
1 files changed, 4 insertions, 22 deletions
diff --git a/src/plugins/hs_apps/sapi/vpp_echo_proto_quic.c b/src/plugins/hs_apps/sapi/vpp_echo_proto_quic.c index bd7903bb771..d20bacb2a5d 100644 --- a/src/plugins/hs_apps/sapi/vpp_echo_proto_quic.c +++ b/src/plugins/hs_apps/sapi/vpp_echo_proto_quic.c @@ -299,32 +299,14 @@ quic_echo_on_connected (session_connected_msg_t * mp, u32 session_index) } static void -quic_echo_retry_connect (u32 session_index) -{ - /* retry connect */ - echo_session_t *session; - echo_main_t *em = &echo_main; - if (session_index == SESSION_INVALID_INDEX) - { - ECHO_LOG (1, "Retrying Qsession connect"); - echo_send_rpc (em, echo_send_connect, (void *) SESSION_INVALID_HANDLE, - SESSION_INVALID_INDEX); - } - else - { - session = pool_elt_at_index (em->sessions, session_index); - ECHO_LOG (1, "Retrying connect %U", echo_format_session, session); - echo_send_rpc (em, echo_send_connect, - (void *) session->vpp_session_handle, session_index); - } -} - -static void quic_echo_connected_cb (session_connected_bundled_msg_t * mp, u32 session_index, u8 is_failed) { if (is_failed) - return quic_echo_retry_connect (session_index); + { + ECHO_FAIL (ECHO_FAIL_QUIC_WRONG_CONNECT, "Echo connect failed"); + return; + } return quic_echo_on_connected ((session_connected_msg_t *) mp, session_index); } |