hw/virtio/virtio.c

   1 /*
   2  * Virtio Support
   3  *
   4  * Copyright IBM, Corp. 2007
   5  *
   6  * Authors:
   7  *  Anthony Liguori   <[email protected]>
   8  *
   9  * This work is licensed under the terms of the GNU GPL, version 2.  See
  10  * the COPYING file in the top-level directory.
  11  *
  12  */
  13
  14 #include <inttypes.h>
  15
  16 #include "trace.h"
  17 #include "exec/address-spaces.h"
  18 #include "qemu/error-report.h"
  19 #include "hw/virtio/virtio.h"
  20 #include "qemu/atomic.h"
  21 #include "hw/virtio/virtio-bus.h"
  22
  23 /*
  24  * The alignment to use between consumer and producer parts of vring.
  25  * x86 pagesize again. This is the default, used by transports like PCI
  26  * which don't provide a means for the guest to tell the host the alignment.
  27  */
  28 #define VIRTIO_PCI_VRING_ALIGN         4096
  29
  30 typedef struct VRingDesc
  31 {
  32     uint64_t addr;
  33     uint32_t len;
  34     uint16_t flags;
  35     uint16_t next;
  36 } VRingDesc;
  37
  38 typedef struct VRingAvail
  39 {
  40     uint16_t flags;
  41     uint16_t idx;
  42     uint16_t ring[0];
  43 } VRingAvail;
  44
  45 typedef struct VRingUsedElem
  46 {
  47     uint32_t id;
  48     uint32_t len;
  49 } VRingUsedElem;
  50
  51 typedef struct VRingUsed
  52 {
  53     uint16_t flags;
  54     uint16_t idx;
  55     VRingUsedElem ring[0];
  56 } VRingUsed;
  57
  58 typedef struct VRing
  59 {
  60     unsigned int num;
  61     unsigned int align;
  62     hwaddr desc;
  63     hwaddr avail;
  64     hwaddr used;
  65 } VRing;
  66
  67 struct VirtQueue
  68 {
  69     VRing vring;
  70     hwaddr pa;
  71     uint16_t last_avail_idx;
  72     /* Last used index value we have signalled on */
  73     uint16_t signalled_used;
  74
  75     /* Last used index value we have signalled on */
  76     bool signalled_used_valid;
  77
  78     /* Notification enabled? */
  79     bool notification;
  80
  81     uint16_t queue_index;
  82
  83     int inuse;
  84
  85     uint16_t vector;
  86     void (*handle_output)(VirtIODevice *vdev, VirtQueue *vq);
  87     VirtIODevice *vdev;
  88     EventNotifier guest_notifier;
  89     EventNotifier host_notifier;
  90 };
  91
  92 /* virt queue functions */
  93 static void virtqueue_init(VirtQueue *vq)
  94 {
  95     hwaddr pa = vq->pa;
  96
  97     vq->vring.desc = pa;
  98     vq->vring.avail = pa + vq->vring.num * sizeof(VRingDesc);
  99     vq->vring.used = vring_align(vq->vring.avail +
 100                                  offsetof(VRingAvail, ring[vq->vring.num]),
 101                                  vq->vring.align);
 102 }
 103
 104 static inline uint64_t vring_desc_addr(hwaddr desc_pa, int i)
 105 {
 106     hwaddr pa;
 107     pa = desc_pa + sizeof(VRingDesc) * i + offsetof(VRingDesc, addr);
 108     return ldq_phys(&address_space_memory, pa);
 109 }
 110
 111 static inline uint32_t vring_desc_len(hwaddr desc_pa, int i)
 112 {
 113     hwaddr pa;
 114     pa = desc_pa + sizeof(VRingDesc) * i + offsetof(VRingDesc, len);
 115     return ldl_phys(&address_space_memory, pa);
 116 }
 117
 118 static inline uint16_t vring_desc_flags(hwaddr desc_pa, int i)
 119 {
 120     hwaddr pa;
 121     pa = desc_pa + sizeof(VRingDesc) * i + offsetof(VRingDesc, flags);
 122     return lduw_phys(&address_space_memory, pa);
 123 }
 124
 125 static inline uint16_t vring_desc_next(hwaddr desc_pa, int i)
 126 {
 127     hwaddr pa;
 128     pa = desc_pa + sizeof(VRingDesc) * i + offsetof(VRingDesc, next);
 129     return lduw_phys(&address_space_memory, pa);
 130 }
 131
 132 static inline uint16_t vring_avail_flags(VirtQueue *vq)
 133 {
 134     hwaddr pa;
 135     pa = vq->vring.avail + offsetof(VRingAvail, flags);
 136     return lduw_phys(&address_space_memory, pa);
 137 }
 138
 139 static inline uint16_t vring_avail_idx(VirtQueue *vq)
 140 {
 141     hwaddr pa;
 142     pa = vq->vring.avail + offsetof(VRingAvail, idx);
 143     return lduw_phys(&address_space_memory, pa);
 144 }
 145
 146 static inline uint16_t vring_avail_ring(VirtQueue *vq, int i)
 147 {
 148     hwaddr pa;
 149     pa = vq->vring.avail + offsetof(VRingAvail, ring[i]);
 150     return lduw_phys(&address_space_memory, pa);
 151 }
 152
 153 static inline uint16_t vring_used_event(VirtQueue *vq)
 154 {
 155     return vring_avail_ring(vq, vq->vring.num);
 156 }
 157
 158 static inline void vring_used_ring_id(VirtQueue *vq, int i, uint32_t val)
 159 {
 160     hwaddr pa;
 161     pa = vq->vring.used + offsetof(VRingUsed, ring[i].id);
 162     stl_phys(&address_space_memory, pa, val);
 163 }
 164
 165 static inline void vring_used_ring_len(VirtQueue *vq, int i, uint32_t val)
 166 {
 167     hwaddr pa;
 168     pa = vq->vring.used + offsetof(VRingUsed, ring[i].len);
 169     stl_phys(&address_space_memory, pa, val);
 170 }
 171
 172 static uint16_t vring_used_idx(VirtQueue *vq)
 173 {
 174     hwaddr pa;
 175     pa = vq->vring.used + offsetof(VRingUsed, idx);
 176     return lduw_phys(&address_space_memory, pa);
 177 }
 178
 179 static inline void vring_used_idx_set(VirtQueue *vq, uint16_t val)
 180 {
 181     hwaddr pa;
 182     pa = vq->vring.used + offsetof(VRingUsed, idx);
 183     stw_phys(&address_space_memory, pa, val);
 184 }
 185
 186 static inline void vring_used_flags_set_bit(VirtQueue *vq, int mask)
 187 {
 188     hwaddr pa;
 189     pa = vq->vring.used + offsetof(VRingUsed, flags);
 190     stw_phys(&address_space_memory,
 191              pa, lduw_phys(&address_space_memory, pa) | mask);
 192 }
 193
 194 static inline void vring_used_flags_unset_bit(VirtQueue *vq, int mask)
 195 {
 196     hwaddr pa;
 197     pa = vq->vring.used + offsetof(VRingUsed, flags);
 198     stw_phys(&address_space_memory,
 199              pa, lduw_phys(&address_space_memory, pa) & ~mask);
 200 }
 201
 202 static inline void vring_avail_event(VirtQueue *vq, uint16_t val)
 203 {
 204     hwaddr pa;
 205     if (!vq->notification) {
 206         return;
 207     }
 208     pa = vq->vring.used + offsetof(VRingUsed, ring[vq->vring.num]);
 209     stw_phys(&address_space_memory, pa, val);
 210 }
 211
 212 void virtio_queue_set_notification(VirtQueue *vq, int enable)
 213 {
 214     vq->notification = enable;
 215     if (vq->vdev->guest_features & (1 << VIRTIO_RING_F_EVENT_IDX)) {
 216         vring_avail_event(vq, vring_avail_idx(vq));
 217     } else if (enable) {
 218         vring_used_flags_unset_bit(vq, VRING_USED_F_NO_NOTIFY);
 219     } else {
 220         vring_used_flags_set_bit(vq, VRING_USED_F_NO_NOTIFY);
 221     }
 222     if (enable) {
 223         /* Expose avail event/used flags before caller checks the avail idx. */
 224         smp_mb();
 225     }
 226 }
 227
 228 int virtio_queue_ready(VirtQueue *vq)
 229 {
 230     return vq->vring.avail != 0;
 231 }
 232
 233 int virtio_queue_empty(VirtQueue *vq)
 234 {
 235     return vring_avail_idx(vq) == vq->last_avail_idx;
 236 }
 237
 238 void virtqueue_fill(VirtQueue *vq, const VirtQueueElement *elem,
 239                     unsigned int len, unsigned int idx)
 240 {
 241     unsigned int offset;
 242     int i;
 243
 244     trace_virtqueue_fill(vq, elem, len, idx);
 245
 246     offset = 0;
 247     for (i = 0; i < elem->in_num; i++) {
 248         size_t size = MIN(len - offset, elem->in_sg[i].iov_len);
 249
 250         cpu_physical_memory_unmap(elem->in_sg[i].iov_base,
 251                                   elem->in_sg[i].iov_len,
 252                                   1, size);
 253
 254         offset += size;
 255     }
 256
 257     for (i = 0; i < elem->out_num; i++)
 258         cpu_physical_memory_unmap(elem->out_sg[i].iov_base,
 259                                   elem->out_sg[i].iov_len,
 260                                   0, elem->out_sg[i].iov_len);
 261
 262     idx = (idx + vring_used_idx(vq)) % vq->vring.num;
 263
 264     /* Get a pointer to the next entry in the used ring. */
 265     vring_used_ring_id(vq, idx, elem->index);
 266     vring_used_ring_len(vq, idx, len);
 267 }
 268
 269 void virtqueue_flush(VirtQueue *vq, unsigned int count)
 270 {
 271     uint16_t old, new;
 272     /* Make sure buffer is written before we update index. */
 273     smp_wmb();
 274     trace_virtqueue_flush(vq, count);
 275     old = vring_used_idx(vq);
 276     new = old + count;
 277     vring_used_idx_set(vq, new);
 278     vq->inuse -= count;
 279     if (unlikely((int16_t)(new - vq->signalled_used) < (uint16_t)(new - old)))
 280         vq->signalled_used_valid = false;
 281 }
 282
 283 void virtqueue_push(VirtQueue *vq, const VirtQueueElement *elem,
 284                     unsigned int len)
 285 {
 286     virtqueue_fill(vq, elem, len, 0);
 287     virtqueue_flush(vq, 1);
 288 }
 289
 290 static int virtqueue_num_heads(VirtQueue *vq, unsigned int idx)
 291 {
 292     uint16_t num_heads = vring_avail_idx(vq) - idx;
 293
 294     /* Check it isn't doing very strange things with descriptor numbers. */
 295     if (num_heads > vq->vring.num) {
 296         error_report("Guest moved used index from %u to %u",
 297                      idx, vring_avail_idx(vq));
 298         exit(1);
 299     }
 300     /* On success, callers read a descriptor at vq->last_avail_idx.
 301      * Make sure descriptor read does not bypass avail index read. */
 302     if (num_heads) {
 303         smp_rmb();
 304     }
 305
 306     return num_heads;
 307 }
 308
 309 static unsigned int virtqueue_get_head(VirtQueue *vq, unsigned int idx)
 310 {
 311     unsigned int head;
 312
 313     /* Grab the next descriptor number they're advertising, and increment
 314      * the index we've seen. */
 315     head = vring_avail_ring(vq, idx % vq->vring.num);
 316
 317     /* If their number is silly, that's a fatal mistake. */
 318     if (head >= vq->vring.num) {
 319         error_report("Guest says index %u is available", head);
 320         exit(1);
 321     }
 322
 323     return head;
 324 }
 325
 326 static unsigned virtqueue_next_desc(hwaddr desc_pa,
 327                                     unsigned int i, unsigned int max)
 328 {
 329     unsigned int next;
 330
 331     /* If this descriptor says it doesn't chain, we're done. */
 332     if (!(vring_desc_flags(desc_pa, i) & VRING_DESC_F_NEXT))
 333         return max;
 334
 335     /* Check they're not leading us off end of descriptors. */
 336     next = vring_desc_next(desc_pa, i);
 337     /* Make sure compiler knows to grab that: we don't want it changing! */
 338     smp_wmb();
 339
 340     if (next >= max) {
 341         error_report("Desc next is %u", next);
 342         exit(1);
 343     }
 344
 345     return next;
 346 }
 347
 348 void virtqueue_get_avail_bytes(VirtQueue *vq, unsigned int *in_bytes,
 349                                unsigned int *out_bytes,
 350                                unsigned max_in_bytes, unsigned max_out_bytes)
 351 {
 352     unsigned int idx;
 353     unsigned int total_bufs, in_total, out_total;
 354
 355     idx = vq->last_avail_idx;
 356
 357     total_bufs = in_total = out_total = 0;
 358     while (virtqueue_num_heads(vq, idx)) {
 359         unsigned int max, num_bufs, indirect = 0;
 360         hwaddr desc_pa;
 361         int i;
 362
 363         max = vq->vring.num;
 364         num_bufs = total_bufs;
 365         i = virtqueue_get_head(vq, idx++);
 366         desc_pa = vq->vring.desc;
 367
 368         if (vring_desc_flags(desc_pa, i) & VRING_DESC_F_INDIRECT) {
 369             if (vring_desc_len(desc_pa, i) % sizeof(VRingDesc)) {
 370                 error_report("Invalid size for indirect buffer table");
 371                 exit(1);
 372             }
 373
 374             /* If we've got too many, that implies a descriptor loop. */
 375             if (num_bufs >= max) {
 376                 error_report("Looped descriptor");
 377                 exit(1);
 378             }
 379
 380             /* loop over the indirect descriptor table */
 381             indirect = 1;
 382             max = vring_desc_len(desc_pa, i) / sizeof(VRingDesc);
 383             desc_pa = vring_desc_addr(desc_pa, i);
 384             num_bufs = i = 0;
 385         }
 386
 387         do {
 388             /* If we've got too many, that implies a descriptor loop. */
 389             if (++num_bufs > max) {
 390                 error_report("Looped descriptor");
 391                 exit(1);
 392             }
 393
 394             if (vring_desc_flags(desc_pa, i) & VRING_DESC_F_WRITE) {
 395                 in_total += vring_desc_len(desc_pa, i);
 396             } else {
 397                 out_total += vring_desc_len(desc_pa, i);
 398             }
 399             if (in_total >= max_in_bytes && out_total >= max_out_bytes) {
 400                 goto done;
 401             }
 402         } while ((i = virtqueue_next_desc(desc_pa, i, max)) != max);
 403
 404         if (!indirect)
 405             total_bufs = num_bufs;
 406         else
 407             total_bufs++;
 408     }
 409 done:
 410     if (in_bytes) {
 411         *in_bytes = in_total;
 412     }
 413     if (out_bytes) {
 414         *out_bytes = out_total;
 415     }
 416 }
 417
 418 int virtqueue_avail_bytes(VirtQueue *vq, unsigned int in_bytes,
 419                           unsigned int out_bytes)
 420 {
 421     unsigned int in_total, out_total;
 422
 423     virtqueue_get_avail_bytes(vq, &in_total, &out_total, in_bytes, out_bytes);
 424     return in_bytes <= in_total && out_bytes <= out_total;
 425 }
 426
 427 void virtqueue_map_sg(struct iovec *sg, hwaddr *addr,
 428     size_t num_sg, int is_write)
 429 {
 430     unsigned int i;
 431     hwaddr len;
 432
 433     if (num_sg > VIRTQUEUE_MAX_SIZE) {
 434         error_report("virtio: map attempt out of bounds: %zd > %d",
 435                      num_sg, VIRTQUEUE_MAX_SIZE);
 436         exit(1);
 437     }
 438
 439     for (i = 0; i < num_sg; i++) {
 440         len = sg[i].iov_len;
 441         sg[i].iov_base = cpu_physical_memory_map(addr[i], &len, is_write);
 442         if (sg[i].iov_base == NULL || len != sg[i].iov_len) {
 443             error_report("virtio: error trying to map MMIO memory");
 444             exit(1);
 445         }
 446     }
 447 }
 448
 449 int virtqueue_pop(VirtQueue *vq, VirtQueueElement *elem)
 450 {
 451     unsigned int i, head, max;
 452     hwaddr desc_pa = vq->vring.desc;
 453
 454     if (!virtqueue_num_heads(vq, vq->last_avail_idx))
 455         return 0;
 456
 457     /* When we start there are none of either input nor output. */
 458     elem->out_num = elem->in_num = 0;
 459
 460     max = vq->vring.num;
 461
 462     i = head = virtqueue_get_head(vq, vq->last_avail_idx++);
 463     if (vq->vdev->guest_features & (1 << VIRTIO_RING_F_EVENT_IDX)) {
 464         vring_avail_event(vq, vring_avail_idx(vq));
 465     }
 466
 467     if (vring_desc_flags(desc_pa, i) & VRING_DESC_F_INDIRECT) {
 468         if (vring_desc_len(desc_pa, i) % sizeof(VRingDesc)) {
 469             error_report("Invalid size for indirect buffer table");
 470             exit(1);
 471         }
 472
 473         /* loop over the indirect descriptor table */
 474         max = vring_desc_len(desc_pa, i) / sizeof(VRingDesc);
 475         desc_pa = vring_desc_addr(desc_pa, i);
 476         i = 0;
 477     }
 478
 479     /* Collect all the descriptors */
 480     do {
 481         struct iovec *sg;
 482
 483         if (vring_desc_flags(desc_pa, i) & VRING_DESC_F_WRITE) {
 484             if (elem->in_num >= ARRAY_SIZE(elem->in_sg)) {
 485                 error_report("Too many write descriptors in indirect table");
 486                 exit(1);
 487             }
 488             elem->in_addr[elem->in_num] = vring_desc_addr(desc_pa, i);
 489             sg = &elem->in_sg[elem->in_num++];
 490         } else {
 491             if (elem->out_num >= ARRAY_SIZE(elem->out_sg)) {
 492                 error_report("Too many read descriptors in indirect table");
 493                 exit(1);
 494             }
 495             elem->out_addr[elem->out_num] = vring_desc_addr(desc_pa, i);
 496             sg = &elem->out_sg[elem->out_num++];
 497         }
 498
 499         sg->iov_len = vring_desc_len(desc_pa, i);
 500
 501         /* If we've got too many, that implies a descriptor loop. */
 502         if ((elem->in_num + elem->out_num) > max) {
 503             error_report("Looped descriptor");
 504             exit(1);
 505         }
 506     } while ((i = virtqueue_next_desc(desc_pa, i, max)) != max);
 507
 508     /* Now map what we have collected */
 509     virtqueue_map_sg(elem->in_sg, elem->in_addr, elem->in_num, 1);
 510     virtqueue_map_sg(elem->out_sg, elem->out_addr, elem->out_num, 0);
 511
 512     elem->index = head;
 513
 514     vq->inuse++;
 515
 516     trace_virtqueue_pop(vq, elem, elem->in_num, elem->out_num);
 517     return elem->in_num + elem->out_num;
 518 }
 519
 520 /* virtio device */
 521 static void virtio_notify_vector(VirtIODevice *vdev, uint16_t vector)
 522 {
 523     BusState *qbus = qdev_get_parent_bus(DEVICE(vdev));
 524     VirtioBusClass *k = VIRTIO_BUS_GET_CLASS(qbus);
 525
 526     if (k->notify) {
 527         k->notify(qbus->parent, vector);
 528     }
 529 }
 530
 531 void virtio_update_irq(VirtIODevice *vdev)
 532 {
 533     virtio_notify_vector(vdev, VIRTIO_NO_VECTOR);
 534 }
 535
 536 void virtio_set_status(VirtIODevice *vdev, uint8_t val)
 537 {
 538     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 539     trace_virtio_set_status(vdev, val);
 540
 541     if (k->set_status) {
 542         k->set_status(vdev, val);
 543     }
 544     vdev->status = val;
 545 }
 546
 547 void virtio_reset(void *opaque)
 548 {
 549     VirtIODevice *vdev = opaque;
 550     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 551     int i;
 552
 553     virtio_set_status(vdev, 0);
 554
 555     if (k->reset) {
 556         k->reset(vdev);
 557     }
 558
 559     vdev->guest_features = 0;
 560     vdev->queue_sel = 0;
 561     vdev->status = 0;
 562     vdev->isr = 0;
 563     vdev->config_vector = VIRTIO_NO_VECTOR;
 564     virtio_notify_vector(vdev, vdev->config_vector);
 565
 566     for(i = 0; i < VIRTIO_PCI_QUEUE_MAX; i++) {
 567         vdev->vq[i].vring.desc = 0;
 568         vdev->vq[i].vring.avail = 0;
 569         vdev->vq[i].vring.used = 0;
 570         vdev->vq[i].last_avail_idx = 0;
 571         vdev->vq[i].pa = 0;
 572         vdev->vq[i].vector = VIRTIO_NO_VECTOR;
 573         vdev->vq[i].signalled_used = 0;
 574         vdev->vq[i].signalled_used_valid = false;
 575         vdev->vq[i].notification = true;
 576     }
 577 }
 578
 579 uint32_t virtio_config_readb(VirtIODevice *vdev, uint32_t addr)
 580 {
 581     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 582     uint8_t val;
 583
 584     if (addr + sizeof(val) > vdev->config_len) {
 585         return (uint32_t)-1;
 586     }
 587
 588     k->get_config(vdev, vdev->config);
 589
 590     val = ldub_p(vdev->config + addr);
 591     return val;
 592 }
 593
 594 uint32_t virtio_config_readw(VirtIODevice *vdev, uint32_t addr)
 595 {
 596     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 597     uint16_t val;
 598
 599     if (addr + sizeof(val) > vdev->config_len) {
 600         return (uint32_t)-1;
 601     }
 602
 603     k->get_config(vdev, vdev->config);
 604
 605     val = lduw_p(vdev->config + addr);
 606     return val;
 607 }
 608
 609 uint32_t virtio_config_readl(VirtIODevice *vdev, uint32_t addr)
 610 {
 611     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 612     uint32_t val;
 613
 614     if (addr + sizeof(val) > vdev->config_len) {
 615         return (uint32_t)-1;
 616     }
 617
 618     k->get_config(vdev, vdev->config);
 619
 620     val = ldl_p(vdev->config + addr);
 621     return val;
 622 }
 623
 624 void virtio_config_writeb(VirtIODevice *vdev, uint32_t addr, uint32_t data)
 625 {
 626     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 627     uint8_t val = data;
 628
 629     if (addr + sizeof(val) > vdev->config_len) {
 630         return;
 631     }
 632
 633     stb_p(vdev->config + addr, val);
 634
 635     if (k->set_config) {
 636         k->set_config(vdev, vdev->config);
 637     }
 638 }
 639
 640 void virtio_config_writew(VirtIODevice *vdev, uint32_t addr, uint32_t data)
 641 {
 642     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 643     uint16_t val = data;
 644
 645     if (addr + sizeof(val) > vdev->config_len) {
 646         return;
 647     }
 648
 649     stw_p(vdev->config + addr, val);
 650
 651     if (k->set_config) {
 652         k->set_config(vdev, vdev->config);
 653     }
 654 }
 655
 656 void virtio_config_writel(VirtIODevice *vdev, uint32_t addr, uint32_t data)
 657 {
 658     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 659     uint32_t val = data;
 660
 661     if (addr + sizeof(val) > vdev->config_len) {
 662         return;
 663     }
 664
 665     stl_p(vdev->config + addr, val);
 666
 667     if (k->set_config) {
 668         k->set_config(vdev, vdev->config);
 669     }
 670 }
 671
 672 void virtio_queue_set_addr(VirtIODevice *vdev, int n, hwaddr addr)
 673 {
 674     vdev->vq[n].pa = addr;
 675     virtqueue_init(&vdev->vq[n]);
 676 }
 677
 678 hwaddr virtio_queue_get_addr(VirtIODevice *vdev, int n)
 679 {
 680     return vdev->vq[n].pa;
 681 }
 682
 683 void virtio_queue_set_num(VirtIODevice *vdev, int n, int num)
 684 {
 685     /* Don't allow guest to flip queue between existent and
 686      * nonexistent states, or to set it to an invalid size.
 687      */
 688     if (!!num != !!vdev->vq[n].vring.num ||
 689         num > VIRTQUEUE_MAX_SIZE ||
 690         num < 0) {
 691         return;
 692     }
 693     vdev->vq[n].vring.num = num;
 694     virtqueue_init(&vdev->vq[n]);
 695 }
 696
 697 int virtio_queue_get_num(VirtIODevice *vdev, int n)
 698 {
 699     return vdev->vq[n].vring.num;
 700 }
 701
 702 int virtio_queue_get_id(VirtQueue *vq)
 703 {
 704     VirtIODevice *vdev = vq->vdev;
 705     assert(vq >= &vdev->vq[0] && vq < &vdev->vq[VIRTIO_PCI_QUEUE_MAX]);
 706     return vq - &vdev->vq[0];
 707 }
 708
 709 void virtio_queue_set_align(VirtIODevice *vdev, int n, int align)
 710 {
 711     BusState *qbus = qdev_get_parent_bus(DEVICE(vdev));
 712     VirtioBusClass *k = VIRTIO_BUS_GET_CLASS(qbus);
 713
 714     /* Check that the transport told us it was going to do this
 715      * (so a buggy transport will immediately assert rather than
 716      * silently failing to migrate this state)
 717      */
 718     assert(k->has_variable_vring_alignment);
 719
 720     vdev->vq[n].vring.align = align;
 721     virtqueue_init(&vdev->vq[n]);
 722 }
 723
 724 void virtio_queue_notify_vq(VirtQueue *vq)
 725 {
 726     if (vq->vring.desc) {
 727         VirtIODevice *vdev = vq->vdev;
 728         trace_virtio_queue_notify(vdev, vq - vdev->vq, vq);
 729         vq->handle_output(vdev, vq);
 730     }
 731 }
 732
 733 void virtio_queue_notify(VirtIODevice *vdev, int n)
 734 {
 735     virtio_queue_notify_vq(&vdev->vq[n]);
 736 }
 737
 738 uint16_t virtio_queue_vector(VirtIODevice *vdev, int n)
 739 {
 740     return n < VIRTIO_PCI_QUEUE_MAX ? vdev->vq[n].vector :
 741         VIRTIO_NO_VECTOR;
 742 }
 743
 744 void virtio_queue_set_vector(VirtIODevice *vdev, int n, uint16_t vector)
 745 {
 746     if (n < VIRTIO_PCI_QUEUE_MAX)
 747         vdev->vq[n].vector = vector;
 748 }
 749
 750 VirtQueue *virtio_add_queue(VirtIODevice *vdev, int queue_size,
 751                             void (*handle_output)(VirtIODevice *, VirtQueue *))
 752 {
 753     int i;
 754
 755     for (i = 0; i < VIRTIO_PCI_QUEUE_MAX; i++) {
 756         if (vdev->vq[i].vring.num == 0)
 757             break;
 758     }
 759
 760     if (i == VIRTIO_PCI_QUEUE_MAX || queue_size > VIRTQUEUE_MAX_SIZE)
 761         abort();
 762
 763     vdev->vq[i].vring.num = queue_size;
 764     vdev->vq[i].vring.align = VIRTIO_PCI_VRING_ALIGN;
 765     vdev->vq[i].handle_output = handle_output;
 766
 767     return &vdev->vq[i];
 768 }
 769
 770 void virtio_del_queue(VirtIODevice *vdev, int n)
 771 {
 772     if (n < 0 || n >= VIRTIO_PCI_QUEUE_MAX) {
 773         abort();
 774     }
 775
 776     vdev->vq[n].vring.num = 0;
 777 }
 778
 779 void virtio_irq(VirtQueue *vq)
 780 {
 781     trace_virtio_irq(vq);
 782     vq->vdev->isr |= 0x01;
 783     virtio_notify_vector(vq->vdev, vq->vector);
 784 }
 785
 786 /* Assuming a given event_idx value from the other size, if
 787  * we have just incremented index from old to new_idx,
 788  * should we trigger an event? */
 789 static inline int vring_need_event(uint16_t event, uint16_t new, uint16_t old)
 790 {
 791         /* Note: Xen has similar logic for notification hold-off
 792          * in include/xen/interface/io/ring.h with req_event and req_prod
 793          * corresponding to event_idx + 1 and new respectively.
 794          * Note also that req_event and req_prod in Xen start at 1,
 795          * event indexes in virtio start at 0. */
 796         return (uint16_t)(new - event - 1) < (uint16_t)(new - old);
 797 }
 798
 799 static bool vring_notify(VirtIODevice *vdev, VirtQueue *vq)
 800 {
 801     uint16_t old, new;
 802     bool v;
 803     /* We need to expose used array entries before checking used event. */
 804     smp_mb();
 805     /* Always notify when queue is empty (when feature acknowledge) */
 806     if (((vdev->guest_features & (1 << VIRTIO_F_NOTIFY_ON_EMPTY)) &&
 807          !vq->inuse && vring_avail_idx(vq) == vq->last_avail_idx)) {
 808         return true;
 809     }
 810
 811     if (!(vdev->guest_features & (1 << VIRTIO_RING_F_EVENT_IDX))) {
 812         return !(vring_avail_flags(vq) & VRING_AVAIL_F_NO_INTERRUPT);
 813     }
 814
 815     v = vq->signalled_used_valid;
 816     vq->signalled_used_valid = true;
 817     old = vq->signalled_used;
 818     new = vq->signalled_used = vring_used_idx(vq);
 819     return !v || vring_need_event(vring_used_event(vq), new, old);
 820 }
 821
 822 void virtio_notify(VirtIODevice *vdev, VirtQueue *vq)
 823 {
 824     if (!vring_notify(vdev, vq)) {
 825         return;
 826     }
 827
 828     trace_virtio_notify(vdev, vq);
 829     vdev->isr |= 0x01;
 830     virtio_notify_vector(vdev, vq->vector);
 831 }
 832
 833 void virtio_notify_config(VirtIODevice *vdev)
 834 {
 835     if (!(vdev->status & VIRTIO_CONFIG_S_DRIVER_OK))
 836         return;
 837
 838     vdev->isr |= 0x03;
 839     virtio_notify_vector(vdev, vdev->config_vector);
 840 }
 841
 842 void virtio_save(VirtIODevice *vdev, QEMUFile *f)
 843 {
 844     BusState *qbus = qdev_get_parent_bus(DEVICE(vdev));
 845     VirtioBusClass *k = VIRTIO_BUS_GET_CLASS(qbus);
 846     int i;
 847
 848     if (k->save_config) {
 849         k->save_config(qbus->parent, f);
 850     }
 851
 852     qemu_put_8s(f, &vdev->status);
 853     qemu_put_8s(f, &vdev->isr);
 854     qemu_put_be16s(f, &vdev->queue_sel);
 855     qemu_put_be32s(f, &vdev->guest_features);
 856     qemu_put_be32(f, vdev->config_len);
 857     qemu_put_buffer(f, vdev->config, vdev->config_len);
 858
 859     for (i = 0; i < VIRTIO_PCI_QUEUE_MAX; i++) {
 860         if (vdev->vq[i].vring.num == 0)
 861             break;
 862     }
 863
 864     qemu_put_be32(f, i);
 865
 866     for (i = 0; i < VIRTIO_PCI_QUEUE_MAX; i++) {
 867         if (vdev->vq[i].vring.num == 0)
 868             break;
 869
 870         qemu_put_be32(f, vdev->vq[i].vring.num);
 871         if (k->has_variable_vring_alignment) {
 872             qemu_put_be32(f, vdev->vq[i].vring.align);
 873         }
 874         qemu_put_be64(f, vdev->vq[i].pa);
 875         qemu_put_be16s(f, &vdev->vq[i].last_avail_idx);
 876         if (k->save_queue) {
 877             k->save_queue(qbus->parent, i, f);
 878         }
 879     }
 880 }
 881
 882 int virtio_set_features(VirtIODevice *vdev, uint32_t val)
 883 {
 884     BusState *qbus = qdev_get_parent_bus(DEVICE(vdev));
 885     VirtioBusClass *vbusk = VIRTIO_BUS_GET_CLASS(qbus);
 886     VirtioDeviceClass *k = VIRTIO_DEVICE_GET_CLASS(vdev);
 887     uint32_t supported_features = vbusk->get_features(qbus->parent);
 888     bool bad = (val & ~supported_features) != 0;
 889
 890     val &= supported_features;
 891     if (k->set_features) {
 892         k->set_features(vdev, val);
 893     }
 894     vdev->guest_features = val;
 895     return bad ? -1 : 0;
 896 }
 897
 898 int virtio_load(VirtIODevice *vdev, QEMUFile *f)
 899 {
 900     int i, ret;
 901     int32_t config_len;
 902     uint32_t num;
 903     uint32_t features;
 904     uint32_t supported_features;
 905     BusState *qbus = qdev_get_parent_bus(DEVICE(vdev));
 906     VirtioBusClass *k = VIRTIO_BUS_GET_CLASS(qbus);
 907
 908     if (k->load_config) {
 909         ret = k->load_config(qbus->parent, f);
 910         if (ret)
 911             return ret;
 912     }
 913
 914     qemu_get_8s(f, &vdev->status);
 915     qemu_get_8s(f, &vdev->isr);
 916     qemu_get_be16s(f, &vdev->queue_sel);
 917     if (vdev->queue_sel >= VIRTIO_PCI_QUEUE_MAX) {
 918         return -1;
 919     }
 920     qemu_get_be32s(f, &features);
 921
 922     if (virtio_set_features(vdev, features) < 0) {
 923         supported_features = k->get_features(qbus->parent);
 924         error_report("Features 0x%x unsupported. Allowed features: 0x%x",
 925                      features, supported_features);
 926         return -1;
 927     }
 928     config_len = qemu_get_be32(f);
 929     if (config_len != vdev->config_len) {
 930         error_report("Unexpected config length 0x%x. Expected 0x%zx",
 931                      config_len, vdev->config_len);
 932         return -1;
 933     }
 934     qemu_get_buffer(f, vdev->config, vdev->config_len);
 935
 936     num = qemu_get_be32(f);
 937
 938     if (num > VIRTIO_PCI_QUEUE_MAX) {
 939         error_report("Invalid number of PCI queues: 0x%x", num);
 940         return -1;
 941     }
 942
 943     for (i = 0; i < num; i++) {
 944         vdev->vq[i].vring.num = qemu_get_be32(f);
 945         if (k->has_variable_vring_alignment) {
 946             vdev->vq[i].vring.align = qemu_get_be32(f);
 947         }
 948         vdev->vq[i].pa = qemu_get_be64(f);
 949         qemu_get_be16s(f, &vdev->vq[i].last_avail_idx);
 950         vdev->vq[i].signalled_used_valid = false;
 951         vdev->vq[i].notification = true;
 952
 953         if (vdev->vq[i].pa) {
 954             uint16_t nheads;
 955             virtqueue_init(&vdev->vq[i]);
 956             nheads = vring_avail_idx(&vdev->vq[i]) - vdev->vq[i].last_avail_idx;
 957             /* Check it isn't doing very strange things with descriptor numbers. */
 958             if (nheads > vdev->vq[i].vring.num) {
 959                 error_report("VQ %d size 0x%x Guest index 0x%x "
 960                              "inconsistent with Host index 0x%x: delta 0x%x",
 961                              i, vdev->vq[i].vring.num,
 962                              vring_avail_idx(&vdev->vq[i]),
 963                              vdev->vq[i].last_avail_idx, nheads);
 964                 return -1;
 965             }
 966         } else if (vdev->vq[i].last_avail_idx) {
 967             error_report("VQ %d address 0x0 "
 968                          "inconsistent with Host index 0x%x",
 969                          i, vdev->vq[i].last_avail_idx);
 970                 return -1;
 971         }
 972         if (k->load_queue) {
 973             ret = k->load_queue(qbus->parent, i, f);
 974             if (ret)
 975                 return ret;
 976         }
 977     }
 978
 979     virtio_notify_vector(vdev, VIRTIO_NO_VECTOR);
 980     return 0;
 981 }
 982
 983 void virtio_cleanup(VirtIODevice *vdev)
 984 {
 985     qemu_del_vm_change_state_handler(vdev->vmstate);
 986     g_free(vdev->config);
 987     g_free(vdev->vq);
 988 }
 989
 990 static void virtio_vmstate_change(void *opaque, int running, RunState state)
 991 {
 992     VirtIODevice *vdev = opaque;
 993     BusState *qbus = qdev_get_parent_bus(DEVICE(vdev));
 994     VirtioBusClass *k = VIRTIO_BUS_GET_CLASS(qbus);
 995     bool backend_run = running && (vdev->status & VIRTIO_CONFIG_S_DRIVER_OK);
 996     vdev->vm_running = running;
 997
 998     if (backend_run) {
 999         virtio_set_status(vdev, vdev->status);
1000     }
1001
1002     if (k->vmstate_change) {
1003         k->vmstate_change(qbus->parent, backend_run);
1004     }
1005
1006     if (!backend_run) {
1007         virtio_set_status(vdev, vdev->status);
1008     }
1009 }
1010
1011 void virtio_init(VirtIODevice *vdev, const char *name,
1012                  uint16_t device_id, size_t config_size)
1013 {
1014     int i;
1015     vdev->device_id = device_id;
1016     vdev->status = 0;
1017     vdev->isr = 0;
1018     vdev->queue_sel = 0;
1019     vdev->config_vector = VIRTIO_NO_VECTOR;
1020     vdev->vq = g_malloc0(sizeof(VirtQueue) * VIRTIO_PCI_QUEUE_MAX);
1021     vdev->vm_running = runstate_is_running();
1022     for (i = 0; i < VIRTIO_PCI_QUEUE_MAX; i++) {
1023         vdev->vq[i].vector = VIRTIO_NO_VECTOR;
1024         vdev->vq[i].vdev = vdev;
1025         vdev->vq[i].queue_index = i;
1026     }
1027
1028     vdev->name = name;
1029     vdev->config_len = config_size;
1030     if (vdev->config_len) {
1031         vdev->config = g_malloc0(config_size);
1032     } else {
1033         vdev->config = NULL;
1034     }
1035     vdev->vmstate = qemu_add_vm_change_state_handler(virtio_vmstate_change,
1036                                                      vdev);
1037 }
1038
1039 hwaddr virtio_queue_get_desc_addr(VirtIODevice *vdev, int n)
1040 {
1041     return vdev->vq[n].vring.desc;
1042 }
1043
1044 hwaddr virtio_queue_get_avail_addr(VirtIODevice *vdev, int n)
1045 {
1046     return vdev->vq[n].vring.avail;
1047 }
1048
1049 hwaddr virtio_queue_get_used_addr(VirtIODevice *vdev, int n)
1050 {
1051     return vdev->vq[n].vring.used;
1052 }
1053
1054 hwaddr virtio_queue_get_ring_addr(VirtIODevice *vdev, int n)
1055 {
1056     return vdev->vq[n].vring.desc;
1057 }
1058
1059 hwaddr virtio_queue_get_desc_size(VirtIODevice *vdev, int n)
1060 {
1061     return sizeof(VRingDesc) * vdev->vq[n].vring.num;
1062 }
1063
1064 hwaddr virtio_queue_get_avail_size(VirtIODevice *vdev, int n)
1065 {
1066     return offsetof(VRingAvail, ring) +
1067         sizeof(uint64_t) * vdev->vq[n].vring.num;
1068 }
1069
1070 hwaddr virtio_queue_get_used_size(VirtIODevice *vdev, int n)
1071 {
1072     return offsetof(VRingUsed, ring) +
1073         sizeof(VRingUsedElem) * vdev->vq[n].vring.num;
1074 }
1075
1076 hwaddr virtio_queue_get_ring_size(VirtIODevice *vdev, int n)
1077 {
1078     return vdev->vq[n].vring.used - vdev->vq[n].vring.desc +
1079             virtio_queue_get_used_size(vdev, n);
1080 }
1081
1082 uint16_t virtio_queue_get_last_avail_idx(VirtIODevice *vdev, int n)
1083 {
1084     return vdev->vq[n].last_avail_idx;
1085 }
1086
1087 void virtio_queue_set_last_avail_idx(VirtIODevice *vdev, int n, uint16_t idx)
1088 {
1089     vdev->vq[n].last_avail_idx = idx;
1090 }
1091
1092 void virtio_queue_invalidate_signalled_used(VirtIODevice *vdev, int n)
1093 {
1094     vdev->vq[n].signalled_used_valid = false;
1095 }
1096
1097 VirtQueue *virtio_get_queue(VirtIODevice *vdev, int n)
1098 {
1099     return vdev->vq + n;
1100 }
1101
1102 uint16_t virtio_get_queue_index(VirtQueue *vq)
1103 {
1104     return vq->queue_index;
1105 }
1106
1107 static void virtio_queue_guest_notifier_read(EventNotifier *n)
1108 {
1109     VirtQueue *vq = container_of(n, VirtQueue, guest_notifier);
1110     if (event_notifier_test_and_clear(n)) {
1111         virtio_irq(vq);
1112     }
1113 }
1114
1115 void virtio_queue_set_guest_notifier_fd_handler(VirtQueue *vq, bool assign,
1116                                                 bool with_irqfd)
1117 {
1118     if (assign && !with_irqfd) {
1119         event_notifier_set_handler(&vq->guest_notifier,
1120                                    virtio_queue_guest_notifier_read);
1121     } else {
1122         event_notifier_set_handler(&vq->guest_notifier, NULL);
1123     }
1124     if (!assign) {
1125         /* Test and clear notifier before closing it,
1126          * in case poll callback didn't have time to run. */
1127         virtio_queue_guest_notifier_read(&vq->guest_notifier);
1128     }
1129 }
1130
1131 EventNotifier *virtio_queue_get_guest_notifier(VirtQueue *vq)
1132 {
1133     return &vq->guest_notifier;
1134 }
1135
1136 static void virtio_queue_host_notifier_read(EventNotifier *n)
1137 {
1138     VirtQueue *vq = container_of(n, VirtQueue, host_notifier);
1139     if (event_notifier_test_and_clear(n)) {
1140         virtio_queue_notify_vq(vq);
1141     }
1142 }
1143
1144 void virtio_queue_set_host_notifier_fd_handler(VirtQueue *vq, bool assign,
1145                                                bool set_handler)
1146 {
1147     if (assign && set_handler) {
1148         event_notifier_set_handler(&vq->host_notifier,
1149                                    virtio_queue_host_notifier_read);
1150     } else {
1151         event_notifier_set_handler(&vq->host_notifier, NULL);
1152     }
1153     if (!assign) {
1154         /* Test and clear notifier before after disabling event,
1155          * in case poll callback didn't have time to run. */
1156         virtio_queue_host_notifier_read(&vq->host_notifier);
1157     }
1158 }
1159
1160 EventNotifier *virtio_queue_get_host_notifier(VirtQueue *vq)
1161 {
1162     return &vq->host_notifier;
1163 }
1164
1165 void virtio_device_set_child_bus_name(VirtIODevice *vdev, char *bus_name)
1166 {
1167     if (vdev->bus_name) {
1168         g_free(vdev->bus_name);
1169         vdev->bus_name = NULL;
1170     }
1171
1172     if (bus_name) {
1173         vdev->bus_name = g_strdup(bus_name);
1174     }
1175 }
1176
1177 static void virtio_device_realize(DeviceState *dev, Error **errp)
1178 {
1179     VirtIODevice *vdev = VIRTIO_DEVICE(dev);
1180     VirtioDeviceClass *vdc = VIRTIO_DEVICE_GET_CLASS(dev);
1181     Error *err = NULL;
1182
1183     if (vdc->realize != NULL) {
1184         vdc->realize(dev, &err);
1185         if (err != NULL) {
1186             error_propagate(errp, err);
1187             return;
1188         }
1189     }
1190     virtio_bus_device_plugged(vdev);
1191 }
1192
1193 static void virtio_device_unrealize(DeviceState *dev, Error **errp)
1194 {
1195     VirtIODevice *vdev = VIRTIO_DEVICE(dev);
1196     VirtioDeviceClass *vdc = VIRTIO_DEVICE_GET_CLASS(dev);
1197     Error *err = NULL;
1198
1199     virtio_bus_device_unplugged(vdev);
1200
1201     if (vdc->unrealize != NULL) {
1202         vdc->unrealize(dev, &err);
1203         if (err != NULL) {
1204             error_propagate(errp, err);
1205             return;
1206         }
1207     }
1208
1209     if (vdev->bus_name) {
1210         g_free(vdev->bus_name);
1211         vdev->bus_name = NULL;
1212     }
1213 }
1214
1215 static void virtio_device_class_init(ObjectClass *klass, void *data)
1216 {
1217     /* Set the default value here. */
1218     DeviceClass *dc = DEVICE_CLASS(klass);
1219
1220     dc->realize = virtio_device_realize;
1221     dc->unrealize = virtio_device_unrealize;
1222     dc->bus_type = TYPE_VIRTIO_BUS;
1223 }
1224
1225 static const TypeInfo virtio_device_info = {
1226     .name = TYPE_VIRTIO_DEVICE,
1227     .parent = TYPE_DEVICE,
1228     .instance_size = sizeof(VirtIODevice),
1229     .class_init = virtio_device_class_init,
1230     .abstract = true,
1231     .class_size = sizeof(VirtioDeviceClass),
1232 };
1233
1234 static void virtio_register_types(void)
1235 {
1236     type_register_static(&virtio_device_info);
1237 }
1238
1239 type_init(virtio_register_types)