Commit ab25ac02 authored by Thomas Gleixner's avatar Thomas Gleixner

x86/irq: Get rid of code duplication

Reusing an existing vector and assigning a new vector has duplicated
code. Consolidate it.

This is also a preparatory patch for finally plugging the cleanup race.
Signed-off-by: default avatarThomas Gleixner <tglx@linutronix.de>
Tested-by: default avatarBorislav Petkov <bp@alien8.de>
Tested-by: default avatarJoe Lawrence <joe.lawrence@stratus.com>
Cc: Jiang Liu <jiang.liu@linux.intel.com>
Cc: Jeremiah Mahler <jmmahler@gmail.com>
Cc: andy.shevchenko@gmail.com
Cc: Guenter Roeck <linux@roeck-us.net>
Cc: stable@vger.kernel.org #4.3+
Link: http://lkml.kernel.org/r/20151231160106.721599216@linutronix.deSigned-off-by: default avatarThomas Gleixner <tglx@linutronix.de>
parent 9ac15b7a
...@@ -118,7 +118,7 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d, ...@@ -118,7 +118,7 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d,
*/ */
static int current_vector = FIRST_EXTERNAL_VECTOR + VECTOR_OFFSET_START; static int current_vector = FIRST_EXTERNAL_VECTOR + VECTOR_OFFSET_START;
static int current_offset = VECTOR_OFFSET_START % 16; static int current_offset = VECTOR_OFFSET_START % 16;
int cpu; int cpu, vector;
if (d->move_in_progress) if (d->move_in_progress)
return -EBUSY; return -EBUSY;
...@@ -128,7 +128,7 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d, ...@@ -128,7 +128,7 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d,
cpumask_clear(searched_cpumask); cpumask_clear(searched_cpumask);
cpu = cpumask_first_and(mask, cpu_online_mask); cpu = cpumask_first_and(mask, cpu_online_mask);
while (cpu < nr_cpu_ids) { while (cpu < nr_cpu_ids) {
int new_cpu, vector, offset; int new_cpu, offset;
/* Get the possible target cpus for @mask/@cpu from the apic */ /* Get the possible target cpus for @mask/@cpu from the apic */
apic->vector_allocation_domain(cpu, vector_cpumask, mask); apic->vector_allocation_domain(cpu, vector_cpumask, mask);
...@@ -148,16 +148,12 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d, ...@@ -148,16 +148,12 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d,
if (cpumask_equal(vector_cpumask, d->domain)) if (cpumask_equal(vector_cpumask, d->domain))
goto success; goto success;
/* /*
* New cpumask using the vector is a proper subset of * Mark the cpus which are not longer in the mask for
* the current in use mask. So cleanup the vector * cleanup.
* allocation for the members that are not used anymore.
*/ */
cpumask_andnot(d->old_domain, d->domain, cpumask_andnot(d->old_domain, d->domain, vector_cpumask);
vector_cpumask); vector = d->cfg.vector;
d->move_in_progress = goto update;
cpumask_intersects(d->old_domain, cpu_online_mask);
cpumask_copy(d->domain, vector_cpumask);
goto success;
} }
vector = current_vector; vector = current_vector;
...@@ -183,16 +179,12 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d, ...@@ -183,16 +179,12 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d,
/* Found one! */ /* Found one! */
current_vector = vector; current_vector = vector;
current_offset = offset; current_offset = offset;
if (d->cfg.vector) { /* Schedule the old vector for cleanup on all cpus */
if (d->cfg.vector)
cpumask_copy(d->old_domain, d->domain); cpumask_copy(d->old_domain, d->domain);
d->move_in_progress =
cpumask_intersects(d->old_domain, cpu_online_mask);
}
for_each_cpu(new_cpu, vector_searchmask) for_each_cpu(new_cpu, vector_searchmask)
per_cpu(vector_irq, new_cpu)[vector] = irq_to_desc(irq); per_cpu(vector_irq, new_cpu)[vector] = irq_to_desc(irq);
d->cfg.vector = vector; goto update;
cpumask_copy(d->domain, vector_cpumask);
goto success;
next_cpu: next_cpu:
/* /*
...@@ -209,6 +201,11 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d, ...@@ -209,6 +201,11 @@ static int __assign_irq_vector(int irq, struct apic_chip_data *d,
} }
return -ENOSPC; return -ENOSPC;
update:
/* Cleanup required ? */
d->move_in_progress = cpumask_intersects(d->old_domain, cpu_online_mask);
d->cfg.vector = vector;
cpumask_copy(d->domain, vector_cpumask);
success: success:
/* /*
* Cache destination APIC IDs into cfg->dest_apicid. This cannot fail * Cache destination APIC IDs into cfg->dest_apicid. This cannot fail
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment