Lines Matching defs:pool
49 * svc_pool->sp_lock protects most of the fields of that pool.
459 struct svc_pool *pool;
472 pool = svc_pool_for_cpu(xprt->xpt_server);
474 percpu_counter_inc(&pool->sp_sockets_queued);
475 spin_lock_bh(&pool->sp_lock);
476 list_add_tail(&xprt->xpt_ready, &pool->sp_sockets);
477 spin_unlock_bh(&pool->sp_lock);
479 svc_pool_wake_idle_thread(pool);
486 static struct svc_xprt *svc_xprt_dequeue(struct svc_pool *pool)
490 if (list_empty(&pool->sp_sockets))
493 spin_lock_bh(&pool->sp_lock);
494 if (likely(!list_empty(&pool->sp_sockets))) {
495 xprt = list_first_entry(&pool->sp_sockets,
500 spin_unlock_bh(&pool->sp_lock);
577 * bother with pool 0 as we don't need to wake up more than one thread for
582 struct svc_pool *pool = &serv->sv_pools[0];
584 set_bit(SP_TASK_PENDING, &pool->sp_flags);
585 svc_pool_wake_idle_thread(pool);
703 struct svc_pool *pool = rqstp->rq_pool;
706 if (test_bit(SP_TASK_PENDING, &pool->sp_flags))
710 if (!list_empty(&pool->sp_sockets))
726 struct svc_pool *pool = rqstp->rq_pool;
731 rqstp->rq_xprt = svc_xprt_dequeue(pool);
737 clear_bit(SP_CONGESTED, &pool->sp_flags);
750 clear_bit(SP_TASK_PENDING, &pool->sp_flags);
751 rqstp->rq_xprt = svc_xprt_dequeue(pool);
759 clear_bit(SP_TASK_PENDING, &pool->sp_flags);
763 if (!test_bit(SP_CONGESTED, &pool->sp_flags))
1086 struct svc_pool *pool;
1092 pool = &serv->sv_pools[i];
1094 spin_lock_bh(&pool->sp_lock);
1095 list_for_each_entry_safe(xprt, tmp, &pool->sp_sockets, xpt_ready) {
1099 spin_unlock_bh(&pool->sp_lock);
1102 spin_unlock_bh(&pool->sp_lock);
1392 struct svc_pool *pool = p;
1398 pool = &serv->sv_pools[0];
1400 unsigned int pidx = (pool - &serv->sv_pools[0]);
1402 pool = &serv->sv_pools[pidx+1];
1404 pool = NULL;
1407 return pool;
1416 struct svc_pool *pool = p;
1419 seq_puts(m, "# pool packets-arrived sockets-enqueued threads-woken threads-timedout\n");
1424 pool->sp_id,
1425 percpu_counter_sum_positive(&pool->sp_messages_arrived),
1426 percpu_counter_sum_positive(&pool->sp_sockets_queued),
1427 percpu_counter_sum_positive(&pool->sp_threads_woken));