[PATCH] PM: Fix SMP races in the freezer
[pv_ops_mirror.git] / kernel / power / process.c
blob6d566bf7085c0b4fd7803a14cbaabef07269198e
1 /*
2 * drivers/power/process.c - Functions for starting/stopping processes on
3 * suspend transitions.
5 * Originally from swsusp.
6 */
9 #undef DEBUG
11 #include <linux/smp_lock.h>
12 #include <linux/interrupt.h>
13 #include <linux/suspend.h>
14 #include <linux/module.h>
15 #include <linux/syscalls.h>
16 #include <linux/freezer.h>
18 /*
19 * Timeout for stopping processes
21 #define TIMEOUT (20 * HZ)
23 #define FREEZER_KERNEL_THREADS 0
24 #define FREEZER_USER_SPACE 1
26 static inline int freezeable(struct task_struct * p)
28 if ((p == current) ||
29 (p->flags & PF_NOFREEZE) ||
30 (p->exit_state == EXIT_ZOMBIE) ||
31 (p->exit_state == EXIT_DEAD))
32 return 0;
33 return 1;
36 /* Refrigerator is place where frozen processes are stored :-). */
37 void refrigerator(void)
39 /* Hmm, should we be allowed to suspend when there are realtime
40 processes around? */
41 long save;
42 save = current->state;
43 pr_debug("%s entered refrigerator\n", current->comm);
45 frozen_process(current);
46 spin_lock_irq(&current->sighand->siglock);
47 recalc_sigpending(); /* We sent fake signal, clean it up */
48 spin_unlock_irq(&current->sighand->siglock);
50 while (frozen(current)) {
51 current->state = TASK_UNINTERRUPTIBLE;
52 schedule();
54 pr_debug("%s left refrigerator\n", current->comm);
55 current->state = save;
58 static inline void freeze_process(struct task_struct *p)
60 unsigned long flags;
62 if (!freezing(p)) {
63 rmb();
64 if (!frozen(p)) {
65 if (p->state == TASK_STOPPED)
66 force_sig_specific(SIGSTOP, p);
68 freeze(p);
69 spin_lock_irqsave(&p->sighand->siglock, flags);
70 signal_wake_up(p, p->state == TASK_STOPPED);
71 spin_unlock_irqrestore(&p->sighand->siglock, flags);
76 static void cancel_freezing(struct task_struct *p)
78 unsigned long flags;
80 if (freezing(p)) {
81 pr_debug(" clean up: %s\n", p->comm);
82 do_not_freeze(p);
83 spin_lock_irqsave(&p->sighand->siglock, flags);
84 recalc_sigpending_tsk(p);
85 spin_unlock_irqrestore(&p->sighand->siglock, flags);
89 static inline int is_user_space(struct task_struct *p)
91 return p->mm && !(p->flags & PF_BORROWED_MM);
94 static unsigned int try_to_freeze_tasks(int freeze_user_space)
96 struct task_struct *g, *p;
97 unsigned long end_time;
98 unsigned int todo;
100 end_time = jiffies + TIMEOUT;
101 do {
102 todo = 0;
103 read_lock(&tasklist_lock);
104 do_each_thread(g, p) {
105 if (!freezeable(p))
106 continue;
108 if (frozen(p))
109 continue;
111 if (p->state == TASK_TRACED && frozen(p->parent)) {
112 cancel_freezing(p);
113 continue;
115 if (is_user_space(p)) {
116 if (!freeze_user_space)
117 continue;
119 /* Freeze the task unless there is a vfork
120 * completion pending
122 if (!p->vfork_done)
123 freeze_process(p);
124 } else {
125 if (freeze_user_space)
126 continue;
128 freeze_process(p);
130 todo++;
131 } while_each_thread(g, p);
132 read_unlock(&tasklist_lock);
133 yield(); /* Yield is okay here */
134 if (todo && time_after(jiffies, end_time))
135 break;
136 } while (todo);
138 if (todo) {
139 /* This does not unfreeze processes that are already frozen
140 * (we have slightly ugly calling convention in that respect,
141 * and caller must call thaw_processes() if something fails),
142 * but it cleans up leftover PF_FREEZE requests.
144 printk("\n");
145 printk(KERN_ERR "Stopping %s timed out after %d seconds "
146 "(%d tasks refusing to freeze):\n",
147 freeze_user_space ? "user space processes" :
148 "kernel threads",
149 TIMEOUT / HZ, todo);
150 read_lock(&tasklist_lock);
151 do_each_thread(g, p) {
152 if (is_user_space(p) == !freeze_user_space)
153 continue;
155 if (freezeable(p) && !frozen(p))
156 printk(KERN_ERR " %s\n", p->comm);
158 cancel_freezing(p);
159 } while_each_thread(g, p);
160 read_unlock(&tasklist_lock);
163 return todo;
167 * freeze_processes - tell processes to enter the refrigerator
169 * Returns 0 on success, or the number of processes that didn't freeze,
170 * although they were told to.
172 int freeze_processes(void)
174 unsigned int nr_unfrozen;
176 printk("Stopping tasks ... ");
177 nr_unfrozen = try_to_freeze_tasks(FREEZER_USER_SPACE);
178 if (nr_unfrozen)
179 return nr_unfrozen;
181 sys_sync();
182 nr_unfrozen = try_to_freeze_tasks(FREEZER_KERNEL_THREADS);
183 if (nr_unfrozen)
184 return nr_unfrozen;
186 printk("done.\n");
187 BUG_ON(in_atomic());
188 return 0;
191 static void thaw_tasks(int thaw_user_space)
193 struct task_struct *g, *p;
195 read_lock(&tasklist_lock);
196 do_each_thread(g, p) {
197 if (!freezeable(p))
198 continue;
200 if (is_user_space(p) == !thaw_user_space)
201 continue;
203 if (!thaw_process(p))
204 printk(KERN_WARNING " Strange, %s not stopped\n",
205 p->comm );
206 } while_each_thread(g, p);
207 read_unlock(&tasklist_lock);
210 void thaw_processes(void)
212 printk("Restarting tasks ... ");
213 thaw_tasks(FREEZER_KERNEL_THREADS);
214 thaw_tasks(FREEZER_USER_SPACE);
215 schedule();
216 printk("done.\n");
219 EXPORT_SYMBOL(refrigerator);