15 #ifndef __included_uri_h__ 16 #define __included_uri_h__ 24 typedef struct _vnet_app_attach_args_t
45 u64 app_event_queue_address;
49 typedef struct _vnet_app_detach_args_t
54 typedef struct _vnet_bind_args_t
68 u32 segment_name_length;
69 u64 server_event_queue_address;
73 typedef struct _vnet_unbind_args_t
83 typedef struct _vnet_connect_args
96 typedef struct _vnet_disconnect_args_t
102 typedef struct _vnet_application_add_tls_cert_args_t
108 typedef struct _vnet_application_add_tls_key_args_t
133 #define foreach_app_options_flags \ 134 _(ACCEPT_REDIRECT, "Use FIFO with redirects") \ 135 _(ADD_SEGMENT, "Add segment and signal app if needed") \ 136 _(IS_BUILTIN, "Application is builtin") \ 137 _(IS_PROXY, "Application is proxying") \ 138 _(USE_GLOBAL_SCOPE, "App can use global session scope") \ 139 _(USE_LOCAL_SCOPE, "App can use local session scope") \ 140 _(USE_MQ_FOR_CTRL_MSGS, "Use message queue for ctr msgs") \ 142 typedef enum _app_options
144 #define _(sym, str) APP_OPTIONS_##sym, 149 typedef enum _app_options_flags
151 #define _(sym, str) APP_OPTIONS_FLAGS_##sym = 1 << APP_OPTIONS_##sym, 184 #define foreach_app_session_field \ 185 _(svm_fifo_t, *rx_fifo) \ 186 _(svm_fifo_t, *tx_fifo) \ 187 _(session_type_t, session_type) \ 188 _(volatile u8, session_state) \ 189 _(u32, session_index) \ 190 _(app_session_transport_t, transport) \ 191 _(svm_msg_q_t, *vpp_evt_q) \ 196 #define _(type, name) type name; 208 u64 vpp_event_queue_address;
209 u64 server_event_queue_address;
233 u64 vpp_event_queue_address;
234 u64 client_event_queue_address;
236 u8 segment_name_length;
275 session_event_t *evt;
287 memset (app_evt->
evt, 0, sizeof (*app_evt->
evt));
288 app_evt->
evt->event_type = evt_type;
313 session_event_t *evt;
333 evt->event_type = evt_type;
348 evt->event_type = evt_type;
360 u32 max_enqueue, actual_write;
361 session_dgram_hdr_t hdr;
365 if (max_enqueue <=
sizeof (session_dgram_hdr_t))
368 max_enqueue -=
sizeof (session_dgram_hdr_t);
369 actual_write =
clib_min (len, max_enqueue);
370 hdr.data_length = actual_write;
378 ASSERT (rv ==
sizeof (hdr));
435 if (max_deq <
sizeof (session_dgram_hdr_t))
#define foreach_app_session_field
flag for dgram mode
clib_error_t * vnet_connect_uri(vnet_connect_args_t *a)
static u8 svm_msg_q_msg_is_invalid(svm_msg_q_msg_t *msg)
Check if message is invalid.
void * svm_msg_q_msg_data(svm_msg_q_t *mq, svm_msg_q_msg_t *msg)
Get data for message in queue.
static u8 svm_msg_q_ring_is_full(svm_msg_q_t *mq, u32 ring_index)
u8 is_ip4
set if uses ip4 networking
#define SESSION_CONN_HDR_LEN
static int app_send_dgram_raw(svm_fifo_t *f, app_session_transport_t *at, svm_msg_q_t *vpp_evt_q, u8 *data, u32 len, u8 noblock)
struct _vnet_connect_args vnet_connect_args_t
static int app_recv_dgram_raw(svm_fifo_t *f, u8 *buf, u32 len, app_session_transport_t *at, u8 clear_evt)
const char test_srv_key_rsa[]
const u32 test_srv_crt_rsa_len
clib_error_t * vnet_unbind(vnet_unbind_args_t *a)
static int app_send_stream(app_session_t *s, u8 *data, u32 len, u8 noblock)
void svm_fifo_overwrite_head(svm_fifo_t *f, u8 *data, u32 len)
static u32 svm_fifo_max_enqueue(svm_fifo_t *f)
struct session_disconnected_reply_msg_ session_disconnected_reply_msg_t
static int app_send_io_evt_to_vpp(svm_msg_q_t *mq, svm_fifo_t *f, u8 evt_type, u8 noblock)
Send fifo io event to vpp worker thread.
struct _vnet_application_add_tls_cert_args_t vnet_app_add_tls_cert_args_t
struct _svm_fifo svm_fifo_t
clib_error_t * vnet_connect(vnet_connect_args_t *a)
int svm_msg_q_lock_and_alloc_msg_w_ring(svm_msg_q_t *mq, u32 ring_index, u8 noblock, svm_msg_q_msg_t *msg)
Lock message queue and allocate message buffer on ring.
static void app_alloc_ctrl_evt_to_vpp(svm_msg_q_t *mq, app_session_evt_t *app_evt, u8 evt_type)
static int app_send(app_session_t *s, u8 *data, u32 len, u8 noblock)
struct session_accepted_msg_ session_accepted_msg_t
struct _vnet_disconnect_args_t vnet_disconnect_args_t
static u32 svm_fifo_max_dequeue(svm_fifo_t *f)
struct _stream_session_cb_vft session_cb_vft_t
struct _vnet_unbind_args_t vnet_unbind_args_t
int svm_fifo_enqueue_nowait(svm_fifo_t *f, u32 max_bytes, const u8 *copy_from_here)
STATIC_ASSERT(sizeof(session_accepted_reply_msg_t)<=16,"accept reply")
struct _vnet_app_attach_args_t vnet_app_attach_args_t
clib_error_t * vnet_app_add_tls_key(vnet_app_add_tls_key_args_t *a)
static int app_recv(app_session_t *s, u8 *data, u32 len)
static session_cb_vft_t session_cb_vft
struct session_accepted_reply_msg_ session_accepted_reply_msg_t
static int app_send_stream_raw(svm_fifo_t *f, svm_msg_q_t *vpp_evt_q, u8 *data, u32 len, u8 noblock)
int vnet_unbind_uri(vnet_unbind_args_t *a)
struct _session_endpoint session_endpoint_t
clib_error_t * vnet_bind(vnet_bind_args_t *a)
static session_handle_t session_handle(stream_session_t *s)
ip46_address_t rmt_ip
remote ip
static void svm_fifo_unset_event(svm_fifo_t *f)
Unsets fifo event flag.
static void svm_msg_q_wait(svm_msg_q_t *mq)
int vnet_bind_uri(vnet_bind_args_t *)
const u32 test_srv_key_rsa_len
static void app_send_ctrl_evt_to_vpp(svm_msg_q_t *mq, app_session_evt_t *app_evt)
static u8 svm_fifo_set_event(svm_fifo_t *f)
Sets fifo event flag.
static void svm_msg_q_unlock(svm_msg_q_t *mq)
Unlock message queue.
clib_error_t * vnet_application_attach(vnet_app_attach_args_t *a)
Attach application to vpp.
#define clib_memcpy(a, b, c)
struct app_session_transport_ app_session_transport_t
struct session_reset_reply_msg_ session_reset_reply_msg_t
int svm_msg_q_add(svm_msg_q_t *mq, svm_msg_q_msg_t *msg, int nowait)
Producer enqueue one message to queue.
static int app_recv_stream(app_session_t *s, u8 *buf, u32 len)
static int svm_msg_q_try_lock(svm_msg_q_t *mq)
Try locking message queue.
enum _app_options_flags app_options_flags_t
const char test_srv_crt_rsa[]
clib_error_t * vnet_app_add_tls_cert(vnet_app_add_tls_cert_args_t *a)
int vnet_disconnect_session(vnet_disconnect_args_t *a)
struct session_disconnected_msg_ session_disconnected_msg_t
void svm_msg_q_add_and_unlock(svm_msg_q_t *mq, svm_msg_q_msg_t *msg)
Producer enqueue one message to queue with mutex held.
enum _app_options app_options_t
app_attach_options_index_t
struct app_session_event_ app_session_evt_t
static int app_send_dgram(app_session_t *s, u8 *data, u32 len, u8 noblock)
struct _vnet_application_add_tls_key_args_t vnet_app_add_tls_key_args_t
int vnet_application_detach(vnet_app_detach_args_t *a)
Detach application from vpp.
u16 lcl_port
local port (network order)
struct _vnet_app_detach_args_t vnet_app_detach_args_t
struct session_connected_msg_ session_connected_msg_t
ip46_address_t lcl_ip
local ip
int svm_fifo_dequeue_drop(svm_fifo_t *f, u32 max_bytes)
struct session_reset_msg_ session_reset_msg_t
static int app_recv_stream_raw(svm_fifo_t *f, u8 *buf, u32 len, u8 clear_evt)
#define foreach_app_options_flags
static int svm_msg_q_lock(svm_msg_q_t *mq)
Lock, or block trying, the message queue.
int svm_fifo_peek(svm_fifo_t *f, u32 relative_offset, u32 max_bytes, u8 *copy_here)
static u8 svm_msg_q_is_full(svm_msg_q_t *mq)
Check if message queue is full.
int svm_fifo_dequeue_nowait(svm_fifo_t *f, u32 max_bytes, u8 *copy_here)
struct _vnet_bind_args_t vnet_bind_args_t
svm_msg_q_msg_t svm_msg_q_alloc_msg_w_ring(svm_msg_q_t *mq, u32 ring_index)
Allocate message buffer on ring.
struct _session_endpoint_extended session_endpoint_extended_t
static int app_recv_dgram(app_session_t *s, u8 *buf, u32 len)
u16 rmt_port
remote port (network order)