43 u32 session_index,
u8 is_failed)
45 static u32 client_index = 0;
51 "Bapi connect errored on session %u", session_index);
61 session->is_dgram = 1;
76 static u32 client_index = 0;
89 session->is_dgram = 1;
131 u32 session_index = session->session_index;
137 rx_fifo->client_session_index = session_index;
138 tx_fifo->client_session_index = session_index;
140 session->rx_fifo = rx_fifo;
141 session->tx_fifo = tx_fifo;
144 sizeof (ip46_address_t));
145 session->transport.lcl_port = mp->
lcl_port;
155 session->is_dgram = 1;
volatile u64 accepted_session_count
teardown_stat_t clean_count
echo_session_t * sessions
#define clib_memcpy_fast(a, b, c)
static void udp_echo_disconnected_cb(session_disconnected_msg_t *mp, echo_session_t *s)
volatile connection_state_t state
static void udp_echo_connected_cb(session_connected_bundled_msg_t *mp, u32 session_index, u8 is_failed)
static void udp_echo_accepted_cb(session_accepted_msg_t *mp, echo_session_t *session)
ECHO_REGISTER_PROTO(TRANSPORT_PROTO_UDP, echo_udp_proto_cb_vft)
volatile u32 n_clients_connected
static void udp_echo_reset_cb(session_reset_msg_t *mp, echo_session_t *s)
#define ECHO_FAIL(fail, _fmt, _args...)
static void udp_echo_sent_disconnect_cb(echo_session_t *s)
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
#define SESSION_INVALID_INDEX
#define clib_atomic_sub_fetch(a, b)
void echo_notify_event(echo_main_t *em, echo_test_evt_t e)
u32 *volatile data_thread_args
struct echo_main_t::@665 uri_elts
#define uword_to_pointer(u, type)
teardown_stat_t close_count
#define clib_atomic_fetch_add(a, b)
volatile u64 bytes_to_receive
static void udp_echo_cleanup_cb(echo_session_t *s, u8 parent_died)
static void udp_echo_bound_uri_cb(session_bound_msg_t *mp, echo_session_t *session)
void echo_session_print_stats(echo_main_t *em, echo_session_t *session)
struct _svm_fifo svm_fifo_t
teardown_stat_t reset_count
void(* disconnected_cb)(session_disconnected_msg_t *mp, echo_session_t *s)