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_session_detach_fifos (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 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 | cleanup_handler (session_cleanup_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()
◆ cleanup_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_session_dequeue_notify()
◆ echo_session_detach_fifos()
◆ 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