16 #ifndef SRC_VNET_SESSION_SESSION_TYPES_H_ 17 #define SRC_VNET_SESSION_SESSION_TYPES_H_ 22 #define SESSION_INVALID_INDEX ((u32)~0) 23 #define SESSION_INVALID_HANDLE ((u64)~0) 24 #define SESSION_CTRL_MSG_MAX_SIZE 84 26 #define foreach_session_endpoint_fields \ 27 foreach_transport_endpoint_cfg_fields \ 28 _(u8, transport_proto) \ 30 typedef struct _session_endpoint
32 #define _(type, name) type name; 37 typedef struct _session_endpoint_cfg
39 #define _(type, name) type name; 53 #define SESSION_IP46_ZERO \ 60 #define TRANSPORT_ENDPOINT_NULL \ 62 .sw_if_index = ENDPOINT_INVALID_INDEX, \ 63 .ip = SESSION_IP46_ZERO, \ 64 .fib_index = ENDPOINT_INVALID_INDEX, \ 68 #define SESSION_ENDPOINT_NULL \ 70 .sw_if_index = ENDPOINT_INVALID_INDEX, \ 71 .ip = SESSION_IP46_ZERO, \ 72 .fib_index = ENDPOINT_INVALID_INDEX, \ 75 .peer = TRANSPORT_ENDPOINT_NULL, \ 76 .transport_proto = 0, \ 78 #define SESSION_ENDPOINT_CFG_NULL \ 80 .sw_if_index = ENDPOINT_INVALID_INDEX, \ 81 .ip = SESSION_IP46_ZERO, \ 82 .fib_index = ENDPOINT_INVALID_INDEX, \ 85 .peer = TRANSPORT_ENDPOINT_NULL, \ 86 .transport_proto = 0, \ 87 .app_wrk_index = ENDPOINT_INVALID_INDEX, \ 88 .opaque = ENDPOINT_INVALID_INDEX, \ 90 .parent_handle = SESSION_INVALID_HANDLE, \ 94 #define session_endpoint_to_transport(_sep) ((transport_endpoint_t *)_sep) 95 #define session_endpoint_to_transport_cfg(_sep) \ 96 ((transport_endpoint_cfg_t *)_sep) 129 #define foreach_session_state \ 130 _(CREATED, "created") \ 131 _(LISTENING, "listening") \ 132 _(CONNECTING, "connecting") \ 133 _(ACCEPTING, "accepting") \ 135 _(OPENED, "opened") \ 136 _(TRANSPORT_CLOSING, "transport-closing") \ 137 _(CLOSING, "closing") \ 138 _(APP_CLOSED, "app-closed") \ 139 _(TRANSPORT_CLOSED, "transport-closed") \ 140 _(CLOSED, "closed") \ 141 _(TRANSPORT_DELETED, "transport-deleted") \ 145 #define _(sym, str) SESSION_STATE_ ## sym, 151 #define foreach_session_flag \ 152 _(RX_EVT, "rx-event") \ 154 _(CUSTOM_TX, "custom-tx") \ 155 _(IS_MIGRATING, "migrating") \ 156 _(UNIDIRECTIONAL, "unidirectional") \ 160 #define _(sym, str) SESSION_F_BIT_ ## sym, 168 #define _(sym, str) SESSION_F_ ## sym = 1 << SESSION_F_BIT_ ## sym, 221 return (proto << 1 | is_ip4);
286 return handle & 0xFFFFFFFF;
303 static inline session_handle_t
306 return (((
u64) thread_index << 32) | (
u64) session_index);
341 #define foreach_session_ctrl_evt \ 343 _(LISTEN_URI, listen_uri) \ 345 _(UNLISTEN, unlisten) \ 346 _(UNLISTEN_REPLY, unlisten_reply) \ 347 _(ACCEPTED, accepted) \ 348 _(ACCEPTED_REPLY, accepted_reply) \ 349 _(CONNECT, connect) \ 350 _(CONNECT_URI, connect_uri) \ 351 _(CONNECTED, connected) \ 352 _(DISCONNECT, disconnect) \ 353 _(DISCONNECTED, disconnected) \ 354 _(DISCONNECTED_REPLY, disconnected_reply) \ 355 _(RESET_REPLY, reset_reply) \ 356 _(REQ_WORKER_UPDATE, req_worker_update) \ 357 _(WORKER_UPDATE, worker_update) \ 358 _(WORKER_UPDATE_REPLY, worker_update_reply) \ 359 _(APP_DETACH, app_detach) \ 360 _(APP_ADD_SEGMENT, app_add_segment) \ 361 _(APP_DEL_SEGMENT, app_del_segment) \ 364 #define FIFO_EVENT_APP_RX SESSION_IO_EVT_RX 365 #define FIFO_EVENT_APP_TX SESSION_IO_EVT_TX 366 #define FIFO_EVENT_DISCONNECT SESSION_CTRL_EVT_CLOSE 367 #define FIFO_EVENT_BUILTIN_RX SESSION_IO_EVT_BUILTIN_RX 368 #define FIFO_EVENT_BUILTIN_TX SESSION_IO_EVT_BUILTIN_TX 398 } __clib_packed session_event_t;
400 #define SESSION_MSG_NULL { } 419 #define SESSION_CONN_ID_LEN 37 420 #define SESSION_CONN_HDR_LEN 45 423 "session conn id wrong length");
u32 al_index
App listener index in app's listener pool if a listener.
u32 connection_index
Index of the transport connection associated to the session.
u8 pad[3]
log2 (size of the packing page block)
#define CLIB_CACHE_LINE_ALIGN_MARK(mark)
struct session_ session_t
session_type_t session_type
Type built from transport and network protocol types.
static u8 session_tx_is_dgram(session_t *s)
u32 session_index
Index in thread pool where session was allocated.
svm_fifo_t * rx_fifo
Pointers to rx/tx buffers.
static transport_proto_t session_get_transport_proto(session_t *s)
transport_tx_fn_type_t transport_protocol_tx_fn_type(transport_proto_t tp)
static u8 session_endpoint_fib_proto(session_endpoint_t *sep)
static void session_parse_handle(session_handle_t handle, u32 *index, u32 *thread_index)
enum fib_protocol_t_ fib_protocol_t
Protocol Type.
static session_handle_t session_handle(session_t *s)
struct _svm_fifo svm_fifo_t
struct _session_endpoint_cfg session_endpoint_cfg_t
static session_type_t session_type_from_proto_and_ip(transport_proto_t proto, u8 is_ip4)
static transport_tx_fn_type_t session_transport_tx_fn_type(session_t *s)
transport_service_type_t transport_protocol_service_type(transport_proto_t tp)
u32 app_index
Index of application that owns the listener.
#define SESSION_CONN_ID_LEN
enum session_flags_ session_flags_t
enum transport_service_type_ transport_service_type_t
session_handle_t listener_handle
Parent listener session index if the result of an accept.
#define foreach_session_endpoint_fields
static transport_proto_t session_type_transport_proto(session_type_t st)
static u32 session_thread_from_handle(session_handle_t handle)
static u32 session_index_from_handle(session_handle_t handle)
#define foreach_session_flag
static session_handle_t session_make_handle(u32 session_index, u32 thread_index)
static fib_protocol_t session_get_fib_proto(session_t *s)
#define foreach_session_state
STATIC_ASSERT(sizeof(session_dgram_hdr_t)==(SESSION_CONN_ID_LEN+8), "session conn id wrong length")
enum _transport_proto transport_proto_t
u8 thread_index
Index of the thread that allocated the session.
u8 ip_is_zero(ip46_address_t *ip46_address, u8 is_ip4)
static u8 session_type_is_ip4(session_type_t st)
volatile u8 session_state
State in session layer state machine.
u32 opaque
Opaque, for general use.
static u8 session_endpoint_is_zero(session_endpoint_t *sep)
u8 ip_is_local_host(ip46_address_t *ip46_address, u8 is_ip4)
enum session_flags_bits_ session_flag_bits_t
static u8 session_has_transport(session_t *s)
u32 app_wrk_index
Index of the app worker that owns the session.
static u8 session_endpoint_is_local(session_endpoint_t *sep)
struct _session_endpoint session_endpoint_t
struct session_dgram_pre_hdr_ session_dgram_pre_hdr_t
static transport_service_type_t session_transport_service_type(session_t *s)
enum transport_dequeue_type_ transport_tx_fn_type_t
struct session_dgram_header_ session_dgram_hdr_t