diff options
| author | Dmitry Torokhov <dtor_core@ameritech.net> | 2006-06-26 01:31:38 -0400 |
|---|---|---|
| committer | Dmitry Torokhov <dtor_core@ameritech.net> | 2006-06-26 01:31:38 -0400 |
| commit | 4854c7b27f0975a2b629f35ea3996d2968eb7c4f (patch) | |
| tree | 4102bdb70289764a2058aff0f907b13d7cf0e0d1 /kernel/kthread.c | |
| parent | 3cbd5b32cb625f5c0f1b1476d154fac873dd49ce (diff) | |
| parent | fcc18e83e1f6fd9fa6b333735bf0fcd530655511 (diff) | |
Merge rsync://rsync.kernel.org/pub/scm/linux/kernel/git/torvalds/linux-2.6
Diffstat (limited to 'kernel/kthread.c')
| -rw-r--r-- | kernel/kthread.c | 61 |
1 files changed, 60 insertions, 1 deletions
diff --git a/kernel/kthread.c b/kernel/kthread.c index c5f3c6613b6d..24be714b04c7 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,12 +201,36 @@ 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); | 219 | return kthread_stop_sem(k, NULL); |
| 172 | } | 220 | } |
| 173 | EXPORT_SYMBOL(kthread_stop); | 221 | EXPORT_SYMBOL(kthread_stop); |
| 174 | 222 | ||
| 223 | /** | ||
| 224 | * kthread_stop_sem - stop a thread created by kthread_create(). | ||
| 225 | * @k: thread created by kthread_create(). | ||
| 226 | * @s: semaphore that @k waits on while idle. | ||
| 227 | * | ||
| 228 | * Does essentially the same thing as kthread_stop() above, but wakes | ||
| 229 | * @k by calling up(@s). | ||
| 230 | * | ||
| 231 | * Returns the result of threadfn(), or %-EINTR if wake_up_process() | ||
| 232 | * was never called. | ||
| 233 | */ | ||
| 175 | int kthread_stop_sem(struct task_struct *k, struct semaphore *s) | 234 | int kthread_stop_sem(struct task_struct *k, struct semaphore *s) |
| 176 | { | 235 | { |
| 177 | int ret; | 236 | int ret; |
| @@ -210,5 +269,5 @@ static __init int helper_init(void) | |||
| 210 | 269 | ||
| 211 | return 0; | 270 | return 0; |
| 212 | } | 271 | } |
| 213 | core_initcall(helper_init); | ||
| 214 | 272 | ||
| 273 | core_initcall(helper_init); | ||
