Commit 2fcdb1b4 authored by Tejun Heo's avatar Tejun Heo
Browse files

workqueue: Factor out init_cpu_worker_pool() 



Factor out init_cpu_worker_pool() from workqueue_init_early(). This is pure
reorganization in preparation of BH workqueue support.

Signed-off-by: default avatarTejun Heo <tj@kernel.org>
Tested-by: default avatarAllen Pais <allen.lkml@gmail.com>
parent c35aea39

kernel/workqueue.c

+18 −14
Original line number Diff line number Diff line
@@ -7147,6 +7147,22 @@ static void __init restrict_unbound_cpumask(const char *name, const struct cpuma 
	cpumask_and(wq_unbound_cpumask, wq_unbound_cpumask, mask);

}



static void __init init_cpu_worker_pool(struct worker_pool *pool, int cpu, int nice)

{

	BUG_ON(init_worker_pool(pool));

	pool->cpu = cpu;

	cpumask_copy(pool->attrs->cpumask, cpumask_of(cpu));

	cpumask_copy(pool->attrs->__pod_cpumask, cpumask_of(cpu));

	pool->attrs->nice = nice;

	pool->attrs->affn_strict = true;

	pool->node = cpu_to_node(cpu);



	/* alloc pool ID */

	mutex_lock(&wq_pool_mutex);

	BUG_ON(worker_pool_assign_id(pool));

	mutex_unlock(&wq_pool_mutex);

}



/**

 * workqueue_init_early - early init for workqueue subsystem

 *
@@ -7207,20 +7223,8 @@ void __init workqueue_init_early(void) 
		struct worker_pool *pool;



		i = 0;

		for_each_cpu_worker_pool(pool, cpu) {

			BUG_ON(init_worker_pool(pool));

			pool->cpu = cpu;

			cpumask_copy(pool->attrs->cpumask, cpumask_of(cpu));

			cpumask_copy(pool->attrs->__pod_cpumask, cpumask_of(cpu));

			pool->attrs->nice = std_nice[i++];

			pool->attrs->affn_strict = true;

			pool->node = cpu_to_node(cpu);



			/* alloc pool ID */

			mutex_lock(&wq_pool_mutex);

			BUG_ON(worker_pool_assign_id(pool));

			mutex_unlock(&wq_pool_mutex);

		}

		for_each_cpu_worker_pool(pool, cpu)

			init_cpu_worker_pool(pool, cpu, std_nice[i++]);

	}



	/* create default unbound and ordered wq attrs */