324 	struct svc_pool *pool;  in svc_xprt_do_enqueue()  local
344 	pool = svc_pool_for_cpu(xprt->xpt_server, cpu);  in svc_xprt_do_enqueue()
346 	atomic_long_inc(&pool->sp_stats.packets);  in svc_xprt_do_enqueue()
351 	list_for_each_entry_rcu(rqstp, &pool->sp_all_threads, rq_all) {  in svc_xprt_do_enqueue()
377 		atomic_long_inc(&pool->sp_stats.threads_woken);  in svc_xprt_do_enqueue()
393 		spin_lock_bh(&pool->sp_lock);  in svc_xprt_do_enqueue()
394 		list_add_tail(&xprt->xpt_ready, &pool->sp_sockets);  in svc_xprt_do_enqueue()
395 		pool->sp_stats.sockets_queued++;  in svc_xprt_do_enqueue()
396 		spin_unlock_bh(&pool->sp_lock);  in svc_xprt_do_enqueue()
422 static struct svc_xprt *svc_xprt_dequeue(struct svc_pool *pool)  in svc_xprt_dequeue()  argument
426 	if (list_empty(&pool->sp_sockets))  in svc_xprt_dequeue()
429 	spin_lock_bh(&pool->sp_lock);  in svc_xprt_dequeue()
430 	if (likely(!list_empty(&pool->sp_sockets))) {  in svc_xprt_dequeue()
431 		xprt = list_first_entry(&pool->sp_sockets,  in svc_xprt_dequeue()
439 	spin_unlock_bh(&pool->sp_lock);  in svc_xprt_dequeue()
511 	struct svc_pool *pool;  in svc_wake_up()  local
513 	pool = &serv->sv_pools[0];  in svc_wake_up()
516 	list_for_each_entry_rcu(rqstp, &pool->sp_all_threads, rq_all) {  in svc_wake_up()
529 	set_bit(SP_TASK_PENDING, &pool->sp_flags);  in svc_wake_up()
645 	struct svc_pool		*pool = rqstp->rq_pool;  in rqst_should_sleep()  local
648 	if (test_and_clear_bit(SP_TASK_PENDING, &pool->sp_flags))  in rqst_should_sleep()
652 	if (!list_empty(&pool->sp_sockets))  in rqst_should_sleep()
669 	struct svc_pool		*pool = rqstp->rq_pool;  in svc_get_next_xprt()  local
680 	xprt = svc_xprt_dequeue(pool);  in svc_get_next_xprt()
689 		clear_bit(SP_TASK_PENDING, &pool->sp_flags);  in svc_get_next_xprt()
717 		atomic_long_inc(&pool->sp_stats.threads_timedout);  in svc_get_next_xprt()
1018 	struct svc_pool *pool;  in svc_dequeue_net()  local
1024 		pool = &serv->sv_pools[i];  in svc_dequeue_net()
1026 		spin_lock_bh(&pool->sp_lock);  in svc_dequeue_net()
1027 		list_for_each_entry_safe(xprt, tmp, &pool->sp_sockets, xpt_ready) {  in svc_dequeue_net()
1031 			spin_unlock_bh(&pool->sp_lock);  in svc_dequeue_net()
1034 		spin_unlock_bh(&pool->sp_lock);  in svc_dequeue_net()
1312 	struct svc_pool *pool = p;  in svc_pool_stats_next()  local
1318 		pool = &serv->sv_pools[0];  in svc_pool_stats_next()
1320 		unsigned int pidx = (pool - &serv->sv_pools[0]);  in svc_pool_stats_next()
1322 			pool = &serv->sv_pools[pidx+1];  in svc_pool_stats_next()
1324 			pool = NULL;  in svc_pool_stats_next()
1327 	return pool;  in svc_pool_stats_next()
1336 	struct svc_pool *pool = p;  in svc_pool_stats_show()  local
1344 		pool->sp_id,  in svc_pool_stats_show()
1345 		(unsigned long)atomic_long_read(&pool->sp_stats.packets),  in svc_pool_stats_show()
1346 		pool->sp_stats.sockets_queued,  in svc_pool_stats_show()
1347 		(unsigned long)atomic_long_read(&pool->sp_stats.threads_woken),  in svc_pool_stats_show()
1348 		(unsigned long)atomic_long_read(&pool->sp_stats.threads_timedout));  in svc_pool_stats_show()