16 #ifndef __included_vpp_echo_common_h__ 17 #define __included_vpp_echo_common_h__ 33 #define vl_print(handle, ...) 39 #define LOGGING_BATCH (100) 40 #define LOG_EVERY_N_IDLE_CYCLES (1e8) 42 #define foreach_echo_fail_code \ 43 _(ECHO_FAIL_NONE, "ECHO_FAIL_NONE") \ 44 _(ECHO_FAIL_USAGE, "ECHO_FAIL_USAGE") \ 45 _(ECHO_FAIL_SEND_IO_EVT, "ECHO_FAIL_SEND_IO_EVT") \ 46 _(ECHO_FAIL_SOCKET_CONNECT, "ECHO_FAIL_SOCKET_CONNECT") \ 47 _(ECHO_FAIL_INIT_SHM_API, "ECHO_FAIL_INIT_SHM_API") \ 48 _(ECHO_FAIL_SHMEM_CONNECT, "ECHO_FAIL_SHMEM_CONNECT") \ 49 _(ECHO_FAIL_TEST_BYTES_ERR, "ECHO_FAIL_TEST_BYTES_ERR") \ 50 _(ECHO_FAIL_BIND, "ECHO_FAIL_BIND") \ 51 _(ECHO_FAIL_SESSION_ACCEPTED_BAD_LISTENER, \ 52 "ECHO_FAIL_SESSION_ACCEPTED_BAD_LISTENER") \ 53 _(ECHO_FAIL_ACCEPTED_WAIT_FOR_SEG_ALLOC, \ 54 "ECHO_FAIL_ACCEPTED_WAIT_FOR_SEG_ALLOC") \ 55 _(ECHO_FAIL_SESSION_CONNECT, "ECHO_FAIL_SESSION_CONNECT") \ 56 _(ECHO_FAIL_CONNECTED_WAIT_FOR_SEG_ALLOC, \ 57 "ECHO_FAIL_CONNECTED_WAIT_FOR_SEG_ALLOC") \ 58 _(ECHO_FAIL_APP_ATTACH, "ECHO_FAIL_APP_ATTACH") \ 59 _(ECHO_FAIL_SERVER_DISCONNECT_TIMEOUT, \ 60 "ECHO_FAIL_SERVER_DISCONNECT_TIMEOUT") \ 61 _(ECHO_FAIL_INVALID_URI, "ECHO_FAIL_INVALID_URI") \ 62 _(ECHO_FAIL_PROTOCOL_NOT_SUPPORTED, \ 63 "ECHO_FAIL_PROTOCOL_NOT_SUPPORTED") \ 64 _(ECHO_FAIL_CONNECT_TO_VPP, "ECHO_FAIL_CONNECT_TO_VPP") \ 65 _(ECHO_FAIL_ATTACH_TO_VPP, "ECHO_FAIL_ATTACH_TO_VPP") \ 66 _(ECHO_FAIL_1ST_PTHREAD_CREATE, "ECHO_FAIL_1ST_PTHREAD_CREATE") \ 67 _(ECHO_FAIL_PTHREAD_CREATE, "ECHO_FAIL_PTHREAD_CREATE") \ 68 _(ECHO_FAIL_DETACH, "ECHO_FAIL_DETACH") \ 69 _(ECHO_FAIL_DEL_CERT_KEY, "ECHO_FAIL_DEL_CERT_KEY") \ 70 _(ECHO_FAIL_MQ_PTHREAD, "ECHO_FAIL_MQ_PTHREAD") \ 71 _(ECHO_FAIL_VL_API_APP_ATTACH, "ECHO_FAIL_VL_API_APP_ATTACH") \ 72 _(ECHO_FAIL_VL_API_MISSING_SEGMENT_NAME, \ 73 "ECHO_FAIL_VL_API_MISSING_SEGMENT_NAME") \ 74 _(ECHO_FAIL_VL_API_NULL_APP_MQ, "ECHO_FAIL_VL_API_NULL_APP_MQ") \ 75 _(ECHO_FAIL_VL_API_RECV_FD_MSG, "ECHO_FAIL_VL_API_RECV_FD_MSG") \ 76 _(ECHO_FAIL_VL_API_SVM_FIFO_SEG_ATTACH, \ 77 "ECHO_FAIL_VL_API_SVM_FIFO_SEG_ATTACH") \ 78 _(ECHO_FAIL_VL_API_FIFO_SEG_ATTACH, \ 79 "ECHO_FAIL_VL_API_FIFO_SEG_ATTACH") \ 80 _(ECHO_FAIL_VL_API_DETACH_REPLY, "ECHO_FAIL_VL_API_DETACH_REPLY") \ 81 _(ECHO_FAIL_VL_API_BIND_URI_REPLY, "ECHO_FAIL_VL_API_BIND_URI_REPLY") \ 82 _(ECHO_FAIL_VL_API_UNBIND_REPLY, "ECHO_FAIL_VL_API_UNBIND_REPLY") \ 83 _(ECHO_FAIL_SESSION_DISCONNECT, "ECHO_FAIL_SESSION_DISCONNECT") \ 84 _(ECHO_FAIL_SESSION_RESET, "ECHO_FAIL_SESSION_RESET") \ 85 _(ECHO_FAIL_VL_API_CERT_KEY_ADD_REPLY, \ 86 "ECHO_FAIL_VL_API_CERT_KEY_ADD_REPLY") \ 87 _(ECHO_FAIL_VL_API_CERT_KEY_DEL_REPLY, \ 88 "ECHO_FAIL_VL_API_CERT_KEY_DEL_REPLY") \ 89 _(ECHO_FAIL_GET_SESSION_FROM_HANDLE, \ 90 "ECHO_FAIL_GET_SESSION_FROM_HANDLE") \ 91 _(ECHO_FAIL_QUIC_WRONG_CONNECT, "ECHO_FAIL_QUIC_WRONG_CONNECT") \ 92 _(ECHO_FAIL_QUIC_WRONG_ACCEPT, "ECHO_FAIL_QUIC_WRONG_ACCEPT") \ 93 _(ECHO_FAIL_TCP_BAPI_CONNECT, "ECHO_FAIL_TCP_BAPI_CONNECT") \ 94 _(ECHO_FAIL_UDP_BAPI_CONNECT, "ECHO_FAIL_UDP_BAPI_CONNECT") \ 95 _(ECHO_FAIL_MISSING_START_EVENT, "ECHO_FAIL_MISSING_START_EVENT") \ 96 _(ECHO_FAIL_MISSING_END_EVENT, "ECHO_FAIL_MISSING_END_EVENT") \ 97 _(ECHO_FAIL_TEST_ASSERT_RX_TOTAL, "ECHO_FAIL_TEST_ASSERT_RX_TOTAL") \ 98 _(ECHO_FAIL_UNIDIRECTIONAL, "ECHO_FAIL_UNIDIRECTIONAL") \ 99 _(ECHO_FAIL_TEST_ASSERT_TX_TOTAL, "ECHO_FAIL_TEST_ASSERT_TX_TOTAL") \ 100 _(ECHO_FAIL_TEST_ASSERT_ALL_SESSIONS_CLOSED, \ 101 "ECHO_FAIL_TEST_ASSERT_ALL_SESSIONS_CLOSED") \ 102 _(ECHO_FAIL_RPC_SIZE, "ECHO_FAIL_RPC_SIZE") 106 #define _(sym, str) sym, 113 #define CHECK_SAME(fail, expected, result, _fmt, _args...) \ 115 if ((expected) != (result)) \ 116 ECHO_FAIL ((fail), "expected same (%lld, got %lld) : "_fmt, \ 117 (u64)(expected), (u64)(result), ##_args); \ 120 #define CHECK_DIFF(fail, expected, result, _fmt, _args...) \ 122 if ((expected) == (result)) \ 123 ECHO_FAIL ((fail), "expected different (both %lld) : "_fmt, \ 124 (u64)(expected), ##_args); \ 127 #define ECHO_FAIL(fail, _fmt, _args...) \ 129 echo_main_t *em = &echo_main; \ 130 em->has_failed = (fail); \ 131 if (vec_len(em->fail_descr)) \ 132 em->fail_descr = format(em->fail_descr, " | %s (%u): "_fmt, \ 133 echo_fail_code_str[fail], fail, ##_args); \ 135 em->fail_descr = format(0, "%s (%u): "_fmt, \ 136 echo_fail_code_str[fail], fail, ##_args); \ 137 em->time_to_stop = 1; \ 138 if (em->log_lvl > 0) \ 139 clib_warning ("%v", em->fail_descr); \ 142 #define ECHO_LOG(lvl, _fmt,_args...) \ 144 echo_main_t *em = &echo_main; \ 145 if (em->log_lvl > lvl) \ 146 clib_warning (_fmt, ##_args); \ 149 #define ECHO_REGISTER_PROTO(proto, vft) \ 150 static void __clib_constructor \ 151 vpp_echo_init_##proto () \ 153 echo_main_t *em = &echo_main; \ 154 vec_validate (em->available_proto_cb_vft, proto); \ 155 em->available_proto_cb_vft[proto] = &vft; \ 161 #define _(type, name) type name; 248 void (*set_defaults_before_opts_cb) (void);
249 void (*set_defaults_after_opts_cb) (void);
250 void (*print_usage_cb) (void);
volatile u32 listen_session_cnt
echo_proto_cb_vft_t ** available_proto_cb_vft
#define foreach_app_session_field
flag for dgram mode
volatile u64 accepted_session_count
echo_disconnect_args_t disconnect
echo_stats_t last_stat_sampling
#define CLIB_CACHE_LINE_ALIGN_MARK(mark)
teardown_stat_t clean_count
u8 * format_ip46_address(u8 *s, va_list *args)
echo_session_t * sessions
clib_spinlock_t sid_vpp_handles_lock
u8 use_sock_api
Flag that decides if socket, instead of svm, api is used to connect to vpp.
svm_queue_t * vl_input_queue
uword unformat_ip6_address(unformat_input_t *input, va_list *args)
u8 * echo_format_bytes_per_sec(u8 *s, va_list *args)
echo_session_t * echo_session_new(echo_main_t *em)
void echo_send_disconnect_session(echo_main_t *em, void *args)
u8 * echo_format_timing_event(u8 *s, va_list *args)
int wait_for_state_change(echo_main_t *em, connection_state_t state, f64 timeout)
void echo_send_attach(echo_main_t *em)
volatile connection_state_t state
void echo_send_connect(echo_main_t *em, void *args)
void echo_send_detach(echo_main_t *em)
volatile int max_sim_connects
echo_session_t * echo_get_session_from_handle(echo_main_t *em, u64 handle)
foreach_app_session_field u64 vpp_session_handle
uword echo_unformat_crypto_engine(unformat_input_t *input, va_list *args)
struct echo_disconnect_args_ echo_disconnect_args_t
enum ssvm_segment_type_ ssvm_segment_type_t
volatile u32 n_clients_connected
volatile u64 bytes_received
void echo_api_hookup(echo_main_t *em)
#define foreach_echo_fail_code
u8 * format_api_error(u8 *s, va_list *args)
int echo_ssvm_segment_attach(char *name, ssvm_segment_type_t type, int fd)
clib_spinlock_t segment_handles_lock
struct teardown_stat_ teardown_stat_t
void init_error_string_table()
void(* echo_rpc_t)(echo_main_t *em, echo_rpc_args_t *arg)
vl_api_fib_path_type_t type
u8 * echo_format_session_state(u8 *s, va_list *args)
void echo_send_add_cert_key(echo_main_t *em)
echo_connect_args_t connect
teardown_stat_t accepted_count
pthread_t mq_thread_handle
uword echo_unformat_timing_event(unformat_input_t *input, va_list *args)
uword unformat_ip4_address(unformat_input_t *input, va_list *args)
uword echo_unformat_close(unformat_input_t *input, va_list *args)
u8 * format_transport_proto(u8 *s, va_list *args)
uword * error_string_by_error_number
uword unformat_transport_proto(unformat_input_t *input, va_list *args)
fifo_segment_main_t segment_main
data_source_t data_source
u8 * format_ip4_address(u8 *s, va_list *args)
enum echo_test_evt_ echo_test_evt_t
void echo_send_del_cert_key(echo_main_t *em)
u8 * format_ip6_address(u8 *s, va_list *args)
void echo_send_listen(echo_main_t *em, ip46_address_t *ip)
uword * shared_segment_handles
struct echo_stats_ echo_stats_t
u8 * echo_format_session_type(u8 *s, va_list *args)
u32 *volatile data_thread_args
void echo_session_handle_add_del(echo_main_t *em, u64 handle, u32 sid)
union session_connected_bundled_msg_ session_connected_bundled_msg_t
void echo_notify_event(echo_main_t *em, echo_test_evt_t e)
u64 parent_session_handle
volatile u32 nxt_available_sidx
char * echo_fail_code_str[]
int echo_send_rpc(echo_main_t *em, void *fp, echo_rpc_args_t *args)
struct echo_proto_cb_vft_ echo_proto_cb_vft_t
teardown_stat_t close_count
u8 * echo_format_session(u8 *s, va_list *args)
volatile u64 bytes_to_receive
void echo_session_print_stats(echo_main_t *em, echo_session_t *session)
void echo_send_unbind(echo_main_t *em, echo_session_t *s)
u8 * echo_format_crypto_engine(u8 *s, va_list *args)
struct echo_connect_args_ echo_connect_args_t
teardown_stat_t active_count
u32 * listen_session_indexes
uword * session_index_by_vpp_handles
struct _svm_queue svm_queue_t
svm_msg_q_t * rpc_msq_queue
vl_api_dhcp_client_state_t state
echo_proto_cb_vft_t * proto_cb_vft
teardown_stat_t connected_count
pthread_t * data_thread_handles
f64 last_stat_sampling_ts
session_connected_msg_t * mp
teardown_stat_t reset_count
u8 send_stream_disconnects
void echo_segment_handle_add_del(echo_main_t *em, u64 segment_handle, u8 add)
u8 * echo_format_app_state(u8 *s, va_list *args)