Go to the source code of this file.
|
static void | echo_session_prealloc (echo_main_t *em) |
|
static void | echo_assert_test_suceeded (echo_main_t *em) |
|
static void | echo_session_dequeue_notify (echo_session_t *s) |
|
static void | stop_signal (int signum) |
|
int | connect_to_vpp (char *name) |
|
static void | print_global_json_stats (echo_main_t *em) |
|
static void | print_global_stats (echo_main_t *em) |
|
void | echo_update_count_on_session_close (echo_main_t *em, echo_session_t *s) |
|
static void | echo_free_sessions (echo_main_t *em) |
|
static void | test_recv_bytes (echo_main_t *em, echo_session_t *s, u8 *rx_buf, u32 n_read) |
|
static int | recv_data_chunk (echo_main_t *em, echo_session_t *s, u8 *rx_buf) |
|
static int | send_data_chunk (echo_session_t *s, u8 *tx_buf, int offset, int len) |
|
static int | mirror_data_chunk (echo_main_t *em, echo_session_t *s, u8 *tx_buf, u64 len) |
|
static void | echo_check_closed_listener (echo_main_t *em, echo_session_t *s) |
|
static void | echo_handle_data (echo_main_t *em, echo_session_t *s, u8 *rx_buf) |
|
static void * | echo_data_thread_fn (void *arg) |
|
static void | session_unlisten_handler (session_unlisten_reply_msg_t *mp) |
|
static void | session_bound_handler (session_bound_msg_t *mp) |
|
static int | echo_segment_is_not_mapped (u64 segment_handle) |
|
static void | session_accepted_handler (session_accepted_msg_t *mp) |
|
static void | session_connected_handler (session_connected_msg_t *mp) |
|
static void | session_disconnected_handler (session_disconnected_msg_t *mp) |
|
static void | session_reset_handler (session_reset_msg_t *mp) |
|
static void | add_segment_handler (session_app_add_segment_msg_t *mp) |
|
static void | del_segment_handler (session_app_del_segment_msg_t *mp) |
|
static void | handle_mq_event (session_event_t *e) |
|
static void | echo_process_rpcs (echo_main_t *em) |
|
static void | echo_print_periodic_stats (echo_main_t *em) |
|
static void * | echo_mq_thread_fn (void *arg) |
|
static void | echo_cycle_ip (echo_main_t *em, ip46_address_t *ip, ip46_address_t *src_ip, u32 i) |
|
static void | clients_run (echo_main_t *em) |
|
static void | server_run (echo_main_t *em) |
|
static void | print_usage_and_exit (void) |
|
static int | echo_process_each_proto_opts (unformat_input_t *a) |
|
static void | echo_set_each_proto_defaults_before_opts (echo_main_t *em) |
|
void | echo_process_opts (int argc, char **argv) |
|
void | echo_process_uri (echo_main_t *em) |
|
static void __clib_constructor | vpp_echo_init () |
|
int | main (int argc, char **argv) |
|
◆ add_segment_handler()
◆ clients_run()
◆ connect_to_vpp()
int connect_to_vpp |
( |
char * |
name | ) |
|
◆ del_segment_handler()
◆ echo_assert_test_suceeded()
static void echo_assert_test_suceeded |
( |
echo_main_t * |
em | ) |
|
|
static |
◆ echo_check_closed_listener()
◆ echo_cycle_ip()
static void echo_cycle_ip |
( |
echo_main_t * |
em, |
|
|
ip46_address_t * |
ip, |
|
|
ip46_address_t * |
src_ip, |
|
|
u32 |
i |
|
) |
| |
|
inlinestatic |
◆ echo_data_thread_fn()
static void* echo_data_thread_fn |
( |
void * |
arg | ) |
|
|
static |
◆ echo_free_sessions()
◆ echo_handle_data()
◆ echo_mq_thread_fn()
static void* echo_mq_thread_fn |
( |
void * |
arg | ) |
|
|
static |
◆ echo_print_periodic_stats()
static void echo_print_periodic_stats |
( |
echo_main_t * |
em | ) |
|
|
inlinestatic |
◆ echo_process_each_proto_opts()
◆ echo_process_opts()
void echo_process_opts |
( |
int |
argc, |
|
|
char ** |
argv |
|
) |
| |
◆ echo_process_rpcs()
◆ echo_process_uri()
◆ echo_segment_is_not_mapped()
static int echo_segment_is_not_mapped |
( |
u64 |
segment_handle | ) |
|
|
static |
◆ echo_session_dequeue_notify()
◆ echo_session_prealloc()
◆ echo_set_each_proto_defaults_before_opts()
static void echo_set_each_proto_defaults_before_opts |
( |
echo_main_t * |
em | ) |
|
|
static |
◆ echo_update_count_on_session_close()
◆ handle_mq_event()
static void handle_mq_event |
( |
session_event_t * |
e | ) |
|
|
static |
◆ main()
int main |
( |
int |
argc, |
|
|
char ** |
argv |
|
) |
| |
◆ mirror_data_chunk()
◆ print_global_json_stats()
static void print_global_json_stats |
( |
echo_main_t * |
em | ) |
|
|
static |
◆ print_global_stats()
◆ print_usage_and_exit()
static void print_usage_and_exit |
( |
void |
| ) |
|
|
static |
◆ recv_data_chunk()
◆ send_data_chunk()
static int send_data_chunk |
( |
echo_session_t * |
s, |
|
|
u8 * |
tx_buf, |
|
|
int |
offset, |
|
|
int |
len |
|
) |
| |
|
static |
◆ server_run()
◆ session_accepted_handler()
◆ session_bound_handler()
◆ session_connected_handler()
◆ session_disconnected_handler()
◆ session_reset_handler()
◆ session_unlisten_handler()
◆ stop_signal()
static void stop_signal |
( |
int |
signum | ) |
|
|
static |
◆ test_recv_bytes()
◆ vpp_echo_init()
static void __clib_constructor vpp_echo_init |
( |
| ) |
|
|
static |
◆ echo_main