smp_64.c 37 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597
  1. /* smp.c: Sparc64 SMP support.
  2. *
  3. * Copyright (C) 1997, 2007, 2008 David S. Miller (davem@davemloft.net)
  4. */
  5. #include <linux/export.h>
  6. #include <linux/kernel.h>
  7. #include <linux/sched/mm.h>
  8. #include <linux/sched/hotplug.h>
  9. #include <linux/mm.h>
  10. #include <linux/pagemap.h>
  11. #include <linux/threads.h>
  12. #include <linux/smp.h>
  13. #include <linux/interrupt.h>
  14. #include <linux/kernel_stat.h>
  15. #include <linux/delay.h>
  16. #include <linux/init.h>
  17. #include <linux/spinlock.h>
  18. #include <linux/fs.h>
  19. #include <linux/seq_file.h>
  20. #include <linux/cache.h>
  21. #include <linux/jiffies.h>
  22. #include <linux/profile.h>
  23. #include <linux/bootmem.h>
  24. #include <linux/vmalloc.h>
  25. #include <linux/ftrace.h>
  26. #include <linux/cpu.h>
  27. #include <linux/slab.h>
  28. #include <linux/kgdb.h>
  29. #include <asm/head.h>
  30. #include <asm/ptrace.h>
  31. #include <linux/atomic.h>
  32. #include <asm/tlbflush.h>
  33. #include <asm/mmu_context.h>
  34. #include <asm/cpudata.h>
  35. #include <asm/hvtramp.h>
  36. #include <asm/io.h>
  37. #include <asm/timer.h>
  38. #include <asm/setup.h>
  39. #include <asm/irq.h>
  40. #include <asm/irq_regs.h>
  41. #include <asm/page.h>
  42. #include <asm/pgtable.h>
  43. #include <asm/oplib.h>
  44. #include <linux/uaccess.h>
  45. #include <asm/starfire.h>
  46. #include <asm/tlb.h>
  47. #include <asm/sections.h>
  48. #include <asm/prom.h>
  49. #include <asm/mdesc.h>
  50. #include <asm/ldc.h>
  51. #include <asm/hypervisor.h>
  52. #include <asm/pcr.h>
  53. #include "cpumap.h"
  54. #include "kernel.h"
  55. DEFINE_PER_CPU(cpumask_t, cpu_sibling_map) = CPU_MASK_NONE;
  56. cpumask_t cpu_core_map[NR_CPUS] __read_mostly =
  57. { [0 ... NR_CPUS-1] = CPU_MASK_NONE };
  58. cpumask_t cpu_core_sib_map[NR_CPUS] __read_mostly = {
  59. [0 ... NR_CPUS-1] = CPU_MASK_NONE };
  60. cpumask_t cpu_core_sib_cache_map[NR_CPUS] __read_mostly = {
  61. [0 ... NR_CPUS - 1] = CPU_MASK_NONE };
  62. EXPORT_PER_CPU_SYMBOL(cpu_sibling_map);
  63. EXPORT_SYMBOL(cpu_core_map);
  64. EXPORT_SYMBOL(cpu_core_sib_map);
  65. EXPORT_SYMBOL(cpu_core_sib_cache_map);
  66. static cpumask_t smp_commenced_mask;
  67. void smp_info(struct seq_file *m)
  68. {
  69. int i;
  70. seq_printf(m, "State:\n");
  71. for_each_online_cpu(i)
  72. seq_printf(m, "CPU%d:\t\tonline\n", i);
  73. }
  74. void smp_bogo(struct seq_file *m)
  75. {
  76. int i;
  77. for_each_online_cpu(i)
  78. seq_printf(m,
  79. "Cpu%dClkTck\t: %016lx\n",
  80. i, cpu_data(i).clock_tick);
  81. }
  82. extern void setup_sparc64_timer(void);
  83. static volatile unsigned long callin_flag = 0;
  84. void smp_callin(void)
  85. {
  86. int cpuid = hard_smp_processor_id();
  87. __local_per_cpu_offset = __per_cpu_offset(cpuid);
  88. if (tlb_type == hypervisor)
  89. sun4v_ktsb_register();
  90. __flush_tlb_all();
  91. setup_sparc64_timer();
  92. if (cheetah_pcache_forced_on)
  93. cheetah_enable_pcache();
  94. callin_flag = 1;
  95. __asm__ __volatile__("membar #Sync\n\t"
  96. "flush %%g6" : : : "memory");
  97. /* Clear this or we will die instantly when we
  98. * schedule back to this idler...
  99. */
  100. current_thread_info()->new_child = 0;
  101. /* Attach to the address space of init_task. */
  102. mmgrab(&init_mm);
  103. current->active_mm = &init_mm;
  104. /* inform the notifiers about the new cpu */
  105. notify_cpu_starting(cpuid);
  106. while (!cpumask_test_cpu(cpuid, &smp_commenced_mask))
  107. rmb();
  108. set_cpu_online(cpuid, true);
  109. /* idle thread is expected to have preempt disabled */
  110. preempt_disable();
  111. local_irq_enable();
  112. cpu_startup_entry(CPUHP_AP_ONLINE_IDLE);
  113. }
  114. void cpu_panic(void)
  115. {
  116. printk("CPU[%d]: Returns from cpu_idle!\n", smp_processor_id());
  117. panic("SMP bolixed\n");
  118. }
  119. /* This tick register synchronization scheme is taken entirely from
  120. * the ia64 port, see arch/ia64/kernel/smpboot.c for details and credit.
  121. *
  122. * The only change I've made is to rework it so that the master
  123. * initiates the synchonization instead of the slave. -DaveM
  124. */
  125. #define MASTER 0
  126. #define SLAVE (SMP_CACHE_BYTES/sizeof(unsigned long))
  127. #define NUM_ROUNDS 64 /* magic value */
  128. #define NUM_ITERS 5 /* likewise */
  129. static DEFINE_RAW_SPINLOCK(itc_sync_lock);
  130. static unsigned long go[SLAVE + 1];
  131. #define DEBUG_TICK_SYNC 0
  132. static inline long get_delta (long *rt, long *master)
  133. {
  134. unsigned long best_t0 = 0, best_t1 = ~0UL, best_tm = 0;
  135. unsigned long tcenter, t0, t1, tm;
  136. unsigned long i;
  137. for (i = 0; i < NUM_ITERS; i++) {
  138. t0 = tick_ops->get_tick();
  139. go[MASTER] = 1;
  140. membar_safe("#StoreLoad");
  141. while (!(tm = go[SLAVE]))
  142. rmb();
  143. go[SLAVE] = 0;
  144. wmb();
  145. t1 = tick_ops->get_tick();
  146. if (t1 - t0 < best_t1 - best_t0)
  147. best_t0 = t0, best_t1 = t1, best_tm = tm;
  148. }
  149. *rt = best_t1 - best_t0;
  150. *master = best_tm - best_t0;
  151. /* average best_t0 and best_t1 without overflow: */
  152. tcenter = (best_t0/2 + best_t1/2);
  153. if (best_t0 % 2 + best_t1 % 2 == 2)
  154. tcenter++;
  155. return tcenter - best_tm;
  156. }
  157. void smp_synchronize_tick_client(void)
  158. {
  159. long i, delta, adj, adjust_latency = 0, done = 0;
  160. unsigned long flags, rt, master_time_stamp;
  161. #if DEBUG_TICK_SYNC
  162. struct {
  163. long rt; /* roundtrip time */
  164. long master; /* master's timestamp */
  165. long diff; /* difference between midpoint and master's timestamp */
  166. long lat; /* estimate of itc adjustment latency */
  167. } t[NUM_ROUNDS];
  168. #endif
  169. go[MASTER] = 1;
  170. while (go[MASTER])
  171. rmb();
  172. local_irq_save(flags);
  173. {
  174. for (i = 0; i < NUM_ROUNDS; i++) {
  175. delta = get_delta(&rt, &master_time_stamp);
  176. if (delta == 0)
  177. done = 1; /* let's lock on to this... */
  178. if (!done) {
  179. if (i > 0) {
  180. adjust_latency += -delta;
  181. adj = -delta + adjust_latency/4;
  182. } else
  183. adj = -delta;
  184. tick_ops->add_tick(adj);
  185. }
  186. #if DEBUG_TICK_SYNC
  187. t[i].rt = rt;
  188. t[i].master = master_time_stamp;
  189. t[i].diff = delta;
  190. t[i].lat = adjust_latency/4;
  191. #endif
  192. }
  193. }
  194. local_irq_restore(flags);
  195. #if DEBUG_TICK_SYNC
  196. for (i = 0; i < NUM_ROUNDS; i++)
  197. printk("rt=%5ld master=%5ld diff=%5ld adjlat=%5ld\n",
  198. t[i].rt, t[i].master, t[i].diff, t[i].lat);
  199. #endif
  200. printk(KERN_INFO "CPU %d: synchronized TICK with master CPU "
  201. "(last diff %ld cycles, maxerr %lu cycles)\n",
  202. smp_processor_id(), delta, rt);
  203. }
  204. static void smp_start_sync_tick_client(int cpu);
  205. static void smp_synchronize_one_tick(int cpu)
  206. {
  207. unsigned long flags, i;
  208. go[MASTER] = 0;
  209. smp_start_sync_tick_client(cpu);
  210. /* wait for client to be ready */
  211. while (!go[MASTER])
  212. rmb();
  213. /* now let the client proceed into his loop */
  214. go[MASTER] = 0;
  215. membar_safe("#StoreLoad");
  216. raw_spin_lock_irqsave(&itc_sync_lock, flags);
  217. {
  218. for (i = 0; i < NUM_ROUNDS*NUM_ITERS; i++) {
  219. while (!go[MASTER])
  220. rmb();
  221. go[MASTER] = 0;
  222. wmb();
  223. go[SLAVE] = tick_ops->get_tick();
  224. membar_safe("#StoreLoad");
  225. }
  226. }
  227. raw_spin_unlock_irqrestore(&itc_sync_lock, flags);
  228. }
  229. #if defined(CONFIG_SUN_LDOMS) && defined(CONFIG_HOTPLUG_CPU)
  230. static void ldom_startcpu_cpuid(unsigned int cpu, unsigned long thread_reg,
  231. void **descrp)
  232. {
  233. extern unsigned long sparc64_ttable_tl0;
  234. extern unsigned long kern_locked_tte_data;
  235. struct hvtramp_descr *hdesc;
  236. unsigned long trampoline_ra;
  237. struct trap_per_cpu *tb;
  238. u64 tte_vaddr, tte_data;
  239. unsigned long hv_err;
  240. int i;
  241. hdesc = kzalloc(sizeof(*hdesc) +
  242. (sizeof(struct hvtramp_mapping) *
  243. num_kernel_image_mappings - 1),
  244. GFP_KERNEL);
  245. if (!hdesc) {
  246. printk(KERN_ERR "ldom_startcpu_cpuid: Cannot allocate "
  247. "hvtramp_descr.\n");
  248. return;
  249. }
  250. *descrp = hdesc;
  251. hdesc->cpu = cpu;
  252. hdesc->num_mappings = num_kernel_image_mappings;
  253. tb = &trap_block[cpu];
  254. hdesc->fault_info_va = (unsigned long) &tb->fault_info;
  255. hdesc->fault_info_pa = kimage_addr_to_ra(&tb->fault_info);
  256. hdesc->thread_reg = thread_reg;
  257. tte_vaddr = (unsigned long) KERNBASE;
  258. tte_data = kern_locked_tte_data;
  259. for (i = 0; i < hdesc->num_mappings; i++) {
  260. hdesc->maps[i].vaddr = tte_vaddr;
  261. hdesc->maps[i].tte = tte_data;
  262. tte_vaddr += 0x400000;
  263. tte_data += 0x400000;
  264. }
  265. trampoline_ra = kimage_addr_to_ra(hv_cpu_startup);
  266. hv_err = sun4v_cpu_start(cpu, trampoline_ra,
  267. kimage_addr_to_ra(&sparc64_ttable_tl0),
  268. __pa(hdesc));
  269. if (hv_err)
  270. printk(KERN_ERR "ldom_startcpu_cpuid: sun4v_cpu_start() "
  271. "gives error %lu\n", hv_err);
  272. }
  273. #endif
  274. extern unsigned long sparc64_cpu_startup;
  275. /* The OBP cpu startup callback truncates the 3rd arg cookie to
  276. * 32-bits (I think) so to be safe we have it read the pointer
  277. * contained here so we work on >4GB machines. -DaveM
  278. */
  279. static struct thread_info *cpu_new_thread = NULL;
  280. static int smp_boot_one_cpu(unsigned int cpu, struct task_struct *idle)
  281. {
  282. unsigned long entry =
  283. (unsigned long)(&sparc64_cpu_startup);
  284. unsigned long cookie =
  285. (unsigned long)(&cpu_new_thread);
  286. void *descr = NULL;
  287. int timeout, ret;
  288. callin_flag = 0;
  289. cpu_new_thread = task_thread_info(idle);
  290. if (tlb_type == hypervisor) {
  291. #if defined(CONFIG_SUN_LDOMS) && defined(CONFIG_HOTPLUG_CPU)
  292. if (ldom_domaining_enabled)
  293. ldom_startcpu_cpuid(cpu,
  294. (unsigned long) cpu_new_thread,
  295. &descr);
  296. else
  297. #endif
  298. prom_startcpu_cpuid(cpu, entry, cookie);
  299. } else {
  300. struct device_node *dp = of_find_node_by_cpuid(cpu);
  301. prom_startcpu(dp->phandle, entry, cookie);
  302. }
  303. for (timeout = 0; timeout < 50000; timeout++) {
  304. if (callin_flag)
  305. break;
  306. udelay(100);
  307. }
  308. if (callin_flag) {
  309. ret = 0;
  310. } else {
  311. printk("Processor %d is stuck.\n", cpu);
  312. ret = -ENODEV;
  313. }
  314. cpu_new_thread = NULL;
  315. kfree(descr);
  316. return ret;
  317. }
  318. static void spitfire_xcall_helper(u64 data0, u64 data1, u64 data2, u64 pstate, unsigned long cpu)
  319. {
  320. u64 result, target;
  321. int stuck, tmp;
  322. if (this_is_starfire) {
  323. /* map to real upaid */
  324. cpu = (((cpu & 0x3c) << 1) |
  325. ((cpu & 0x40) >> 4) |
  326. (cpu & 0x3));
  327. }
  328. target = (cpu << 14) | 0x70;
  329. again:
  330. /* Ok, this is the real Spitfire Errata #54.
  331. * One must read back from a UDB internal register
  332. * after writes to the UDB interrupt dispatch, but
  333. * before the membar Sync for that write.
  334. * So we use the high UDB control register (ASI 0x7f,
  335. * ADDR 0x20) for the dummy read. -DaveM
  336. */
  337. tmp = 0x40;
  338. __asm__ __volatile__(
  339. "wrpr %1, %2, %%pstate\n\t"
  340. "stxa %4, [%0] %3\n\t"
  341. "stxa %5, [%0+%8] %3\n\t"
  342. "add %0, %8, %0\n\t"
  343. "stxa %6, [%0+%8] %3\n\t"
  344. "membar #Sync\n\t"
  345. "stxa %%g0, [%7] %3\n\t"
  346. "membar #Sync\n\t"
  347. "mov 0x20, %%g1\n\t"
  348. "ldxa [%%g1] 0x7f, %%g0\n\t"
  349. "membar #Sync"
  350. : "=r" (tmp)
  351. : "r" (pstate), "i" (PSTATE_IE), "i" (ASI_INTR_W),
  352. "r" (data0), "r" (data1), "r" (data2), "r" (target),
  353. "r" (0x10), "0" (tmp)
  354. : "g1");
  355. /* NOTE: PSTATE_IE is still clear. */
  356. stuck = 100000;
  357. do {
  358. __asm__ __volatile__("ldxa [%%g0] %1, %0"
  359. : "=r" (result)
  360. : "i" (ASI_INTR_DISPATCH_STAT));
  361. if (result == 0) {
  362. __asm__ __volatile__("wrpr %0, 0x0, %%pstate"
  363. : : "r" (pstate));
  364. return;
  365. }
  366. stuck -= 1;
  367. if (stuck == 0)
  368. break;
  369. } while (result & 0x1);
  370. __asm__ __volatile__("wrpr %0, 0x0, %%pstate"
  371. : : "r" (pstate));
  372. if (stuck == 0) {
  373. printk("CPU[%d]: mondo stuckage result[%016llx]\n",
  374. smp_processor_id(), result);
  375. } else {
  376. udelay(2);
  377. goto again;
  378. }
  379. }
  380. static void spitfire_xcall_deliver(struct trap_per_cpu *tb, int cnt)
  381. {
  382. u64 *mondo, data0, data1, data2;
  383. u16 *cpu_list;
  384. u64 pstate;
  385. int i;
  386. __asm__ __volatile__("rdpr %%pstate, %0" : "=r" (pstate));
  387. cpu_list = __va(tb->cpu_list_pa);
  388. mondo = __va(tb->cpu_mondo_block_pa);
  389. data0 = mondo[0];
  390. data1 = mondo[1];
  391. data2 = mondo[2];
  392. for (i = 0; i < cnt; i++)
  393. spitfire_xcall_helper(data0, data1, data2, pstate, cpu_list[i]);
  394. }
  395. /* Cheetah now allows to send the whole 64-bytes of data in the interrupt
  396. * packet, but we have no use for that. However we do take advantage of
  397. * the new pipelining feature (ie. dispatch to multiple cpus simultaneously).
  398. */
  399. static void cheetah_xcall_deliver(struct trap_per_cpu *tb, int cnt)
  400. {
  401. int nack_busy_id, is_jbus, need_more;
  402. u64 *mondo, pstate, ver, busy_mask;
  403. u16 *cpu_list;
  404. cpu_list = __va(tb->cpu_list_pa);
  405. mondo = __va(tb->cpu_mondo_block_pa);
  406. /* Unfortunately, someone at Sun had the brilliant idea to make the
  407. * busy/nack fields hard-coded by ITID number for this Ultra-III
  408. * derivative processor.
  409. */
  410. __asm__ ("rdpr %%ver, %0" : "=r" (ver));
  411. is_jbus = ((ver >> 32) == __JALAPENO_ID ||
  412. (ver >> 32) == __SERRANO_ID);
  413. __asm__ __volatile__("rdpr %%pstate, %0" : "=r" (pstate));
  414. retry:
  415. need_more = 0;
  416. __asm__ __volatile__("wrpr %0, %1, %%pstate\n\t"
  417. : : "r" (pstate), "i" (PSTATE_IE));
  418. /* Setup the dispatch data registers. */
  419. __asm__ __volatile__("stxa %0, [%3] %6\n\t"
  420. "stxa %1, [%4] %6\n\t"
  421. "stxa %2, [%5] %6\n\t"
  422. "membar #Sync\n\t"
  423. : /* no outputs */
  424. : "r" (mondo[0]), "r" (mondo[1]), "r" (mondo[2]),
  425. "r" (0x40), "r" (0x50), "r" (0x60),
  426. "i" (ASI_INTR_W));
  427. nack_busy_id = 0;
  428. busy_mask = 0;
  429. {
  430. int i;
  431. for (i = 0; i < cnt; i++) {
  432. u64 target, nr;
  433. nr = cpu_list[i];
  434. if (nr == 0xffff)
  435. continue;
  436. target = (nr << 14) | 0x70;
  437. if (is_jbus) {
  438. busy_mask |= (0x1UL << (nr * 2));
  439. } else {
  440. target |= (nack_busy_id << 24);
  441. busy_mask |= (0x1UL <<
  442. (nack_busy_id * 2));
  443. }
  444. __asm__ __volatile__(
  445. "stxa %%g0, [%0] %1\n\t"
  446. "membar #Sync\n\t"
  447. : /* no outputs */
  448. : "r" (target), "i" (ASI_INTR_W));
  449. nack_busy_id++;
  450. if (nack_busy_id == 32) {
  451. need_more = 1;
  452. break;
  453. }
  454. }
  455. }
  456. /* Now, poll for completion. */
  457. {
  458. u64 dispatch_stat, nack_mask;
  459. long stuck;
  460. stuck = 100000 * nack_busy_id;
  461. nack_mask = busy_mask << 1;
  462. do {
  463. __asm__ __volatile__("ldxa [%%g0] %1, %0"
  464. : "=r" (dispatch_stat)
  465. : "i" (ASI_INTR_DISPATCH_STAT));
  466. if (!(dispatch_stat & (busy_mask | nack_mask))) {
  467. __asm__ __volatile__("wrpr %0, 0x0, %%pstate"
  468. : : "r" (pstate));
  469. if (unlikely(need_more)) {
  470. int i, this_cnt = 0;
  471. for (i = 0; i < cnt; i++) {
  472. if (cpu_list[i] == 0xffff)
  473. continue;
  474. cpu_list[i] = 0xffff;
  475. this_cnt++;
  476. if (this_cnt == 32)
  477. break;
  478. }
  479. goto retry;
  480. }
  481. return;
  482. }
  483. if (!--stuck)
  484. break;
  485. } while (dispatch_stat & busy_mask);
  486. __asm__ __volatile__("wrpr %0, 0x0, %%pstate"
  487. : : "r" (pstate));
  488. if (dispatch_stat & busy_mask) {
  489. /* Busy bits will not clear, continue instead
  490. * of freezing up on this cpu.
  491. */
  492. printk("CPU[%d]: mondo stuckage result[%016llx]\n",
  493. smp_processor_id(), dispatch_stat);
  494. } else {
  495. int i, this_busy_nack = 0;
  496. /* Delay some random time with interrupts enabled
  497. * to prevent deadlock.
  498. */
  499. udelay(2 * nack_busy_id);
  500. /* Clear out the mask bits for cpus which did not
  501. * NACK us.
  502. */
  503. for (i = 0; i < cnt; i++) {
  504. u64 check_mask, nr;
  505. nr = cpu_list[i];
  506. if (nr == 0xffff)
  507. continue;
  508. if (is_jbus)
  509. check_mask = (0x2UL << (2*nr));
  510. else
  511. check_mask = (0x2UL <<
  512. this_busy_nack);
  513. if ((dispatch_stat & check_mask) == 0)
  514. cpu_list[i] = 0xffff;
  515. this_busy_nack += 2;
  516. if (this_busy_nack == 64)
  517. break;
  518. }
  519. goto retry;
  520. }
  521. }
  522. }
  523. /* Multi-cpu list version. */
  524. static void hypervisor_xcall_deliver(struct trap_per_cpu *tb, int cnt)
  525. {
  526. int retries, this_cpu, prev_sent, i, saw_cpu_error;
  527. unsigned long status;
  528. u16 *cpu_list;
  529. this_cpu = smp_processor_id();
  530. cpu_list = __va(tb->cpu_list_pa);
  531. saw_cpu_error = 0;
  532. retries = 0;
  533. prev_sent = 0;
  534. do {
  535. int forward_progress, n_sent;
  536. status = sun4v_cpu_mondo_send(cnt,
  537. tb->cpu_list_pa,
  538. tb->cpu_mondo_block_pa);
  539. /* HV_EOK means all cpus received the xcall, we're done. */
  540. if (likely(status == HV_EOK))
  541. break;
  542. /* First, see if we made any forward progress.
  543. *
  544. * The hypervisor indicates successful sends by setting
  545. * cpu list entries to the value 0xffff.
  546. */
  547. n_sent = 0;
  548. for (i = 0; i < cnt; i++) {
  549. if (likely(cpu_list[i] == 0xffff))
  550. n_sent++;
  551. }
  552. forward_progress = 0;
  553. if (n_sent > prev_sent)
  554. forward_progress = 1;
  555. prev_sent = n_sent;
  556. /* If we get a HV_ECPUERROR, then one or more of the cpus
  557. * in the list are in error state. Use the cpu_state()
  558. * hypervisor call to find out which cpus are in error state.
  559. */
  560. if (unlikely(status == HV_ECPUERROR)) {
  561. for (i = 0; i < cnt; i++) {
  562. long err;
  563. u16 cpu;
  564. cpu = cpu_list[i];
  565. if (cpu == 0xffff)
  566. continue;
  567. err = sun4v_cpu_state(cpu);
  568. if (err == HV_CPU_STATE_ERROR) {
  569. saw_cpu_error = (cpu + 1);
  570. cpu_list[i] = 0xffff;
  571. }
  572. }
  573. } else if (unlikely(status != HV_EWOULDBLOCK))
  574. goto fatal_mondo_error;
  575. /* Don't bother rewriting the CPU list, just leave the
  576. * 0xffff and non-0xffff entries in there and the
  577. * hypervisor will do the right thing.
  578. *
  579. * Only advance timeout state if we didn't make any
  580. * forward progress.
  581. */
  582. if (unlikely(!forward_progress)) {
  583. if (unlikely(++retries > 10000))
  584. goto fatal_mondo_timeout;
  585. /* Delay a little bit to let other cpus catch up
  586. * on their cpu mondo queue work.
  587. */
  588. udelay(2 * cnt);
  589. }
  590. } while (1);
  591. if (unlikely(saw_cpu_error))
  592. goto fatal_mondo_cpu_error;
  593. return;
  594. fatal_mondo_cpu_error:
  595. printk(KERN_CRIT "CPU[%d]: SUN4V mondo cpu error, some target cpus "
  596. "(including %d) were in error state\n",
  597. this_cpu, saw_cpu_error - 1);
  598. return;
  599. fatal_mondo_timeout:
  600. printk(KERN_CRIT "CPU[%d]: SUN4V mondo timeout, no forward "
  601. " progress after %d retries.\n",
  602. this_cpu, retries);
  603. goto dump_cpu_list_and_out;
  604. fatal_mondo_error:
  605. printk(KERN_CRIT "CPU[%d]: Unexpected SUN4V mondo error %lu\n",
  606. this_cpu, status);
  607. printk(KERN_CRIT "CPU[%d]: Args were cnt(%d) cpulist_pa(%lx) "
  608. "mondo_block_pa(%lx)\n",
  609. this_cpu, cnt, tb->cpu_list_pa, tb->cpu_mondo_block_pa);
  610. dump_cpu_list_and_out:
  611. printk(KERN_CRIT "CPU[%d]: CPU list [ ", this_cpu);
  612. for (i = 0; i < cnt; i++)
  613. printk("%u ", cpu_list[i]);
  614. printk("]\n");
  615. }
  616. static void (*xcall_deliver_impl)(struct trap_per_cpu *, int);
  617. static void xcall_deliver(u64 data0, u64 data1, u64 data2, const cpumask_t *mask)
  618. {
  619. struct trap_per_cpu *tb;
  620. int this_cpu, i, cnt;
  621. unsigned long flags;
  622. u16 *cpu_list;
  623. u64 *mondo;
  624. /* We have to do this whole thing with interrupts fully disabled.
  625. * Otherwise if we send an xcall from interrupt context it will
  626. * corrupt both our mondo block and cpu list state.
  627. *
  628. * One consequence of this is that we cannot use timeout mechanisms
  629. * that depend upon interrupts being delivered locally. So, for
  630. * example, we cannot sample jiffies and expect it to advance.
  631. *
  632. * Fortunately, udelay() uses %stick/%tick so we can use that.
  633. */
  634. local_irq_save(flags);
  635. this_cpu = smp_processor_id();
  636. tb = &trap_block[this_cpu];
  637. mondo = __va(tb->cpu_mondo_block_pa);
  638. mondo[0] = data0;
  639. mondo[1] = data1;
  640. mondo[2] = data2;
  641. wmb();
  642. cpu_list = __va(tb->cpu_list_pa);
  643. /* Setup the initial cpu list. */
  644. cnt = 0;
  645. for_each_cpu(i, mask) {
  646. if (i == this_cpu || !cpu_online(i))
  647. continue;
  648. cpu_list[cnt++] = i;
  649. }
  650. if (cnt)
  651. xcall_deliver_impl(tb, cnt);
  652. local_irq_restore(flags);
  653. }
  654. /* Send cross call to all processors mentioned in MASK_P
  655. * except self. Really, there are only two cases currently,
  656. * "cpu_online_mask" and "mm_cpumask(mm)".
  657. */
  658. static void smp_cross_call_masked(unsigned long *func, u32 ctx, u64 data1, u64 data2, const cpumask_t *mask)
  659. {
  660. u64 data0 = (((u64)ctx)<<32 | (((u64)func) & 0xffffffff));
  661. xcall_deliver(data0, data1, data2, mask);
  662. }
  663. /* Send cross call to all processors except self. */
  664. static void smp_cross_call(unsigned long *func, u32 ctx, u64 data1, u64 data2)
  665. {
  666. smp_cross_call_masked(func, ctx, data1, data2, cpu_online_mask);
  667. }
  668. extern unsigned long xcall_sync_tick;
  669. static void smp_start_sync_tick_client(int cpu)
  670. {
  671. xcall_deliver((u64) &xcall_sync_tick, 0, 0,
  672. cpumask_of(cpu));
  673. }
  674. extern unsigned long xcall_call_function;
  675. void arch_send_call_function_ipi_mask(const struct cpumask *mask)
  676. {
  677. xcall_deliver((u64) &xcall_call_function, 0, 0, mask);
  678. }
  679. extern unsigned long xcall_call_function_single;
  680. void arch_send_call_function_single_ipi(int cpu)
  681. {
  682. xcall_deliver((u64) &xcall_call_function_single, 0, 0,
  683. cpumask_of(cpu));
  684. }
  685. void __irq_entry smp_call_function_client(int irq, struct pt_regs *regs)
  686. {
  687. clear_softint(1 << irq);
  688. irq_enter();
  689. generic_smp_call_function_interrupt();
  690. irq_exit();
  691. }
  692. void __irq_entry smp_call_function_single_client(int irq, struct pt_regs *regs)
  693. {
  694. clear_softint(1 << irq);
  695. irq_enter();
  696. generic_smp_call_function_single_interrupt();
  697. irq_exit();
  698. }
  699. static void tsb_sync(void *info)
  700. {
  701. struct trap_per_cpu *tp = &trap_block[raw_smp_processor_id()];
  702. struct mm_struct *mm = info;
  703. /* It is not valid to test "current->active_mm == mm" here.
  704. *
  705. * The value of "current" is not changed atomically with
  706. * switch_mm(). But that's OK, we just need to check the
  707. * current cpu's trap block PGD physical address.
  708. */
  709. if (tp->pgd_paddr == __pa(mm->pgd))
  710. tsb_context_switch(mm);
  711. }
  712. void smp_tsb_sync(struct mm_struct *mm)
  713. {
  714. smp_call_function_many(mm_cpumask(mm), tsb_sync, mm, 1);
  715. }
  716. extern unsigned long xcall_flush_tlb_mm;
  717. extern unsigned long xcall_flush_tlb_page;
  718. extern unsigned long xcall_flush_tlb_kernel_range;
  719. extern unsigned long xcall_fetch_glob_regs;
  720. extern unsigned long xcall_fetch_glob_pmu;
  721. extern unsigned long xcall_fetch_glob_pmu_n4;
  722. extern unsigned long xcall_receive_signal;
  723. extern unsigned long xcall_new_mmu_context_version;
  724. #ifdef CONFIG_KGDB
  725. extern unsigned long xcall_kgdb_capture;
  726. #endif
  727. #ifdef DCACHE_ALIASING_POSSIBLE
  728. extern unsigned long xcall_flush_dcache_page_cheetah;
  729. #endif
  730. extern unsigned long xcall_flush_dcache_page_spitfire;
  731. static inline void __local_flush_dcache_page(struct page *page)
  732. {
  733. #ifdef DCACHE_ALIASING_POSSIBLE
  734. __flush_dcache_page(page_address(page),
  735. ((tlb_type == spitfire) &&
  736. page_mapping(page) != NULL));
  737. #else
  738. if (page_mapping(page) != NULL &&
  739. tlb_type == spitfire)
  740. __flush_icache_page(__pa(page_address(page)));
  741. #endif
  742. }
  743. void smp_flush_dcache_page_impl(struct page *page, int cpu)
  744. {
  745. int this_cpu;
  746. if (tlb_type == hypervisor)
  747. return;
  748. #ifdef CONFIG_DEBUG_DCFLUSH
  749. atomic_inc(&dcpage_flushes);
  750. #endif
  751. this_cpu = get_cpu();
  752. if (cpu == this_cpu) {
  753. __local_flush_dcache_page(page);
  754. } else if (cpu_online(cpu)) {
  755. void *pg_addr = page_address(page);
  756. u64 data0 = 0;
  757. if (tlb_type == spitfire) {
  758. data0 = ((u64)&xcall_flush_dcache_page_spitfire);
  759. if (page_mapping(page) != NULL)
  760. data0 |= ((u64)1 << 32);
  761. } else if (tlb_type == cheetah || tlb_type == cheetah_plus) {
  762. #ifdef DCACHE_ALIASING_POSSIBLE
  763. data0 = ((u64)&xcall_flush_dcache_page_cheetah);
  764. #endif
  765. }
  766. if (data0) {
  767. xcall_deliver(data0, __pa(pg_addr),
  768. (u64) pg_addr, cpumask_of(cpu));
  769. #ifdef CONFIG_DEBUG_DCFLUSH
  770. atomic_inc(&dcpage_flushes_xcall);
  771. #endif
  772. }
  773. }
  774. put_cpu();
  775. }
  776. void flush_dcache_page_all(struct mm_struct *mm, struct page *page)
  777. {
  778. void *pg_addr;
  779. u64 data0;
  780. if (tlb_type == hypervisor)
  781. return;
  782. preempt_disable();
  783. #ifdef CONFIG_DEBUG_DCFLUSH
  784. atomic_inc(&dcpage_flushes);
  785. #endif
  786. data0 = 0;
  787. pg_addr = page_address(page);
  788. if (tlb_type == spitfire) {
  789. data0 = ((u64)&xcall_flush_dcache_page_spitfire);
  790. if (page_mapping(page) != NULL)
  791. data0 |= ((u64)1 << 32);
  792. } else if (tlb_type == cheetah || tlb_type == cheetah_plus) {
  793. #ifdef DCACHE_ALIASING_POSSIBLE
  794. data0 = ((u64)&xcall_flush_dcache_page_cheetah);
  795. #endif
  796. }
  797. if (data0) {
  798. xcall_deliver(data0, __pa(pg_addr),
  799. (u64) pg_addr, cpu_online_mask);
  800. #ifdef CONFIG_DEBUG_DCFLUSH
  801. atomic_inc(&dcpage_flushes_xcall);
  802. #endif
  803. }
  804. __local_flush_dcache_page(page);
  805. preempt_enable();
  806. }
  807. void __irq_entry smp_new_mmu_context_version_client(int irq, struct pt_regs *regs)
  808. {
  809. struct mm_struct *mm;
  810. unsigned long flags;
  811. clear_softint(1 << irq);
  812. /* See if we need to allocate a new TLB context because
  813. * the version of the one we are using is now out of date.
  814. */
  815. mm = current->active_mm;
  816. if (unlikely(!mm || (mm == &init_mm)))
  817. return;
  818. spin_lock_irqsave(&mm->context.lock, flags);
  819. if (unlikely(!CTX_VALID(mm->context)))
  820. get_new_mmu_context(mm);
  821. spin_unlock_irqrestore(&mm->context.lock, flags);
  822. load_secondary_context(mm);
  823. __flush_tlb_mm(CTX_HWBITS(mm->context),
  824. SECONDARY_CONTEXT);
  825. }
  826. void smp_new_mmu_context_version(void)
  827. {
  828. smp_cross_call(&xcall_new_mmu_context_version, 0, 0, 0);
  829. }
  830. #ifdef CONFIG_KGDB
  831. void kgdb_roundup_cpus(unsigned long flags)
  832. {
  833. smp_cross_call(&xcall_kgdb_capture, 0, 0, 0);
  834. }
  835. #endif
  836. void smp_fetch_global_regs(void)
  837. {
  838. smp_cross_call(&xcall_fetch_glob_regs, 0, 0, 0);
  839. }
  840. void smp_fetch_global_pmu(void)
  841. {
  842. if (tlb_type == hypervisor &&
  843. sun4v_chip_type >= SUN4V_CHIP_NIAGARA4)
  844. smp_cross_call(&xcall_fetch_glob_pmu_n4, 0, 0, 0);
  845. else
  846. smp_cross_call(&xcall_fetch_glob_pmu, 0, 0, 0);
  847. }
  848. /* We know that the window frames of the user have been flushed
  849. * to the stack before we get here because all callers of us
  850. * are flush_tlb_*() routines, and these run after flush_cache_*()
  851. * which performs the flushw.
  852. *
  853. * The SMP TLB coherency scheme we use works as follows:
  854. *
  855. * 1) mm->cpu_vm_mask is a bit mask of which cpus an address
  856. * space has (potentially) executed on, this is the heuristic
  857. * we use to avoid doing cross calls.
  858. *
  859. * Also, for flushing from kswapd and also for clones, we
  860. * use cpu_vm_mask as the list of cpus to make run the TLB.
  861. *
  862. * 2) TLB context numbers are shared globally across all processors
  863. * in the system, this allows us to play several games to avoid
  864. * cross calls.
  865. *
  866. * One invariant is that when a cpu switches to a process, and
  867. * that processes tsk->active_mm->cpu_vm_mask does not have the
  868. * current cpu's bit set, that tlb context is flushed locally.
  869. *
  870. * If the address space is non-shared (ie. mm->count == 1) we avoid
  871. * cross calls when we want to flush the currently running process's
  872. * tlb state. This is done by clearing all cpu bits except the current
  873. * processor's in current->mm->cpu_vm_mask and performing the
  874. * flush locally only. This will force any subsequent cpus which run
  875. * this task to flush the context from the local tlb if the process
  876. * migrates to another cpu (again).
  877. *
  878. * 3) For shared address spaces (threads) and swapping we bite the
  879. * bullet for most cases and perform the cross call (but only to
  880. * the cpus listed in cpu_vm_mask).
  881. *
  882. * The performance gain from "optimizing" away the cross call for threads is
  883. * questionable (in theory the big win for threads is the massive sharing of
  884. * address space state across processors).
  885. */
  886. /* This currently is only used by the hugetlb arch pre-fault
  887. * hook on UltraSPARC-III+ and later when changing the pagesize
  888. * bits of the context register for an address space.
  889. */
  890. void smp_flush_tlb_mm(struct mm_struct *mm)
  891. {
  892. u32 ctx = CTX_HWBITS(mm->context);
  893. int cpu = get_cpu();
  894. if (atomic_read(&mm->mm_users) == 1) {
  895. cpumask_copy(mm_cpumask(mm), cpumask_of(cpu));
  896. goto local_flush_and_out;
  897. }
  898. smp_cross_call_masked(&xcall_flush_tlb_mm,
  899. ctx, 0, 0,
  900. mm_cpumask(mm));
  901. local_flush_and_out:
  902. __flush_tlb_mm(ctx, SECONDARY_CONTEXT);
  903. put_cpu();
  904. }
  905. struct tlb_pending_info {
  906. unsigned long ctx;
  907. unsigned long nr;
  908. unsigned long *vaddrs;
  909. };
  910. static void tlb_pending_func(void *info)
  911. {
  912. struct tlb_pending_info *t = info;
  913. __flush_tlb_pending(t->ctx, t->nr, t->vaddrs);
  914. }
  915. void smp_flush_tlb_pending(struct mm_struct *mm, unsigned long nr, unsigned long *vaddrs)
  916. {
  917. u32 ctx = CTX_HWBITS(mm->context);
  918. struct tlb_pending_info info;
  919. int cpu = get_cpu();
  920. info.ctx = ctx;
  921. info.nr = nr;
  922. info.vaddrs = vaddrs;
  923. if (mm == current->mm && atomic_read(&mm->mm_users) == 1)
  924. cpumask_copy(mm_cpumask(mm), cpumask_of(cpu));
  925. else
  926. smp_call_function_many(mm_cpumask(mm), tlb_pending_func,
  927. &info, 1);
  928. __flush_tlb_pending(ctx, nr, vaddrs);
  929. put_cpu();
  930. }
  931. void smp_flush_tlb_page(struct mm_struct *mm, unsigned long vaddr)
  932. {
  933. unsigned long context = CTX_HWBITS(mm->context);
  934. int cpu = get_cpu();
  935. if (mm == current->mm && atomic_read(&mm->mm_users) == 1)
  936. cpumask_copy(mm_cpumask(mm), cpumask_of(cpu));
  937. else
  938. smp_cross_call_masked(&xcall_flush_tlb_page,
  939. context, vaddr, 0,
  940. mm_cpumask(mm));
  941. __flush_tlb_page(context, vaddr);
  942. put_cpu();
  943. }
  944. void smp_flush_tlb_kernel_range(unsigned long start, unsigned long end)
  945. {
  946. start &= PAGE_MASK;
  947. end = PAGE_ALIGN(end);
  948. if (start != end) {
  949. smp_cross_call(&xcall_flush_tlb_kernel_range,
  950. 0, start, end);
  951. __flush_tlb_kernel_range(start, end);
  952. }
  953. }
  954. /* CPU capture. */
  955. /* #define CAPTURE_DEBUG */
  956. extern unsigned long xcall_capture;
  957. static atomic_t smp_capture_depth = ATOMIC_INIT(0);
  958. static atomic_t smp_capture_registry = ATOMIC_INIT(0);
  959. static unsigned long penguins_are_doing_time;
  960. void smp_capture(void)
  961. {
  962. int result = atomic_add_return(1, &smp_capture_depth);
  963. if (result == 1) {
  964. int ncpus = num_online_cpus();
  965. #ifdef CAPTURE_DEBUG
  966. printk("CPU[%d]: Sending penguins to jail...",
  967. smp_processor_id());
  968. #endif
  969. penguins_are_doing_time = 1;
  970. atomic_inc(&smp_capture_registry);
  971. smp_cross_call(&xcall_capture, 0, 0, 0);
  972. while (atomic_read(&smp_capture_registry) != ncpus)
  973. rmb();
  974. #ifdef CAPTURE_DEBUG
  975. printk("done\n");
  976. #endif
  977. }
  978. }
  979. void smp_release(void)
  980. {
  981. if (atomic_dec_and_test(&smp_capture_depth)) {
  982. #ifdef CAPTURE_DEBUG
  983. printk("CPU[%d]: Giving pardon to "
  984. "imprisoned penguins\n",
  985. smp_processor_id());
  986. #endif
  987. penguins_are_doing_time = 0;
  988. membar_safe("#StoreLoad");
  989. atomic_dec(&smp_capture_registry);
  990. }
  991. }
  992. /* Imprisoned penguins run with %pil == PIL_NORMAL_MAX, but PSTATE_IE
  993. * set, so they can service tlb flush xcalls...
  994. */
  995. extern void prom_world(int);
  996. void __irq_entry smp_penguin_jailcell(int irq, struct pt_regs *regs)
  997. {
  998. clear_softint(1 << irq);
  999. preempt_disable();
  1000. __asm__ __volatile__("flushw");
  1001. prom_world(1);
  1002. atomic_inc(&smp_capture_registry);
  1003. membar_safe("#StoreLoad");
  1004. while (penguins_are_doing_time)
  1005. rmb();
  1006. atomic_dec(&smp_capture_registry);
  1007. prom_world(0);
  1008. preempt_enable();
  1009. }
  1010. /* /proc/profile writes can call this, don't __init it please. */
  1011. int setup_profiling_timer(unsigned int multiplier)
  1012. {
  1013. return -EINVAL;
  1014. }
  1015. void __init smp_prepare_cpus(unsigned int max_cpus)
  1016. {
  1017. }
  1018. void smp_prepare_boot_cpu(void)
  1019. {
  1020. }
  1021. void __init smp_setup_processor_id(void)
  1022. {
  1023. if (tlb_type == spitfire)
  1024. xcall_deliver_impl = spitfire_xcall_deliver;
  1025. else if (tlb_type == cheetah || tlb_type == cheetah_plus)
  1026. xcall_deliver_impl = cheetah_xcall_deliver;
  1027. else
  1028. xcall_deliver_impl = hypervisor_xcall_deliver;
  1029. }
  1030. void __init smp_fill_in_cpu_possible_map(void)
  1031. {
  1032. int possible_cpus = num_possible_cpus();
  1033. int i;
  1034. if (possible_cpus > nr_cpu_ids)
  1035. possible_cpus = nr_cpu_ids;
  1036. for (i = 0; i < possible_cpus; i++)
  1037. set_cpu_possible(i, true);
  1038. for (; i < NR_CPUS; i++)
  1039. set_cpu_possible(i, false);
  1040. }
  1041. void smp_fill_in_sib_core_maps(void)
  1042. {
  1043. unsigned int i;
  1044. for_each_present_cpu(i) {
  1045. unsigned int j;
  1046. cpumask_clear(&cpu_core_map[i]);
  1047. if (cpu_data(i).core_id == 0) {
  1048. cpumask_set_cpu(i, &cpu_core_map[i]);
  1049. continue;
  1050. }
  1051. for_each_present_cpu(j) {
  1052. if (cpu_data(i).core_id ==
  1053. cpu_data(j).core_id)
  1054. cpumask_set_cpu(j, &cpu_core_map[i]);
  1055. }
  1056. }
  1057. for_each_present_cpu(i) {
  1058. unsigned int j;
  1059. for_each_present_cpu(j) {
  1060. if (cpu_data(i).max_cache_id ==
  1061. cpu_data(j).max_cache_id)
  1062. cpumask_set_cpu(j, &cpu_core_sib_cache_map[i]);
  1063. if (cpu_data(i).sock_id == cpu_data(j).sock_id)
  1064. cpumask_set_cpu(j, &cpu_core_sib_map[i]);
  1065. }
  1066. }
  1067. for_each_present_cpu(i) {
  1068. unsigned int j;
  1069. cpumask_clear(&per_cpu(cpu_sibling_map, i));
  1070. if (cpu_data(i).proc_id == -1) {
  1071. cpumask_set_cpu(i, &per_cpu(cpu_sibling_map, i));
  1072. continue;
  1073. }
  1074. for_each_present_cpu(j) {
  1075. if (cpu_data(i).proc_id ==
  1076. cpu_data(j).proc_id)
  1077. cpumask_set_cpu(j, &per_cpu(cpu_sibling_map, i));
  1078. }
  1079. }
  1080. }
  1081. int __cpu_up(unsigned int cpu, struct task_struct *tidle)
  1082. {
  1083. int ret = smp_boot_one_cpu(cpu, tidle);
  1084. if (!ret) {
  1085. cpumask_set_cpu(cpu, &smp_commenced_mask);
  1086. while (!cpu_online(cpu))
  1087. mb();
  1088. if (!cpu_online(cpu)) {
  1089. ret = -ENODEV;
  1090. } else {
  1091. /* On SUN4V, writes to %tick and %stick are
  1092. * not allowed.
  1093. */
  1094. if (tlb_type != hypervisor)
  1095. smp_synchronize_one_tick(cpu);
  1096. }
  1097. }
  1098. return ret;
  1099. }
  1100. #ifdef CONFIG_HOTPLUG_CPU
  1101. void cpu_play_dead(void)
  1102. {
  1103. int cpu = smp_processor_id();
  1104. unsigned long pstate;
  1105. idle_task_exit();
  1106. if (tlb_type == hypervisor) {
  1107. struct trap_per_cpu *tb = &trap_block[cpu];
  1108. sun4v_cpu_qconf(HV_CPU_QUEUE_CPU_MONDO,
  1109. tb->cpu_mondo_pa, 0);
  1110. sun4v_cpu_qconf(HV_CPU_QUEUE_DEVICE_MONDO,
  1111. tb->dev_mondo_pa, 0);
  1112. sun4v_cpu_qconf(HV_CPU_QUEUE_RES_ERROR,
  1113. tb->resum_mondo_pa, 0);
  1114. sun4v_cpu_qconf(HV_CPU_QUEUE_NONRES_ERROR,
  1115. tb->nonresum_mondo_pa, 0);
  1116. }
  1117. cpumask_clear_cpu(cpu, &smp_commenced_mask);
  1118. membar_safe("#Sync");
  1119. local_irq_disable();
  1120. __asm__ __volatile__(
  1121. "rdpr %%pstate, %0\n\t"
  1122. "wrpr %0, %1, %%pstate"
  1123. : "=r" (pstate)
  1124. : "i" (PSTATE_IE));
  1125. while (1)
  1126. barrier();
  1127. }
  1128. int __cpu_disable(void)
  1129. {
  1130. int cpu = smp_processor_id();
  1131. cpuinfo_sparc *c;
  1132. int i;
  1133. for_each_cpu(i, &cpu_core_map[cpu])
  1134. cpumask_clear_cpu(cpu, &cpu_core_map[i]);
  1135. cpumask_clear(&cpu_core_map[cpu]);
  1136. for_each_cpu(i, &per_cpu(cpu_sibling_map, cpu))
  1137. cpumask_clear_cpu(cpu, &per_cpu(cpu_sibling_map, i));
  1138. cpumask_clear(&per_cpu(cpu_sibling_map, cpu));
  1139. c = &cpu_data(cpu);
  1140. c->core_id = 0;
  1141. c->proc_id = -1;
  1142. smp_wmb();
  1143. /* Make sure no interrupts point to this cpu. */
  1144. fixup_irqs();
  1145. local_irq_enable();
  1146. mdelay(1);
  1147. local_irq_disable();
  1148. set_cpu_online(cpu, false);
  1149. cpu_map_rebuild();
  1150. return 0;
  1151. }
  1152. void __cpu_die(unsigned int cpu)
  1153. {
  1154. int i;
  1155. for (i = 0; i < 100; i++) {
  1156. smp_rmb();
  1157. if (!cpumask_test_cpu(cpu, &smp_commenced_mask))
  1158. break;
  1159. msleep(100);
  1160. }
  1161. if (cpumask_test_cpu(cpu, &smp_commenced_mask)) {
  1162. printk(KERN_ERR "CPU %u didn't die...\n", cpu);
  1163. } else {
  1164. #if defined(CONFIG_SUN_LDOMS)
  1165. unsigned long hv_err;
  1166. int limit = 100;
  1167. do {
  1168. hv_err = sun4v_cpu_stop(cpu);
  1169. if (hv_err == HV_EOK) {
  1170. set_cpu_present(cpu, false);
  1171. break;
  1172. }
  1173. } while (--limit > 0);
  1174. if (limit <= 0) {
  1175. printk(KERN_ERR "sun4v_cpu_stop() fails err=%lu\n",
  1176. hv_err);
  1177. }
  1178. #endif
  1179. }
  1180. }
  1181. #endif
  1182. void __init smp_cpus_done(unsigned int max_cpus)
  1183. {
  1184. }
  1185. void smp_send_reschedule(int cpu)
  1186. {
  1187. if (cpu == smp_processor_id()) {
  1188. WARN_ON_ONCE(preemptible());
  1189. set_softint(1 << PIL_SMP_RECEIVE_SIGNAL);
  1190. } else {
  1191. xcall_deliver((u64) &xcall_receive_signal,
  1192. 0, 0, cpumask_of(cpu));
  1193. }
  1194. }
  1195. void __irq_entry smp_receive_signal_client(int irq, struct pt_regs *regs)
  1196. {
  1197. clear_softint(1 << irq);
  1198. scheduler_ipi();
  1199. }
  1200. static void stop_this_cpu(void *dummy)
  1201. {
  1202. set_cpu_online(smp_processor_id(), false);
  1203. prom_stopself();
  1204. }
  1205. void smp_send_stop(void)
  1206. {
  1207. int cpu;
  1208. if (tlb_type == hypervisor) {
  1209. int this_cpu = smp_processor_id();
  1210. #ifdef CONFIG_SERIAL_SUNHV
  1211. sunhv_migrate_hvcons_irq(this_cpu);
  1212. #endif
  1213. for_each_online_cpu(cpu) {
  1214. if (cpu == this_cpu)
  1215. continue;
  1216. set_cpu_online(cpu, false);
  1217. #ifdef CONFIG_SUN_LDOMS
  1218. if (ldom_domaining_enabled) {
  1219. unsigned long hv_err;
  1220. hv_err = sun4v_cpu_stop(cpu);
  1221. if (hv_err)
  1222. printk(KERN_ERR "sun4v_cpu_stop() "
  1223. "failed err=%lu\n", hv_err);
  1224. } else
  1225. #endif
  1226. prom_stopcpu_cpuid(cpu);
  1227. }
  1228. } else
  1229. smp_call_function(stop_this_cpu, NULL, 0);
  1230. }
  1231. /**
  1232. * pcpu_alloc_bootmem - NUMA friendly alloc_bootmem wrapper for percpu
  1233. * @cpu: cpu to allocate for
  1234. * @size: size allocation in bytes
  1235. * @align: alignment
  1236. *
  1237. * Allocate @size bytes aligned at @align for cpu @cpu. This wrapper
  1238. * does the right thing for NUMA regardless of the current
  1239. * configuration.
  1240. *
  1241. * RETURNS:
  1242. * Pointer to the allocated area on success, NULL on failure.
  1243. */
  1244. static void * __init pcpu_alloc_bootmem(unsigned int cpu, size_t size,
  1245. size_t align)
  1246. {
  1247. const unsigned long goal = __pa(MAX_DMA_ADDRESS);
  1248. #ifdef CONFIG_NEED_MULTIPLE_NODES
  1249. int node = cpu_to_node(cpu);
  1250. void *ptr;
  1251. if (!node_online(node) || !NODE_DATA(node)) {
  1252. ptr = __alloc_bootmem(size, align, goal);
  1253. pr_info("cpu %d has no node %d or node-local memory\n",
  1254. cpu, node);
  1255. pr_debug("per cpu data for cpu%d %lu bytes at %016lx\n",
  1256. cpu, size, __pa(ptr));
  1257. } else {
  1258. ptr = __alloc_bootmem_node(NODE_DATA(node),
  1259. size, align, goal);
  1260. pr_debug("per cpu data for cpu%d %lu bytes on node%d at "
  1261. "%016lx\n", cpu, size, node, __pa(ptr));
  1262. }
  1263. return ptr;
  1264. #else
  1265. return __alloc_bootmem(size, align, goal);
  1266. #endif
  1267. }
  1268. static void __init pcpu_free_bootmem(void *ptr, size_t size)
  1269. {
  1270. free_bootmem(__pa(ptr), size);
  1271. }
  1272. static int __init pcpu_cpu_distance(unsigned int from, unsigned int to)
  1273. {
  1274. if (cpu_to_node(from) == cpu_to_node(to))
  1275. return LOCAL_DISTANCE;
  1276. else
  1277. return REMOTE_DISTANCE;
  1278. }
  1279. static void __init pcpu_populate_pte(unsigned long addr)
  1280. {
  1281. pgd_t *pgd = pgd_offset_k(addr);
  1282. pud_t *pud;
  1283. pmd_t *pmd;
  1284. if (pgd_none(*pgd)) {
  1285. pud_t *new;
  1286. new = __alloc_bootmem(PAGE_SIZE, PAGE_SIZE, PAGE_SIZE);
  1287. pgd_populate(&init_mm, pgd, new);
  1288. }
  1289. pud = pud_offset(pgd, addr);
  1290. if (pud_none(*pud)) {
  1291. pmd_t *new;
  1292. new = __alloc_bootmem(PAGE_SIZE, PAGE_SIZE, PAGE_SIZE);
  1293. pud_populate(&init_mm, pud, new);
  1294. }
  1295. pmd = pmd_offset(pud, addr);
  1296. if (!pmd_present(*pmd)) {
  1297. pte_t *new;
  1298. new = __alloc_bootmem(PAGE_SIZE, PAGE_SIZE, PAGE_SIZE);
  1299. pmd_populate_kernel(&init_mm, pmd, new);
  1300. }
  1301. }
  1302. void __init setup_per_cpu_areas(void)
  1303. {
  1304. unsigned long delta;
  1305. unsigned int cpu;
  1306. int rc = -EINVAL;
  1307. if (pcpu_chosen_fc != PCPU_FC_PAGE) {
  1308. rc = pcpu_embed_first_chunk(PERCPU_MODULE_RESERVE,
  1309. PERCPU_DYNAMIC_RESERVE, 4 << 20,
  1310. pcpu_cpu_distance,
  1311. pcpu_alloc_bootmem,
  1312. pcpu_free_bootmem);
  1313. if (rc)
  1314. pr_warning("PERCPU: %s allocator failed (%d), "
  1315. "falling back to page size\n",
  1316. pcpu_fc_names[pcpu_chosen_fc], rc);
  1317. }
  1318. if (rc < 0)
  1319. rc = pcpu_page_first_chunk(PERCPU_MODULE_RESERVE,
  1320. pcpu_alloc_bootmem,
  1321. pcpu_free_bootmem,
  1322. pcpu_populate_pte);
  1323. if (rc < 0)
  1324. panic("cannot initialize percpu area (err=%d)", rc);
  1325. delta = (unsigned long)pcpu_base_addr - (unsigned long)__per_cpu_start;
  1326. for_each_possible_cpu(cpu)
  1327. __per_cpu_offset(cpu) = delta + pcpu_unit_offsets[cpu];
  1328. /* Setup %g5 for the boot cpu. */
  1329. __local_per_cpu_offset = __per_cpu_offset(smp_processor_id());
  1330. of_fill_in_cpu_data();
  1331. if (tlb_type == hypervisor)
  1332. mdesc_fill_in_cpu_data(cpu_all_mask);
  1333. }