virtio-net: Use a byte to store RX mode flags
[qemu] / hw / virtio-net.c
1 /*
2  * Virtio Network Device
3  *
4  * Copyright IBM, Corp. 2007
5  *
6  * Authors:
7  *  Anthony Liguori   <aliguori@us.ibm.com>
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 "virtio.h"
15 #include "net.h"
16 #include "qemu-timer.h"
17 #include "virtio-net.h"
18
19 #define VIRTIO_NET_VM_VERSION    8
20
21 #define MAC_TABLE_ENTRIES    32
22 #define MAX_VLAN    (1 << 12)   /* Per 802.1Q definition */
23
24 typedef struct VirtIONet
25 {
26     VirtIODevice vdev;
27     uint8_t mac[ETH_ALEN];
28     uint16_t status;
29     VirtQueue *rx_vq;
30     VirtQueue *tx_vq;
31     VirtQueue *ctrl_vq;
32     VLANClientState *vc;
33     QEMUTimer *tx_timer;
34     int tx_timer_active;
35     int mergeable_rx_bufs;
36     uint8_t promisc;
37     uint8_t allmulti;
38     struct {
39         int in_use;
40         uint8_t *macs;
41     } mac_table;
42     uint32_t *vlans;
43 } VirtIONet;
44
45 /* TODO
46  * - we could suppress RX interrupt if we were so inclined.
47  */
48
49 static VirtIONet *to_virtio_net(VirtIODevice *vdev)
50 {
51     return (VirtIONet *)vdev;
52 }
53
54 static void virtio_net_get_config(VirtIODevice *vdev, uint8_t *config)
55 {
56     VirtIONet *n = to_virtio_net(vdev);
57     struct virtio_net_config netcfg;
58
59     netcfg.status = n->status;
60     memcpy(netcfg.mac, n->mac, ETH_ALEN);
61     memcpy(config, &netcfg, sizeof(netcfg));
62 }
63
64 static void virtio_net_set_config(VirtIODevice *vdev, const uint8_t *config)
65 {
66     VirtIONet *n = to_virtio_net(vdev);
67     struct virtio_net_config netcfg;
68
69     memcpy(&netcfg, config, sizeof(netcfg));
70
71     if (memcmp(netcfg.mac, n->mac, ETH_ALEN)) {
72         memcpy(n->mac, netcfg.mac, ETH_ALEN);
73         qemu_format_nic_info_str(n->vc, n->mac);
74     }
75 }
76
77 static void virtio_net_set_link_status(VLANClientState *vc)
78 {
79     VirtIONet *n = vc->opaque;
80     uint16_t old_status = n->status;
81
82     if (vc->link_down)
83         n->status &= ~VIRTIO_NET_S_LINK_UP;
84     else
85         n->status |= VIRTIO_NET_S_LINK_UP;
86
87     if (n->status != old_status)
88         virtio_notify_config(&n->vdev);
89 }
90
91 static void virtio_net_reset(VirtIODevice *vdev)
92 {
93     VirtIONet *n = to_virtio_net(vdev);
94
95     /* Reset back to compatibility mode */
96     n->promisc = 1;
97     n->allmulti = 0;
98
99     /* Flush any MAC and VLAN filter table state */
100     n->mac_table.in_use = 0;
101     memset(n->mac_table.macs, 0, MAC_TABLE_ENTRIES * ETH_ALEN);
102     memset(n->vlans, 0, MAX_VLAN >> 3);
103 }
104
105 static uint32_t virtio_net_get_features(VirtIODevice *vdev)
106 {
107     uint32_t features = (1 << VIRTIO_NET_F_MAC) |
108                         (1 << VIRTIO_NET_F_STATUS) |
109                         (1 << VIRTIO_NET_F_CTRL_VQ) |
110                         (1 << VIRTIO_NET_F_CTRL_RX) |
111                         (1 << VIRTIO_NET_F_CTRL_VLAN);
112
113     return features;
114 }
115
116 static uint32_t virtio_net_bad_features(VirtIODevice *vdev)
117 {
118     uint32_t features = 0;
119
120     /* Linux kernel 2.6.25.  It understood MAC (as everyone must),
121      * but also these: */
122     features |= (1 << VIRTIO_NET_F_MAC);
123     features |= (1 << VIRTIO_NET_F_GUEST_CSUM);
124     features |= (1 << VIRTIO_NET_F_GUEST_TSO4);
125     features |= (1 << VIRTIO_NET_F_GUEST_TSO6);
126     features |= (1 << VIRTIO_NET_F_GUEST_ECN);
127
128     return features & virtio_net_get_features(vdev);
129 }
130
131 static void virtio_net_set_features(VirtIODevice *vdev, uint32_t features)
132 {
133     VirtIONet *n = to_virtio_net(vdev);
134
135     n->mergeable_rx_bufs = !!(features & (1 << VIRTIO_NET_F_MRG_RXBUF));
136 }
137
138 static int virtio_net_handle_rx_mode(VirtIONet *n, uint8_t cmd,
139                                      VirtQueueElement *elem)
140 {
141     uint8_t on;
142
143     if (elem->out_num != 2 || elem->out_sg[1].iov_len != sizeof(on)) {
144         fprintf(stderr, "virtio-net ctrl invalid rx mode command\n");
145         exit(1);
146     }
147
148     on = ldub_p(elem->out_sg[1].iov_base);
149
150     if (cmd == VIRTIO_NET_CTRL_RX_MODE_PROMISC)
151         n->promisc = on;
152     else if (cmd == VIRTIO_NET_CTRL_RX_MODE_ALLMULTI)
153         n->allmulti = on;
154     else
155         return VIRTIO_NET_ERR;
156
157     return VIRTIO_NET_OK;
158 }
159
160 static int virtio_net_handle_mac(VirtIONet *n, uint8_t cmd,
161                                  VirtQueueElement *elem)
162 {
163     struct virtio_net_ctrl_mac mac_data;
164
165     if (cmd != VIRTIO_NET_CTRL_MAC_TABLE_SET || elem->out_num != 3 ||
166         elem->out_sg[1].iov_len < sizeof(mac_data) ||
167         elem->out_sg[2].iov_len < sizeof(mac_data))
168         return VIRTIO_NET_ERR;
169
170     n->mac_table.in_use = 0;
171     memset(n->mac_table.macs, 0, MAC_TABLE_ENTRIES * ETH_ALEN);
172
173     mac_data.entries = ldl_le_p(elem->out_sg[1].iov_base);
174
175     if (sizeof(mac_data.entries) +
176         (mac_data.entries * ETH_ALEN) > elem->out_sg[1].iov_len)
177         return VIRTIO_NET_ERR;
178
179     if (mac_data.entries <= MAC_TABLE_ENTRIES) {
180         memcpy(n->mac_table.macs, elem->out_sg[1].iov_base + sizeof(mac_data),
181                mac_data.entries * ETH_ALEN);
182         n->mac_table.in_use += mac_data.entries;
183     } else {
184         n->promisc = 1;
185         return VIRTIO_NET_OK;
186     }
187
188     mac_data.entries = ldl_le_p(elem->out_sg[2].iov_base);
189
190     if (sizeof(mac_data.entries) +
191         (mac_data.entries * ETH_ALEN) > elem->out_sg[2].iov_len)
192         return VIRTIO_NET_ERR;
193
194     if (mac_data.entries) {
195         if (n->mac_table.in_use + mac_data.entries <= MAC_TABLE_ENTRIES) {
196             memcpy(n->mac_table.macs + (n->mac_table.in_use * ETH_ALEN),
197                    elem->out_sg[2].iov_base + sizeof(mac_data),
198                    mac_data.entries * ETH_ALEN);
199             n->mac_table.in_use += mac_data.entries;
200         } else
201             n->allmulti = 1;
202     }
203
204     return VIRTIO_NET_OK;
205 }
206
207 static int virtio_net_handle_vlan_table(VirtIONet *n, uint8_t cmd,
208                                         VirtQueueElement *elem)
209 {
210     uint16_t vid;
211
212     if (elem->out_num != 2 || elem->out_sg[1].iov_len != sizeof(vid)) {
213         fprintf(stderr, "virtio-net ctrl invalid vlan command\n");
214         return VIRTIO_NET_ERR;
215     }
216
217     vid = lduw_le_p(elem->out_sg[1].iov_base);
218
219     if (vid >= MAX_VLAN)
220         return VIRTIO_NET_ERR;
221
222     if (cmd == VIRTIO_NET_CTRL_VLAN_ADD)
223         n->vlans[vid >> 5] |= (1U << (vid & 0x1f));
224     else if (cmd == VIRTIO_NET_CTRL_VLAN_DEL)
225         n->vlans[vid >> 5] &= ~(1U << (vid & 0x1f));
226     else
227         return VIRTIO_NET_ERR;
228
229     return VIRTIO_NET_OK;
230 }
231
232 static void virtio_net_handle_ctrl(VirtIODevice *vdev, VirtQueue *vq)
233 {
234     VirtIONet *n = to_virtio_net(vdev);
235     struct virtio_net_ctrl_hdr ctrl;
236     virtio_net_ctrl_ack status = VIRTIO_NET_ERR;
237     VirtQueueElement elem;
238
239     while (virtqueue_pop(vq, &elem)) {
240         if ((elem.in_num < 1) || (elem.out_num < 1)) {
241             fprintf(stderr, "virtio-net ctrl missing headers\n");
242             exit(1);
243         }
244
245         if (elem.out_sg[0].iov_len < sizeof(ctrl) ||
246             elem.in_sg[elem.in_num - 1].iov_len < sizeof(status)) {
247             fprintf(stderr, "virtio-net ctrl header not in correct element\n");
248             exit(1);
249         }
250
251         ctrl.class = ldub_p(elem.out_sg[0].iov_base);
252         ctrl.cmd = ldub_p(elem.out_sg[0].iov_base + sizeof(ctrl.class));
253
254         if (ctrl.class == VIRTIO_NET_CTRL_RX_MODE)
255             status = virtio_net_handle_rx_mode(n, ctrl.cmd, &elem);
256         else if (ctrl.class == VIRTIO_NET_CTRL_MAC)
257             status = virtio_net_handle_mac(n, ctrl.cmd, &elem);
258         else if (ctrl.class == VIRTIO_NET_CTRL_VLAN)
259             status = virtio_net_handle_vlan_table(n, ctrl.cmd, &elem);
260
261         stb_p(elem.in_sg[elem.in_num - 1].iov_base, status);
262
263         virtqueue_push(vq, &elem, sizeof(status));
264         virtio_notify(vdev, vq);
265     }
266 }
267
268 /* RX */
269
270 static void virtio_net_handle_rx(VirtIODevice *vdev, VirtQueue *vq)
271 {
272     VirtIONet *n = to_virtio_net(vdev);
273
274     qemu_flush_queued_packets(n->vc);
275 }
276
277 static int do_virtio_net_can_receive(VirtIONet *n, int bufsize)
278 {
279     if (!virtio_queue_ready(n->rx_vq) ||
280         !(n->vdev.status & VIRTIO_CONFIG_S_DRIVER_OK))
281         return 0;
282
283     if (virtio_queue_empty(n->rx_vq) ||
284         (n->mergeable_rx_bufs &&
285          !virtqueue_avail_bytes(n->rx_vq, bufsize, 0))) {
286         virtio_queue_set_notification(n->rx_vq, 1);
287         return 0;
288     }
289
290     virtio_queue_set_notification(n->rx_vq, 0);
291     return 1;
292 }
293
294 static int virtio_net_can_receive(VLANClientState *vc)
295 {
296     VirtIONet *n = vc->opaque;
297
298     return do_virtio_net_can_receive(n, VIRTIO_NET_MAX_BUFSIZE);
299 }
300
301 static int iov_fill(struct iovec *iov, int iovcnt, const void *buf, int count)
302 {
303     int offset, i;
304
305     offset = i = 0;
306     while (offset < count && i < iovcnt) {
307         int len = MIN(iov[i].iov_len, count - offset);
308         memcpy(iov[i].iov_base, buf + offset, len);
309         offset += len;
310         i++;
311     }
312
313     return offset;
314 }
315
316 static int receive_header(VirtIONet *n, struct iovec *iov, int iovcnt,
317                           const void *buf, size_t size, size_t hdr_len)
318 {
319     struct virtio_net_hdr *hdr = (struct virtio_net_hdr *)iov[0].iov_base;
320     int offset = 0;
321
322     hdr->flags = 0;
323     hdr->gso_type = VIRTIO_NET_HDR_GSO_NONE;
324
325     /* We only ever receive a struct virtio_net_hdr from the tapfd,
326      * but we may be passing along a larger header to the guest.
327      */
328     iov[0].iov_base += hdr_len;
329     iov[0].iov_len  -= hdr_len;
330
331     return offset;
332 }
333
334 static int receive_filter(VirtIONet *n, const uint8_t *buf, int size)
335 {
336     static const uint8_t bcast[] = {0xff, 0xff, 0xff, 0xff, 0xff, 0xff};
337     static const uint8_t vlan[] = {0x81, 0x00};
338     uint8_t *ptr = (uint8_t *)buf;
339     int i;
340
341     if (n->promisc)
342         return 1;
343
344     if (!memcmp(&ptr[12], vlan, sizeof(vlan))) {
345         int vid = be16_to_cpup((uint16_t *)(ptr + 14)) & 0xfff;
346         if (!(n->vlans[vid >> 5] & (1U << (vid & 0x1f))))
347             return 0;
348     }
349
350     if ((ptr[0] & 1) && n->allmulti)
351         return 1;
352
353     if (!memcmp(ptr, bcast, sizeof(bcast)))
354         return 1;
355
356     if (!memcmp(ptr, n->mac, ETH_ALEN))
357         return 1;
358
359     for (i = 0; i < n->mac_table.in_use; i++) {
360         if (!memcmp(ptr, &n->mac_table.macs[i * ETH_ALEN], ETH_ALEN))
361             return 1;
362     }
363
364     return 0;
365 }
366
367 static ssize_t virtio_net_receive(VLANClientState *vc, const uint8_t *buf, size_t size)
368 {
369     VirtIONet *n = vc->opaque;
370     struct virtio_net_hdr_mrg_rxbuf *mhdr = NULL;
371     size_t hdr_len, offset, i;
372
373     if (!do_virtio_net_can_receive(n, size))
374         return 0;
375
376     if (!receive_filter(n, buf, size))
377         return size;
378
379     /* hdr_len refers to the header we supply to the guest */
380     hdr_len = n->mergeable_rx_bufs ?
381         sizeof(struct virtio_net_hdr_mrg_rxbuf) : sizeof(struct virtio_net_hdr);
382
383     offset = i = 0;
384
385     while (offset < size) {
386         VirtQueueElement elem;
387         int len, total;
388         struct iovec sg[VIRTQUEUE_MAX_SIZE];
389
390         len = total = 0;
391
392         if ((i != 0 && !n->mergeable_rx_bufs) ||
393             virtqueue_pop(n->rx_vq, &elem) == 0) {
394             if (i == 0)
395                 return -1;
396             fprintf(stderr, "virtio-net truncating packet\n");
397             exit(1);
398         }
399
400         if (elem.in_num < 1) {
401             fprintf(stderr, "virtio-net receive queue contains no in buffers\n");
402             exit(1);
403         }
404
405         if (!n->mergeable_rx_bufs && elem.in_sg[0].iov_len != hdr_len) {
406             fprintf(stderr, "virtio-net header not in first element\n");
407             exit(1);
408         }
409
410         memcpy(&sg, &elem.in_sg[0], sizeof(sg[0]) * elem.in_num);
411
412         if (i == 0) {
413             if (n->mergeable_rx_bufs)
414                 mhdr = (struct virtio_net_hdr_mrg_rxbuf *)sg[0].iov_base;
415
416             offset += receive_header(n, sg, elem.in_num,
417                                      buf + offset, size - offset, hdr_len);
418             total += hdr_len;
419         }
420
421         /* copy in packet.  ugh */
422         len = iov_fill(sg, elem.in_num,
423                        buf + offset, size - offset);
424         total += len;
425
426         /* signal other side */
427         virtqueue_fill(n->rx_vq, &elem, total, i++);
428
429         offset += len;
430     }
431
432     if (mhdr)
433         mhdr->num_buffers = i;
434
435     virtqueue_flush(n->rx_vq, i);
436     virtio_notify(&n->vdev, n->rx_vq);
437
438     return size;
439 }
440
441 /* TX */
442 static void virtio_net_flush_tx(VirtIONet *n, VirtQueue *vq)
443 {
444     VirtQueueElement elem;
445     int has_vnet_hdr = 0;
446
447     if (!(n->vdev.status & VIRTIO_CONFIG_S_DRIVER_OK))
448         return;
449
450     while (virtqueue_pop(vq, &elem)) {
451         ssize_t len = 0;
452         unsigned int out_num = elem.out_num;
453         struct iovec *out_sg = &elem.out_sg[0];
454         unsigned hdr_len;
455
456         /* hdr_len refers to the header received from the guest */
457         hdr_len = n->mergeable_rx_bufs ?
458             sizeof(struct virtio_net_hdr_mrg_rxbuf) :
459             sizeof(struct virtio_net_hdr);
460
461         if (out_num < 1 || out_sg->iov_len != hdr_len) {
462             fprintf(stderr, "virtio-net header not in first element\n");
463             exit(1);
464         }
465
466         /* ignore the header if GSO is not supported */
467         if (!has_vnet_hdr) {
468             out_num--;
469             out_sg++;
470             len += hdr_len;
471         } else if (n->mergeable_rx_bufs) {
472             /* tapfd expects a struct virtio_net_hdr */
473             hdr_len -= sizeof(struct virtio_net_hdr);
474             out_sg->iov_len -= hdr_len;
475             len += hdr_len;
476         }
477
478         len += qemu_sendv_packet(n->vc, out_sg, out_num);
479
480         virtqueue_push(vq, &elem, len);
481         virtio_notify(&n->vdev, vq);
482     }
483 }
484
485 static void virtio_net_handle_tx(VirtIODevice *vdev, VirtQueue *vq)
486 {
487     VirtIONet *n = to_virtio_net(vdev);
488
489     if (n->tx_timer_active) {
490         virtio_queue_set_notification(vq, 1);
491         qemu_del_timer(n->tx_timer);
492         n->tx_timer_active = 0;
493         virtio_net_flush_tx(n, vq);
494     } else {
495         qemu_mod_timer(n->tx_timer,
496                        qemu_get_clock(vm_clock) + TX_TIMER_INTERVAL);
497         n->tx_timer_active = 1;
498         virtio_queue_set_notification(vq, 0);
499     }
500 }
501
502 static void virtio_net_tx_timer(void *opaque)
503 {
504     VirtIONet *n = opaque;
505
506     n->tx_timer_active = 0;
507
508     /* Just in case the driver is not ready on more */
509     if (!(n->vdev.status & VIRTIO_CONFIG_S_DRIVER_OK))
510         return;
511
512     virtio_queue_set_notification(n->tx_vq, 1);
513     virtio_net_flush_tx(n, n->tx_vq);
514 }
515
516 static void virtio_net_save(QEMUFile *f, void *opaque)
517 {
518     VirtIONet *n = opaque;
519
520     virtio_save(&n->vdev, f);
521
522     qemu_put_buffer(f, n->mac, ETH_ALEN);
523     qemu_put_be32(f, n->tx_timer_active);
524     qemu_put_be32(f, n->mergeable_rx_bufs);
525     qemu_put_be16(f, n->status);
526     qemu_put_byte(f, n->promisc);
527     qemu_put_byte(f, n->allmulti);
528     qemu_put_be32(f, n->mac_table.in_use);
529     qemu_put_buffer(f, n->mac_table.macs, n->mac_table.in_use * ETH_ALEN);
530     qemu_put_buffer(f, (uint8_t *)n->vlans, MAX_VLAN >> 3);
531     qemu_put_be32(f, 0); /* vnet-hdr placeholder */
532 }
533
534 static int virtio_net_load(QEMUFile *f, void *opaque, int version_id)
535 {
536     VirtIONet *n = opaque;
537
538     if (version_id < 2 || version_id > VIRTIO_NET_VM_VERSION)
539         return -EINVAL;
540
541     virtio_load(&n->vdev, f);
542
543     qemu_get_buffer(f, n->mac, ETH_ALEN);
544     n->tx_timer_active = qemu_get_be32(f);
545     n->mergeable_rx_bufs = qemu_get_be32(f);
546
547     if (version_id >= 3)
548         n->status = qemu_get_be16(f);
549
550     if (version_id >= 4) {
551         if (version_id < 8) {
552             n->promisc = qemu_get_be32(f);
553             n->allmulti = qemu_get_be32(f);
554         } else {
555             n->promisc = qemu_get_byte(f);
556             n->allmulti = qemu_get_byte(f);
557         }
558     }
559
560     if (version_id >= 5) {
561         n->mac_table.in_use = qemu_get_be32(f);
562         /* MAC_TABLE_ENTRIES may be different from the saved image */
563         if (n->mac_table.in_use <= MAC_TABLE_ENTRIES) {
564             qemu_get_buffer(f, n->mac_table.macs,
565                             n->mac_table.in_use * ETH_ALEN);
566         } else if (n->mac_table.in_use) {
567             qemu_fseek(f, n->mac_table.in_use * ETH_ALEN, SEEK_CUR);
568             n->promisc = 1;
569             n->mac_table.in_use = 0;
570         }
571     }
572  
573     if (version_id >= 6)
574         qemu_get_buffer(f, (uint8_t *)n->vlans, MAX_VLAN >> 3);
575
576     if (version_id >= 7 && qemu_get_be32(f)) {
577         fprintf(stderr,
578                 "virtio-net: saved image requires vnet header support\n");
579         exit(1);
580     }
581
582     if (n->tx_timer_active) {
583         qemu_mod_timer(n->tx_timer,
584                        qemu_get_clock(vm_clock) + TX_TIMER_INTERVAL);
585     }
586
587     return 0;
588 }
589
590 static void virtio_net_cleanup(VLANClientState *vc)
591 {
592     VirtIONet *n = vc->opaque;
593
594     unregister_savevm("virtio-net", n);
595
596     qemu_free(n->mac_table.macs);
597     qemu_free(n->vlans);
598
599     qemu_del_timer(n->tx_timer);
600     qemu_free_timer(n->tx_timer);
601
602     virtio_cleanup(&n->vdev);
603 }
604
605 VirtIODevice *virtio_net_init(DeviceState *dev)
606 {
607     VirtIONet *n;
608     static int virtio_net_id;
609
610     n = (VirtIONet *)virtio_common_init("virtio-net", VIRTIO_ID_NET,
611                                         sizeof(struct virtio_net_config),
612                                         sizeof(VirtIONet));
613
614     n->vdev.get_config = virtio_net_get_config;
615     n->vdev.set_config = virtio_net_set_config;
616     n->vdev.get_features = virtio_net_get_features;
617     n->vdev.set_features = virtio_net_set_features;
618     n->vdev.bad_features = virtio_net_bad_features;
619     n->vdev.reset = virtio_net_reset;
620     n->rx_vq = virtio_add_queue(&n->vdev, 256, virtio_net_handle_rx);
621     n->tx_vq = virtio_add_queue(&n->vdev, 256, virtio_net_handle_tx);
622     n->ctrl_vq = virtio_add_queue(&n->vdev, 16, virtio_net_handle_ctrl);
623     qdev_get_macaddr(dev, n->mac);
624     n->status = VIRTIO_NET_S_LINK_UP;
625     n->vc = qdev_get_vlan_client(dev,
626                                  virtio_net_can_receive,
627                                  virtio_net_receive, NULL,
628                                  virtio_net_cleanup, n);
629     n->vc->link_status_changed = virtio_net_set_link_status;
630
631     qemu_format_nic_info_str(n->vc, n->mac);
632
633     n->tx_timer = qemu_new_timer(vm_clock, virtio_net_tx_timer, n);
634     n->tx_timer_active = 0;
635     n->mergeable_rx_bufs = 0;
636     n->promisc = 1; /* for compatibility */
637
638     n->mac_table.macs = qemu_mallocz(MAC_TABLE_ENTRIES * ETH_ALEN);
639
640     n->vlans = qemu_mallocz(MAX_VLAN >> 3);
641
642     register_savevm("virtio-net", virtio_net_id++, VIRTIO_NET_VM_VERSION,
643                     virtio_net_save, virtio_net_load, n);
644
645     return &n->vdev;
646 }