Commit bbeee4b2 authored by Chris Metcalf's avatar Chris Metcalf

arch/tile: warn and retry if an IPI is not accepted by the target cpu

Previously we assumed this was impossible, but in fact it can happen.
Handle it gracefully by retrying after issuing a warning.
Signed-off-by: default avatarChris Metcalf <cmetcalf@tilera.com>
parent b2ce2bda
...@@ -36,6 +36,22 @@ static unsigned long __iomem *ipi_mappings[NR_CPUS]; ...@@ -36,6 +36,22 @@ static unsigned long __iomem *ipi_mappings[NR_CPUS];
/* Set by smp_send_stop() to avoid recursive panics. */ /* Set by smp_send_stop() to avoid recursive panics. */
static int stopping_cpus; static int stopping_cpus;
static void __send_IPI_many(HV_Recipient *recip, int nrecip, int tag)
{
int sent = 0;
while (sent < nrecip) {
int rc = hv_send_message(recip, nrecip,
(HV_VirtAddr)&tag, sizeof(tag));
if (rc < 0) {
if (!stopping_cpus) /* avoid recursive panic */
panic("hv_send_message returned %d", rc);
break;
}
WARN_ONCE(rc == 0, "hv_send_message() returned zero\n");
sent += rc;
}
}
void send_IPI_single(int cpu, int tag) void send_IPI_single(int cpu, int tag)
{ {
HV_Recipient recip = { HV_Recipient recip = {
...@@ -43,14 +59,13 @@ void send_IPI_single(int cpu, int tag) ...@@ -43,14 +59,13 @@ void send_IPI_single(int cpu, int tag)
.x = cpu % smp_width, .x = cpu % smp_width,
.state = HV_TO_BE_SENT .state = HV_TO_BE_SENT
}; };
int rc = hv_send_message(&recip, 1, (HV_VirtAddr)&tag, sizeof(tag)); __send_IPI_many(&recip, 1, tag);
BUG_ON(rc <= 0);
} }
void send_IPI_many(const struct cpumask *mask, int tag) void send_IPI_many(const struct cpumask *mask, int tag)
{ {
HV_Recipient recip[NR_CPUS]; HV_Recipient recip[NR_CPUS];
int cpu, sent; int cpu;
int nrecip = 0; int nrecip = 0;
int my_cpu = smp_processor_id(); int my_cpu = smp_processor_id();
for_each_cpu(cpu, mask) { for_each_cpu(cpu, mask) {
...@@ -61,17 +76,7 @@ void send_IPI_many(const struct cpumask *mask, int tag) ...@@ -61,17 +76,7 @@ void send_IPI_many(const struct cpumask *mask, int tag)
r->x = cpu % smp_width; r->x = cpu % smp_width;
r->state = HV_TO_BE_SENT; r->state = HV_TO_BE_SENT;
} }
sent = 0; __send_IPI_many(recip, nrecip, tag);
while (sent < nrecip) {
int rc = hv_send_message(recip, nrecip,
(HV_VirtAddr)&tag, sizeof(tag));
if (rc <= 0) {
if (!stopping_cpus) /* avoid recursive panic */
panic("hv_send_message returned %d", rc);
break;
}
sent += rc;
}
} }
void send_IPI_allbutself(int tag) void send_IPI_allbutself(int tag)
......
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