diff options
author | Florin Coras <fcoras@cisco.com> | 2020-10-14 16:35:58 -0700 |
---|---|---|
committer | Florin Coras <florin.coras@gmail.com> | 2020-10-15 16:59:55 +0000 |
commit | c127d5ad0a9c09b25facabf28288324f125701ad (patch) | |
tree | 25d310d446781014c11c44a4055f6d369e227b49 /src/vcl/vcl_private.h | |
parent | e8346c8fd49d611d4093f62e414c15470254d436 (diff) |
vcl: refactor session state enum
Only allow one state instead of using flags.
Type: improvement
Signed-off-by: Florin Coras <fcoras@cisco.com>
Change-Id: I08ffccbf8c3f6e2f61533996bb36c799cbc931e7
Diffstat (limited to 'src/vcl/vcl_private.h')
-rw-r--r-- | src/vcl/vcl_private.h | 65 |
1 files changed, 35 insertions, 30 deletions
diff --git a/src/vcl/vcl_private.h b/src/vcl/vcl_private.h index 89151faa316..e03804f6c11 100644 --- a/src/vcl/vcl_private.h +++ b/src/vcl/vcl_private.h @@ -62,23 +62,19 @@ typedef enum STATE_APP_READY } vcl_bapi_app_state_t; -typedef enum -{ - STATE_CLOSED = 0, - STATE_CONNECT = 0x01, - STATE_LISTEN = 0x02, - STATE_ACCEPT = 0x04, - STATE_VPP_CLOSING = 0x08, - STATE_DISCONNECT = 0x10, - STATE_DETACHED = 0x20, - STATE_UPDATED = 0x40, - STATE_LISTEN_NO_MQ = 0x80, +typedef enum vcl_session_state_ +{ + VCL_STATE_CLOSED, + VCL_STATE_CONNECT, + VCL_STATE_LISTEN, + VCL_STATE_ACCEPT, + VCL_STATE_VPP_CLOSING, + VCL_STATE_DISCONNECT, + VCL_STATE_DETACHED, + VCL_STATE_UPDATED, + VCL_STATE_LISTEN_NO_MQ, } vcl_session_state_t; -#define SERVER_STATE_OPEN (STATE_ACCEPT|STATE_VPP_CLOSING) -#define CLIENT_STATE_OPEN (STATE_CONNECT|STATE_VPP_CLOSING) -#define STATE_OPEN (SERVER_STATE_OPEN | CLIENT_STATE_OPEN) - typedef struct epoll_event vppcom_epoll_event_t; typedef struct @@ -509,18 +505,18 @@ vcl_session_is_connectable_listener (vcl_worker_t * wrk, if (session->session_type != VPPCOM_PROTO_QUIC) return 0; if (session->listener_index == VCL_INVALID_SESSION_INDEX) - return !(session->session_state & STATE_LISTEN); + return !(session->session_state == VCL_STATE_LISTEN); ls = vcl_session_get_w_handle (wrk, session->listener_index); if (!ls) return VPPCOM_EBADFD; - return ls->session_state & STATE_LISTEN; + return ls->session_state == VCL_STATE_LISTEN; } static inline vcl_session_t * vcl_session_table_lookup_listener (vcl_worker_t * wrk, u64 handle) { uword *p; - vcl_session_t *session; + vcl_session_t *s; p = hash_get (wrk->session_index_by_vpp_handles, handle); if (!p) @@ -529,16 +525,17 @@ vcl_session_table_lookup_listener (vcl_worker_t * wrk, u64 handle) " %llx", handle); return 0; } - session = vcl_session_get (wrk, p[0]); - if (!session) + s = vcl_session_get (wrk, p[0]); + if (!s) { VDBG (1, "invalid listen session index (%u)", p[0]); return 0; } - ASSERT ((session->session_state & (STATE_LISTEN | STATE_LISTEN_NO_MQ)) || - vcl_session_is_connectable_listener (wrk, session)); - return session; + ASSERT (s->session_state == VCL_STATE_LISTEN + || s->session_state == VCL_STATE_LISTEN_NO_MQ + || vcl_session_is_connectable_listener (wrk, s)); + return s; } const char *vppcom_session_state_str (vcl_session_state_t state); @@ -558,37 +555,45 @@ 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 + || s->session_state == VCL_STATE_VPP_CLOSING); +} + +static inline u8 vcl_session_is_open (vcl_session_t * s) { - return ((s->session_state & STATE_OPEN) - || (s->session_state == STATE_LISTEN + return ((vcl_session_is_ready (s)) + || (s->session_state == VCL_STATE_LISTEN && s->session_type == VPPCOM_PROTO_UDP)); } static inline u8 vcl_session_is_closing (vcl_session_t * s) { - return (s->session_state == STATE_VPP_CLOSING - || s->session_state == STATE_DISCONNECT); + return (s->session_state == VCL_STATE_VPP_CLOSING + || s->session_state == VCL_STATE_DISCONNECT); } static inline u8 vcl_session_is_closed (vcl_session_t * s) { - return (!s || (s->session_state == STATE_CLOSED)); + return (!s || (s->session_state == VCL_STATE_CLOSED)); } static inline int vcl_session_closing_error (vcl_session_t * s) { /* Return 0 on closing sockets */ - return s->session_state == STATE_DISCONNECT ? VPPCOM_ECONNRESET : 0; + return s->session_state == VCL_STATE_DISCONNECT ? VPPCOM_ECONNRESET : 0; } static inline int vcl_session_closed_error (vcl_session_t * s) { - return s->session_state == STATE_DISCONNECT + return s->session_state == VCL_STATE_DISCONNECT ? VPPCOM_ECONNRESET : VPPCOM_ENOTCONN; } |