X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fvcl%2Fvppcom.c;h=229a251846f10f3c1dbb54bb7d9a83324cb6f22e;hb=5824cc52d1a000b4c4b2ed5da2f1b7761888f0cc;hp=947bf287e2d23dbe9d28cc202f6083c6ed2828a9;hpb=5980e539d424469fc2869c94f709b8b24d7bc077;p=vpp.git

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)