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_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 | handle_mq_event (session_event_t *e) |
|
static void | echo_process_rpcs (echo_main_t *em) |
|
static int | echo_mq_dequeue_batch (svm_msg_q_t *mq, svm_msg_q_msg_t *msg_vec, u32 n_max_msg) |
|
static void * | echo_mq_thread_fn (void *arg) |
|
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) |
|
◆ clients_run()
◆ connect_to_vpp()
int connect_to_vpp |
( |
char * |
name | ) |
|
◆ echo_assert_test_suceeded()
static void echo_assert_test_suceeded |
( |
echo_main_t * |
em | ) |
|
|
static |
◆ echo_check_closed_listener()
◆ echo_data_thread_fn()
static void* echo_data_thread_fn |
( |
void * |
arg | ) |
|
|
static |
◆ echo_free_sessions()
◆ echo_handle_data()
◆ echo_mq_dequeue_batch()
◆ echo_mq_thread_fn()
static void* echo_mq_thread_fn |
( |
void * |
arg | ) |
|
|
static |
◆ 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_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()
◆ 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