Skip to content

Commit

Permalink
[PATCH] Add kthread_stop_sem()
Browse files Browse the repository at this point in the history
Enhance the kthread API by adding kthread_stop_sem, for use in stopping
threads that spend their idle time waiting on a semaphore.

Signed-off-by: Alan Stern <[email protected]>
Signed-off-by: Andrew Morton <[email protected]>
Signed-off-by: Linus Torvalds <[email protected]>
  • Loading branch information
AlanStern authored and Linus Torvalds committed Oct 31, 2005
1 parent 83521d3 commit 61e1a9e
Show file tree
Hide file tree
Showing 2 changed files with 23 additions and 2 deletions.
12 changes: 12 additions & 0 deletions include/linux/kthread.h
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,18 @@ void kthread_bind(struct task_struct *k, unsigned int cpu);
* was never called. */
int kthread_stop(struct task_struct *k);

/**
* kthread_stop_sem: stop a thread created by kthread_create().
* @k: thread created by kthread_create().
* @s: semaphore that @k waits on while idle.
*
* Does essentially the same thing as kthread_stop() above, but wakes
* @k by calling up(@s).
*
* Returns the result of threadfn(), or -EINTR if wake_up_process()
* was never called. */
int kthread_stop_sem(struct task_struct *k, struct semaphore *s);

/**
* kthread_should_stop: should this kthread return now?
*
Expand Down
13 changes: 11 additions & 2 deletions kernel/kthread.c
Original file line number Diff line number Diff line change
Expand Up @@ -164,6 +164,12 @@ void kthread_bind(struct task_struct *k, unsigned int cpu)
EXPORT_SYMBOL(kthread_bind);

int kthread_stop(struct task_struct *k)
{
return kthread_stop_sem(k, NULL);
}
EXPORT_SYMBOL(kthread_stop);

int kthread_stop_sem(struct task_struct *k, struct semaphore *s)
{
int ret;

Expand All @@ -178,7 +184,10 @@ int kthread_stop(struct task_struct *k)

/* Now set kthread_should_stop() to true, and wake it up. */
kthread_stop_info.k = k;
wake_up_process(k);
if (s)
up(s);
else
wake_up_process(k);
put_task_struct(k);

/* Once it dies, reset stop ptr, gather result and we're done. */
Expand All @@ -189,7 +198,7 @@ int kthread_stop(struct task_struct *k)

return ret;
}
EXPORT_SYMBOL(kthread_stop);
EXPORT_SYMBOL(kthread_stop_sem);

static __init int helper_init(void)
{
Expand Down

0 comments on commit 61e1a9e

Please sign in to comment.