11 	struct test_order *t = evt_test_priv(test);  in order_test_result()  local
13 	return t->result;  in order_test_result()
20 	struct test_order *t = p->t;  in order_producer()  local
21 	struct evt_options *opt = t->opt;  in order_producer()
24 	struct rte_mempool *pool = t->pool;  in order_producer()
25 	const uint64_t nb_pkts = t->nb_pkts;  in order_producer()
26 	uint32_t *producer_flow_seq = t->producer_flow_seq;  in order_producer()
27 	const uint32_t nb_flows = t->nb_flows;  in order_producer()
44 	while (count < nb_pkts && t->err == false) {  in order_producer()
51 		*order_mbuf_seqn(t, m) = producer_flow_seq[flow]++;  in order_producer()
52 		order_flow_id_save(t, flow, m, &ev);  in order_producer()
55 			if (t->err)  in order_producer()
138 	struct test_order *t;  in order_test_setup()  local
157 	t = evt_test_priv(test);  in order_test_setup()
159 	t->flow_id_dynfield_offset =  in order_test_setup()
161 	if (t->flow_id_dynfield_offset < 0) {  in order_test_setup()
166 	t->seqn_dynfield_offset =  in order_test_setup()
168 	if (t->seqn_dynfield_offset < 0) {  in order_test_setup()
173 	t->producer_flow_seq = rte_zmalloc_socket("test_producer_flow_seq",  in order_test_setup()
174 				 sizeof(*t->producer_flow_seq) * opt->nb_flows,  in order_test_setup()
177 	if (t->producer_flow_seq  == NULL) {  in order_test_setup()
182 	t->expected_flow_seq = rte_zmalloc_socket("test_expected_flow_seq",  in order_test_setup()
183 				 sizeof(*t->expected_flow_seq) * opt->nb_flows,  in order_test_setup()
186 	if (t->expected_flow_seq  == NULL) {  in order_test_setup()
190 	rte_atomic64_set(&t->outstand_pkts, opt->nb_pkts);  in order_test_setup()
191 	t->err = false;  in order_test_setup()
192 	t->nb_pkts = opt->nb_pkts;  in order_test_setup()
193 	t->nb_flows = opt->nb_flows;  in order_test_setup()
194 	t->result = EVT_TEST_FAILED;  in order_test_setup()
195 	t->opt = opt;  in order_test_setup()
199 	rte_free(t->producer_flow_seq);  in order_test_setup()
210 	struct test_order *t = evt_test_priv(test);  in order_test_destroy()  local
212 	rte_free(t->expected_flow_seq);  in order_test_destroy()
213 	rte_free(t->producer_flow_seq);  in order_test_destroy()
220 	struct test_order *t = evt_test_priv(test);  in order_mempool_setup()  local
222 	t->pool  = rte_pktmbuf_pool_create(test->name, opt->pool_sz,  in order_mempool_setup()
226 	if (t->pool == NULL) {  in order_mempool_setup()
238 	struct test_order *t = evt_test_priv(test);  in order_mempool_destroy()  local
240 	rte_mempool_free(t->pool);  in order_mempool_destroy()
266 	struct test_order *t = evt_test_priv(test);  in order_launch_lcores()  local
274 		ret = rte_eal_remote_launch(worker, &t->worker[wkr_idx],  in order_launch_lcores()
286 	ret = rte_eal_remote_launch(order_producer, &t->prod, plcore);  in order_launch_lcores()
295 	while (t->err == false) {  in order_launch_lcores()
297 		int64_t remaining = rte_atomic64_read(&t->outstand_pkts);  in order_launch_lcores()
300 			t->result = EVT_TEST_SUCCESS;  in order_launch_lcores()
310 				t->err = true;  in order_launch_lcores()
329 	struct test_order *t = evt_test_priv(test);  in order_event_dev_port_setup()  local
351 		struct worker_data *w = &t->worker[port];  in order_event_dev_port_setup()
355 		w->t = t;  in order_event_dev_port_setup()
369 	struct prod_data *p = &t->prod;  in order_event_dev_port_setup()
374 	p->t = t;  in order_event_dev_port_setup()