typedef struct
{
+ CLIB_CACHE_LINE_ALIGN_MARK (cacheline0);
app_session_t data;
u64 bytes_to_send;
u64 bytes_sent;
u64 bytes_received;
u64 vpp_session_handle;
u8 thread_index;
-} session_t;
+} eclient_session_t;
typedef struct
{
* Application setup parameters
*/
svm_queue_t *vl_input_queue; /**< vpe input queue */
- svm_queue_t **vpp_event_queue;
+ svm_msg_q_t **vpp_event_queue;
u32 cli_node_index; /**< cli process node index */
u32 my_client_index; /**< loopback API client handle */
/*
* Test state variables
*/
- session_t *sessions; /**< Session pool, shared */
+ eclient_session_t *sessions; /**< Session pool, shared */
clib_spinlock_t sessions_lock;
u8 **rx_buf; /**< intermediate rx buffers */
u8 *connect_test_data; /**< Pre-computed test data */
vlib_main_t *vlib_main;
} echo_client_main_t;
+enum
+{
+ ECHO_CLIENTS_STARTING,
+ ECHO_CLIENTS_RUNNING,
+ ECHO_CLIENTS_EXITING
+} echo_clients_test_state_e;
extern echo_client_main_t echo_client_main;
vlib_node_registration_t echo_clients_node;