112 	struct rte_mbuf *bufs[BURST];  in sanity_test()  local
120 	if (rte_mempool_get_bulk(p, (void *)bufs, BURST) != 0) {  in sanity_test()
128 		bufs[i]->hash.usr = 0;  in sanity_test()
132 		processed += rte_distributor_process(db, &bufs[processed],  in sanity_test()
147 		rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test()
161 			bufs[i]->hash.usr = (i & 1) << 8;  in sanity_test()
163 		rte_distributor_process(db, bufs, BURST);  in sanity_test()
174 			rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test()
190 		bufs[i]->hash.usr = i+1;  in sanity_test()
192 	rte_distributor_process(db, bufs, BURST);  in sanity_test()
203 		rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test()
213 	rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test()
326 	struct rte_mbuf *bufs[BURST];  in sanity_test_with_mbuf_alloc()  local
334 		while (rte_mempool_get_bulk(p, (void *)bufs, BURST) < 0)  in sanity_test_with_mbuf_alloc()
337 			bufs[j]->hash.usr = (i+j) << 1;  in sanity_test_with_mbuf_alloc()
343 				&bufs[processed], BURST - processed);  in sanity_test_with_mbuf_alloc()
433 	struct rte_mbuf *bufs[BURST];  in sanity_test_with_worker_shutdown()  local
443 	if (rte_mempool_get_bulk(p, (void *)bufs, BURST) != 0) {  in sanity_test_with_worker_shutdown()
453 		bufs[i]->hash.usr = 1;  in sanity_test_with_worker_shutdown()
457 		processed += rte_distributor_process(d, &bufs[processed],  in sanity_test_with_worker_shutdown()
468 		rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test_with_worker_shutdown()
499 	rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test_with_worker_shutdown()
517 	struct rte_mbuf *bufs[BURST];  in test_flush_with_worker_shutdown()  local
525 	if (rte_mempool_get_bulk(p, (void *)bufs, BURST) != 0) {  in test_flush_with_worker_shutdown()
533 		bufs[i]->hash.usr = 0;  in test_flush_with_worker_shutdown()
537 		processed += rte_distributor_process(d, &bufs[processed],  in test_flush_with_worker_shutdown()
569 	rte_mempool_put_bulk(p, (void *)bufs, BURST);  in test_flush_with_worker_shutdown()
615 	struct rte_mbuf *bufs[buf_count];  in sanity_mark_test()  local
624 	if (rte_mempool_get_bulk(p, (void *)bufs, buf_count) != 0) {  in sanity_mark_test()
637 		bufs[0 * burst + i]->hash.usr = 1 << shift;  in sanity_mark_test()
638 		bufs[1 * burst + i]->hash.usr = ((i < burst / 2) ? 1 : 2)  in sanity_mark_test()
640 		bufs[2 * burst + i]->hash.usr = ((i < burst / 2) ? 2 : 1)  in sanity_mark_test()
647 		*seq_field(bufs[i]) = i << seq_shift;  in sanity_mark_test()
654 				&bufs[i * burst + processed],  in sanity_mark_test()
709 	rte_mempool_put_bulk(p, (void *)bufs, buf_count);  in sanity_mark_test()
778 	struct rte_mbuf *bufs[RTE_MAX_LCORE];  in quit_workers()  local
780 	if (rte_mempool_get_bulk(p, (void *)bufs, num_workers) != 0) {  in quit_workers()
788 		bufs[i]->hash.usr = i << 1;  in quit_workers()
789 		rte_distributor_process(d, &bufs[i], 1);  in quit_workers()
800 	rte_mempool_put_bulk(p, (void *)bufs, num_workers);  in quit_workers()