2129 	struct thread_rx_conf *rx_conf;  in lthread_rx()  local
2131 	rx_conf = (struct thread_rx_conf *)dummy;  in lthread_rx()
2132 	lthread_set_data((void *)rx_conf);  in lthread_rx()
2137 	lthread_set_affinity(rx_conf->conf.lcore_id);  in lthread_rx()
2139 	if (rx_conf->n_rx_queue == 0) {  in lthread_rx()
2146 	for (i = 0; i < rx_conf->n_rx_queue; i++) {  in lthread_rx()
2148 		portid = rx_conf->rx_queue_list[i].port_id;  in lthread_rx()
2149 		queueid = rx_conf->rx_queue_list[i].queue_id;  in lthread_rx()
2158 	for (i = 0; i < rx_conf->n_rx_queue; i++)  in lthread_rx()
2159 		lthread_cond_init(NULL, &rx_conf->ready[i], NULL);  in lthread_rx()
2163 	rx_conf->conf.cpu_id = sched_getcpu();  in lthread_rx()
2170 		for (i = 0; i < rx_conf->n_rx_queue; ++i) {  in lthread_rx()
2171 			portid = rx_conf->rx_queue_list[i].port_id;  in lthread_rx()
2172 			queueid = rx_conf->rx_queue_list[i].queue_id;  in lthread_rx()
2174 			SET_CPU_BUSY(rx_conf, CPU_POLL);  in lthread_rx()
2177 			SET_CPU_IDLE(rx_conf, CPU_POLL);  in lthread_rx()
2180 				worker_id = (worker_id + 1) % rx_conf->n_ring;  in lthread_rx()
2183 				SET_CPU_BUSY(rx_conf, CPU_PROCESS);  in lthread_rx()
2185 						rx_conf->ring[worker_id],  in lthread_rx()
2192 					lthread_cond_signal(rx_conf->ready[worker_id]);  in lthread_rx()
2207 				SET_CPU_IDLE(rx_conf, CPU_PROCESS);  in lthread_rx()
2386 	struct thread_rx_conf *rx_conf;  in pthread_rx()  local
2389 	rx_conf = (struct thread_rx_conf *)dummy;  in pthread_rx()
2391 	if (rx_conf->n_rx_queue == 0) {  in pthread_rx()
2398 	for (i = 0; i < rx_conf->n_rx_queue; i++) {  in pthread_rx()
2400 		portid = rx_conf->rx_queue_list[i].port_id;  in pthread_rx()
2401 		queueid = rx_conf->rx_queue_list[i].queue_id;  in pthread_rx()
2408 	rx_conf->conf.cpu_id = sched_getcpu();  in pthread_rx()
2415 		for (i = 0; i < rx_conf->n_rx_queue; ++i) {  in pthread_rx()
2416 			portid = rx_conf->rx_queue_list[i].port_id;  in pthread_rx()
2417 			queueid = rx_conf->rx_queue_list[i].queue_id;  in pthread_rx()
2419 			SET_CPU_BUSY(rx_conf, CPU_POLL);  in pthread_rx()
2422 			SET_CPU_IDLE(rx_conf, CPU_POLL);  in pthread_rx()
2429 			SET_CPU_BUSY(rx_conf, CPU_PROCESS);  in pthread_rx()
2430 			worker_id = (worker_id + 1) % rx_conf->n_ring;  in pthread_rx()
2431 			n = rte_ring_sp_enqueue_burst(rx_conf->ring[worker_id],  in pthread_rx()
2444 			SET_CPU_IDLE(rx_conf, CPU_PROCESS);  in pthread_rx()
2548 	struct thread_rx_conf *rx_conf;  in init_rx_rings()  local
2568 		rx_conf = &rx_thread[rx_thread_id];  in init_rx_rings()
2569 		socket_io = rte_lcore_to_socket_id(rx_conf->conf.lcore_id);  in init_rx_rings()
2582 		rx_conf->ring[rx_conf->n_ring] = ring;  in init_rx_rings()
2585 		tx_conf->ready = &rx_conf->ready[rx_conf->n_ring];  in init_rx_rings()
2587 		rx_conf->n_ring++;  in init_rx_rings()