1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25#include <linux/cache.h>
26#include <linux/spinlock.h>
27#include <linux/threads.h>
28#include <linux/cpumask.h>
29#include <linux/seqlock.h>
30
31
32
33
34
35
36
37#define MAX_RCU_LVLS 4
38#if CONFIG_RCU_FANOUT > 16
39#define RCU_FANOUT_LEAF 16
40#else
41#define RCU_FANOUT_LEAF (CONFIG_RCU_FANOUT)
42#endif
43#define RCU_FANOUT_1 (RCU_FANOUT_LEAF)
44#define RCU_FANOUT_2 (RCU_FANOUT_1 * CONFIG_RCU_FANOUT)
45#define RCU_FANOUT_3 (RCU_FANOUT_2 * CONFIG_RCU_FANOUT)
46#define RCU_FANOUT_4 (RCU_FANOUT_3 * CONFIG_RCU_FANOUT)
47
48#if NR_CPUS <= RCU_FANOUT_1
49# define NUM_RCU_LVLS 1
50# define NUM_RCU_LVL_0 1
51# define NUM_RCU_LVL_1 (NR_CPUS)
52# define NUM_RCU_LVL_2 0
53# define NUM_RCU_LVL_3 0
54# define NUM_RCU_LVL_4 0
55#elif NR_CPUS <= RCU_FANOUT_2
56# define NUM_RCU_LVLS 2
57# define NUM_RCU_LVL_0 1
58# define NUM_RCU_LVL_1 DIV_ROUND_UP(NR_CPUS, RCU_FANOUT_1)
59# define NUM_RCU_LVL_2 (NR_CPUS)
60# define NUM_RCU_LVL_3 0
61# define NUM_RCU_LVL_4 0
62#elif NR_CPUS <= RCU_FANOUT_3
63# define NUM_RCU_LVLS 3
64# define NUM_RCU_LVL_0 1
65# define NUM_RCU_LVL_1 DIV_ROUND_UP(NR_CPUS, RCU_FANOUT_2)
66# define NUM_RCU_LVL_2 DIV_ROUND_UP(NR_CPUS, RCU_FANOUT_1)
67# define NUM_RCU_LVL_3 (NR_CPUS)
68# define NUM_RCU_LVL_4 0
69#elif NR_CPUS <= RCU_FANOUT_4
70# define NUM_RCU_LVLS 4
71# define NUM_RCU_LVL_0 1
72# define NUM_RCU_LVL_1 DIV_ROUND_UP(NR_CPUS, RCU_FANOUT_3)
73# define NUM_RCU_LVL_2 DIV_ROUND_UP(NR_CPUS, RCU_FANOUT_2)
74# define NUM_RCU_LVL_3 DIV_ROUND_UP(NR_CPUS, RCU_FANOUT_1)
75# define NUM_RCU_LVL_4 (NR_CPUS)
76#else
77# error "CONFIG_RCU_FANOUT insufficient for NR_CPUS"
78#endif
79
80#define RCU_SUM (NUM_RCU_LVL_0 + NUM_RCU_LVL_1 + NUM_RCU_LVL_2 + NUM_RCU_LVL_3 + NUM_RCU_LVL_4)
81#define NUM_RCU_NODES (RCU_SUM - NR_CPUS)
82
83
84
85
86struct rcu_dynticks {
87 long long dynticks_nesting;
88
89 int dynticks_nmi_nesting;
90 atomic_t dynticks;
91};
92
93
94#define RCU_KTHREAD_STOPPED 0
95#define RCU_KTHREAD_RUNNING 1
96#define RCU_KTHREAD_WAITING 2
97#define RCU_KTHREAD_OFFCPU 3
98#define RCU_KTHREAD_YIELDING 4
99#define RCU_KTHREAD_MAX 4
100
101
102
103
104struct rcu_node {
105 raw_spinlock_t lock;
106
107 unsigned long gpnum;
108
109
110 unsigned long completed;
111
112
113 unsigned long qsmask;
114
115
116
117
118
119 unsigned long expmask;
120
121
122
123 atomic_t wakemask;
124
125
126 unsigned long qsmaskinit;
127
128 unsigned long grpmask;
129
130 int grplo;
131 int grphi;
132 u8 grpnum;
133 u8 level;
134 struct rcu_node *parent;
135 struct list_head blkd_tasks;
136
137
138
139 struct list_head *gp_tasks;
140
141
142
143 struct list_head *exp_tasks;
144
145
146
147
148
149#ifdef CONFIG_RCU_BOOST
150 struct list_head *boost_tasks;
151
152
153
154
155
156
157
158 unsigned long boost_time;
159
160 struct task_struct *boost_kthread_task;
161
162
163 unsigned int boost_kthread_status;
164
165 unsigned long n_tasks_boosted;
166
167 unsigned long n_exp_boosts;
168
169 unsigned long n_normal_boosts;
170
171 unsigned long n_balk_blkd_tasks;
172
173 unsigned long n_balk_exp_gp_tasks;
174
175 unsigned long n_balk_boost_tasks;
176
177 unsigned long n_balk_notblocked;
178
179 unsigned long n_balk_notyet;
180
181 unsigned long n_balk_nos;
182
183
184#endif
185 struct task_struct *node_kthread_task;
186
187
188
189 unsigned int node_kthread_status;
190
191} ____cacheline_internodealigned_in_smp;
192
193
194
195
196
197#define rcu_for_each_node_breadth_first(rsp, rnp) \
198 for ((rnp) = &(rsp)->node[0]; \
199 (rnp) < &(rsp)->node[NUM_RCU_NODES]; (rnp)++)
200
201
202
203
204
205
206#define rcu_for_each_nonleaf_node_breadth_first(rsp, rnp) \
207 for ((rnp) = &(rsp)->node[0]; \
208 (rnp) < (rsp)->level[NUM_RCU_LVLS - 1]; (rnp)++)
209
210
211
212
213
214
215
216#define rcu_for_each_leaf_node(rsp, rnp) \
217 for ((rnp) = (rsp)->level[NUM_RCU_LVLS - 1]; \
218 (rnp) < &(rsp)->node[NUM_RCU_NODES]; (rnp)++)
219
220
221#define RCU_DONE_TAIL 0
222#define RCU_WAIT_TAIL 1
223#define RCU_NEXT_READY_TAIL 2
224#define RCU_NEXT_TAIL 3
225#define RCU_NEXT_SIZE 4
226
227
228struct rcu_data {
229
230 unsigned long completed;
231
232 unsigned long gpnum;
233
234 unsigned long passed_quiesce_gpnum;
235
236 bool passed_quiesce;
237 bool qs_pending;
238 bool beenonline;
239 bool preemptible;
240 struct rcu_node *mynode;
241 unsigned long grpmask;
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266 struct rcu_head *nxtlist;
267 struct rcu_head **nxttail[RCU_NEXT_SIZE];
268 long qlen;
269 long qlen_last_fqs_check;
270
271 unsigned long n_cbs_invoked;
272 unsigned long n_cbs_orphaned;
273 unsigned long n_cbs_adopted;
274 unsigned long n_force_qs_snap;
275
276 long blimit;
277
278
279 struct rcu_dynticks *dynticks;
280 int dynticks_snap;
281
282
283 unsigned long dynticks_fqs;
284 unsigned long offline_fqs;
285 unsigned long resched_ipi;
286
287
288 unsigned long n_rcu_pending;
289 unsigned long n_rp_qs_pending;
290 unsigned long n_rp_report_qs;
291 unsigned long n_rp_cb_ready;
292 unsigned long n_rp_cpu_needs_gp;
293 unsigned long n_rp_gp_completed;
294 unsigned long n_rp_gp_started;
295 unsigned long n_rp_need_fqs;
296 unsigned long n_rp_need_nothing;
297
298 int cpu;
299 struct rcu_state *rsp;
300};
301
302
303#define RCU_GP_IDLE 0
304#define RCU_GP_INIT 1
305#define RCU_SAVE_DYNTICK 2
306#define RCU_FORCE_QS 3
307#define RCU_SIGNAL_INIT RCU_SAVE_DYNTICK
308
309#define RCU_JIFFIES_TILL_FORCE_QS 3
310
311#ifdef CONFIG_PROVE_RCU
312#define RCU_STALL_DELAY_DELTA (5 * HZ)
313#else
314#define RCU_STALL_DELAY_DELTA 0
315#endif
316
317#define RCU_SECONDS_TILL_STALL_CHECK (CONFIG_RCU_CPU_STALL_TIMEOUT * HZ + \
318 RCU_STALL_DELAY_DELTA)
319
320#define RCU_SECONDS_TILL_STALL_RECHECK (3 * RCU_SECONDS_TILL_STALL_CHECK + 30)
321
322#define RCU_STALL_RAT_DELAY 2
323
324
325
326
327#define rcu_wait(cond) \
328do { \
329 for (;;) { \
330 set_current_state(TASK_INTERRUPTIBLE); \
331 if (cond) \
332 break; \
333 schedule(); \
334 } \
335 __set_current_state(TASK_RUNNING); \
336} while (0)
337
338
339
340
341
342
343
344
345
346
347
348struct rcu_state {
349 struct rcu_node node[NUM_RCU_NODES];
350 struct rcu_node *level[NUM_RCU_LVLS];
351 u32 levelcnt[MAX_RCU_LVLS + 1];
352 u8 levelspread[NUM_RCU_LVLS];
353 struct rcu_data __percpu *rda;
354
355
356
357 u8 fqs_state ____cacheline_internodealigned_in_smp;
358
359 u8 fqs_active;
360
361 u8 fqs_need_gp;
362
363
364
365
366 u8 boost;
367 unsigned long gpnum;
368 unsigned long completed;
369
370
371
372 raw_spinlock_t onofflock;
373
374 raw_spinlock_t fqslock;
375
376 unsigned long jiffies_force_qs;
377
378 unsigned long n_force_qs;
379
380 unsigned long n_force_qs_lh;
381
382 unsigned long n_force_qs_ngp;
383
384 unsigned long gp_start;
385
386 unsigned long jiffies_stall;
387
388 unsigned long gp_max;
389
390 char *name;
391};
392
393
394
395#define RCU_OFL_TASKS_NORM_GP 0x1
396
397#define RCU_OFL_TASKS_EXP_GP 0x2
398
399
400
401
402
403extern struct rcu_state rcu_sched_state;
404DECLARE_PER_CPU(struct rcu_data, rcu_sched_data);
405
406extern struct rcu_state rcu_bh_state;
407DECLARE_PER_CPU(struct rcu_data, rcu_bh_data);
408
409#ifdef CONFIG_TREE_PREEMPT_RCU
410extern struct rcu_state rcu_preempt_state;
411DECLARE_PER_CPU(struct rcu_data, rcu_preempt_data);
412#endif
413
414#ifdef CONFIG_RCU_BOOST
415DECLARE_PER_CPU(unsigned int, rcu_cpu_kthread_status);
416DECLARE_PER_CPU(int, rcu_cpu_kthread_cpu);
417DECLARE_PER_CPU(unsigned int, rcu_cpu_kthread_loops);
418DECLARE_PER_CPU(char, rcu_cpu_has_work);
419#endif
420
421#ifndef RCU_TREE_NONCORE
422
423
424static void rcu_bootup_announce(void);
425long rcu_batches_completed(void);
426static void rcu_preempt_note_context_switch(int cpu);
427static int rcu_preempt_blocked_readers_cgp(struct rcu_node *rnp);
428#ifdef CONFIG_HOTPLUG_CPU
429static void rcu_report_unblock_qs_rnp(struct rcu_node *rnp,
430 unsigned long flags);
431static void rcu_stop_cpu_kthread(int cpu);
432#endif
433static void rcu_print_detail_task_stall(struct rcu_state *rsp);
434static int rcu_print_task_stall(struct rcu_node *rnp);
435static void rcu_preempt_stall_reset(void);
436static void rcu_preempt_check_blocked_tasks(struct rcu_node *rnp);
437#ifdef CONFIG_HOTPLUG_CPU
438static int rcu_preempt_offline_tasks(struct rcu_state *rsp,
439 struct rcu_node *rnp,
440 struct rcu_data *rdp);
441static void rcu_preempt_offline_cpu(int cpu);
442#endif
443static void rcu_preempt_check_callbacks(int cpu);
444static void rcu_preempt_process_callbacks(void);
445void call_rcu(struct rcu_head *head, void (*func)(struct rcu_head *rcu));
446#if defined(CONFIG_HOTPLUG_CPU) || defined(CONFIG_TREE_PREEMPT_RCU)
447static void rcu_report_exp_rnp(struct rcu_state *rsp, struct rcu_node *rnp,
448 bool wake);
449#endif
450static int rcu_preempt_pending(int cpu);
451static int rcu_preempt_needs_cpu(int cpu);
452static void __cpuinit rcu_preempt_init_percpu_data(int cpu);
453static void rcu_preempt_send_cbs_to_online(void);
454static void __init __rcu_init_preempt(void);
455static void rcu_initiate_boost(struct rcu_node *rnp, unsigned long flags);
456static void rcu_preempt_boost_start_gp(struct rcu_node *rnp);
457static void invoke_rcu_callbacks_kthread(void);
458static bool rcu_is_callbacks_kthread(void);
459#ifdef CONFIG_RCU_BOOST
460static void rcu_preempt_do_callbacks(void);
461static void rcu_boost_kthread_setaffinity(struct rcu_node *rnp,
462 cpumask_var_t cm);
463static int __cpuinit rcu_spawn_one_boost_kthread(struct rcu_state *rsp,
464 struct rcu_node *rnp,
465 int rnp_index);
466static void invoke_rcu_node_kthread(struct rcu_node *rnp);
467static void rcu_yield(void (*f)(unsigned long), unsigned long arg);
468#endif
469static void rcu_cpu_kthread_setrt(int cpu, int to_rt);
470static void __cpuinit rcu_prepare_kthreads(int cpu);
471static void rcu_prepare_for_idle_init(int cpu);
472static void rcu_cleanup_after_idle(int cpu);
473static void rcu_prepare_for_idle(int cpu);
474
475#endif
476