xref: /openbmc/qemu/hw/intc/spapr_xive_kvm.c (revision 56b11587dfc79dc6453d857159801dcc38f24d0c)
1 /*
2  * QEMU PowerPC sPAPR XIVE interrupt controller model
3  *
4  * Copyright (c) 2017-2019, IBM Corporation.
5  *
6  * This code is licensed under the GPL version 2 or later. See the
7  * COPYING file in the top-level directory.
8  */
9 
10 #include "qemu/osdep.h"
11 #include "qemu/log.h"
12 #include "qemu/error-report.h"
13 #include "qapi/error.h"
14 #include "target/ppc/cpu.h"
15 #include "sysemu/cpus.h"
16 #include "sysemu/kvm.h"
17 #include "hw/ppc/spapr.h"
18 #include "hw/ppc/spapr_cpu_core.h"
19 #include "hw/ppc/spapr_xive.h"
20 #include "hw/ppc/xive.h"
21 #include "kvm_ppc.h"
22 
23 #include <sys/ioctl.h>
24 
25 /*
26  * Helpers for CPU hotplug
27  *
28  * TODO: make a common KVMEnabledCPU layer for XICS and XIVE
29  */
30 typedef struct KVMEnabledCPU {
31     unsigned long vcpu_id;
32     QLIST_ENTRY(KVMEnabledCPU) node;
33 } KVMEnabledCPU;
34 
35 static QLIST_HEAD(, KVMEnabledCPU)
36     kvm_enabled_cpus = QLIST_HEAD_INITIALIZER(&kvm_enabled_cpus);
37 
38 static bool kvm_cpu_is_enabled(CPUState *cs)
39 {
40     KVMEnabledCPU *enabled_cpu;
41     unsigned long vcpu_id = kvm_arch_vcpu_id(cs);
42 
43     QLIST_FOREACH(enabled_cpu, &kvm_enabled_cpus, node) {
44         if (enabled_cpu->vcpu_id == vcpu_id) {
45             return true;
46         }
47     }
48     return false;
49 }
50 
51 static void kvm_cpu_enable(CPUState *cs)
52 {
53     KVMEnabledCPU *enabled_cpu;
54     unsigned long vcpu_id = kvm_arch_vcpu_id(cs);
55 
56     enabled_cpu = g_malloc(sizeof(*enabled_cpu));
57     enabled_cpu->vcpu_id = vcpu_id;
58     QLIST_INSERT_HEAD(&kvm_enabled_cpus, enabled_cpu, node);
59 }
60 
61 static void kvm_cpu_disable_all(void)
62 {
63     KVMEnabledCPU *enabled_cpu, *next;
64 
65     QLIST_FOREACH_SAFE(enabled_cpu, &kvm_enabled_cpus, node, next) {
66         QLIST_REMOVE(enabled_cpu, node);
67         g_free(enabled_cpu);
68     }
69 }
70 
71 /*
72  * XIVE Thread Interrupt Management context (KVM)
73  */
74 
75 static void kvmppc_xive_cpu_set_state(XiveTCTX *tctx, Error **errp)
76 {
77     uint64_t state[2];
78     int ret;
79 
80     /* word0 and word1 of the OS ring. */
81     state[0] = *((uint64_t *) &tctx->regs[TM_QW1_OS]);
82 
83     ret = kvm_set_one_reg(tctx->cs, KVM_REG_PPC_VP_STATE, state);
84     if (ret != 0) {
85         error_setg_errno(errp, errno,
86                          "XIVE: could not restore KVM state of CPU %ld",
87                          kvm_arch_vcpu_id(tctx->cs));
88     }
89 }
90 
91 void kvmppc_xive_cpu_get_state(XiveTCTX *tctx, Error **errp)
92 {
93     uint64_t state[2] = { 0 };
94     int ret;
95 
96     ret = kvm_get_one_reg(tctx->cs, KVM_REG_PPC_VP_STATE, state);
97     if (ret != 0) {
98         error_setg_errno(errp, errno,
99                          "XIVE: could not capture KVM state of CPU %ld",
100                          kvm_arch_vcpu_id(tctx->cs));
101         return;
102     }
103 
104     /* word0 and word1 of the OS ring. */
105     *((uint64_t *) &tctx->regs[TM_QW1_OS]) = state[0];
106 }
107 
108 typedef struct {
109     XiveTCTX *tctx;
110     Error *err;
111 } XiveCpuGetState;
112 
113 static void kvmppc_xive_cpu_do_synchronize_state(CPUState *cpu,
114                                                  run_on_cpu_data arg)
115 {
116     XiveCpuGetState *s = arg.host_ptr;
117 
118     kvmppc_xive_cpu_get_state(s->tctx, &s->err);
119 }
120 
121 void kvmppc_xive_cpu_synchronize_state(XiveTCTX *tctx, Error **errp)
122 {
123     XiveCpuGetState s = {
124         .tctx = tctx,
125         .err = NULL,
126     };
127 
128     /*
129      * Kick the vCPU to make sure they are available for the KVM ioctl.
130      */
131     run_on_cpu(tctx->cs, kvmppc_xive_cpu_do_synchronize_state,
132                RUN_ON_CPU_HOST_PTR(&s));
133 
134     if (s.err) {
135         error_propagate(errp, s.err);
136         return;
137     }
138 }
139 
140 void kvmppc_xive_cpu_connect(XiveTCTX *tctx, Error **errp)
141 {
142     SpaprXive *xive = SPAPR_MACHINE(qdev_get_machine())->xive;
143     unsigned long vcpu_id;
144     int ret;
145 
146     /* Check if CPU was hot unplugged and replugged. */
147     if (kvm_cpu_is_enabled(tctx->cs)) {
148         return;
149     }
150 
151     vcpu_id = kvm_arch_vcpu_id(tctx->cs);
152 
153     ret = kvm_vcpu_enable_cap(tctx->cs, KVM_CAP_PPC_IRQ_XIVE, 0, xive->fd,
154                               vcpu_id, 0);
155     if (ret < 0) {
156         error_setg(errp, "XIVE: unable to connect CPU%ld to KVM device: %s",
157                    vcpu_id, strerror(errno));
158         return;
159     }
160 
161     kvm_cpu_enable(tctx->cs);
162 }
163 
164 /*
165  * XIVE Interrupt Source (KVM)
166  */
167 
168 void kvmppc_xive_set_source_config(SpaprXive *xive, uint32_t lisn, XiveEAS *eas,
169                                    Error **errp)
170 {
171     uint32_t end_idx;
172     uint32_t end_blk;
173     uint8_t priority;
174     uint32_t server;
175     bool masked;
176     uint32_t eisn;
177     uint64_t kvm_src;
178     Error *local_err = NULL;
179 
180     assert(xive_eas_is_valid(eas));
181 
182     end_idx = xive_get_field64(EAS_END_INDEX, eas->w);
183     end_blk = xive_get_field64(EAS_END_BLOCK, eas->w);
184     eisn = xive_get_field64(EAS_END_DATA, eas->w);
185     masked = xive_eas_is_masked(eas);
186 
187     spapr_xive_end_to_target(end_blk, end_idx, &server, &priority);
188 
189     kvm_src = priority << KVM_XIVE_SOURCE_PRIORITY_SHIFT &
190         KVM_XIVE_SOURCE_PRIORITY_MASK;
191     kvm_src |= server << KVM_XIVE_SOURCE_SERVER_SHIFT &
192         KVM_XIVE_SOURCE_SERVER_MASK;
193     kvm_src |= ((uint64_t) masked << KVM_XIVE_SOURCE_MASKED_SHIFT) &
194         KVM_XIVE_SOURCE_MASKED_MASK;
195     kvm_src |= ((uint64_t)eisn << KVM_XIVE_SOURCE_EISN_SHIFT) &
196         KVM_XIVE_SOURCE_EISN_MASK;
197 
198     kvm_device_access(xive->fd, KVM_DEV_XIVE_GRP_SOURCE_CONFIG, lisn,
199                       &kvm_src, true, &local_err);
200     if (local_err) {
201         error_propagate(errp, local_err);
202         return;
203     }
204 }
205 
206 void kvmppc_xive_sync_source(SpaprXive *xive, uint32_t lisn, Error **errp)
207 {
208     kvm_device_access(xive->fd, KVM_DEV_XIVE_GRP_SOURCE_SYNC, lisn,
209                       NULL, true, errp);
210 }
211 
212 /*
213  * At reset, the interrupt sources are simply created and MASKED. We
214  * only need to inform the KVM XIVE device about their type: LSI or
215  * MSI.
216  */
217 void kvmppc_xive_source_reset_one(XiveSource *xsrc, int srcno, Error **errp)
218 {
219     SpaprXive *xive = SPAPR_XIVE(xsrc->xive);
220     uint64_t state = 0;
221 
222     if (xive_source_irq_is_lsi(xsrc, srcno)) {
223         state |= KVM_XIVE_LEVEL_SENSITIVE;
224         if (xsrc->status[srcno] & XIVE_STATUS_ASSERTED) {
225             state |= KVM_XIVE_LEVEL_ASSERTED;
226         }
227     }
228 
229     kvm_device_access(xive->fd, KVM_DEV_XIVE_GRP_SOURCE, srcno, &state,
230                       true, errp);
231 }
232 
233 void kvmppc_xive_source_reset(XiveSource *xsrc, Error **errp)
234 {
235     int i;
236 
237     for (i = 0; i < xsrc->nr_irqs; i++) {
238         Error *local_err = NULL;
239 
240         kvmppc_xive_source_reset_one(xsrc, i, &local_err);
241         if (local_err) {
242             error_propagate(errp, local_err);
243             return;
244         }
245     }
246 }
247 
248 /*
249  * This is used to perform the magic loads on the ESB pages, described
250  * in xive.h.
251  *
252  * Memory barriers should not be needed for loads (no store for now).
253  */
254 static uint64_t xive_esb_rw(XiveSource *xsrc, int srcno, uint32_t offset,
255                             uint64_t data, bool write)
256 {
257     uint64_t *addr = xsrc->esb_mmap + xive_source_esb_mgmt(xsrc, srcno) +
258         offset;
259 
260     if (write) {
261         *addr = cpu_to_be64(data);
262         return -1;
263     } else {
264         /* Prevent the compiler from optimizing away the load */
265         volatile uint64_t value = be64_to_cpu(*addr);
266         return value;
267     }
268 }
269 
270 static uint8_t xive_esb_read(XiveSource *xsrc, int srcno, uint32_t offset)
271 {
272     return xive_esb_rw(xsrc, srcno, offset, 0, 0) & 0x3;
273 }
274 
275 static void xive_esb_trigger(XiveSource *xsrc, int srcno)
276 {
277     uint64_t *addr = xsrc->esb_mmap + xive_source_esb_page(xsrc, srcno);
278 
279     *addr = 0x0;
280 }
281 
282 uint64_t kvmppc_xive_esb_rw(XiveSource *xsrc, int srcno, uint32_t offset,
283                             uint64_t data, bool write)
284 {
285     if (write) {
286         return xive_esb_rw(xsrc, srcno, offset, data, 1);
287     }
288 
289     /*
290      * Special Load EOI handling for LSI sources. Q bit is never set
291      * and the interrupt should be re-triggered if the level is still
292      * asserted.
293      */
294     if (xive_source_irq_is_lsi(xsrc, srcno) &&
295         offset == XIVE_ESB_LOAD_EOI) {
296         xive_esb_read(xsrc, srcno, XIVE_ESB_SET_PQ_00);
297         if (xsrc->status[srcno] & XIVE_STATUS_ASSERTED) {
298             xive_esb_trigger(xsrc, srcno);
299         }
300         return 0;
301     } else {
302         return xive_esb_rw(xsrc, srcno, offset, 0, 0);
303     }
304 }
305 
306 static void kvmppc_xive_source_get_state(XiveSource *xsrc)
307 {
308     int i;
309 
310     for (i = 0; i < xsrc->nr_irqs; i++) {
311         /* Perform a load without side effect to retrieve the PQ bits */
312         uint8_t pq = xive_esb_read(xsrc, i, XIVE_ESB_GET);
313 
314         /* and save PQ locally */
315         xive_source_esb_set(xsrc, i, pq);
316     }
317 }
318 
319 void kvmppc_xive_source_set_irq(void *opaque, int srcno, int val)
320 {
321     XiveSource *xsrc = opaque;
322     struct kvm_irq_level args;
323     int rc;
324 
325     args.irq = srcno;
326     if (!xive_source_irq_is_lsi(xsrc, srcno)) {
327         if (!val) {
328             return;
329         }
330         args.level = KVM_INTERRUPT_SET;
331     } else {
332         if (val) {
333             xsrc->status[srcno] |= XIVE_STATUS_ASSERTED;
334             args.level = KVM_INTERRUPT_SET_LEVEL;
335         } else {
336             xsrc->status[srcno] &= ~XIVE_STATUS_ASSERTED;
337             args.level = KVM_INTERRUPT_UNSET;
338         }
339     }
340     rc = kvm_vm_ioctl(kvm_state, KVM_IRQ_LINE, &args);
341     if (rc < 0) {
342         error_report("XIVE: kvm_irq_line() failed : %s", strerror(errno));
343     }
344 }
345 
346 /*
347  * sPAPR XIVE interrupt controller (KVM)
348  */
349 void kvmppc_xive_get_queue_config(SpaprXive *xive, uint8_t end_blk,
350                                   uint32_t end_idx, XiveEND *end,
351                                   Error **errp)
352 {
353     struct kvm_ppc_xive_eq kvm_eq = { 0 };
354     uint64_t kvm_eq_idx;
355     uint8_t priority;
356     uint32_t server;
357     Error *local_err = NULL;
358 
359     assert(xive_end_is_valid(end));
360 
361     /* Encode the tuple (server, prio) as a KVM EQ index */
362     spapr_xive_end_to_target(end_blk, end_idx, &server, &priority);
363 
364     kvm_eq_idx = priority << KVM_XIVE_EQ_PRIORITY_SHIFT &
365             KVM_XIVE_EQ_PRIORITY_MASK;
366     kvm_eq_idx |= server << KVM_XIVE_EQ_SERVER_SHIFT &
367         KVM_XIVE_EQ_SERVER_MASK;
368 
369     kvm_device_access(xive->fd, KVM_DEV_XIVE_GRP_EQ_CONFIG, kvm_eq_idx,
370                       &kvm_eq, false, &local_err);
371     if (local_err) {
372         error_propagate(errp, local_err);
373         return;
374     }
375 
376     /*
377      * The EQ index and toggle bit are updated by HW. These are the
378      * only fields from KVM we want to update QEMU with. The other END
379      * fields should already be in the QEMU END table.
380      */
381     end->w1 = xive_set_field32(END_W1_GENERATION, 0ul, kvm_eq.qtoggle) |
382         xive_set_field32(END_W1_PAGE_OFF, 0ul, kvm_eq.qindex);
383 }
384 
385 void kvmppc_xive_set_queue_config(SpaprXive *xive, uint8_t end_blk,
386                                   uint32_t end_idx, XiveEND *end,
387                                   Error **errp)
388 {
389     struct kvm_ppc_xive_eq kvm_eq = { 0 };
390     uint64_t kvm_eq_idx;
391     uint8_t priority;
392     uint32_t server;
393     Error *local_err = NULL;
394 
395     /*
396      * Build the KVM state from the local END structure.
397      */
398 
399     kvm_eq.flags = 0;
400     if (xive_get_field32(END_W0_UCOND_NOTIFY, end->w0)) {
401         kvm_eq.flags |= KVM_XIVE_EQ_ALWAYS_NOTIFY;
402     }
403 
404     /*
405      * If the hcall is disabling the EQ, set the size and page address
406      * to zero. When migrating, only valid ENDs are taken into
407      * account.
408      */
409     if (xive_end_is_valid(end)) {
410         kvm_eq.qshift = xive_get_field32(END_W0_QSIZE, end->w0) + 12;
411         kvm_eq.qaddr  = xive_end_qaddr(end);
412         /*
413          * The EQ toggle bit and index should only be relevant when
414          * restoring the EQ state
415          */
416         kvm_eq.qtoggle = xive_get_field32(END_W1_GENERATION, end->w1);
417         kvm_eq.qindex  = xive_get_field32(END_W1_PAGE_OFF, end->w1);
418     } else {
419         kvm_eq.qshift = 0;
420         kvm_eq.qaddr  = 0;
421     }
422 
423     /* Encode the tuple (server, prio) as a KVM EQ index */
424     spapr_xive_end_to_target(end_blk, end_idx, &server, &priority);
425 
426     kvm_eq_idx = priority << KVM_XIVE_EQ_PRIORITY_SHIFT &
427             KVM_XIVE_EQ_PRIORITY_MASK;
428     kvm_eq_idx |= server << KVM_XIVE_EQ_SERVER_SHIFT &
429         KVM_XIVE_EQ_SERVER_MASK;
430 
431     kvm_device_access(xive->fd, KVM_DEV_XIVE_GRP_EQ_CONFIG, kvm_eq_idx,
432                       &kvm_eq, true, &local_err);
433     if (local_err) {
434         error_propagate(errp, local_err);
435         return;
436     }
437 }
438 
439 void kvmppc_xive_reset(SpaprXive *xive, Error **errp)
440 {
441     kvm_device_access(xive->fd, KVM_DEV_XIVE_GRP_CTRL, KVM_DEV_XIVE_RESET,
442                       NULL, true, errp);
443 }
444 
445 static void kvmppc_xive_get_queues(SpaprXive *xive, Error **errp)
446 {
447     Error *local_err = NULL;
448     int i;
449 
450     for (i = 0; i < xive->nr_ends; i++) {
451         if (!xive_end_is_valid(&xive->endt[i])) {
452             continue;
453         }
454 
455         kvmppc_xive_get_queue_config(xive, SPAPR_XIVE_BLOCK_ID, i,
456                                      &xive->endt[i], &local_err);
457         if (local_err) {
458             error_propagate(errp, local_err);
459             return;
460         }
461     }
462 }
463 
464 /*
465  * The primary goal of the XIVE VM change handler is to mark the EQ
466  * pages dirty when all XIVE event notifications have stopped.
467  *
468  * Whenever the VM is stopped, the VM change handler sets the source
469  * PQs to PENDING to stop the flow of events and to possibly catch a
470  * triggered interrupt occuring while the VM is stopped. The previous
471  * state is saved in anticipation of a migration. The XIVE controller
472  * is then synced through KVM to flush any in-flight event
473  * notification and stabilize the EQs.
474  *
475  * At this stage, we can mark the EQ page dirty and let a migration
476  * sequence transfer the EQ pages to the destination, which is done
477  * just after the stop state.
478  *
479  * The previous configuration of the sources is restored when the VM
480  * runs again. If an interrupt was queued while the VM was stopped,
481  * simply generate a trigger.
482  */
483 static void kvmppc_xive_change_state_handler(void *opaque, int running,
484                                              RunState state)
485 {
486     SpaprXive *xive = opaque;
487     XiveSource *xsrc = &xive->source;
488     Error *local_err = NULL;
489     int i;
490 
491     /*
492      * Restore the sources to their initial state. This is called when
493      * the VM resumes after a stop or a migration.
494      */
495     if (running) {
496         for (i = 0; i < xsrc->nr_irqs; i++) {
497             uint8_t pq = xive_source_esb_get(xsrc, i);
498             uint8_t old_pq;
499 
500             old_pq = xive_esb_read(xsrc, i, XIVE_ESB_SET_PQ_00 + (pq << 8));
501 
502             /*
503              * An interrupt was queued while the VM was stopped,
504              * generate a trigger.
505              */
506             if (pq == XIVE_ESB_RESET && old_pq == XIVE_ESB_QUEUED) {
507                 xive_esb_trigger(xsrc, i);
508             }
509         }
510 
511         return;
512     }
513 
514     /*
515      * Mask the sources, to stop the flow of event notifications, and
516      * save the PQs locally in the XiveSource object. The XiveSource
517      * state will be collected later on by its vmstate handler if a
518      * migration is in progress.
519      */
520     for (i = 0; i < xsrc->nr_irqs; i++) {
521         uint8_t pq = xive_esb_read(xsrc, i, XIVE_ESB_GET);
522 
523         /*
524          * PQ is set to PENDING to possibly catch a triggered
525          * interrupt occuring while the VM is stopped (hotplug event
526          * for instance) .
527          */
528         if (pq != XIVE_ESB_OFF) {
529             pq = xive_esb_read(xsrc, i, XIVE_ESB_SET_PQ_10);
530         }
531         xive_source_esb_set(xsrc, i, pq);
532     }
533 
534     /*
535      * Sync the XIVE controller in KVM, to flush in-flight event
536      * notification that should be enqueued in the EQs and mark the
537      * XIVE EQ pages dirty to collect all updates.
538      */
539     kvm_device_access(xive->fd, KVM_DEV_XIVE_GRP_CTRL,
540                       KVM_DEV_XIVE_EQ_SYNC, NULL, true, &local_err);
541     if (local_err) {
542         error_report_err(local_err);
543         return;
544     }
545 }
546 
547 void kvmppc_xive_synchronize_state(SpaprXive *xive, Error **errp)
548 {
549     /*
550      * When the VM is stopped, the sources are masked and the previous
551      * state is saved in anticipation of a migration. We should not
552      * synchronize the source state in that case else we will override
553      * the saved state.
554      */
555     if (runstate_is_running()) {
556         kvmppc_xive_source_get_state(&xive->source);
557     }
558 
559     /* EAT: there is no extra state to query from KVM */
560 
561     /* ENDT */
562     kvmppc_xive_get_queues(xive, errp);
563 }
564 
565 /*
566  * The SpaprXive 'pre_save' method is called by the vmstate handler of
567  * the SpaprXive model, after the XIVE controller is synced in the VM
568  * change handler.
569  */
570 int kvmppc_xive_pre_save(SpaprXive *xive)
571 {
572     Error *local_err = NULL;
573 
574     /* EAT: there is no extra state to query from KVM */
575 
576     /* ENDT */
577     kvmppc_xive_get_queues(xive, &local_err);
578     if (local_err) {
579         error_report_err(local_err);
580         return -1;
581     }
582 
583     return 0;
584 }
585 
586 /*
587  * The SpaprXive 'post_load' method is not called by a vmstate
588  * handler. It is called at the sPAPR machine level at the end of the
589  * migration sequence by the sPAPR IRQ backend 'post_load' method,
590  * when all XIVE states have been transferred and loaded.
591  */
592 int kvmppc_xive_post_load(SpaprXive *xive, int version_id)
593 {
594     Error *local_err = NULL;
595     CPUState *cs;
596     int i;
597 
598     /* Restore the ENDT first. The targetting depends on it. */
599     for (i = 0; i < xive->nr_ends; i++) {
600         if (!xive_end_is_valid(&xive->endt[i])) {
601             continue;
602         }
603 
604         kvmppc_xive_set_queue_config(xive, SPAPR_XIVE_BLOCK_ID, i,
605                                      &xive->endt[i], &local_err);
606         if (local_err) {
607             error_report_err(local_err);
608             return -1;
609         }
610     }
611 
612     /* Restore the EAT */
613     for (i = 0; i < xive->nr_irqs; i++) {
614         if (!xive_eas_is_valid(&xive->eat[i])) {
615             continue;
616         }
617 
618         kvmppc_xive_set_source_config(xive, i, &xive->eat[i], &local_err);
619         if (local_err) {
620             error_report_err(local_err);
621             return -1;
622         }
623     }
624 
625     /* Restore the thread interrupt contexts */
626     CPU_FOREACH(cs) {
627         PowerPCCPU *cpu = POWERPC_CPU(cs);
628 
629         kvmppc_xive_cpu_set_state(spapr_cpu_state(cpu)->tctx, &local_err);
630         if (local_err) {
631             error_report_err(local_err);
632             return -1;
633         }
634     }
635 
636     /* The source states will be restored when the machine starts running */
637     return 0;
638 }
639 
640 static void *kvmppc_xive_mmap(SpaprXive *xive, int pgoff, size_t len,
641                               Error **errp)
642 {
643     void *addr;
644     uint32_t page_shift = 16; /* TODO: fix page_shift */
645 
646     addr = mmap(NULL, len, PROT_WRITE | PROT_READ, MAP_SHARED, xive->fd,
647                 pgoff << page_shift);
648     if (addr == MAP_FAILED) {
649         error_setg_errno(errp, errno, "XIVE: unable to set memory mapping");
650         return NULL;
651     }
652 
653     return addr;
654 }
655 
656 /*
657  * All the XIVE memory regions are now backed by mappings from the KVM
658  * XIVE device.
659  */
660 void kvmppc_xive_connect(SpaprXive *xive, Error **errp)
661 {
662     XiveSource *xsrc = &xive->source;
663     XiveENDSource *end_xsrc = &xive->end_source;
664     Error *local_err = NULL;
665     size_t esb_len = (1ull << xsrc->esb_shift) * xsrc->nr_irqs;
666     size_t tima_len = 4ull << TM_SHIFT;
667 
668     if (!kvmppc_has_cap_xive()) {
669         error_setg(errp, "IRQ_XIVE capability must be present for KVM");
670         return;
671     }
672 
673     /* First, create the KVM XIVE device */
674     xive->fd = kvm_create_device(kvm_state, KVM_DEV_TYPE_XIVE, false);
675     if (xive->fd < 0) {
676         error_setg_errno(errp, -xive->fd, "XIVE: error creating KVM device");
677         return;
678     }
679 
680     /*
681      * 1. Source ESB pages - KVM mapping
682      */
683     xsrc->esb_mmap = kvmppc_xive_mmap(xive, KVM_XIVE_ESB_PAGE_OFFSET, esb_len,
684                                       &local_err);
685     if (local_err) {
686         error_propagate(errp, local_err);
687         return;
688     }
689 
690     memory_region_init_ram_device_ptr(&xsrc->esb_mmio, OBJECT(xsrc),
691                                       "xive.esb", esb_len, xsrc->esb_mmap);
692     sysbus_init_mmio(SYS_BUS_DEVICE(xive), &xsrc->esb_mmio);
693 
694     /*
695      * 2. END ESB pages (No KVM support yet)
696      */
697     sysbus_init_mmio(SYS_BUS_DEVICE(xive), &end_xsrc->esb_mmio);
698 
699     /*
700      * 3. TIMA pages - KVM mapping
701      */
702     xive->tm_mmap = kvmppc_xive_mmap(xive, KVM_XIVE_TIMA_PAGE_OFFSET, tima_len,
703                                      &local_err);
704     if (local_err) {
705         error_propagate(errp, local_err);
706         return;
707     }
708     memory_region_init_ram_device_ptr(&xive->tm_mmio, OBJECT(xive),
709                                       "xive.tima", tima_len, xive->tm_mmap);
710     sysbus_init_mmio(SYS_BUS_DEVICE(xive), &xive->tm_mmio);
711 
712     xive->change = qemu_add_vm_change_state_handler(
713         kvmppc_xive_change_state_handler, xive);
714 
715     kvm_kernel_irqchip = true;
716     kvm_msi_via_irqfd_allowed = true;
717     kvm_gsi_direct_mapping = true;
718 
719     /* Map all regions */
720     spapr_xive_map_mmio(xive);
721 }
722 
723 void kvmppc_xive_disconnect(SpaprXive *xive, Error **errp)
724 {
725     XiveSource *xsrc;
726     size_t esb_len;
727 
728     /* The KVM XIVE device is not in use */
729     if (!xive || xive->fd == -1) {
730         return;
731     }
732 
733     if (!kvmppc_has_cap_xive()) {
734         error_setg(errp, "IRQ_XIVE capability must be present for KVM");
735         return;
736     }
737 
738     /* Clear the KVM mapping */
739     xsrc = &xive->source;
740     esb_len = (1ull << xsrc->esb_shift) * xsrc->nr_irqs;
741 
742     sysbus_mmio_unmap(SYS_BUS_DEVICE(xive), 0);
743     munmap(xsrc->esb_mmap, esb_len);
744 
745     sysbus_mmio_unmap(SYS_BUS_DEVICE(xive), 1);
746 
747     sysbus_mmio_unmap(SYS_BUS_DEVICE(xive), 2);
748     munmap(xive->tm_mmap, 4ull << TM_SHIFT);
749 
750     /*
751      * When the KVM device fd is closed, the KVM device is destroyed
752      * and removed from the list of devices of the VM. The VCPU
753      * presenters are also detached from the device.
754      */
755     close(xive->fd);
756     xive->fd = -1;
757 
758     kvm_kernel_irqchip = false;
759     kvm_msi_via_irqfd_allowed = false;
760     kvm_gsi_direct_mapping = false;
761 
762     /* Clear the local list of presenter (hotplug) */
763     kvm_cpu_disable_all();
764 
765     /* VM Change state handler is not needed anymore */
766     qemu_del_vm_change_state_handler(xive->change);
767 }
768