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;
130 u32 session_index = session->session_index;
137 ECHO_FAIL (ECHO_FAIL_ACCEPTED_WAIT_FOR_SEG_ALLOC,
138 "accepted wait_for_segment_allocation errored");
144 sizeof (ip46_address_t));
145 session->transport.lcl_port = mp->
lcl_port;
154 session->is_dgram = 1;
volatile u64 accepted_session_count
teardown_stat_t clean_count
echo_session_t * sessions
struct echo_main_t::@681 uri_elts
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
static_always_inline void * clib_memcpy_fast(void *restrict dst, const void *restrict src, size_t n)
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)
int echo_attach_session(uword segment_handle, uword rxf_offset, uword txf_offset, uword mq_offset, echo_session_t *s)
void echo_session_print_stats(echo_main_t *em, echo_session_t *session)
teardown_stat_t reset_count
void(* disconnected_cb)(session_disconnected_msg_t *mp, echo_session_t *s)