|
static int | session_send_evt_to_thread (void *data, void *args, u32 thread_index, session_evt_type_t evt_type) |
|
int | session_send_io_evt_to_thread (svm_fifo_t *f, session_evt_type_t evt_type) |
|
int | session_send_io_evt_to_thread_custom (void *data, u32 thread_index, session_evt_type_t evt_type) |
|
int | session_send_ctrl_evt_to_thread (session_t *s, session_evt_type_t evt_type) |
|
void | session_send_rpc_evt_to_thread_force (u32 thread_index, void *fp, void *rpc_args) |
|
void | session_send_rpc_evt_to_thread (u32 thread_index, void *fp, void *rpc_args) |
|
void | session_add_self_custom_tx_evt (transport_connection_t *tc, u8 has_prio) |
|
void | sesssion_reschedule_tx (transport_connection_t *tc) |
|
static void | session_program_transport_ctrl_evt (session_t *s, session_evt_type_t evt) |
|
session_t * | session_alloc (u32 thread_index) |
|
void | session_free (session_t *s) |
|
u8 | session_is_valid (u32 si, u8 thread_index) |
|
static void | session_cleanup_notify (session_t *s, session_cleanup_ntf_t ntf) |
|
void | session_free_w_fifos (session_t *s) |
|
static void | session_delete (session_t *s) |
| Cleans up session and lookup table. More...
|
|
void | session_cleanup_half_open (transport_proto_t tp, session_handle_t ho_handle) |
|
void | session_half_open_delete_notify (transport_proto_t tp, session_handle_t ho_handle) |
|
session_t * | session_alloc_for_connection (transport_connection_t *tc) |
|
static void | session_enqueue_discard_chain_bytes (vlib_main_t *vm, vlib_buffer_t *b, vlib_buffer_t **chain_b, u32 n_bytes_to_drop) |
| Discards bytes from buffer chain. More...
|
|
static int | session_enqueue_chain_tail (session_t *s, vlib_buffer_t *b, u32 offset, u8 is_in_order) |
| Enqueue buffer chain tail. More...
|
|
void | session_fifo_tuning (session_t *s, svm_fifo_t *f, session_ft_action_t act, u32 len) |
|
int | session_enqueue_stream_connection (transport_connection_t *tc, vlib_buffer_t *b, u32 offset, u8 queue_event, u8 is_in_order) |
|
int | session_enqueue_dgram_connection (session_t *s, session_dgram_hdr_t *hdr, vlib_buffer_t *b, u8 proto, u8 queue_event) |
|
int | session_tx_fifo_peek_bytes (transport_connection_t *tc, u8 *buffer, u32 offset, u32 max_bytes) |
|
u32 | session_tx_fifo_dequeue_drop (transport_connection_t *tc, u32 max_bytes) |
|
static int | session_notify_subscribers (u32 app_index, session_t *s, svm_fifo_t *f, session_evt_type_t evt_type) |
|
static int | session_enqueue_notify_inline (session_t *s) |
| Notify session peer that new data has been enqueued. More...
|
|
int | session_enqueue_notify (session_t *s) |
|
static void | session_enqueue_notify_rpc (void *arg) |
|
void | session_enqueue_notify_thread (session_handle_t sh) |
| Like session_enqueue_notify, but can be called from a thread that does not own the session. More...
|
|
int | session_dequeue_notify (session_t *s) |
|
int | session_main_flush_enqueue_events (u8 transport_proto, u32 thread_index) |
| Flushes queue of sessions that are to be notified of new data enqueued events. More...
|
|
int | session_main_flush_all_enqueue_events (u8 transport_proto) |
|
int | session_stream_connect_notify (transport_connection_t *tc, session_error_t err) |
|
static void | session_switch_pool_reply (void *arg) |
|
static void | session_switch_pool (void *cb_args) |
| Notify old thread of the session pool switch. More...
|
|
int | session_dgram_connect_notify (transport_connection_t *tc, u32 old_thread_index, session_t **new_session) |
| Move dgram session to the right thread. More...
|
|
void | session_transport_closing_notify (transport_connection_t *tc) |
| Notification from transport that connection is being closed. More...
|
|
void | session_transport_delete_notify (transport_connection_t *tc) |
| Notification from transport that connection is being deleted. More...
|
|
void | session_transport_closed_notify (transport_connection_t *tc) |
| Notification from transport that it is closed. More...
|
|
void | session_transport_reset_notify (transport_connection_t *tc) |
| Notify application that connection has been reset. More...
|
|
int | session_stream_accept_notify (transport_connection_t *tc) |
|
int | session_stream_accept (transport_connection_t *tc, u32 listener_index, u32 thread_index, u8 notify) |
| Accept a stream session. More...
|
|
int | session_dgram_accept (transport_connection_t *tc, u32 listener_index, u32 thread_index) |
|
int | session_open_cl (u32 app_wrk_index, session_endpoint_t *rmt, u32 opaque) |
|
int | session_open_vc (u32 app_wrk_index, session_endpoint_t *rmt, u32 opaque) |
|
int | session_open_app (u32 app_wrk_index, session_endpoint_t *rmt, u32 opaque) |
|
int | session_open (u32 app_wrk_index, session_endpoint_t *rmt, u32 opaque) |
| Ask transport to open connection to remote transport endpoint. More...
|
|
int | session_listen (session_t *ls, session_endpoint_cfg_t *sep) |
| Ask transport to listen on session endpoint. More...
|
|
int | session_stop_listen (session_t *s) |
| Ask transport to stop listening on local transport endpoint. More...
|
|
void | session_close (session_t *s) |
| Initialize session closing procedure. More...
|
|
void | session_reset (session_t *s) |
| Force a close without waiting for data to be flushed. More...
|
|
void | session_transport_close (session_t *s) |
| Notify transport the session can be disconnected. More...
|
|
void | session_transport_reset (session_t *s) |
| Force transport close. More...
|
|
void | session_transport_cleanup (session_t *s) |
| Cleanup transport and session state. More...
|
|
void | session_vpp_event_queues_allocate (session_main_t *smm) |
| Allocate event queues in the shared-memory segment. More...
|
|
ssvm_private_t * | session_main_get_evt_q_segment (void) |
|
u64 | session_segment_handle (session_t *s) |
|
void | session_register_transport (transport_proto_t transport_proto, const transport_proto_vft_t *vft, u8 is_ip4, u32 output_node) |
| Initialize session layer for given transport proto and ip version. More...
|
|
transport_proto_t | session_add_transport_proto (void) |
|
transport_connection_t * | session_get_transport (session_t *s) |
|
void | session_get_endpoint (session_t *s, transport_endpoint_t *tep, u8 is_lcl) |
|
transport_connection_t * | listen_session_get_transport (session_t *s) |
|
void | session_queue_run_on_main_thread (vlib_main_t *vm) |
|
static clib_error_t * | session_manager_main_enable (vlib_main_t *vm) |
|
static void | session_manager_main_disable (vlib_main_t *vm) |
|
void | session_node_enable_disable (u8 is_en) |
|
clib_error_t * | vnet_session_enable_disable (vlib_main_t *vm, u8 is_en) |
|
clib_error_t * | session_main_init (vlib_main_t *vm) |
|
static clib_error_t * | session_main_loop_init (vlib_main_t *vm) |
|
static clib_error_t * | session_config_fn (vlib_main_t *vm, unformat_input_t *input) |
|
Session and session manager.
Definition in file session.c.