80 	struct rte_distributor *db = wp->dist;  in handle_work()  local
84 	num = rte_distributor_get_pkt(db, id, buf, NULL, 0);  in handle_work()
88 		num = rte_distributor_get_pkt(db, id,  in handle_work()
93 	rte_distributor_return_pkt(db, id, buf, num);  in handle_work()
111 	struct rte_distributor *db = wp->dist;  in sanity_test()  local
132 		processed += rte_distributor_process(db, &bufs[processed],  in sanity_test()
138 		rte_distributor_flush(db);  in sanity_test()
139 		count += rte_distributor_returned_pkts(db,  in sanity_test()
163 		rte_distributor_process(db, bufs, BURST);  in sanity_test()
166 			rte_distributor_flush(db);  in sanity_test()
167 			count += rte_distributor_returned_pkts(db,  in sanity_test()
192 	rte_distributor_process(db, bufs, BURST);  in sanity_test()
195 		rte_distributor_flush(db);  in sanity_test()
196 		count += rte_distributor_returned_pkts(db,  in sanity_test()
222 	rte_distributor_flush(db);  in sanity_test()
223 	rte_distributor_clear_returns(db);  in sanity_test()
234 		rte_distributor_process(db,  in sanity_test()
236 		count = rte_distributor_returned_pkts(db,  in sanity_test()
241 	rte_distributor_flush(db);  in sanity_test()
242 	count = rte_distributor_returned_pkts(db,  in sanity_test()
248 		rte_distributor_flush(db);  in sanity_test()
249 		count = rte_distributor_returned_pkts(db,  in sanity_test()
583 	struct rte_distributor *db = wp->dist;  in handle_and_mark_work()  local
586 	num = rte_distributor_get_pkt(db, id, buf, NULL, 0);  in handle_and_mark_work()
592 		num = rte_distributor_get_pkt(db, id,  in handle_and_mark_work()
597 	rte_distributor_return_pkt(db, id, buf, num);  in handle_and_mark_work()
614 	struct rte_distributor *db = wp->dist;  in sanity_mark_test()  local
653 			processed += rte_distributor_process(db,  in sanity_mark_test()
656 		count += rte_distributor_returned_pkts(db, &returns[count],  in sanity_mark_test()
661 		rte_distributor_flush(db);  in sanity_mark_test()
662 		count += rte_distributor_returned_pkts(db, &returns[count],  in sanity_mark_test()
722 	struct rte_distributor *db = NULL;  in test_error_distributor_create_name()  local
733 	db = rte_distributor_create(name, rte_socket_id(),  in test_error_distributor_create_name()
736 	if (db != NULL || rte_errno != EINVAL) {  in test_error_distributor_create_name()
749 	struct rte_distributor *db = NULL;  in test_error_distributor_create_numworkers()  local
759 	db = rte_distributor_create("test_numworkers", rte_socket_id(),  in test_error_distributor_create_numworkers()
762 	if (db != NULL || rte_errno != EINVAL) {  in test_error_distributor_create_numworkers()
813 	static struct rte_distributor *db;  in test_distributor()  local
835 	if (db == NULL) {  in test_distributor()
836 		db = rte_distributor_create("Test_dist_burst", rte_socket_id(),  in test_distributor()
839 		if (db == NULL) {  in test_distributor()
844 		rte_distributor_flush(db);  in test_distributor()
845 		rte_distributor_clear_returns(db);  in test_distributor()
874 	dist[1] = db;  in test_distributor()