vcl: remove accept state and rename connect to ready 69/29469/3
authorFlorin Coras <fcoras@cisco.com>
Thu, 15 Oct 2020 17:54:47 +0000 (10:54 -0700)
committerFlorin Coras <florin.coras@gmail.com>
Fri, 16 Oct 2020 18:35:40 +0000 (18:35 +0000)
Type: refactor

Signed-off-by: Florin Coras <fcoras@cisco.com>
Change-Id: I57fcc6f9c154a6f83e0d59873b76c2e380e6f90a

src/vcl/vcl_private.h
src/vcl/vppcom.c

index e03804f..8e4c229 100644 (file)
@@ -65,9 +65,8 @@ typedef enum
 typedef enum vcl_session_state_
 {
   VCL_STATE_CLOSED,
-  VCL_STATE_CONNECT,
   VCL_STATE_LISTEN,
-  VCL_STATE_ACCEPT,
+  VCL_STATE_READY,
   VCL_STATE_VPP_CLOSING,
   VCL_STATE_DISCONNECT,
   VCL_STATE_DETACHED,
@@ -557,8 +556,7 @@ vcl_session_is_cl (vcl_session_t * s)
 static inline u8
 vcl_session_is_ready (vcl_session_t * s)
 {
-  return (s->session_state == VCL_STATE_ACCEPT
-         || s->session_state == VCL_STATE_CONNECT
+  return (s->session_state == VCL_STATE_READY
          || s->session_state == VCL_STATE_VPP_CLOSING);
 }
 
index ca20ffc..bb59358 100644 (file)
@@ -63,14 +63,11 @@ vppcom_session_state_str (vcl_session_state_t state)
     case VCL_STATE_CLOSED:
       st = "STATE_CLOSED";
       break;
-    case VCL_STATE_CONNECT:
-      st = "STATE_CONNECT";
-      break;
     case VCL_STATE_LISTEN:
       st = "STATE_LISTEN";
       break;
-    case VCL_STATE_ACCEPT:
-      st = "STATE_ACCEPT";
+    case VCL_STATE_READY:
+      st = "STATE_READY";
       break;
     case VCL_STATE_VPP_CLOSING:
       st = "STATE_VPP_CLOSING";
@@ -418,7 +415,7 @@ vcl_session_accepted_handler (vcl_worker_t * wrk, session_accepted_msg_t * mp,
   session->rx_fifo = rx_fifo;
   session->tx_fifo = tx_fifo;
 
-  session->session_state = VCL_STATE_ACCEPT;
+  session->session_state = VCL_STATE_READY;
   session->transport.rmt_port = mp->rmt.port;
   session->transport.is_ip4 = mp->rmt.is_ip4;
   clib_memcpy_fast (&session->transport.rmt_ip, &mp->rmt.ip,
@@ -527,7 +524,7 @@ vcl_session_connected_handler (vcl_worker_t * wrk,
       && session->session_state == VCL_STATE_CLOSED)
     vcl_send_session_disconnect (wrk, session);
   else
-    session->session_state = VCL_STATE_CONNECT;
+    session->session_state = VCL_STATE_READY;
 
   /* Add it to lookup table */
   vcl_session_table_add_vpp_handle (wrk, mp->handle, session_index);
@@ -999,7 +996,7 @@ vppcom_wait_for_session_state_change (u32 session_index,
        {
          return VPPCOM_EBADFD;
        }
-      if (session->session_state & state)
+      if (session->session_state == state)
        {
          return VPPCOM_OK;
        }
@@ -1716,7 +1713,7 @@ vppcom_session_connect (uint32_t session_handle, vppcom_endpt_t * server_ep)
   if (VCL_SESS_ATTR_TEST (session->attr, VCL_SESS_ATTR_NONBLOCK))
     {
       /* State set to STATE_UPDATED to ensure the session is not assumed
-       * to be open and to also allow the app to close it prior to vpp's
+       * to be ready and to also allow the app to close it prior to vpp's
        * connected reply. */
       session->session_state = VCL_STATE_UPDATED;
       return VPPCOM_EINPROGRESS;
@@ -1725,7 +1722,7 @@ vppcom_session_connect (uint32_t session_handle, vppcom_endpt_t * server_ep)
   /*
    * Wait for reply from vpp if blocking
    */
-  rv = vppcom_wait_for_session_state_change (session_index, VCL_STATE_CONNECT,
+  rv = vppcom_wait_for_session_state_change (session_index, VCL_STATE_READY,
                                             vcm->cfg.session_timeout);
 
   session = vcl_session_get (wrk, session_index);
@@ -1784,7 +1781,7 @@ vppcom_session_stream_connect (uint32_t session_handle,
    * Send connect request and wait for reply from vpp
    */
   vcl_send_session_connect (wrk, session);
-  rv = vppcom_wait_for_session_state_change (session_index, VCL_STATE_CONNECT,
+  rv = vppcom_wait_for_session_state_change (session_index, VCL_STATE_READY,
                                             vcm->cfg.session_timeout);
 
   session->listener_index = parent_session_index;