From 5824cc52d1a000b4c4b2ed5da2f1b7761888f0cc Mon Sep 17 00:00:00 2001 From: Florin Coras Date: Tue, 20 Oct 2020 18:44:41 -0700 Subject: vcl: wait for sendto to connect if needed Type: fix Signed-off-by: Florin Coras Change-Id: I39948b046c79dea1b034619e1eaa22dd8a4997fb --- src/vcl/vppcom.c | 23 +++++++++++++++-------- 1 file changed, 15 insertions(+), 8 deletions(-) (limited to 'src/vcl') diff --git a/src/vcl/vppcom.c b/src/vcl/vppcom.c index 947bf287e2d..229a251846f 100644 --- a/src/vcl/vppcom.c +++ b/src/vcl/vppcom.c @@ -3683,21 +3683,28 @@ vppcom_session_sendto (uint32_t session_handle, void *buffer, if (ep) { - if (s->session_type != VPPCOM_PROTO_UDP - || (s->flags & VCL_SESSION_F_CONNECTED)) + if (!vcl_session_is_cl (s)) return VPPCOM_EINVAL; /* Session not connected/bound in vpp. Create it by 'connecting' it */ if (PREDICT_FALSE (s->session_state == VCL_STATE_CLOSED)) { + u32 session_index = s->session_index; + f64 timeout = vcm->cfg.session_timeout; + int rv; + vcl_send_session_connect (wrk, s); + rv = vppcom_wait_for_session_state_change (session_index, + VCL_STATE_READY, + timeout); + if (rv < 0) + return rv; + s = vcl_session_get (wrk, session_index); } - else - { - s->transport.is_ip4 = ep->is_ip4; - s->transport.rmt_port = ep->port; - vcl_ip_copy_from_ep (&s->transport.rmt_ip, ep); - } + + s->transport.is_ip4 = ep->is_ip4; + s->transport.rmt_port = ep->port; + vcl_ip_copy_from_ep (&s->transport.rmt_ip, ep); } if (flags) -- cgit 1.2.3-korg