]> CyberLeo.Net >> Repos - FreeBSD/FreeBSD.git/blob - sys/arm64/arm64/mp_machdep.c
Add a memory barrier to ensure the atomic write is visible to the other
[FreeBSD/FreeBSD.git] / sys / arm64 / arm64 / mp_machdep.c
1 /*-
2  * Copyright (c) 2015-2016 The FreeBSD Foundation
3  * All rights reserved.
4  *
5  * This software was developed by Andrew Turner under
6  * sponsorship from the FreeBSD Foundation.
7  *
8  * Redistribution and use in source and binary forms, with or without
9  * modification, are permitted provided that the following conditions
10  * are met:
11  * 1. Redistributions of source code must retain the above copyright
12  *    notice, this list of conditions and the following disclaimer.
13  * 2. Redistributions in binary form must reproduce the above copyright
14  *    notice, this list of conditions and the following disclaimer in the
15  *    documentation and/or other materials provided with the distribution.
16  *
17  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
18  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
21  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27  * SUCH DAMAGE.
28  *
29  */
30
31 #include "opt_acpi.h"
32 #include "opt_kstack_pages.h"
33 #include "opt_platform.h"
34
35 #include <sys/cdefs.h>
36 __FBSDID("$FreeBSD$");
37
38 #include <sys/param.h>
39 #include <sys/systm.h>
40 #include <sys/bus.h>
41 #include <sys/cpu.h>
42 #include <sys/kernel.h>
43 #include <sys/malloc.h>
44 #include <sys/module.h>
45 #include <sys/mutex.h>
46 #include <sys/proc.h>
47 #include <sys/sched.h>
48 #include <sys/smp.h>
49
50 #include <vm/vm.h>
51 #include <vm/pmap.h>
52 #include <vm/vm_extern.h>
53 #include <vm/vm_kern.h>
54
55 #include <machine/machdep.h>
56 #include <machine/intr.h>
57 #include <machine/smp.h>
58 #ifdef VFP
59 #include <machine/vfp.h>
60 #endif
61
62 #ifdef DEV_ACPI
63 #include <contrib/dev/acpica/include/acpi.h>
64 #include <dev/acpica/acpivar.h>
65 #endif
66
67 #ifdef FDT
68 #include <dev/ofw/openfirm.h>
69 #include <dev/ofw/ofw_bus.h>
70 #include <dev/ofw/ofw_bus_subr.h>
71 #include <dev/ofw/ofw_cpu.h>
72 #endif
73
74 #include <dev/psci/psci.h>
75
76 #include "pic_if.h"
77
78 #define MP_QUIRK_CPULIST        0x01    /* The list of cpus may be wrong, */
79                                         /* don't panic if one fails to start */
80 static uint32_t mp_quirks;
81
82 #ifdef FDT
83 static struct {
84         const char *compat;
85         uint32_t quirks;
86 } fdt_quirks[] = {
87         { "arm,foundation-aarch64",     MP_QUIRK_CPULIST },
88         { "arm,fvp-base",               MP_QUIRK_CPULIST },
89         /* This is incorrect in some DTS files */
90         { "arm,vfp-base",               MP_QUIRK_CPULIST },
91         { NULL, 0 },
92 };
93 #endif
94
95 typedef void intr_ipi_send_t(void *, cpuset_t, u_int);
96 typedef void intr_ipi_handler_t(void *);
97
98 #define INTR_IPI_NAMELEN        (MAXCOMLEN + 1)
99 struct intr_ipi {
100         intr_ipi_handler_t *    ii_handler;
101         void *                  ii_handler_arg;
102         intr_ipi_send_t *       ii_send;
103         void *                  ii_send_arg;
104         char                    ii_name[INTR_IPI_NAMELEN];
105         u_long *                ii_count;
106 };
107
108 static struct intr_ipi ipi_sources[INTR_IPI_COUNT];
109
110 static struct intr_ipi *intr_ipi_lookup(u_int);
111 static void intr_pic_ipi_setup(u_int, const char *, intr_ipi_handler_t *,
112     void *);
113
114 extern struct pcpu __pcpu[];
115
116 static device_identify_t arm64_cpu_identify;
117 static device_probe_t arm64_cpu_probe;
118 static device_attach_t arm64_cpu_attach;
119
120 static void ipi_ast(void *);
121 static void ipi_hardclock(void *);
122 static void ipi_preempt(void *);
123 static void ipi_rendezvous(void *);
124 static void ipi_stop(void *);
125
126 struct mtx ap_boot_mtx;
127 struct pcb stoppcbs[MAXCPU];
128
129 static device_t cpu_list[MAXCPU];
130
131 /*
132  * Not all systems boot from the first CPU in the device tree. To work around
133  * this we need to find which CPU we have booted from so when we later
134  * enable the secondary CPUs we skip this one.
135  */
136 static int cpu0 = -1;
137
138 void mpentry(unsigned long cpuid);
139 void init_secondary(uint64_t);
140
141 uint8_t secondary_stacks[MAXCPU - 1][PAGE_SIZE * KSTACK_PAGES] __aligned(16);
142
143 /* Set to 1 once we're ready to let the APs out of the pen. */
144 volatile int aps_ready = 0;
145
146 /* Temporary variables for init_secondary()  */
147 void *dpcpu[MAXCPU - 1];
148
149 static device_method_t arm64_cpu_methods[] = {
150         /* Device interface */
151         DEVMETHOD(device_identify,      arm64_cpu_identify),
152         DEVMETHOD(device_probe,         arm64_cpu_probe),
153         DEVMETHOD(device_attach,        arm64_cpu_attach),
154
155         DEVMETHOD_END
156 };
157
158 static devclass_t arm64_cpu_devclass;
159 static driver_t arm64_cpu_driver = {
160         "arm64_cpu",
161         arm64_cpu_methods,
162         0
163 };
164
165 DRIVER_MODULE(arm64_cpu, cpu, arm64_cpu_driver, arm64_cpu_devclass, 0, 0);
166
167 static void
168 arm64_cpu_identify(driver_t *driver, device_t parent)
169 {
170
171         if (device_find_child(parent, "arm64_cpu", -1) != NULL)
172                 return;
173         if (BUS_ADD_CHILD(parent, 0, "arm64_cpu", -1) == NULL)
174                 device_printf(parent, "add child failed\n");
175 }
176
177 static int
178 arm64_cpu_probe(device_t dev)
179 {
180         u_int cpuid;
181
182         cpuid = device_get_unit(dev);
183         if (cpuid >= MAXCPU || cpuid > mp_maxid)
184                 return (EINVAL);
185
186         device_quiet(dev);
187         return (0);
188 }
189
190 static int
191 arm64_cpu_attach(device_t dev)
192 {
193         const uint32_t *reg;
194         size_t reg_size;
195         u_int cpuid;
196         int i;
197
198         cpuid = device_get_unit(dev);
199
200         if (cpuid >= MAXCPU || cpuid > mp_maxid)
201                 return (EINVAL);
202         KASSERT(cpu_list[cpuid] == NULL, ("Already have cpu %u", cpuid));
203
204         reg = cpu_get_cpuid(dev, &reg_size);
205         if (reg == NULL)
206                 return (EINVAL);
207
208         if (bootverbose) {
209                 device_printf(dev, "register <");
210                 for (i = 0; i < reg_size; i++)
211                         printf("%s%x", (i == 0) ? "" : " ", reg[i]);
212                 printf(">\n");
213         }
214
215         /* Set the device to start it later */
216         cpu_list[cpuid] = dev;
217
218         return (0);
219 }
220
221 static void
222 release_aps(void *dummy __unused)
223 {
224         int i;
225
226         /* Only release CPUs if they exist */
227         if (mp_ncpus == 1)
228                 return;
229
230         intr_pic_ipi_setup(IPI_AST, "ast", ipi_ast, NULL);
231         intr_pic_ipi_setup(IPI_PREEMPT, "preempt", ipi_preempt, NULL);
232         intr_pic_ipi_setup(IPI_RENDEZVOUS, "rendezvous", ipi_rendezvous, NULL);
233         intr_pic_ipi_setup(IPI_STOP, "stop", ipi_stop, NULL);
234         intr_pic_ipi_setup(IPI_STOP_HARD, "stop hard", ipi_stop, NULL);
235         intr_pic_ipi_setup(IPI_HARDCLOCK, "hardclock", ipi_hardclock, NULL);
236
237         atomic_store_rel_int(&aps_ready, 1);
238         /* Wake up the other CPUs */
239         __asm __volatile(
240             "dsb ishst  \n"
241             "sev        \n"
242             ::: "memory");
243
244         printf("Release APs\n");
245
246         for (i = 0; i < 2000; i++) {
247                 if (smp_started)
248                         return;
249                 DELAY(1000);
250         }
251
252         printf("APs not started\n");
253 }
254 SYSINIT(start_aps, SI_SUB_SMP, SI_ORDER_FIRST, release_aps, NULL);
255
256 void
257 init_secondary(uint64_t cpu)
258 {
259         struct pcpu *pcpup;
260
261         pcpup = &__pcpu[cpu];
262         /*
263          * Set the pcpu pointer with a backup in tpidr_el1 to be
264          * loaded when entering the kernel from userland.
265          */
266         __asm __volatile(
267             "mov x18, %0 \n"
268             "msr tpidr_el1, %0" :: "r"(pcpup));
269
270         /* Spin until the BSP releases the APs */
271         while (!aps_ready)
272                 __asm __volatile("wfe");
273
274         /* Initialize curthread */
275         KASSERT(PCPU_GET(idlethread) != NULL, ("no idle thread"));
276         pcpup->pc_curthread = pcpup->pc_idlethread;
277         pcpup->pc_curpcb = pcpup->pc_idlethread->td_pcb;
278
279         /*
280          * Identify current CPU. This is necessary to setup
281          * affinity registers and to provide support for
282          * runtime chip identification.
283          */
284         identify_cpu();
285
286         intr_pic_init_secondary();
287
288         /* Start per-CPU event timers. */
289         cpu_initclocks_ap();
290
291 #ifdef VFP
292         vfp_init();
293 #endif
294
295         dbg_init();
296         pan_enable();
297
298         /* Enable interrupts */
299         intr_enable();
300
301         mtx_lock_spin(&ap_boot_mtx);
302
303         atomic_add_rel_32(&smp_cpus, 1);
304
305         if (smp_cpus == mp_ncpus) {
306                 /* enable IPI's, tlb shootdown, freezes etc */
307                 atomic_store_rel_int(&smp_started, 1);
308         }
309
310         mtx_unlock_spin(&ap_boot_mtx);
311
312         /* Enter the scheduler */
313         sched_throw(NULL);
314
315         panic("scheduler returned us to init_secondary");
316         /* NOTREACHED */
317 }
318
319 /*
320  *  Send IPI thru interrupt controller.
321  */
322 static void
323 pic_ipi_send(void *arg, cpuset_t cpus, u_int ipi)
324 {
325
326         KASSERT(intr_irq_root_dev != NULL, ("%s: no root attached", __func__));
327         PIC_IPI_SEND(intr_irq_root_dev, arg, cpus, ipi);
328 }
329
330 /*
331  *  Setup IPI handler on interrupt controller.
332  *
333  *  Not SMP coherent.
334  */
335 static void
336 intr_pic_ipi_setup(u_int ipi, const char *name, intr_ipi_handler_t *hand,
337     void *arg)
338 {
339         struct intr_irqsrc *isrc;
340         struct intr_ipi *ii;
341         int error;
342
343         KASSERT(intr_irq_root_dev != NULL, ("%s: no root attached", __func__));
344         KASSERT(hand != NULL, ("%s: ipi %u no handler", __func__, ipi));
345
346         error = PIC_IPI_SETUP(intr_irq_root_dev, ipi, &isrc);
347         if (error != 0)
348                 return;
349
350         isrc->isrc_handlers++;
351
352         ii = intr_ipi_lookup(ipi);
353         KASSERT(ii->ii_count == NULL, ("%s: ipi %u reused", __func__, ipi));
354
355         ii->ii_handler = hand;
356         ii->ii_handler_arg = arg;
357         ii->ii_send = pic_ipi_send;
358         ii->ii_send_arg = isrc;
359         strlcpy(ii->ii_name, name, INTR_IPI_NAMELEN);
360         ii->ii_count = intr_ipi_setup_counters(name);
361 }
362
363 static void
364 intr_ipi_send(cpuset_t cpus, u_int ipi)
365 {
366         struct intr_ipi *ii;
367
368         ii = intr_ipi_lookup(ipi);
369         if (ii->ii_count == NULL)
370                 panic("%s: not setup IPI %u", __func__, ipi);
371
372         ii->ii_send(ii->ii_send_arg, cpus, ipi);
373 }
374
375 static void
376 ipi_ast(void *dummy __unused)
377 {
378
379         CTR0(KTR_SMP, "IPI_AST");
380 }
381
382 static void
383 ipi_hardclock(void *dummy __unused)
384 {
385
386         CTR1(KTR_SMP, "%s: IPI_HARDCLOCK", __func__);
387         hardclockintr();
388 }
389
390 static void
391 ipi_preempt(void *dummy __unused)
392 {
393         CTR1(KTR_SMP, "%s: IPI_PREEMPT", __func__);
394         sched_preempt(curthread);
395 }
396
397 static void
398 ipi_rendezvous(void *dummy __unused)
399 {
400
401         CTR0(KTR_SMP, "IPI_RENDEZVOUS");
402         smp_rendezvous_action();
403 }
404
405 static void
406 ipi_stop(void *dummy __unused)
407 {
408         u_int cpu;
409
410         CTR0(KTR_SMP, "IPI_STOP");
411
412         cpu = PCPU_GET(cpuid);
413         savectx(&stoppcbs[cpu]);
414
415         /* Indicate we are stopped */
416         CPU_SET_ATOMIC(cpu, &stopped_cpus);
417
418         /* Wait for restart */
419         while (!CPU_ISSET(cpu, &started_cpus))
420                 cpu_spinwait();
421
422         CPU_CLR_ATOMIC(cpu, &started_cpus);
423         CPU_CLR_ATOMIC(cpu, &stopped_cpus);
424         CTR0(KTR_SMP, "IPI_STOP (restart)");
425 }
426
427 struct cpu_group *
428 cpu_topo(void)
429 {
430
431         return (smp_topo_none());
432 }
433
434 /* Determine if we running MP machine */
435 int
436 cpu_mp_probe(void)
437 {
438
439         /* ARM64TODO: Read the u bit of mpidr_el1 to determine this */
440         return (1);
441 }
442
443 static bool
444 start_cpu(u_int id, uint64_t target_cpu)
445 {
446         struct pcpu *pcpup;
447         vm_paddr_t pa;
448         u_int cpuid;
449         int err;
450
451         /* Check we are able to start this cpu */
452         if (id > mp_maxid)
453                 return (false);
454
455         KASSERT(id < MAXCPU, ("Too many CPUs"));
456
457         /* We are already running on cpu 0 */
458         if (id == cpu0)
459                 return (true);
460
461         /*
462          * Rotate the CPU IDs to put the boot CPU as CPU 0. We keep the other
463          * CPUs ordered as the are likely grouped into clusters so it can be
464          * useful to keep that property, e.g. for the GICv3 driver to send
465          * an IPI to all CPUs in the cluster.
466          */
467         cpuid = id;
468         if (cpuid < cpu0)
469                 cpuid += mp_maxid + 1;
470         cpuid -= cpu0;
471
472         pcpup = &__pcpu[cpuid];
473         pcpu_init(pcpup, cpuid, sizeof(struct pcpu));
474
475         dpcpu[cpuid - 1] = (void *)kmem_malloc(kernel_arena, DPCPU_SIZE,
476             M_WAITOK | M_ZERO);
477         dpcpu_init(dpcpu[cpuid - 1], cpuid);
478
479         printf("Starting CPU %u (%lx)\n", cpuid, target_cpu);
480         pa = pmap_extract(kernel_pmap, (vm_offset_t)mpentry);
481
482         err = psci_cpu_on(target_cpu, pa, cpuid);
483         if (err != PSCI_RETVAL_SUCCESS) {
484                 /*
485                  * Panic here if INVARIANTS are enabled and PSCI failed to
486                  * start the requested CPU. If psci_cpu_on returns PSCI_MISSING
487                  * to indicate we are unable to use it to start the given CPU.
488                  */
489                 KASSERT(err == PSCI_MISSING ||
490                     (mp_quirks & MP_QUIRK_CPULIST) == MP_QUIRK_CPULIST,
491                     ("Failed to start CPU %u (%lx)\n", id, target_cpu));
492
493                 pcpu_destroy(pcpup);
494                 kmem_free(kernel_arena, (vm_offset_t)dpcpu[cpuid - 1],
495                     DPCPU_SIZE);
496                 dpcpu[cpuid - 1] = NULL;
497                 mp_ncpus--;
498
499                 /* Notify the user that the CPU failed to start */
500                 printf("Failed to start CPU %u (%lx)\n", id, target_cpu);
501         } else
502                 CPU_SET(cpuid, &all_cpus);
503
504         return (true);
505 }
506
507 #ifdef DEV_ACPI
508 static void
509 madt_handler(ACPI_SUBTABLE_HEADER *entry, void *arg)
510 {
511         ACPI_MADT_GENERIC_INTERRUPT *intr;
512         u_int *cpuid;
513
514         switch(entry->Type) {
515         case ACPI_MADT_TYPE_GENERIC_INTERRUPT:
516                 intr = (ACPI_MADT_GENERIC_INTERRUPT *)entry;
517                 cpuid = arg;
518
519                 start_cpu((*cpuid), intr->ArmMpidr);
520                 (*cpuid)++;
521                 break;
522         default:
523                 break;
524         }
525 }
526
527 static void
528 cpu_init_acpi(void)
529 {
530         ACPI_TABLE_MADT *madt;
531         vm_paddr_t physaddr;
532         u_int cpuid;
533
534         physaddr = acpi_find_table(ACPI_SIG_MADT);
535         if (physaddr == 0)
536                 return;
537
538         madt = acpi_map_table(physaddr, ACPI_SIG_MADT);
539         if (madt == NULL) {
540                 printf("Unable to map the MADT, not starting APs\n");
541                 return;
542         }
543
544         cpuid = 0;
545         acpi_walk_subtables(madt + 1, (char *)madt + madt->Header.Length,
546             madt_handler, &cpuid);
547
548         acpi_unmap_table(madt);
549 }
550 #endif
551
552 #ifdef FDT
553 static boolean_t
554 cpu_init_fdt(u_int id, phandle_t node, u_int addr_size, pcell_t *reg)
555 {
556         uint64_t target_cpu;
557         int domain;
558
559         target_cpu = reg[0];
560         if (addr_size == 2) {
561                 target_cpu <<= 32;
562                 target_cpu |= reg[1];
563         }
564
565         if (!start_cpu(id, target_cpu))
566                 return (FALSE);
567
568         /* Try to read the numa node of this cpu */
569         if (OF_getencprop(node, "numa-node-id", &domain, sizeof(domain)) > 0) {
570                 __pcpu[id].pc_domain = domain;
571                 if (domain < MAXMEMDOM)
572                         CPU_SET(id, &cpuset_domain[domain]);
573         }
574
575         return (TRUE);
576 }
577 #endif
578
579 /* Initialize and fire up non-boot processors */
580 void
581 cpu_mp_start(void)
582 {
583 #ifdef FDT
584         phandle_t node;
585         int i;
586 #endif
587
588         mtx_init(&ap_boot_mtx, "ap boot", NULL, MTX_SPIN);
589
590         CPU_SET(0, &all_cpus);
591
592         switch(arm64_bus_method) {
593 #ifdef DEV_ACPI
594         case ARM64_BUS_ACPI:
595                 KASSERT(cpu0 >= 0, ("Current CPU was not found"));
596                 cpu_init_acpi();
597                 break;
598 #endif
599 #ifdef FDT
600         case ARM64_BUS_FDT:
601                 node = OF_peer(0);
602                 for (i = 0; fdt_quirks[i].compat != NULL; i++) {
603                         if (ofw_bus_node_is_compatible(node,
604                             fdt_quirks[i].compat) != 0) {
605                                 mp_quirks = fdt_quirks[i].quirks;
606                         }
607                 }
608                 KASSERT(cpu0 >= 0, ("Current CPU was not found"));
609                 ofw_cpu_early_foreach(cpu_init_fdt, true);
610                 break;
611 #endif
612         default:
613                 break;
614         }
615 }
616
617 /* Introduce rest of cores to the world */
618 void
619 cpu_mp_announce(void)
620 {
621 }
622
623 #ifdef DEV_ACPI
624 static void
625 cpu_count_acpi_handler(ACPI_SUBTABLE_HEADER *entry, void *arg)
626 {
627         ACPI_MADT_GENERIC_INTERRUPT *intr;
628         u_int *cores = arg;
629         uint64_t mpidr_reg;
630
631         switch(entry->Type) {
632         case ACPI_MADT_TYPE_GENERIC_INTERRUPT:
633                 intr = (ACPI_MADT_GENERIC_INTERRUPT *)entry;
634                 if (cpu0 < 0) {
635                         mpidr_reg = READ_SPECIALREG(mpidr_el1);
636                         if ((mpidr_reg & 0xff00fffffful) == intr->ArmMpidr)
637                                 cpu0 = *cores;
638                 }
639                 (*cores)++;
640                 break;
641         default:
642                 break;
643         }
644 }
645
646 static u_int
647 cpu_count_acpi(void)
648 {
649         ACPI_TABLE_MADT *madt;
650         vm_paddr_t physaddr;
651         u_int cores;
652
653         physaddr = acpi_find_table(ACPI_SIG_MADT);
654         if (physaddr == 0)
655                 return (0);
656
657         madt = acpi_map_table(physaddr, ACPI_SIG_MADT);
658         if (madt == NULL) {
659                 printf("Unable to map the MADT, not starting APs\n");
660                 return (0);
661         }
662
663         cores = 0;
664         acpi_walk_subtables(madt + 1, (char *)madt + madt->Header.Length,
665             cpu_count_acpi_handler, &cores);
666
667         acpi_unmap_table(madt);
668
669         return (cores);
670 }
671 #endif
672
673 #ifdef FDT
674 static boolean_t
675 cpu_find_cpu0_fdt(u_int id, phandle_t node, u_int addr_size, pcell_t *reg)
676 {
677         uint64_t mpidr_fdt, mpidr_reg;
678
679         if (cpu0 < 0) {
680                 mpidr_fdt = reg[0];
681                 if (addr_size == 2) {
682                         mpidr_fdt <<= 32;
683                         mpidr_fdt |= reg[1];
684                 }
685
686                 mpidr_reg = READ_SPECIALREG(mpidr_el1);
687
688                 if ((mpidr_reg & 0xff00fffffful) == mpidr_fdt)
689                         cpu0 = id;
690         }
691
692         return (TRUE);
693 }
694 #endif
695
696 void
697 cpu_mp_setmaxid(void)
698 {
699 #if defined(DEV_ACPI) || defined(FDT)
700         int cores;
701 #endif
702
703         switch(arm64_bus_method) {
704 #ifdef DEV_ACPI
705         case ARM64_BUS_ACPI:
706                 cores = cpu_count_acpi();
707                 if (cores > 0) {
708                         cores = MIN(cores, MAXCPU);
709                         if (bootverbose)
710                                 printf("Found %d CPUs in the ACPI tables\n",
711                                     cores);
712                         mp_ncpus = cores;
713                         mp_maxid = cores - 1;
714                         return;
715                 }
716                 break;
717 #endif
718 #ifdef FDT
719         case ARM64_BUS_FDT:
720                 cores = ofw_cpu_early_foreach(cpu_find_cpu0_fdt, false);
721                 if (cores > 0) {
722                         cores = MIN(cores, MAXCPU);
723                         if (bootverbose)
724                                 printf("Found %d CPUs in the device tree\n",
725                                     cores);
726                         mp_ncpus = cores;
727                         mp_maxid = cores - 1;
728                         return;
729                 }
730                 break;
731 #endif
732         default:
733                 break;
734         }
735
736         if (bootverbose)
737                 printf("No CPU data, limiting to 1 core\n");
738         mp_ncpus = 1;
739         mp_maxid = 0;
740 }
741
742 /*
743  *  Lookup IPI source.
744  */
745 static struct intr_ipi *
746 intr_ipi_lookup(u_int ipi)
747 {
748
749         if (ipi >= INTR_IPI_COUNT)
750                 panic("%s: no such IPI %u", __func__, ipi);
751
752         return (&ipi_sources[ipi]);
753 }
754
755 /*
756  *  interrupt controller dispatch function for IPIs. It should
757  *  be called straight from the interrupt controller, when associated
758  *  interrupt source is learned. Or from anybody who has an interrupt
759  *  source mapped.
760  */
761 void
762 intr_ipi_dispatch(u_int ipi, struct trapframe *tf)
763 {
764         void *arg;
765         struct intr_ipi *ii;
766
767         ii = intr_ipi_lookup(ipi);
768         if (ii->ii_count == NULL)
769                 panic("%s: not setup IPI %u", __func__, ipi);
770
771         intr_ipi_increment_count(ii->ii_count, PCPU_GET(cpuid));
772
773         /*
774          * Supply ipi filter with trapframe argument
775          * if none is registered.
776          */
777         arg = ii->ii_handler_arg != NULL ? ii->ii_handler_arg : tf;
778         ii->ii_handler(arg);
779 }
780
781 #ifdef notyet
782 /*
783  *  Map IPI into interrupt controller.
784  *
785  *  Not SMP coherent.
786  */
787 static int
788 ipi_map(struct intr_irqsrc *isrc, u_int ipi)
789 {
790         boolean_t is_percpu;
791         int error;
792
793         if (ipi >= INTR_IPI_COUNT)
794                 panic("%s: no such IPI %u", __func__, ipi);
795
796         KASSERT(intr_irq_root_dev != NULL, ("%s: no root attached", __func__));
797
798         isrc->isrc_type = INTR_ISRCT_NAMESPACE;
799         isrc->isrc_nspc_type = INTR_IRQ_NSPC_IPI;
800         isrc->isrc_nspc_num = ipi_next_num;
801
802         error = PIC_REGISTER(intr_irq_root_dev, isrc, &is_percpu);
803         if (error == 0) {
804                 isrc->isrc_dev = intr_irq_root_dev;
805                 ipi_next_num++;
806         }
807         return (error);
808 }
809
810 /*
811  *  Setup IPI handler to interrupt source.
812  *
813  *  Note that there could be more ways how to send and receive IPIs
814  *  on a platform like fast interrupts for example. In that case,
815  *  one can call this function with ASIF_NOALLOC flag set and then
816  *  call intr_ipi_dispatch() when appropriate.
817  *
818  *  Not SMP coherent.
819  */
820 int
821 intr_ipi_set_handler(u_int ipi, const char *name, intr_ipi_filter_t *filter,
822     void *arg, u_int flags)
823 {
824         struct intr_irqsrc *isrc;
825         int error;
826
827         if (filter == NULL)
828                 return(EINVAL);
829
830         isrc = intr_ipi_lookup(ipi);
831         if (isrc->isrc_ipifilter != NULL)
832                 return (EEXIST);
833
834         if ((flags & AISHF_NOALLOC) == 0) {
835                 error = ipi_map(isrc, ipi);
836                 if (error != 0)
837                         return (error);
838         }
839
840         isrc->isrc_ipifilter = filter;
841         isrc->isrc_arg = arg;
842         isrc->isrc_handlers = 1;
843         isrc->isrc_count = intr_ipi_setup_counters(name);
844         isrc->isrc_index = 0; /* it should not be used in IPI case */
845
846         if (isrc->isrc_dev != NULL) {
847                 PIC_ENABLE_INTR(isrc->isrc_dev, isrc);
848                 PIC_ENABLE_SOURCE(isrc->isrc_dev, isrc);
849         }
850         return (0);
851 }
852 #endif
853
854 /* Sending IPI */
855 void
856 ipi_all_but_self(u_int ipi)
857 {
858         cpuset_t cpus;
859
860         cpus = all_cpus;
861         CPU_CLR(PCPU_GET(cpuid), &cpus);
862         CTR2(KTR_SMP, "%s: ipi: %x", __func__, ipi);
863         intr_ipi_send(cpus, ipi);
864 }
865
866 void
867 ipi_cpu(int cpu, u_int ipi)
868 {
869         cpuset_t cpus;
870
871         CPU_ZERO(&cpus);
872         CPU_SET(cpu, &cpus);
873
874         CTR3(KTR_SMP, "%s: cpu: %d, ipi: %x", __func__, cpu, ipi);
875         intr_ipi_send(cpus, ipi);
876 }
877
878 void
879 ipi_selected(cpuset_t cpus, u_int ipi)
880 {
881
882         CTR2(KTR_SMP, "%s: ipi: %x", __func__, ipi);
883         intr_ipi_send(cpus, ipi);
884 }