Blame view

kernel/task_work.c 2.17 KB
e73f8959a   Oleg Nesterov   task_work_add: ge...
1
2
3
  #include <linux/spinlock.h>
  #include <linux/task_work.h>
  #include <linux/tracehook.h>
9da33de62   Oleg Nesterov   task_work: task_w...
4
  static struct callback_head work_exited; /* all we need is ->next == NULL */
e73f8959a   Oleg Nesterov   task_work_add: ge...
5
  int
ac3d0da8f   Oleg Nesterov   task_work: Make t...
6
  task_work_add(struct task_struct *task, struct callback_head *work, bool notify)
e73f8959a   Oleg Nesterov   task_work_add: ge...
7
  {
ac3d0da8f   Oleg Nesterov   task_work: Make t...
8
  	struct callback_head *head;
9da33de62   Oleg Nesterov   task_work: task_w...
9

ac3d0da8f   Oleg Nesterov   task_work: Make t...
10
11
  	do {
  		head = ACCESS_ONCE(task->task_works);
9da33de62   Oleg Nesterov   task_work: task_w...
12
13
  		if (unlikely(head == &work_exited))
  			return -ESRCH;
ac3d0da8f   Oleg Nesterov   task_work: Make t...
14
15
  		work->next = head;
  	} while (cmpxchg(&task->task_works, head, work) != head);
e73f8959a   Oleg Nesterov   task_work_add: ge...
16

ed3e694d7   Al Viro   move exit_task_wo...
17
  	if (notify)
e73f8959a   Oleg Nesterov   task_work_add: ge...
18
  		set_notify_resume(task);
ed3e694d7   Al Viro   move exit_task_wo...
19
  	return 0;
e73f8959a   Oleg Nesterov   task_work_add: ge...
20
  }
67d121455   Al Viro   merge task_work a...
21
  struct callback_head *
e73f8959a   Oleg Nesterov   task_work_add: ge...
22
23
  task_work_cancel(struct task_struct *task, task_work_func_t func)
  {
ac3d0da8f   Oleg Nesterov   task_work: Make t...
24
25
  	struct callback_head **pprev = &task->task_works;
  	struct callback_head *work = NULL;
e73f8959a   Oleg Nesterov   task_work_add: ge...
26
  	unsigned long flags;
ac3d0da8f   Oleg Nesterov   task_work: Make t...
27
28
29
30
  	/*
  	 * If cmpxchg() fails we continue without updating pprev.
  	 * Either we raced with task_work_add() which added the
  	 * new entry before this work, we will find it again. Or
9da33de62   Oleg Nesterov   task_work: task_w...
31
  	 * we raced with task_work_run(), *pprev == NULL/exited.
ac3d0da8f   Oleg Nesterov   task_work: Make t...
32
  	 */
e73f8959a   Oleg Nesterov   task_work_add: ge...
33
  	raw_spin_lock_irqsave(&task->pi_lock, flags);
ac3d0da8f   Oleg Nesterov   task_work: Make t...
34
35
36
37
38
39
  	while ((work = ACCESS_ONCE(*pprev))) {
  		read_barrier_depends();
  		if (work->func != func)
  			pprev = &work->next;
  		else if (cmpxchg(pprev, work, work->next) == work)
  			break;
e73f8959a   Oleg Nesterov   task_work_add: ge...
40
  	}
e73f8959a   Oleg Nesterov   task_work_add: ge...
41
  	raw_spin_unlock_irqrestore(&task->pi_lock, flags);
ac3d0da8f   Oleg Nesterov   task_work: Make t...
42
43
  
  	return work;
e73f8959a   Oleg Nesterov   task_work_add: ge...
44
45
46
47
48
  }
  
  void task_work_run(void)
  {
  	struct task_struct *task = current;
ac3d0da8f   Oleg Nesterov   task_work: Make t...
49
  	struct callback_head *work, *head, *next;
e73f8959a   Oleg Nesterov   task_work_add: ge...
50

ac3d0da8f   Oleg Nesterov   task_work: Make t...
51
  	for (;;) {
9da33de62   Oleg Nesterov   task_work: task_w...
52
53
54
55
56
57
58
59
60
  		/*
  		 * work->func() can do task_work_add(), do not set
  		 * work_exited unless the list is empty.
  		 */
  		do {
  			work = ACCESS_ONCE(task->task_works);
  			head = !work && (task->flags & PF_EXITING) ?
  				&work_exited : NULL;
  		} while (cmpxchg(&task->task_works, work, head) != work);
ac3d0da8f   Oleg Nesterov   task_work: Make t...
61
62
63
64
65
66
67
68
69
  		if (!work)
  			break;
  		/*
  		 * Synchronize with task_work_cancel(). It can't remove
  		 * the first entry == work, cmpxchg(task_works) should
  		 * fail, but it can play with *work and other entries.
  		 */
  		raw_spin_unlock_wait(&task->pi_lock);
  		smp_mb();
e73f8959a   Oleg Nesterov   task_work_add: ge...
70

ac3d0da8f   Oleg Nesterov   task_work: Make t...
71
72
73
74
75
76
77
78
  		/* Reverse the list to run the works in fifo order */
  		head = NULL;
  		do {
  			next = work->next;
  			work->next = head;
  			head = work;
  			work = next;
  		} while (work);
e73f8959a   Oleg Nesterov   task_work_add: ge...
79

ac3d0da8f   Oleg Nesterov   task_work: Make t...
80
81
82
83
84
  		work = head;
  		do {
  			next = work->next;
  			work->func(work);
  			work = next;
f341861fb   Eric Dumazet   task_work: add a ...
85
  			cond_resched();
ac3d0da8f   Oleg Nesterov   task_work: Make t...
86
  		} while (work);
e73f8959a   Oleg Nesterov   task_work_add: ge...
87
88
  	}
  }