18 #define BURST 32  macro
112 	struct rte_mbuf *bufs[BURST];  in sanity_test()
113 	struct rte_mbuf *returns[BURST*2];  in sanity_test()
120 	if (rte_mempool_get_bulk(p, (void *)bufs, BURST) != 0) {  in sanity_test()
127 	for (i = 0; i < BURST; i++)  in sanity_test()
131 	while (processed < BURST)  in sanity_test()
133 			BURST - processed);  in sanity_test()
140 				returns, BURST*2);  in sanity_test()
141 	} while (count < BURST);  in sanity_test()
143 	if (total_packet_count() != BURST) {  in sanity_test()
146 				__LINE__, BURST, total_packet_count());  in sanity_test()
147 		rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test()
160 		for (i = 0; i < BURST; i++)  in sanity_test()
163 		rte_distributor_process(db, bufs, BURST);  in sanity_test()
168 					returns, BURST*2);  in sanity_test()
169 		} while (count < BURST);  in sanity_test()
170 		if (total_packet_count() != BURST) {  in sanity_test()
173 					__LINE__, BURST, total_packet_count());  in sanity_test()
174 			rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test()
189 	for (i = 0; i < BURST; i++)  in sanity_test()
192 	rte_distributor_process(db, bufs, BURST);  in sanity_test()
197 				returns, BURST*2);  in sanity_test()
198 	} while (count < BURST);  in sanity_test()
199 	if (total_packet_count() != BURST) {  in sanity_test()
202 				__LINE__, BURST, total_packet_count());  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()
233 	for (i = 0; i < BIG_BATCH/BURST; i++) {  in sanity_test()
235 				&many_bufs[i*BURST], BURST);  in sanity_test()
326 	struct rte_mbuf *bufs[BURST];  in sanity_test_with_mbuf_alloc()
332 	for (i = 0; i < ((1<<ITER_POWER)); i += BURST) {  in sanity_test_with_mbuf_alloc()
334 		while (rte_mempool_get_bulk(p, (void *)bufs, BURST) < 0)  in sanity_test_with_mbuf_alloc()
336 		for (j = 0; j < BURST; j++) {  in sanity_test_with_mbuf_alloc()
341 		while (processed < BURST)  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()
434 	struct rte_mbuf *bufs2[BURST];  in sanity_test_with_worker_shutdown()
443 	if (rte_mempool_get_bulk(p, (void *)bufs, BURST) != 0) {  in sanity_test_with_worker_shutdown()
452 	for (i = 0; i < BURST; i++)  in sanity_test_with_worker_shutdown()
456 	while (processed < BURST)  in sanity_test_with_worker_shutdown()
458 			BURST - processed);  in sanity_test_with_worker_shutdown()
466 	if (rte_mempool_get_bulk(p, (void *)bufs2, BURST) != 0) {  in sanity_test_with_worker_shutdown()
468 		rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test_with_worker_shutdown()
471 	for (i = 0; i < BURST; i++)  in sanity_test_with_worker_shutdown()
476 	rte_distributor_process(d, bufs2, BURST);  in sanity_test_with_worker_shutdown()
492 	if (total_packet_count() != BURST * 2) {  in sanity_test_with_worker_shutdown()
495 				__LINE__, BURST * 2, total_packet_count());  in sanity_test_with_worker_shutdown()
499 	rte_mempool_put_bulk(p, (void *)bufs, BURST);  in sanity_test_with_worker_shutdown()
500 	rte_mempool_put_bulk(p, (void *)bufs2, BURST);  in sanity_test_with_worker_shutdown()
517 	struct rte_mbuf *bufs[BURST];  in test_flush_with_worker_shutdown()
525 	if (rte_mempool_get_bulk(p, (void *)bufs, BURST) != 0) {  in test_flush_with_worker_shutdown()
532 	for (i = 0; i < BURST; i++)  in test_flush_with_worker_shutdown()
536 	while (processed < BURST)  in test_flush_with_worker_shutdown()
538 			BURST - processed);  in test_flush_with_worker_shutdown()
562 	if (total_packet_count() != BURST) {  in test_flush_with_worker_shutdown()
565 				__LINE__, BURST, total_packet_count());  in test_flush_with_worker_shutdown()
569 	rte_mempool_put_bulk(p, (void *)bufs, BURST);  in test_flush_with_worker_shutdown()
865 		p = rte_pktmbuf_pool_create("DT_MBUF_POOL", nb_bufs, BURST,  in test_distributor()