diff options
Diffstat (limited to 'kernel/kthread.c')
| -rw-r--r-- | kernel/kthread.c | 63 |
1 files changed, 51 insertions, 12 deletions
diff --git a/kernel/kthread.c b/kernel/kthread.c index c5f3c6613b6d..4f9c60ef95e8 100644 --- a/kernel/kthread.c +++ b/kernel/kthread.c | |||
| @@ -45,6 +45,13 @@ struct kthread_stop_info | |||
| 45 | static DEFINE_MUTEX(kthread_stop_lock); | 45 | static DEFINE_MUTEX(kthread_stop_lock); |
| 46 | static struct kthread_stop_info kthread_stop_info; | 46 | static struct kthread_stop_info kthread_stop_info; |
| 47 | 47 | ||
| 48 | /** | ||
| 49 | * kthread_should_stop - should this kthread return now? | ||
| 50 | * | ||
| 51 | * When someone calls kthread_stop on your kthread, it will be woken | ||
| 52 | * and this will return true. You should then return, and your return | ||
| 53 | * value will be passed through to kthread_stop(). | ||
| 54 | */ | ||
| 48 | int kthread_should_stop(void) | 55 | int kthread_should_stop(void) |
| 49 | { | 56 | { |
| 50 | return (kthread_stop_info.k == current); | 57 | return (kthread_stop_info.k == current); |
| @@ -122,6 +129,25 @@ static void keventd_create_kthread(void *_create) | |||
| 122 | complete(&create->done); | 129 | complete(&create->done); |
| 123 | } | 130 | } |
| 124 | 131 | ||
| 132 | /** | ||
| 133 | * kthread_create - create a kthread. | ||
| 134 | * @threadfn: the function to run until signal_pending(current). | ||
| 135 | * @data: data ptr for @threadfn. | ||
| 136 | * @namefmt: printf-style name for the thread. | ||
| 137 | * | ||
| 138 | * Description: This helper function creates and names a kernel | ||
| 139 | * thread. The thread will be stopped: use wake_up_process() to start | ||
| 140 | * it. See also kthread_run(), kthread_create_on_cpu(). | ||
| 141 | * | ||
| 142 | * When woken, the thread will run @threadfn() with @data as its | ||
| 143 | * argument. @threadfn can either call do_exit() directly if it is a | ||
| 144 | * standalone thread for which noone will call kthread_stop(), or | ||
| 145 | * return when 'kthread_should_stop()' is true (which means | ||
| 146 | * kthread_stop() has been called). The return value should be zero | ||
| 147 | * or a negative error number; it will be passed to kthread_stop(). | ||
| 148 | * | ||
| 149 | * Returns a task_struct or ERR_PTR(-ENOMEM). | ||
| 150 | */ | ||
| 125 | struct task_struct *kthread_create(int (*threadfn)(void *data), | 151 | struct task_struct *kthread_create(int (*threadfn)(void *data), |
| 126 | void *data, | 152 | void *data, |
| 127 | const char namefmt[], | 153 | const char namefmt[], |
| @@ -156,6 +182,15 @@ struct task_struct *kthread_create(int (*threadfn)(void *data), | |||
| 156 | } | 182 | } |
| 157 | EXPORT_SYMBOL(kthread_create); | 183 | EXPORT_SYMBOL(kthread_create); |
| 158 | 184 | ||
| 185 | /** | ||
| 186 | * kthread_bind - bind a just-created kthread to a cpu. | ||
| 187 | * @k: thread created by kthread_create(). | ||
| 188 | * @cpu: cpu (might not be online, must be possible) for @k to run on. | ||
| 189 | * | ||
| 190 | * Description: This function is equivalent to set_cpus_allowed(), | ||
| 191 | * except that @cpu doesn't need to be online, and the thread must be | ||
| 192 | * stopped (i.e., just returned from kthread_create(). | ||
| 193 | */ | ||
| 159 | void kthread_bind(struct task_struct *k, unsigned int cpu) | 194 | void kthread_bind(struct task_struct *k, unsigned int cpu) |
| 160 | { | 195 | { |
| 161 | BUG_ON(k->state != TASK_INTERRUPTIBLE); | 196 | BUG_ON(k->state != TASK_INTERRUPTIBLE); |
| @@ -166,14 +201,21 @@ void kthread_bind(struct task_struct *k, unsigned int cpu) | |||
| 166 | } | 201 | } |
| 167 | EXPORT_SYMBOL(kthread_bind); | 202 | EXPORT_SYMBOL(kthread_bind); |
| 168 | 203 | ||
| 204 | /** | ||
| 205 | * kthread_stop - stop a thread created by kthread_create(). | ||
| 206 | * @k: thread created by kthread_create(). | ||
| 207 | * | ||
| 208 | * Sets kthread_should_stop() for @k to return true, wakes it, and | ||
| 209 | * waits for it to exit. Your threadfn() must not call do_exit() | ||
| 210 | * itself if you use this function! This can also be called after | ||
| 211 | * kthread_create() instead of calling wake_up_process(): the thread | ||
| 212 | * will exit without calling threadfn(). | ||
| 213 | * | ||
| 214 | * Returns the result of threadfn(), or %-EINTR if wake_up_process() | ||
| 215 | * was never called. | ||
| 216 | */ | ||
| 169 | int kthread_stop(struct task_struct *k) | 217 | int kthread_stop(struct task_struct *k) |
| 170 | { | 218 | { |
| 171 | return kthread_stop_sem(k, NULL); | ||
| 172 | } | ||
| 173 | EXPORT_SYMBOL(kthread_stop); | ||
| 174 | |||
| 175 | int kthread_stop_sem(struct task_struct *k, struct semaphore *s) | ||
| 176 | { | ||
| 177 | int ret; | 219 | int ret; |
| 178 | 220 | ||
| 179 | mutex_lock(&kthread_stop_lock); | 221 | mutex_lock(&kthread_stop_lock); |
| @@ -187,10 +229,7 @@ int kthread_stop_sem(struct task_struct *k, struct semaphore *s) | |||
| 187 | 229 | ||
| 188 | /* Now set kthread_should_stop() to true, and wake it up. */ | 230 | /* Now set kthread_should_stop() to true, and wake it up. */ |
| 189 | kthread_stop_info.k = k; | 231 | kthread_stop_info.k = k; |
| 190 | if (s) | 232 | wake_up_process(k); |
| 191 | up(s); | ||
| 192 | else | ||
| 193 | wake_up_process(k); | ||
| 194 | put_task_struct(k); | 233 | put_task_struct(k); |
| 195 | 234 | ||
| 196 | /* Once it dies, reset stop ptr, gather result and we're done. */ | 235 | /* Once it dies, reset stop ptr, gather result and we're done. */ |
| @@ -201,7 +240,7 @@ int kthread_stop_sem(struct task_struct *k, struct semaphore *s) | |||
| 201 | 240 | ||
| 202 | return ret; | 241 | return ret; |
| 203 | } | 242 | } |
| 204 | EXPORT_SYMBOL(kthread_stop_sem); | 243 | EXPORT_SYMBOL(kthread_stop); |
| 205 | 244 | ||
| 206 | static __init int helper_init(void) | 245 | static __init int helper_init(void) |
| 207 | { | 246 | { |
| @@ -210,5 +249,5 @@ static __init int helper_init(void) | |||
| 210 | 249 | ||
| 211 | return 0; | 250 | return 0; |
| 212 | } | 251 | } |
| 213 | core_initcall(helper_init); | ||
| 214 | 252 | ||
| 253 | core_initcall(helper_init); | ||
