numa_migrate.c 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. /*
  2. * NUMA irq-desc migration code
  3. *
  4. * Migrate IRQ data structures (irq_desc, chip_data, etc.) over to
  5. * the new "home node" of the IRQ.
  6. */
  7. #include <linux/irq.h>
  8. #include <linux/module.h>
  9. #include <linux/random.h>
  10. #include <linux/interrupt.h>
  11. #include <linux/kernel_stat.h>
  12. #include "internals.h"
  13. static void init_copy_kstat_irqs(struct irq_desc *old_desc,
  14. struct irq_desc *desc,
  15. int cpu, int nr)
  16. {
  17. init_kstat_irqs(desc, cpu, nr);
  18. if (desc->kstat_irqs != old_desc->kstat_irqs)
  19. memcpy(desc->kstat_irqs, old_desc->kstat_irqs,
  20. nr * sizeof(*desc->kstat_irqs));
  21. }
  22. static void free_kstat_irqs(struct irq_desc *old_desc, struct irq_desc *desc)
  23. {
  24. if (old_desc->kstat_irqs == desc->kstat_irqs)
  25. return;
  26. kfree(old_desc->kstat_irqs);
  27. old_desc->kstat_irqs = NULL;
  28. }
  29. static void init_copy_one_irq_desc(int irq, struct irq_desc *old_desc,
  30. struct irq_desc *desc, int cpu)
  31. {
  32. memcpy(desc, old_desc, sizeof(struct irq_desc));
  33. spin_lock_init(&desc->lock);
  34. desc->cpu = cpu;
  35. lockdep_set_class(&desc->lock, &irq_desc_lock_class);
  36. init_copy_kstat_irqs(old_desc, desc, cpu, nr_cpu_ids);
  37. arch_init_copy_chip_data(old_desc, desc, cpu);
  38. }
  39. static void free_one_irq_desc(struct irq_desc *old_desc, struct irq_desc *desc)
  40. {
  41. free_kstat_irqs(old_desc, desc);
  42. arch_free_chip_data(old_desc, desc);
  43. }
  44. static struct irq_desc *__real_move_irq_desc(struct irq_desc *old_desc,
  45. int cpu)
  46. {
  47. struct irq_desc *desc;
  48. unsigned int irq;
  49. unsigned long flags;
  50. int node;
  51. irq = old_desc->irq;
  52. spin_lock_irqsave(&sparse_irq_lock, flags);
  53. /* We have to check it to avoid races with another CPU */
  54. desc = irq_desc_ptrs[irq];
  55. if (desc && old_desc != desc)
  56. goto out_unlock;
  57. node = cpu_to_node(cpu);
  58. desc = kzalloc_node(sizeof(*desc), GFP_ATOMIC, node);
  59. if (!desc) {
  60. printk(KERN_ERR "irq %d: can not get new irq_desc for migration.\n", irq);
  61. /* still use old one */
  62. desc = old_desc;
  63. goto out_unlock;
  64. }
  65. init_copy_one_irq_desc(irq, old_desc, desc, cpu);
  66. irq_desc_ptrs[irq] = desc;
  67. spin_unlock_irqrestore(&sparse_irq_lock, flags);
  68. /* free the old one */
  69. free_one_irq_desc(old_desc, desc);
  70. spin_unlock(&old_desc->lock);
  71. kfree(old_desc);
  72. spin_lock(&desc->lock);
  73. return desc;
  74. out_unlock:
  75. spin_unlock_irqrestore(&sparse_irq_lock, flags);
  76. return desc;
  77. }
  78. struct irq_desc *move_irq_desc(struct irq_desc *desc, int cpu)
  79. {
  80. int old_cpu;
  81. int node, old_node;
  82. /* those all static, do move them */
  83. if (desc->irq < NR_IRQS_LEGACY)
  84. return desc;
  85. old_cpu = desc->cpu;
  86. if (old_cpu != cpu) {
  87. node = cpu_to_node(cpu);
  88. old_node = cpu_to_node(old_cpu);
  89. if (old_node != node)
  90. desc = __real_move_irq_desc(desc, cpu);
  91. else
  92. desc->cpu = cpu;
  93. }
  94. return desc;
  95. }