idle: Fix hlt/nohlt command-line handling in new generic idle
[GitHub/mt8127/android_kernel_alcatel_ttab.git] / kernel / softirq.c
CommitLineData
1da177e4
LT
1/*
2 * linux/kernel/softirq.c
3 *
4 * Copyright (C) 1992 Linus Torvalds
5 *
b10db7f0
PM
6 * Distribute under GPLv2.
7 *
8 * Rewritten. Old one was good in 2.2, but in 2.3 it was immoral. --ANK (990903)
54514a70
DM
9 *
10 * Remote softirq infrastructure is by Jens Axboe.
1da177e4
LT
11 */
12
9984de1a 13#include <linux/export.h>
1da177e4
LT
14#include <linux/kernel_stat.h>
15#include <linux/interrupt.h>
16#include <linux/init.h>
17#include <linux/mm.h>
18#include <linux/notifier.h>
19#include <linux/percpu.h>
20#include <linux/cpu.h>
83144186 21#include <linux/freezer.h>
1da177e4
LT
22#include <linux/kthread.h>
23#include <linux/rcupdate.h>
7e49fcce 24#include <linux/ftrace.h>
78eef01b 25#include <linux/smp.h>
3e339b5d 26#include <linux/smpboot.h>
79bf2bb3 27#include <linux/tick.h>
a0e39ed3
HC
28
29#define CREATE_TRACE_POINTS
ad8d75ff 30#include <trace/events/irq.h>
1da177e4
LT
31
32#include <asm/irq.h>
33/*
34 - No shared variables, all the data are CPU local.
35 - If a softirq needs serialization, let it serialize itself
36 by its own spinlocks.
37 - Even if softirq is serialized, only local cpu is marked for
38 execution. Hence, we get something sort of weak cpu binding.
39 Though it is still not clear, will it result in better locality
40 or will not.
41
42 Examples:
43 - NET RX softirq. It is multithreaded and does not require
44 any global serialization.
45 - NET TX softirq. It kicks software netdevice queues, hence
46 it is logically serialized per device, but this serialization
47 is invisible to common code.
48 - Tasklets: serialized wrt itself.
49 */
50
51#ifndef __ARCH_IRQ_STAT
52irq_cpustat_t irq_stat[NR_CPUS] ____cacheline_aligned;
53EXPORT_SYMBOL(irq_stat);
54#endif
55
978b0116 56static struct softirq_action softirq_vec[NR_SOFTIRQS] __cacheline_aligned_in_smp;
1da177e4 57
4dd53d89 58DEFINE_PER_CPU(struct task_struct *, ksoftirqd);
1da177e4 59
5d592b44 60char *softirq_to_name[NR_SOFTIRQS] = {
5dd4de58 61 "HI", "TIMER", "NET_TX", "NET_RX", "BLOCK", "BLOCK_IOPOLL",
09223371 62 "TASKLET", "SCHED", "HRTIMER", "RCU"
5d592b44
JB
63};
64
1da177e4
LT
65/*
66 * we cannot loop indefinitely here to avoid userspace starvation,
67 * but we also don't want to introduce a worst case 1/HZ latency
68 * to the pending events, so lets the scheduler to balance
69 * the softirq load for us.
70 */
676cb02d 71static void wakeup_softirqd(void)
1da177e4
LT
72{
73 /* Interrupts are disabled: no need to stop preemption */
909ea964 74 struct task_struct *tsk = __this_cpu_read(ksoftirqd);
1da177e4
LT
75
76 if (tsk && tsk->state != TASK_RUNNING)
77 wake_up_process(tsk);
78}
79
75e1056f
VP
80/*
81 * preempt_count and SOFTIRQ_OFFSET usage:
82 * - preempt_count is changed by SOFTIRQ_OFFSET on entering or leaving
83 * softirq processing.
84 * - preempt_count is changed by SOFTIRQ_DISABLE_OFFSET (= 2 * SOFTIRQ_OFFSET)
85 * on local_bh_disable or local_bh_enable.
86 * This lets us distinguish between whether we are currently processing
87 * softirq and whether we just have bh disabled.
88 */
89
de30a2b3
IM
90/*
91 * This one is for softirq.c-internal use,
92 * where hardirqs are disabled legitimately:
93 */
3c829c36 94#ifdef CONFIG_TRACE_IRQFLAGS
75e1056f 95static void __local_bh_disable(unsigned long ip, unsigned int cnt)
de30a2b3
IM
96{
97 unsigned long flags;
98
99 WARN_ON_ONCE(in_irq());
100
101 raw_local_irq_save(flags);
7e49fcce
SR
102 /*
103 * The preempt tracer hooks into add_preempt_count and will break
104 * lockdep because it calls back into lockdep after SOFTIRQ_OFFSET
105 * is set and before current->softirq_enabled is cleared.
106 * We must manually increment preempt_count here and manually
107 * call the trace_preempt_off later.
108 */
75e1056f 109 preempt_count() += cnt;
de30a2b3
IM
110 /*
111 * Were softirqs turned off above:
112 */
75e1056f 113 if (softirq_count() == cnt)
de30a2b3
IM
114 trace_softirqs_off(ip);
115 raw_local_irq_restore(flags);
7e49fcce 116
75e1056f 117 if (preempt_count() == cnt)
7e49fcce 118 trace_preempt_off(CALLER_ADDR0, get_parent_ip(CALLER_ADDR1));
de30a2b3 119}
3c829c36 120#else /* !CONFIG_TRACE_IRQFLAGS */
75e1056f 121static inline void __local_bh_disable(unsigned long ip, unsigned int cnt)
3c829c36 122{
75e1056f 123 add_preempt_count(cnt);
3c829c36
TC
124 barrier();
125}
126#endif /* CONFIG_TRACE_IRQFLAGS */
de30a2b3
IM
127
128void local_bh_disable(void)
129{
75e1056f
VP
130 __local_bh_disable((unsigned long)__builtin_return_address(0),
131 SOFTIRQ_DISABLE_OFFSET);
de30a2b3
IM
132}
133
134EXPORT_SYMBOL(local_bh_disable);
135
75e1056f
VP
136static void __local_bh_enable(unsigned int cnt)
137{
138 WARN_ON_ONCE(in_irq());
139 WARN_ON_ONCE(!irqs_disabled());
140
141 if (softirq_count() == cnt)
142 trace_softirqs_on((unsigned long)__builtin_return_address(0));
143 sub_preempt_count(cnt);
144}
145
de30a2b3
IM
146/*
147 * Special-case - softirqs can safely be enabled in
148 * cond_resched_softirq(), or by __do_softirq(),
149 * without processing still-pending softirqs:
150 */
151void _local_bh_enable(void)
152{
75e1056f 153 __local_bh_enable(SOFTIRQ_DISABLE_OFFSET);
de30a2b3
IM
154}
155
156EXPORT_SYMBOL(_local_bh_enable);
157
0f476b6d 158static inline void _local_bh_enable_ip(unsigned long ip)
de30a2b3 159{
0f476b6d 160 WARN_ON_ONCE(in_irq() || irqs_disabled());
3c829c36 161#ifdef CONFIG_TRACE_IRQFLAGS
0f476b6d 162 local_irq_disable();
3c829c36 163#endif
de30a2b3
IM
164 /*
165 * Are softirqs going to be turned on now:
166 */
75e1056f 167 if (softirq_count() == SOFTIRQ_DISABLE_OFFSET)
0f476b6d 168 trace_softirqs_on(ip);
de30a2b3
IM
169 /*
170 * Keep preemption disabled until we are done with
171 * softirq processing:
172 */
75e1056f 173 sub_preempt_count(SOFTIRQ_DISABLE_OFFSET - 1);
de30a2b3
IM
174
175 if (unlikely(!in_interrupt() && local_softirq_pending()))
176 do_softirq();
177
178 dec_preempt_count();
3c829c36 179#ifdef CONFIG_TRACE_IRQFLAGS
0f476b6d 180 local_irq_enable();
3c829c36 181#endif
de30a2b3
IM
182 preempt_check_resched();
183}
0f476b6d
JB
184
185void local_bh_enable(void)
186{
187 _local_bh_enable_ip((unsigned long)__builtin_return_address(0));
188}
de30a2b3
IM
189EXPORT_SYMBOL(local_bh_enable);
190
191void local_bh_enable_ip(unsigned long ip)
192{
0f476b6d 193 _local_bh_enable_ip(ip);
de30a2b3
IM
194}
195EXPORT_SYMBOL(local_bh_enable_ip);
196
1da177e4 197/*
c10d7367
ED
198 * We restart softirq processing for at most 2 ms,
199 * and if need_resched() is not set.
1da177e4 200 *
c10d7367 201 * These limits have been established via experimentation.
1da177e4
LT
202 * The two things to balance is latency against fairness -
203 * we want to handle softirqs as soon as possible, but they
204 * should not be able to lock up the box.
205 */
c10d7367 206#define MAX_SOFTIRQ_TIME msecs_to_jiffies(2)
1da177e4
LT
207
208asmlinkage void __do_softirq(void)
209{
210 struct softirq_action *h;
211 __u32 pending;
c10d7367 212 unsigned long end = jiffies + MAX_SOFTIRQ_TIME;
1da177e4 213 int cpu;
907aed48
MG
214 unsigned long old_flags = current->flags;
215
216 /*
217 * Mask out PF_MEMALLOC s current task context is borrowed for the
218 * softirq. A softirq handled such as network RX might set PF_MEMALLOC
219 * again if the socket is related to swap
220 */
221 current->flags &= ~PF_MEMALLOC;
1da177e4
LT
222
223 pending = local_softirq_pending();
6a61671b 224 account_irq_enter_time(current);
829035fd 225
75e1056f
VP
226 __local_bh_disable((unsigned long)__builtin_return_address(0),
227 SOFTIRQ_OFFSET);
d820ac4c 228 lockdep_softirq_enter();
1da177e4 229
1da177e4
LT
230 cpu = smp_processor_id();
231restart:
232 /* Reset the pending bitmask before enabling irqs */
3f74478b 233 set_softirq_pending(0);
1da177e4 234
c70f5d66 235 local_irq_enable();
1da177e4
LT
236
237 h = softirq_vec;
238
239 do {
240 if (pending & 1) {
f4bc6bb2 241 unsigned int vec_nr = h - softirq_vec;
8e85b4b5
TG
242 int prev_count = preempt_count();
243
f4bc6bb2
TG
244 kstat_incr_softirqs_this_cpu(vec_nr);
245
246 trace_softirq_entry(vec_nr);
1da177e4 247 h->action(h);
f4bc6bb2 248 trace_softirq_exit(vec_nr);
8e85b4b5 249 if (unlikely(prev_count != preempt_count())) {
f4bc6bb2 250 printk(KERN_ERR "huh, entered softirq %u %s %p"
8e85b4b5 251 "with preempt_count %08x,"
f4bc6bb2
TG
252 " exited with %08x?\n", vec_nr,
253 softirq_to_name[vec_nr], h->action,
254 prev_count, preempt_count());
8e85b4b5
TG
255 preempt_count() = prev_count;
256 }
257
d6714c22 258 rcu_bh_qs(cpu);
1da177e4
LT
259 }
260 h++;
261 pending >>= 1;
262 } while (pending);
263
c70f5d66 264 local_irq_disable();
1da177e4
LT
265
266 pending = local_softirq_pending();
c10d7367
ED
267 if (pending) {
268 if (time_before(jiffies, end) && !need_resched())
269 goto restart;
1da177e4 270
1da177e4 271 wakeup_softirqd();
c10d7367 272 }
1da177e4 273
d820ac4c 274 lockdep_softirq_exit();
829035fd 275
6a61671b 276 account_irq_exit_time(current);
75e1056f 277 __local_bh_enable(SOFTIRQ_OFFSET);
907aed48 278 tsk_restore_flags(current, old_flags, PF_MEMALLOC);
1da177e4
LT
279}
280
281#ifndef __ARCH_HAS_DO_SOFTIRQ
282
283asmlinkage void do_softirq(void)
284{
285 __u32 pending;
286 unsigned long flags;
287
288 if (in_interrupt())
289 return;
290
291 local_irq_save(flags);
292
293 pending = local_softirq_pending();
294
295 if (pending)
296 __do_softirq();
297
298 local_irq_restore(flags);
299}
300
1da177e4
LT
301#endif
302
dde4b2b5
IM
303/*
304 * Enter an interrupt context.
305 */
306void irq_enter(void)
307{
6378ddb5 308 int cpu = smp_processor_id();
719254fa 309
64db4cff 310 rcu_irq_enter();
0a8a2e78 311 if (is_idle_task(current) && !in_interrupt()) {
d267f87f
VP
312 /*
313 * Prevent raise_softirq from needlessly waking up ksoftirqd
314 * here, as softirq will be serviced on return from interrupt.
315 */
316 local_bh_disable();
719254fa 317 tick_check_idle(cpu);
d267f87f
VP
318 _local_bh_enable();
319 }
320
321 __irq_enter();
dde4b2b5
IM
322}
323
8d32a307
TG
324static inline void invoke_softirq(void)
325{
facd8b80 326 if (!force_irqthreads)
8d32a307 327 __do_softirq();
facd8b80 328 else
8d32a307
TG
329 wakeup_softirqd();
330}
1da177e4
LT
331
332/*
333 * Exit an interrupt context. Process softirqs if needed and possible:
334 */
335void irq_exit(void)
336{
74eed016 337#ifndef __ARCH_IRQ_EXIT_IRQS_DISABLED
4cd5d111 338 local_irq_disable();
74eed016
TG
339#else
340 WARN_ON_ONCE(!irqs_disabled());
341#endif
342
6a61671b 343 account_irq_exit_time(current);
de30a2b3 344 trace_hardirq_exit();
4d4c4e24 345 sub_preempt_count(HARDIRQ_OFFSET);
1da177e4
LT
346 if (!in_interrupt() && local_softirq_pending())
347 invoke_softirq();
79bf2bb3
TG
348
349#ifdef CONFIG_NO_HZ
350 /* Make sure that timer wheel updates are propagated */
64db4cff 351 if (idle_cpu(smp_processor_id()) && !in_interrupt() && !need_resched())
280f0677 352 tick_nohz_irq_exit();
79bf2bb3 353#endif
416eb33c 354 rcu_irq_exit();
1da177e4
LT
355}
356
357/*
358 * This function must run with irqs disabled!
359 */
7ad5b3a5 360inline void raise_softirq_irqoff(unsigned int nr)
1da177e4
LT
361{
362 __raise_softirq_irqoff(nr);
363
364 /*
365 * If we're in an interrupt or softirq, we're done
366 * (this also catches softirq-disabled code). We will
367 * actually run the softirq once we return from
368 * the irq or softirq.
369 *
370 * Otherwise we wake up ksoftirqd to make sure we
371 * schedule the softirq soon.
372 */
373 if (!in_interrupt())
374 wakeup_softirqd();
375}
376
7ad5b3a5 377void raise_softirq(unsigned int nr)
1da177e4
LT
378{
379 unsigned long flags;
380
381 local_irq_save(flags);
382 raise_softirq_irqoff(nr);
383 local_irq_restore(flags);
384}
385
f069686e
SR
386void __raise_softirq_irqoff(unsigned int nr)
387{
388 trace_softirq_raise(nr);
389 or_softirq_pending(1UL << nr);
390}
391
962cf36c 392void open_softirq(int nr, void (*action)(struct softirq_action *))
1da177e4 393{
1da177e4
LT
394 softirq_vec[nr].action = action;
395}
396
9ba5f005
PZ
397/*
398 * Tasklets
399 */
1da177e4
LT
400struct tasklet_head
401{
48f20a9a
OJ
402 struct tasklet_struct *head;
403 struct tasklet_struct **tail;
1da177e4
LT
404};
405
4620b49f
VN
406static DEFINE_PER_CPU(struct tasklet_head, tasklet_vec);
407static DEFINE_PER_CPU(struct tasklet_head, tasklet_hi_vec);
1da177e4 408
7ad5b3a5 409void __tasklet_schedule(struct tasklet_struct *t)
1da177e4
LT
410{
411 unsigned long flags;
412
413 local_irq_save(flags);
48f20a9a 414 t->next = NULL;
909ea964
CL
415 *__this_cpu_read(tasklet_vec.tail) = t;
416 __this_cpu_write(tasklet_vec.tail, &(t->next));
1da177e4
LT
417 raise_softirq_irqoff(TASKLET_SOFTIRQ);
418 local_irq_restore(flags);
419}
420
421EXPORT_SYMBOL(__tasklet_schedule);
422
7ad5b3a5 423void __tasklet_hi_schedule(struct tasklet_struct *t)
1da177e4
LT
424{
425 unsigned long flags;
426
427 local_irq_save(flags);
48f20a9a 428 t->next = NULL;
909ea964
CL
429 *__this_cpu_read(tasklet_hi_vec.tail) = t;
430 __this_cpu_write(tasklet_hi_vec.tail, &(t->next));
1da177e4
LT
431 raise_softirq_irqoff(HI_SOFTIRQ);
432 local_irq_restore(flags);
433}
434
435EXPORT_SYMBOL(__tasklet_hi_schedule);
436
7c692cba
VN
437void __tasklet_hi_schedule_first(struct tasklet_struct *t)
438{
439 BUG_ON(!irqs_disabled());
440
909ea964
CL
441 t->next = __this_cpu_read(tasklet_hi_vec.head);
442 __this_cpu_write(tasklet_hi_vec.head, t);
7c692cba
VN
443 __raise_softirq_irqoff(HI_SOFTIRQ);
444}
445
446EXPORT_SYMBOL(__tasklet_hi_schedule_first);
447
1da177e4
LT
448static void tasklet_action(struct softirq_action *a)
449{
450 struct tasklet_struct *list;
451
452 local_irq_disable();
909ea964
CL
453 list = __this_cpu_read(tasklet_vec.head);
454 __this_cpu_write(tasklet_vec.head, NULL);
455 __this_cpu_write(tasklet_vec.tail, &__get_cpu_var(tasklet_vec).head);
1da177e4
LT
456 local_irq_enable();
457
458 while (list) {
459 struct tasklet_struct *t = list;
460
461 list = list->next;
462
463 if (tasklet_trylock(t)) {
464 if (!atomic_read(&t->count)) {
465 if (!test_and_clear_bit(TASKLET_STATE_SCHED, &t->state))
466 BUG();
467 t->func(t->data);
468 tasklet_unlock(t);
469 continue;
470 }
471 tasklet_unlock(t);
472 }
473
474 local_irq_disable();
48f20a9a 475 t->next = NULL;
909ea964
CL
476 *__this_cpu_read(tasklet_vec.tail) = t;
477 __this_cpu_write(tasklet_vec.tail, &(t->next));
1da177e4
LT
478 __raise_softirq_irqoff(TASKLET_SOFTIRQ);
479 local_irq_enable();
480 }
481}
482
483static void tasklet_hi_action(struct softirq_action *a)
484{
485 struct tasklet_struct *list;
486
487 local_irq_disable();
909ea964
CL
488 list = __this_cpu_read(tasklet_hi_vec.head);
489 __this_cpu_write(tasklet_hi_vec.head, NULL);
490 __this_cpu_write(tasklet_hi_vec.tail, &__get_cpu_var(tasklet_hi_vec).head);
1da177e4
LT
491 local_irq_enable();
492
493 while (list) {
494 struct tasklet_struct *t = list;
495
496 list = list->next;
497
498 if (tasklet_trylock(t)) {
499 if (!atomic_read(&t->count)) {
500 if (!test_and_clear_bit(TASKLET_STATE_SCHED, &t->state))
501 BUG();
502 t->func(t->data);
503 tasklet_unlock(t);
504 continue;
505 }
506 tasklet_unlock(t);
507 }
508
509 local_irq_disable();
48f20a9a 510 t->next = NULL;
909ea964
CL
511 *__this_cpu_read(tasklet_hi_vec.tail) = t;
512 __this_cpu_write(tasklet_hi_vec.tail, &(t->next));
1da177e4
LT
513 __raise_softirq_irqoff(HI_SOFTIRQ);
514 local_irq_enable();
515 }
516}
517
518
519void tasklet_init(struct tasklet_struct *t,
520 void (*func)(unsigned long), unsigned long data)
521{
522 t->next = NULL;
523 t->state = 0;
524 atomic_set(&t->count, 0);
525 t->func = func;
526 t->data = data;
527}
528
529EXPORT_SYMBOL(tasklet_init);
530
531void tasklet_kill(struct tasklet_struct *t)
532{
533 if (in_interrupt())
534 printk("Attempt to kill tasklet from interrupt\n");
535
536 while (test_and_set_bit(TASKLET_STATE_SCHED, &t->state)) {
79d381c9 537 do {
1da177e4 538 yield();
79d381c9 539 } while (test_bit(TASKLET_STATE_SCHED, &t->state));
1da177e4
LT
540 }
541 tasklet_unlock_wait(t);
542 clear_bit(TASKLET_STATE_SCHED, &t->state);
543}
544
545EXPORT_SYMBOL(tasklet_kill);
546
9ba5f005
PZ
547/*
548 * tasklet_hrtimer
549 */
550
551/*
b9c30322
PZ
552 * The trampoline is called when the hrtimer expires. It schedules a tasklet
553 * to run __tasklet_hrtimer_trampoline() which in turn will call the intended
554 * hrtimer callback, but from softirq context.
9ba5f005
PZ
555 */
556static enum hrtimer_restart __hrtimer_tasklet_trampoline(struct hrtimer *timer)
557{
558 struct tasklet_hrtimer *ttimer =
559 container_of(timer, struct tasklet_hrtimer, timer);
560
b9c30322
PZ
561 tasklet_hi_schedule(&ttimer->tasklet);
562 return HRTIMER_NORESTART;
9ba5f005
PZ
563}
564
565/*
566 * Helper function which calls the hrtimer callback from
567 * tasklet/softirq context
568 */
569static void __tasklet_hrtimer_trampoline(unsigned long data)
570{
571 struct tasklet_hrtimer *ttimer = (void *)data;
572 enum hrtimer_restart restart;
573
574 restart = ttimer->function(&ttimer->timer);
575 if (restart != HRTIMER_NORESTART)
576 hrtimer_restart(&ttimer->timer);
577}
578
579/**
580 * tasklet_hrtimer_init - Init a tasklet/hrtimer combo for softirq callbacks
581 * @ttimer: tasklet_hrtimer which is initialized
25985edc 582 * @function: hrtimer callback function which gets called from softirq context
9ba5f005
PZ
583 * @which_clock: clock id (CLOCK_MONOTONIC/CLOCK_REALTIME)
584 * @mode: hrtimer mode (HRTIMER_MODE_ABS/HRTIMER_MODE_REL)
585 */
586void tasklet_hrtimer_init(struct tasklet_hrtimer *ttimer,
587 enum hrtimer_restart (*function)(struct hrtimer *),
588 clockid_t which_clock, enum hrtimer_mode mode)
589{
590 hrtimer_init(&ttimer->timer, which_clock, mode);
591 ttimer->timer.function = __hrtimer_tasklet_trampoline;
592 tasklet_init(&ttimer->tasklet, __tasklet_hrtimer_trampoline,
593 (unsigned long)ttimer);
594 ttimer->function = function;
595}
596EXPORT_SYMBOL_GPL(tasklet_hrtimer_init);
597
598/*
599 * Remote softirq bits
600 */
601
54514a70
DM
602DEFINE_PER_CPU(struct list_head [NR_SOFTIRQS], softirq_work_list);
603EXPORT_PER_CPU_SYMBOL(softirq_work_list);
604
605static void __local_trigger(struct call_single_data *cp, int softirq)
606{
607 struct list_head *head = &__get_cpu_var(softirq_work_list[softirq]);
608
609 list_add_tail(&cp->list, head);
610
611 /* Trigger the softirq only if the list was previously empty. */
612 if (head->next == &cp->list)
613 raise_softirq_irqoff(softirq);
614}
615
616#ifdef CONFIG_USE_GENERIC_SMP_HELPERS
617static void remote_softirq_receive(void *data)
618{
619 struct call_single_data *cp = data;
620 unsigned long flags;
621 int softirq;
622
3440a1ca 623 softirq = *(int *)cp->info;
54514a70
DM
624 local_irq_save(flags);
625 __local_trigger(cp, softirq);
626 local_irq_restore(flags);
627}
628
629static int __try_remote_softirq(struct call_single_data *cp, int cpu, int softirq)
630{
631 if (cpu_online(cpu)) {
632 cp->func = remote_softirq_receive;
3440a1ca 633 cp->info = &softirq;
54514a70 634 cp->flags = 0;
54514a70 635
6e275637 636 __smp_call_function_single(cpu, cp, 0);
54514a70
DM
637 return 0;
638 }
639 return 1;
640}
641#else /* CONFIG_USE_GENERIC_SMP_HELPERS */
642static int __try_remote_softirq(struct call_single_data *cp, int cpu, int softirq)
643{
644 return 1;
645}
646#endif
647
648/**
649 * __send_remote_softirq - try to schedule softirq work on a remote cpu
650 * @cp: private SMP call function data area
651 * @cpu: the remote cpu
652 * @this_cpu: the currently executing cpu
653 * @softirq: the softirq for the work
654 *
655 * Attempt to schedule softirq work on a remote cpu. If this cannot be
656 * done, the work is instead queued up on the local cpu.
657 *
658 * Interrupts must be disabled.
659 */
660void __send_remote_softirq(struct call_single_data *cp, int cpu, int this_cpu, int softirq)
661{
662 if (cpu == this_cpu || __try_remote_softirq(cp, cpu, softirq))
663 __local_trigger(cp, softirq);
664}
665EXPORT_SYMBOL(__send_remote_softirq);
666
667/**
668 * send_remote_softirq - try to schedule softirq work on a remote cpu
669 * @cp: private SMP call function data area
670 * @cpu: the remote cpu
671 * @softirq: the softirq for the work
672 *
673 * Like __send_remote_softirq except that disabling interrupts and
674 * computing the current cpu is done for the caller.
675 */
676void send_remote_softirq(struct call_single_data *cp, int cpu, int softirq)
677{
678 unsigned long flags;
679 int this_cpu;
680
681 local_irq_save(flags);
682 this_cpu = smp_processor_id();
683 __send_remote_softirq(cp, cpu, this_cpu, softirq);
684 local_irq_restore(flags);
685}
686EXPORT_SYMBOL(send_remote_softirq);
687
688static int __cpuinit remote_softirq_cpu_notify(struct notifier_block *self,
689 unsigned long action, void *hcpu)
690{
691 /*
692 * If a CPU goes away, splice its entries to the current CPU
693 * and trigger a run of the softirq
694 */
695 if (action == CPU_DEAD || action == CPU_DEAD_FROZEN) {
696 int cpu = (unsigned long) hcpu;
697 int i;
698
699 local_irq_disable();
700 for (i = 0; i < NR_SOFTIRQS; i++) {
701 struct list_head *head = &per_cpu(softirq_work_list[i], cpu);
702 struct list_head *local_head;
703
704 if (list_empty(head))
705 continue;
706
707 local_head = &__get_cpu_var(softirq_work_list[i]);
708 list_splice_init(head, local_head);
709 raise_softirq_irqoff(i);
710 }
711 local_irq_enable();
712 }
713
714 return NOTIFY_OK;
715}
716
717static struct notifier_block __cpuinitdata remote_softirq_cpu_notifier = {
718 .notifier_call = remote_softirq_cpu_notify,
719};
720
1da177e4
LT
721void __init softirq_init(void)
722{
48f20a9a
OJ
723 int cpu;
724
725 for_each_possible_cpu(cpu) {
54514a70
DM
726 int i;
727
48f20a9a
OJ
728 per_cpu(tasklet_vec, cpu).tail =
729 &per_cpu(tasklet_vec, cpu).head;
730 per_cpu(tasklet_hi_vec, cpu).tail =
731 &per_cpu(tasklet_hi_vec, cpu).head;
54514a70
DM
732 for (i = 0; i < NR_SOFTIRQS; i++)
733 INIT_LIST_HEAD(&per_cpu(softirq_work_list[i], cpu));
48f20a9a
OJ
734 }
735
54514a70
DM
736 register_hotcpu_notifier(&remote_softirq_cpu_notifier);
737
962cf36c
CM
738 open_softirq(TASKLET_SOFTIRQ, tasklet_action);
739 open_softirq(HI_SOFTIRQ, tasklet_hi_action);
1da177e4
LT
740}
741
3e339b5d 742static int ksoftirqd_should_run(unsigned int cpu)
1da177e4 743{
3e339b5d
TG
744 return local_softirq_pending();
745}
1da177e4 746
3e339b5d
TG
747static void run_ksoftirqd(unsigned int cpu)
748{
749 local_irq_disable();
750 if (local_softirq_pending()) {
751 __do_softirq();
752 rcu_note_context_switch(cpu);
753 local_irq_enable();
754 cond_resched();
755 return;
1da177e4 756 }
3e339b5d 757 local_irq_enable();
1da177e4
LT
758}
759
760#ifdef CONFIG_HOTPLUG_CPU
761/*
762 * tasklet_kill_immediate is called to remove a tasklet which can already be
763 * scheduled for execution on @cpu.
764 *
765 * Unlike tasklet_kill, this function removes the tasklet
766 * _immediately_, even if the tasklet is in TASKLET_STATE_SCHED state.
767 *
768 * When this function is called, @cpu must be in the CPU_DEAD state.
769 */
770void tasklet_kill_immediate(struct tasklet_struct *t, unsigned int cpu)
771{
772 struct tasklet_struct **i;
773
774 BUG_ON(cpu_online(cpu));
775 BUG_ON(test_bit(TASKLET_STATE_RUN, &t->state));
776
777 if (!test_bit(TASKLET_STATE_SCHED, &t->state))
778 return;
779
780 /* CPU is dead, so no lock needed. */
48f20a9a 781 for (i = &per_cpu(tasklet_vec, cpu).head; *i; i = &(*i)->next) {
1da177e4
LT
782 if (*i == t) {
783 *i = t->next;
48f20a9a
OJ
784 /* If this was the tail element, move the tail ptr */
785 if (*i == NULL)
786 per_cpu(tasklet_vec, cpu).tail = i;
1da177e4
LT
787 return;
788 }
789 }
790 BUG();
791}
792
793static void takeover_tasklets(unsigned int cpu)
794{
1da177e4
LT
795 /* CPU is dead, so no lock needed. */
796 local_irq_disable();
797
798 /* Find end, append list for that CPU. */
e5e41723 799 if (&per_cpu(tasklet_vec, cpu).head != per_cpu(tasklet_vec, cpu).tail) {
909ea964
CL
800 *__this_cpu_read(tasklet_vec.tail) = per_cpu(tasklet_vec, cpu).head;
801 this_cpu_write(tasklet_vec.tail, per_cpu(tasklet_vec, cpu).tail);
e5e41723
CB
802 per_cpu(tasklet_vec, cpu).head = NULL;
803 per_cpu(tasklet_vec, cpu).tail = &per_cpu(tasklet_vec, cpu).head;
804 }
1da177e4
LT
805 raise_softirq_irqoff(TASKLET_SOFTIRQ);
806
e5e41723 807 if (&per_cpu(tasklet_hi_vec, cpu).head != per_cpu(tasklet_hi_vec, cpu).tail) {
909ea964
CL
808 *__this_cpu_read(tasklet_hi_vec.tail) = per_cpu(tasklet_hi_vec, cpu).head;
809 __this_cpu_write(tasklet_hi_vec.tail, per_cpu(tasklet_hi_vec, cpu).tail);
e5e41723
CB
810 per_cpu(tasklet_hi_vec, cpu).head = NULL;
811 per_cpu(tasklet_hi_vec, cpu).tail = &per_cpu(tasklet_hi_vec, cpu).head;
812 }
1da177e4
LT
813 raise_softirq_irqoff(HI_SOFTIRQ);
814
815 local_irq_enable();
816}
817#endif /* CONFIG_HOTPLUG_CPU */
818
8c78f307 819static int __cpuinit cpu_callback(struct notifier_block *nfb,
1da177e4
LT
820 unsigned long action,
821 void *hcpu)
822{
1da177e4 823 switch (action) {
1da177e4 824#ifdef CONFIG_HOTPLUG_CPU
1da177e4 825 case CPU_DEAD:
3e339b5d
TG
826 case CPU_DEAD_FROZEN:
827 takeover_tasklets((unsigned long)hcpu);
1da177e4
LT
828 break;
829#endif /* CONFIG_HOTPLUG_CPU */
3e339b5d 830 }
1da177e4
LT
831 return NOTIFY_OK;
832}
833
8c78f307 834static struct notifier_block __cpuinitdata cpu_nfb = {
1da177e4
LT
835 .notifier_call = cpu_callback
836};
837
3e339b5d
TG
838static struct smp_hotplug_thread softirq_threads = {
839 .store = &ksoftirqd,
840 .thread_should_run = ksoftirqd_should_run,
841 .thread_fn = run_ksoftirqd,
842 .thread_comm = "ksoftirqd/%u",
843};
844
7babe8db 845static __init int spawn_ksoftirqd(void)
1da177e4 846{
1da177e4 847 register_cpu_notifier(&cpu_nfb);
3e339b5d
TG
848
849 BUG_ON(smpboot_register_percpu_thread(&softirq_threads));
850
1da177e4
LT
851 return 0;
852}
7babe8db 853early_initcall(spawn_ksoftirqd);
78eef01b 854
43a25632
YL
855/*
856 * [ These __weak aliases are kept in a separate compilation unit, so that
857 * GCC does not inline them incorrectly. ]
858 */
859
860int __init __weak early_irq_init(void)
861{
862 return 0;
863}
864
b683de2b 865#ifdef CONFIG_GENERIC_HARDIRQS
4a046d17
YL
866int __init __weak arch_probe_nr_irqs(void)
867{
b683de2b 868 return NR_IRQS_LEGACY;
4a046d17
YL
869}
870
43a25632
YL
871int __init __weak arch_early_irq_init(void)
872{
873 return 0;
874}
b683de2b 875#endif