X-Git-Url: http://v3vee.org/palacios/gitweb/gitweb.cgi?a=blobdiff_plain;f=linux_module%2Fpalacios-stubs.c;h=8eeeb7dcafa9e8637663e0975b32e24d85b7674d;hb=b1128b2a9d269fefc786c60c26878b372d5e39c1;hp=05789fb2e4eb02366651c46b7e02d1a7302b1f4e;hpb=ed7cae62acb31ddd833c7efb0f6cda1b4915e7cb;p=palacios.git diff --git a/linux_module/palacios-stubs.c b/linux_module/palacios-stubs.c index 05789fb..8eeeb7d 100644 --- a/linux_module/palacios-stubs.c +++ b/linux_module/palacios-stubs.c @@ -180,7 +180,7 @@ static int lnx_thread_target(void * arg) { /** * Creates a kernel thread. */ -static void +static void * palacios_start_kernel_thread( int (*fn) (void * arg), void * arg, @@ -192,8 +192,7 @@ palacios_start_kernel_thread( thread_info->arg = arg; thread_info->name = thread_name; - kthread_run( lnx_thread_target, thread_info, thread_name ); - return; + return kthread_run( lnx_thread_target, thread_info, thread_name ); } @@ -220,12 +219,37 @@ palacios_start_thread_on_cpu(int cpu_id, return NULL; } - kthread_bind(thread, cpu_id); + set_cpus_allowed_ptr(thread, cpumask_of(cpu_id)); wake_up_process(thread); return thread; } + +/** + * Rebind a kernel thread to the specified CPU + * The thread will be running on target CPU on return + * non-zero return means failure + */ +static int +palacios_move_thread_to_cpu(int new_cpu_id, + void * thread_ptr) { + struct task_struct * thread = (struct task_struct *)thread_ptr; + + printk("Moving thread (%p) to cpu %d\n", thread, new_cpu_id); + + if (thread == NULL) { + thread = current; + } + + /* + * Bind to the specified CPU. When this call returns, + * the thread should be running on the target CPU. + */ + return set_cpus_allowed_ptr(thread, cpumask_of(new_cpu_id)); +} + + /** * Returns the CPU ID that the caller is running on. */ @@ -461,6 +485,7 @@ static struct v3_os_hooks palacios_os_hooks = { .interrupt_cpu = palacios_interrupt_cpu, .call_on_cpu = palacios_xcall, .start_thread_on_cpu = palacios_start_thread_on_cpu, + .move_thread_to_cpu = palacios_move_thread_to_cpu, };