Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 504f52b5 authored by Eric Dumazet's avatar Eric Dumazet Committed by Linus Torvalds
Browse files

mm: NUMA aware alloc_task_struct_node() 



All kthreads being created from a single helper task, they all use memory
from a single node for their kernel stack and task struct.

This patch suite creates kthread_create_on_cpu(), adding a 'cpu' parameter
to parameters already used by kthread_create().

This parameter serves in allocating memory for the new kthread on its
memory node if available.

Users of this new function are : ksoftirqd, kworker, migration, pktgend...

This patch:

Add a node parameter to alloc_task_struct(), and change its name to
alloc_task_struct_node()

This change is needed to allow NUMA aware kthread_create_on_cpu()

Signed-off-by: default avatarEric Dumazet <eric.dumazet@gmail.com>
Acked-by: default avatarDavid S. Miller <davem@davemloft.net>
Reviewed-by: default avatarAndi Kleen <ak@linux.intel.com>
Acked-by: default avatarRusty Russell <rusty@rustcorp.com.au>
Cc: Tejun Heo <tj@kernel.org>
Cc: Tony Luck <tony.luck@intel.com>
Cc: Fenghua Yu <fenghua.yu@intel.com>
Cc: David Howells <dhowells@redhat.com>
Cc: <linux-arch@vger.kernel.org>
Signed-off-by: default avatarAndrew Morton <akpm@linux-foundation.org>
Signed-off-by: default avatarLinus Torvalds <torvalds@linux-foundation.org>
parent 9d502c1c

arch/frv/include/asm/processor.h

+1 −1
Original line number Diff line number Diff line
@@ -137,7 +137,7 @@ unsigned long get_wchan(struct task_struct *p); 
#define	KSTK_ESP(tsk)	((tsk)->thread.frame0->sp)



/* Allocation and freeing of basic task resources. */

extern struct task_struct *alloc_task_struct(void);

extern struct task_struct *alloc_task_struct_node(int node);

extern void free_task_struct(struct task_struct *p);



#define cpu_relax()    barrier()

arch/frv/kernel/process.c

+3 −2
Original line number Diff line number Diff line
@@ -44,9 +44,10 @@ asmlinkage void ret_from_fork(void); 
void (*pm_power_off)(void);

EXPORT_SYMBOL(pm_power_off);



struct task_struct *alloc_task_struct(void)

struct task_struct *alloc_task_struct_node(int node)

{

	struct task_struct *p = kmalloc(THREAD_SIZE, GFP_KERNEL);

	struct task_struct *p = kmalloc_node(THREAD_SIZE, GFP_KERNEL, node);



	if (p)

		atomic_set((atomic_t *)(p+1), 1);

	return p;

arch/ia64/include/asm/thread_info.h

+8 −1
Original line number Diff line number Diff line
@@ -84,7 +84,14 @@ struct thread_info { 
#define end_of_stack(p) (unsigned long *)((void *)(p) + IA64_RBS_OFFSET)



#define __HAVE_ARCH_TASK_STRUCT_ALLOCATOR

#define alloc_task_struct()	((struct task_struct *)__get_free_pages(GFP_KERNEL | __GFP_COMP, KERNEL_STACK_SIZE_ORDER))

#define alloc_task_struct_node(node)						\

({										\

	struct page *page = alloc_pages_node(node, GFP_KERNEL | __GFP_COMP,	\

					     KERNEL_STACK_SIZE_ORDER);		\

	struct task_struct *ret = page ? page_address(page) : NULL;		\

										\

	ret;

})

#define free_task_struct(tsk)	free_pages((unsigned long) (tsk), KERNEL_STACK_SIZE_ORDER)



#endif /* !__ASSEMBLY */

arch/um/include/asm/processor-generic.h

+1 −1
Original line number Diff line number Diff line
@@ -66,7 +66,7 @@ struct thread_struct { 
	.request		= { 0 } \

}



extern struct task_struct *alloc_task_struct(void);

extern struct task_struct *alloc_task_struct_node(int node);



static inline void release_thread(struct task_struct *task)

{

kernel/fork.c

+6 −4
Original line number Diff line number Diff line
@@ -109,8 +109,10 @@ int nr_processes(void) 
}



#ifndef __HAVE_ARCH_TASK_STRUCT_ALLOCATOR

# define alloc_task_struct()	kmem_cache_alloc(task_struct_cachep, GFP_KERNEL)

# define free_task_struct(tsk)	kmem_cache_free(task_struct_cachep, (tsk))

# define alloc_task_struct_node(node)		\

		kmem_cache_alloc_node(task_struct_cachep, GFP_KERNEL, node)

# define free_task_struct(tsk)			\

		kmem_cache_free(task_struct_cachep, (tsk))

static struct kmem_cache *task_struct_cachep;

#endif
@@ -249,12 +251,12 @@ static struct task_struct *dup_task_struct(struct task_struct *orig) 
	struct task_struct *tsk;

	struct thread_info *ti;

	unsigned long *stackend;



	int node = numa_node_id();

	int err;



	prepare_to_copy(orig);



	tsk = alloc_task_struct();

	tsk = alloc_task_struct_node(node);

	if (!tsk)

		return NULL;