Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 1 | /* |
| 2 | *------------------------------------------------------------------ |
| 3 | * Copyright (c) 2016 Cisco and/or its affiliates. |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at: |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | *------------------------------------------------------------------ |
| 16 | */ |
| 17 | |
| 18 | #include <sys/types.h> |
| 19 | #include <sys/stat.h> |
| 20 | #include <fcntl.h> |
| 21 | #include <net/if.h> |
| 22 | #include <linux/if_tun.h> |
| 23 | #include <sys/ioctl.h> |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 24 | #include <sys/eventfd.h> |
| 25 | |
| 26 | #include <vlib/vlib.h> |
| 27 | #include <vlib/unix/unix.h> |
| 28 | #include <vnet/ethernet/ethernet.h> |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 29 | #include <vnet/feature/feature.h> |
Mohsin Kazmi | 9e2a785 | 2020-08-13 18:57:26 +0200 | [diff] [blame] | 30 | #include <vnet/gso/gro_func.h> |
Damjan Marion | 9410053 | 2020-11-06 23:25:57 +0100 | [diff] [blame] | 31 | #include <vnet/interface/rx_queue_funcs.h> |
Milan Lenco | 73e7f42 | 2017-12-14 10:04:25 +0100 | [diff] [blame] | 32 | #include <vnet/ip/ip4_packet.h> |
| 33 | #include <vnet/ip/ip6_packet.h> |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 34 | #include <vnet/udp/udp_packet.h> |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 35 | #include <vnet/devices/virtio/virtio.h> |
| 36 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 37 | #define foreach_virtio_input_error \ |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 38 | _(BUFFER_ALLOC, "buffer alloc error") \ |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 39 | _(UNKNOWN, "unknown") |
| 40 | |
| 41 | typedef enum |
| 42 | { |
Mohsin Kazmi | ddd2183 | 2019-01-22 13:05:00 +0000 | [diff] [blame] | 43 | #define _(f,s) VIRTIO_INPUT_ERROR_##f, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 44 | foreach_virtio_input_error |
| 45 | #undef _ |
Mohsin Kazmi | ddd2183 | 2019-01-22 13:05:00 +0000 | [diff] [blame] | 46 | VIRTIO_INPUT_N_ERROR, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 47 | } virtio_input_error_t; |
| 48 | |
| 49 | static char *virtio_input_error_strings[] = { |
| 50 | #define _(n,s) s, |
| 51 | foreach_virtio_input_error |
| 52 | #undef _ |
| 53 | }; |
| 54 | |
| 55 | typedef struct |
| 56 | { |
| 57 | u32 next_index; |
| 58 | u32 hw_if_index; |
| 59 | u16 ring; |
| 60 | u16 len; |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 61 | virtio_net_hdr_v1_t hdr; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 62 | } virtio_input_trace_t; |
| 63 | |
| 64 | static u8 * |
| 65 | format_virtio_input_trace (u8 * s, va_list * args) |
| 66 | { |
| 67 | CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *); |
| 68 | CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *); |
| 69 | virtio_input_trace_t *t = va_arg (*args, virtio_input_trace_t *); |
| 70 | u32 indent = format_get_indent (s); |
| 71 | |
| 72 | s = format (s, "virtio: hw_if_index %d next-index %d vring %u len %u", |
| 73 | t->hw_if_index, t->next_index, t->ring, t->len); |
| 74 | s = format (s, "\n%Uhdr: flags 0x%02x gso_type 0x%02x hdr_len %u " |
| 75 | "gso_size %u csum_start %u csum_offset %u num_buffers %u", |
| 76 | format_white_space, indent + 2, |
| 77 | t->hdr.flags, t->hdr.gso_type, t->hdr.hdr_len, t->hdr.gso_size, |
| 78 | t->hdr.csum_start, t->hdr.csum_offset, t->hdr.num_buffers); |
| 79 | return s; |
| 80 | } |
| 81 | |
| 82 | static_always_inline void |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 83 | virtio_refill_vring_split (vlib_main_t * vm, virtio_if_t * vif, |
| 84 | virtio_if_type_t type, virtio_vring_t * vring, |
| 85 | const int hdr_sz, u32 node_index) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 86 | { |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 87 | u16 used, next, avail, n_slots, n_refill; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 88 | u16 sz = vring->size; |
| 89 | u16 mask = sz - 1; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 90 | |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 91 | more: |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 92 | used = vring->desc_in_use; |
| 93 | |
| 94 | if (sz - used < sz / 8) |
| 95 | return; |
| 96 | |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 97 | /* deliver free buffers in chunks of 64 */ |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 98 | n_refill = clib_min (sz - used, 64); |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 99 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 100 | next = vring->desc_next; |
| 101 | avail = vring->avail->idx; |
Mohsin Kazmi | 80659b4 | 2019-01-31 13:18:00 +0000 | [diff] [blame] | 102 | n_slots = |
| 103 | vlib_buffer_alloc_to_ring_from_pool (vm, vring->buffers, next, |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 104 | vring->size, n_refill, |
Mohsin Kazmi | 80659b4 | 2019-01-31 13:18:00 +0000 | [diff] [blame] | 105 | vring->buffer_pool_index); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 106 | |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 107 | if (PREDICT_FALSE (n_slots != n_refill)) |
| 108 | { |
| 109 | vlib_error_count (vm, node_index, |
| 110 | VIRTIO_INPUT_ERROR_BUFFER_ALLOC, n_refill - n_slots); |
| 111 | if (n_slots == 0) |
| 112 | return; |
| 113 | } |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 114 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 115 | while (n_slots) |
| 116 | { |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 117 | vring_desc_t *d = &vring->desc[next];; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 118 | vlib_buffer_t *b = vlib_get_buffer (vm, vring->buffers[next]); |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 119 | /* |
| 120 | * current_data may not be initialized with 0 and may contain |
| 121 | * previous offset. Here we want to make sure, it should be 0 |
| 122 | * initialized. |
| 123 | */ |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 124 | b->current_data = -hdr_sz; |
Mohsin Kazmi | 8f01084 | 2020-12-10 10:22:34 +0000 | [diff] [blame] | 125 | clib_memset (vlib_buffer_get_current (b), 0, hdr_sz); |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 126 | d->addr = |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 127 | ((type == VIRTIO_IF_TYPE_PCI) ? vlib_buffer_get_current_pa (vm, |
| 128 | b) : |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 129 | pointer_to_uword (vlib_buffer_get_current (b))); |
Damjan Marion | 8934a04 | 2019-02-09 23:29:26 +0100 | [diff] [blame] | 130 | d->len = vlib_buffer_get_default_data_size (vm) + hdr_sz; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 131 | d->flags = VRING_DESC_F_WRITE; |
| 132 | vring->avail->ring[avail & mask] = next; |
| 133 | avail++; |
| 134 | next = (next + 1) & mask; |
| 135 | n_slots--; |
| 136 | used++; |
| 137 | } |
Mohsin Kazmi | d8b7dec | 2020-12-10 09:49:21 +0000 | [diff] [blame] | 138 | clib_atomic_store_seq_cst (&vring->avail->idx, avail); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 139 | vring->desc_next = next; |
| 140 | vring->desc_in_use = used; |
Mohsin Kazmi | d8b7dec | 2020-12-10 09:49:21 +0000 | [diff] [blame] | 141 | if ((clib_atomic_load_seq_cst (&vring->used->flags) & |
| 142 | VRING_USED_F_NO_NOTIFY) == 0) |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 143 | { |
| 144 | virtio_kick (vm, vring, vif); |
| 145 | } |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 146 | goto more; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 147 | } |
| 148 | |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 149 | static_always_inline void |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 150 | virtio_refill_vring_packed (vlib_main_t * vm, virtio_if_t * vif, |
| 151 | virtio_if_type_t type, virtio_vring_t * vring, |
| 152 | const int hdr_sz, u32 node_index) |
| 153 | { |
| 154 | u16 used, next, n_slots, n_refill, flags = 0, first_desc_flags; |
| 155 | u16 sz = vring->size; |
| 156 | |
| 157 | more: |
| 158 | used = vring->desc_in_use; |
| 159 | |
| 160 | if (sz == used) |
| 161 | return; |
| 162 | |
| 163 | /* deliver free buffers in chunks of 64 */ |
| 164 | n_refill = clib_min (sz - used, 64); |
| 165 | |
| 166 | next = vring->desc_next; |
| 167 | first_desc_flags = vring->packed_desc[next].flags; |
| 168 | n_slots = |
| 169 | vlib_buffer_alloc_to_ring_from_pool (vm, vring->buffers, next, |
| 170 | sz, n_refill, |
| 171 | vring->buffer_pool_index); |
| 172 | |
| 173 | if (PREDICT_FALSE (n_slots != n_refill)) |
| 174 | { |
| 175 | vlib_error_count (vm, node_index, |
| 176 | VIRTIO_INPUT_ERROR_BUFFER_ALLOC, n_refill - n_slots); |
| 177 | if (n_slots == 0) |
| 178 | return; |
| 179 | } |
| 180 | |
| 181 | while (n_slots) |
| 182 | { |
| 183 | vring_packed_desc_t *d = &vring->packed_desc[next]; |
| 184 | vlib_buffer_t *b = vlib_get_buffer (vm, vring->buffers[next]); |
| 185 | /* |
| 186 | * current_data may not be initialized with 0 and may contain |
| 187 | * previous offset. Here we want to make sure, it should be 0 |
| 188 | * initialized. |
| 189 | */ |
| 190 | b->current_data = -hdr_sz; |
Mohsin Kazmi | 8f01084 | 2020-12-10 10:22:34 +0000 | [diff] [blame] | 191 | clib_memset (vlib_buffer_get_current (b), 0, hdr_sz); |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 192 | d->addr = |
| 193 | ((type == VIRTIO_IF_TYPE_PCI) ? vlib_buffer_get_current_pa (vm, |
| 194 | b) : |
| 195 | pointer_to_uword (vlib_buffer_get_current (b))); |
| 196 | d->len = vlib_buffer_get_default_data_size (vm) + hdr_sz; |
| 197 | |
| 198 | if (vring->avail_wrap_counter) |
| 199 | flags = (VRING_DESC_F_AVAIL | VRING_DESC_F_WRITE); |
| 200 | else |
| 201 | flags = (VRING_DESC_F_USED | VRING_DESC_F_WRITE); |
| 202 | |
| 203 | d->id = next; |
| 204 | if (vring->desc_next == next) |
| 205 | first_desc_flags = flags; |
| 206 | else |
| 207 | d->flags = flags; |
| 208 | |
| 209 | next++; |
| 210 | if (next >= sz) |
| 211 | { |
| 212 | next = 0; |
| 213 | vring->avail_wrap_counter ^= 1; |
| 214 | } |
| 215 | n_slots--; |
| 216 | used++; |
| 217 | } |
| 218 | CLIB_MEMORY_STORE_BARRIER (); |
| 219 | vring->packed_desc[vring->desc_next].flags = first_desc_flags; |
| 220 | vring->desc_next = next; |
| 221 | vring->desc_in_use = used; |
| 222 | CLIB_MEMORY_BARRIER (); |
| 223 | if (vring->device_event->flags != VRING_EVENT_F_DISABLE) |
| 224 | { |
| 225 | virtio_kick (vm, vring, vif); |
| 226 | } |
| 227 | |
| 228 | goto more; |
| 229 | } |
| 230 | |
| 231 | static_always_inline void |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 232 | virtio_needs_csum (vlib_buffer_t * b0, virtio_net_hdr_v1_t * hdr, |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 233 | u8 * l4_proto, u8 * l4_hdr_sz, virtio_if_type_t type) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 234 | { |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 235 | if (hdr->flags & VIRTIO_NET_HDR_F_NEEDS_CSUM) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 236 | { |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 237 | u16 ethertype = 0, l2hdr_sz = 0; |
Mohsin Kazmi | 6809538 | 2021-02-10 11:26:24 +0100 | [diff] [blame] | 238 | u32 oflags = 0; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 239 | |
| 240 | if (type == VIRTIO_IF_TYPE_TUN) |
| 241 | { |
| 242 | switch (b0->data[0] & 0xf0) |
| 243 | { |
| 244 | case 0x40: |
| 245 | ethertype = ETHERNET_TYPE_IP4; |
| 246 | break; |
| 247 | case 0x60: |
| 248 | ethertype = ETHERNET_TYPE_IP6; |
| 249 | break; |
| 250 | } |
| 251 | } |
| 252 | else |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 253 | { |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 254 | ethernet_header_t *eh = |
| 255 | (ethernet_header_t *) vlib_buffer_get_current (b0); |
| 256 | ethertype = clib_net_to_host_u16 (eh->type); |
| 257 | l2hdr_sz = sizeof (ethernet_header_t); |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 258 | |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 259 | if (ethernet_frame_is_tagged (ethertype)) |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 260 | { |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 261 | ethernet_vlan_header_t *vlan = |
| 262 | (ethernet_vlan_header_t *) (eh + 1); |
| 263 | |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 264 | ethertype = clib_net_to_host_u16 (vlan->type); |
| 265 | l2hdr_sz += sizeof (*vlan); |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 266 | if (ethertype == ETHERNET_TYPE_VLAN) |
| 267 | { |
| 268 | vlan++; |
| 269 | ethertype = clib_net_to_host_u16 (vlan->type); |
| 270 | l2hdr_sz += sizeof (*vlan); |
| 271 | } |
| 272 | } |
| 273 | } |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 274 | |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 275 | vnet_buffer (b0)->l2_hdr_offset = 0; |
| 276 | vnet_buffer (b0)->l3_hdr_offset = l2hdr_sz; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 277 | |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 278 | if (PREDICT_TRUE (ethertype == ETHERNET_TYPE_IP4)) |
| 279 | { |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 280 | ip4_header_t *ip4 = |
| 281 | (ip4_header_t *) (vlib_buffer_get_current (b0) + l2hdr_sz); |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 282 | vnet_buffer (b0)->l4_hdr_offset = l2hdr_sz + ip4_header_bytes (ip4); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 283 | *l4_proto = ip4->protocol; |
Mohsin Kazmi | 6809538 | 2021-02-10 11:26:24 +0100 | [diff] [blame] | 284 | oflags |= VNET_BUFFER_OFFLOAD_F_IP_CKSUM; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 285 | b0->flags |= |
Mohsin Kazmi | 6809538 | 2021-02-10 11:26:24 +0100 | [diff] [blame] | 286 | (VNET_BUFFER_F_IS_IP4 | VNET_BUFFER_F_L2_HDR_OFFSET_VALID | |
| 287 | VNET_BUFFER_F_L3_HDR_OFFSET_VALID | |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 288 | VNET_BUFFER_F_L4_HDR_OFFSET_VALID); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 289 | } |
| 290 | else if (PREDICT_TRUE (ethertype == ETHERNET_TYPE_IP6)) |
| 291 | { |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 292 | ip6_header_t *ip6 = |
| 293 | (ip6_header_t *) (vlib_buffer_get_current (b0) + l2hdr_sz); |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 294 | vnet_buffer (b0)->l4_hdr_offset = l2hdr_sz + sizeof (ip6_header_t); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 295 | /* FIXME IPv6 EH traversal */ |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 296 | *l4_proto = ip6->protocol; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 297 | b0->flags |= (VNET_BUFFER_F_IS_IP6 | |
| 298 | VNET_BUFFER_F_L2_HDR_OFFSET_VALID |
| 299 | | VNET_BUFFER_F_L3_HDR_OFFSET_VALID | |
| 300 | VNET_BUFFER_F_L4_HDR_OFFSET_VALID); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 301 | } |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 302 | if (*l4_proto == IP_PROTOCOL_TCP) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 303 | { |
Mohsin Kazmi | 6809538 | 2021-02-10 11:26:24 +0100 | [diff] [blame] | 304 | oflags |= VNET_BUFFER_OFFLOAD_F_TCP_CKSUM; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 305 | tcp_header_t *tcp = (tcp_header_t *) (vlib_buffer_get_current (b0) + |
| 306 | vnet_buffer |
| 307 | (b0)->l4_hdr_offset); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 308 | *l4_hdr_sz = tcp_header_bytes (tcp); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 309 | } |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 310 | else if (*l4_proto == IP_PROTOCOL_UDP) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 311 | { |
Mohsin Kazmi | 6809538 | 2021-02-10 11:26:24 +0100 | [diff] [blame] | 312 | oflags |= VNET_BUFFER_OFFLOAD_F_UDP_CKSUM; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 313 | udp_header_t *udp = (udp_header_t *) (vlib_buffer_get_current (b0) + |
| 314 | vnet_buffer |
| 315 | (b0)->l4_hdr_offset); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 316 | *l4_hdr_sz = sizeof (*udp); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 317 | } |
Mohsin Kazmi | 6809538 | 2021-02-10 11:26:24 +0100 | [diff] [blame] | 318 | if (oflags) |
| 319 | vnet_buffer_offload_flags_set (b0, oflags); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 320 | } |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 321 | } |
| 322 | |
| 323 | static_always_inline void |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 324 | fill_gso_buffer_flags (vlib_buffer_t * b0, virtio_net_hdr_v1_t * hdr, |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 325 | u8 l4_proto, u8 l4_hdr_sz) |
| 326 | { |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 327 | if (hdr->gso_type == VIRTIO_NET_HDR_GSO_TCPV4) |
| 328 | { |
| 329 | ASSERT (hdr->flags & VIRTIO_NET_HDR_F_NEEDS_CSUM); |
| 330 | vnet_buffer2 (b0)->gso_size = hdr->gso_size; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 331 | vnet_buffer2 (b0)->gso_l4_hdr_sz = l4_hdr_sz; |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 332 | b0->flags |= VNET_BUFFER_F_GSO | VNET_BUFFER_F_IS_IP4; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 333 | } |
| 334 | if (hdr->gso_type == VIRTIO_NET_HDR_GSO_TCPV6) |
| 335 | { |
| 336 | ASSERT (hdr->flags & VIRTIO_NET_HDR_F_NEEDS_CSUM); |
| 337 | vnet_buffer2 (b0)->gso_size = hdr->gso_size; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 338 | vnet_buffer2 (b0)->gso_l4_hdr_sz = l4_hdr_sz; |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 339 | b0->flags |= VNET_BUFFER_F_GSO | VNET_BUFFER_F_IS_IP6; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 340 | } |
| 341 | } |
| 342 | |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 343 | static_always_inline u16 |
| 344 | virtio_n_left_to_process (virtio_vring_t * vring, const int packed) |
| 345 | { |
| 346 | if (packed) |
| 347 | return vring->desc_in_use; |
| 348 | else |
| 349 | return vring->used->idx - vring->last_used_idx; |
| 350 | } |
| 351 | |
| 352 | static_always_inline u16 |
| 353 | virtio_get_slot_id (virtio_vring_t * vring, const int packed, u16 last, |
| 354 | u16 mask) |
| 355 | { |
| 356 | if (packed) |
| 357 | return vring->packed_desc[last].id; |
| 358 | else |
| 359 | return vring->used->ring[last & mask].id; |
| 360 | } |
| 361 | |
| 362 | static_always_inline u16 |
| 363 | virtio_get_len (virtio_vring_t * vring, const int packed, const int hdr_sz, |
| 364 | u16 last, u16 mask) |
| 365 | { |
| 366 | if (packed) |
| 367 | return vring->packed_desc[last].len - hdr_sz; |
| 368 | else |
| 369 | return vring->used->ring[last & mask].len - hdr_sz; |
| 370 | } |
| 371 | |
| 372 | #define increment_last(last, packed, vring) \ |
| 373 | do { \ |
| 374 | last++; \ |
| 375 | if (packed && last >= vring->size) \ |
| 376 | { \ |
| 377 | last = 0; \ |
| 378 | vring->used_wrap_counter ^= 1; \ |
| 379 | } \ |
| 380 | } while (0) |
| 381 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 382 | static_always_inline uword |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 383 | virtio_device_input_gso_inline (vlib_main_t * vm, vlib_node_runtime_t * node, |
| 384 | vlib_frame_t * frame, virtio_if_t * vif, |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 385 | virtio_vring_t * vring, virtio_if_type_t type, |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 386 | int gso_enabled, int checksum_offload_enabled, |
| 387 | int packed) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 388 | { |
| 389 | vnet_main_t *vnm = vnet_get_main (); |
Damjan Marion | 067cd62 | 2018-07-11 12:47:43 +0200 | [diff] [blame] | 390 | u32 thread_index = vm->thread_index; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 391 | uword n_trace = vlib_get_trace_count (vm, node); |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 392 | u32 next_index; |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 393 | const int hdr_sz = vif->virtio_net_hdr_sz; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 394 | u32 *to_next = 0; |
| 395 | u32 n_rx_packets = 0; |
| 396 | u32 n_rx_bytes = 0; |
| 397 | u16 mask = vring->size - 1; |
| 398 | u16 last = vring->last_used_idx; |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 399 | u16 n_left = virtio_n_left_to_process (vring, packed); |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 400 | vlib_buffer_t bt; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 401 | |
| 402 | if (n_left == 0) |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 403 | return 0; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 404 | |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 405 | if (type == VIRTIO_IF_TYPE_TUN) |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 406 | { |
| 407 | next_index = VNET_DEVICE_INPUT_NEXT_IP4_INPUT; |
| 408 | } |
| 409 | else |
| 410 | { |
| 411 | next_index = VNET_DEVICE_INPUT_NEXT_ETHERNET_INPUT; |
| 412 | if (PREDICT_FALSE (vif->per_interface_next_index != ~0)) |
| 413 | next_index = vif->per_interface_next_index; |
| 414 | |
| 415 | /* only for l2, redirect if feature path enabled */ |
| 416 | vnet_feature_start_device_input_x1 (vif->sw_if_index, &next_index, &bt); |
| 417 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 418 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 419 | while (n_left) |
| 420 | { |
| 421 | u32 n_left_to_next; |
| 422 | u32 next0 = next_index; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 423 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 424 | vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next); |
| 425 | |
| 426 | while (n_left && n_left_to_next) |
| 427 | { |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 428 | if (packed) |
| 429 | { |
| 430 | vring_packed_desc_t *d = &vring->packed_desc[last]; |
| 431 | u16 flags = d->flags; |
| 432 | if ((flags & VRING_DESC_F_AVAIL) != |
| 433 | (vring->used_wrap_counter << 7) |
| 434 | || (flags & VRING_DESC_F_USED) != |
| 435 | (vring->used_wrap_counter << 15)) |
| 436 | { |
| 437 | n_left = 0; |
| 438 | break; |
| 439 | } |
| 440 | } |
Mohsin Kazmi | 516e4ed | 2020-02-24 15:54:24 +0100 | [diff] [blame] | 441 | u8 l4_proto = 0, l4_hdr_sz = 0; |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 442 | u16 num_buffers = 1; |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 443 | virtio_net_hdr_v1_t *hdr; |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 444 | u16 slot = virtio_get_slot_id (vring, packed, last, mask); |
| 445 | u16 len = virtio_get_len (vring, packed, hdr_sz, last, mask); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 446 | u32 bi0 = vring->buffers[slot]; |
| 447 | vlib_buffer_t *b0 = vlib_get_buffer (vm, bi0); |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 448 | hdr = vlib_buffer_get_current (b0); |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 449 | if (hdr_sz == sizeof (virtio_net_hdr_v1_t)) |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 450 | num_buffers = hdr->num_buffers; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 451 | |
Mohsin Kazmi | 8975dbd | 2020-06-24 16:19:19 +0200 | [diff] [blame] | 452 | b0->flags = VLIB_BUFFER_TOTAL_LENGTH_VALID; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 453 | b0->current_data = 0; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 454 | b0->current_length = len; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 455 | |
Mohsin Kazmi | 6d4af89 | 2020-01-03 15:11:53 +0000 | [diff] [blame] | 456 | if (checksum_offload_enabled) |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 457 | virtio_needs_csum (b0, hdr, &l4_proto, &l4_hdr_sz, type); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 458 | |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 459 | if (gso_enabled) |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 460 | fill_gso_buffer_flags (b0, hdr, l4_proto, l4_hdr_sz); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 461 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 462 | vnet_buffer (b0)->sw_if_index[VLIB_RX] = vif->sw_if_index; |
| 463 | vnet_buffer (b0)->sw_if_index[VLIB_TX] = (u32) ~ 0; |
| 464 | |
| 465 | /* if multisegment packet */ |
| 466 | if (PREDICT_FALSE (num_buffers > 1)) |
| 467 | { |
| 468 | vlib_buffer_t *pb, *cb; |
| 469 | pb = b0; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 470 | b0->total_length_not_including_first_buffer = 0; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 471 | while (num_buffers > 1) |
| 472 | { |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 473 | increment_last (last, packed, vring); |
| 474 | u16 cslot = virtio_get_slot_id (vring, packed, last, mask); |
Mohsin Kazmi | a17381a | 2020-12-03 11:35:23 +0100 | [diff] [blame] | 475 | /* hdr size is 0 after 1st packet in chain buffers */ |
| 476 | u16 clen = virtio_get_len (vring, packed, 0, last, mask); |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 477 | u32 cbi = vring->buffers[cslot]; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 478 | cb = vlib_get_buffer (vm, cbi); |
| 479 | |
| 480 | /* current buffer */ |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 481 | cb->current_length = clen; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 482 | |
| 483 | /* previous buffer */ |
| 484 | pb->next_buffer = cbi; |
| 485 | pb->flags |= VLIB_BUFFER_NEXT_PRESENT; |
| 486 | |
| 487 | /* first buffer */ |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 488 | b0->total_length_not_including_first_buffer += clen; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 489 | |
| 490 | pb = cb; |
| 491 | vring->desc_in_use--; |
| 492 | num_buffers--; |
| 493 | n_left--; |
| 494 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 495 | len += b0->total_length_not_including_first_buffer; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 496 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 497 | |
| 498 | if (type == VIRTIO_IF_TYPE_TUN) |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 499 | { |
| 500 | switch (b0->data[0] & 0xf0) |
| 501 | { |
| 502 | case 0x40: |
| 503 | next0 = VNET_DEVICE_INPUT_NEXT_IP4_INPUT; |
| 504 | break; |
| 505 | case 0x60: |
| 506 | next0 = VNET_DEVICE_INPUT_NEXT_IP6_INPUT; |
| 507 | break; |
| 508 | default: |
| 509 | next0 = VNET_DEVICE_INPUT_NEXT_DROP; |
| 510 | break; |
| 511 | } |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 512 | |
| 513 | if (PREDICT_FALSE (vif->per_interface_next_index != ~0)) |
| 514 | next0 = vif->per_interface_next_index; |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 515 | } |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 516 | else |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 517 | { |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 518 | /* copy feature arc data from template */ |
| 519 | b0->current_config_index = bt.current_config_index; |
| 520 | vnet_buffer (b0)->feature_arc_index = |
| 521 | vnet_buffer (&bt)->feature_arc_index; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 522 | } |
Damjan Marion | 06c194d | 2019-11-13 10:12:53 +0100 | [diff] [blame] | 523 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 524 | /* trace */ |
| 525 | VLIB_BUFFER_TRACE_TRAJECTORY_INIT (b0); |
| 526 | |
Benoît Ganne | 9a3973e | 2020-10-02 19:36:57 +0200 | [diff] [blame] | 527 | if (PREDICT_FALSE (n_trace > 0 && vlib_trace_buffer (vm, node, next0, b0, /* follow_chain */ |
| 528 | 1))) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 529 | { |
| 530 | virtio_input_trace_t *tr; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 531 | vlib_set_trace_count (vm, node, --n_trace); |
| 532 | tr = vlib_add_trace (vm, node, b0, sizeof (*tr)); |
| 533 | tr->next_index = next0; |
| 534 | tr->hw_if_index = vif->hw_if_index; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 535 | tr->len = len; |
Dave Barach | 178cf49 | 2018-11-13 16:34:13 -0500 | [diff] [blame] | 536 | clib_memcpy_fast (&tr->hdr, hdr, hdr_sz); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 537 | } |
| 538 | |
| 539 | /* enqueue buffer */ |
| 540 | to_next[0] = bi0; |
| 541 | vring->desc_in_use--; |
| 542 | to_next += 1; |
| 543 | n_left_to_next--; |
| 544 | n_left--; |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 545 | increment_last (last, packed, vring); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 546 | |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 547 | /* only tun interfaces may have different next index */ |
| 548 | if (type == VIRTIO_IF_TYPE_TUN) |
| 549 | vlib_validate_buffer_enqueue_x1 (vm, node, next_index, to_next, |
| 550 | n_left_to_next, bi0, next0); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 551 | |
| 552 | /* next packet */ |
| 553 | n_rx_packets++; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 554 | n_rx_bytes += len; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 555 | } |
| 556 | vlib_put_next_frame (vm, node, next_index, n_left_to_next); |
| 557 | } |
| 558 | vring->last_used_idx = last; |
| 559 | |
| 560 | vlib_increment_combined_counter (vnm->interface_main.combined_sw_if_counters |
| 561 | + VNET_INTERFACE_COUNTER_RX, thread_index, |
Steven Luong | efa119d | 2019-08-30 10:49:44 -0700 | [diff] [blame] | 562 | vif->sw_if_index, n_rx_packets, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 563 | n_rx_bytes); |
| 564 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 565 | return n_rx_packets; |
| 566 | } |
| 567 | |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 568 | static_always_inline uword |
| 569 | virtio_device_input_inline (vlib_main_t * vm, vlib_node_runtime_t * node, |
| 570 | vlib_frame_t * frame, virtio_if_t * vif, u16 qid, |
| 571 | virtio_if_type_t type) |
| 572 | { |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 573 | virtio_vring_t *vring = vec_elt_at_index (vif->rxq_vrings, qid); |
| 574 | const int hdr_sz = vif->virtio_net_hdr_sz; |
| 575 | u16 txq_id = vm->thread_index % vif->num_txqs; |
| 576 | virtio_vring_t *txq_vring = vec_elt_at_index (vif->txq_vrings, txq_id); |
| 577 | uword rv; |
| 578 | |
| 579 | if (clib_spinlock_trylock_if_init (&txq_vring->lockp)) |
| 580 | { |
| 581 | if (vif->packet_coalesce) |
| 582 | vnet_gro_flow_table_schedule_node_on_dispatcher |
| 583 | (vm, txq_vring->flow_table); |
| 584 | else if (vif->packet_buffering) |
| 585 | virtio_vring_buffering_schedule_node_on_dispatcher |
| 586 | (vm, txq_vring->buffering); |
| 587 | clib_spinlock_unlock_if_init (&txq_vring->lockp); |
| 588 | } |
| 589 | |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 590 | if (vif->is_packed) |
| 591 | { |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 592 | if (vif->gso_enabled) |
| 593 | rv = |
| 594 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 595 | 1, 1, 1); |
| 596 | else if (vif->csum_offload_enabled) |
| 597 | rv = |
| 598 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 599 | 0, 1, 1); |
| 600 | else |
| 601 | rv = |
| 602 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 603 | 0, 0, 1); |
| 604 | |
| 605 | virtio_refill_vring_packed (vm, vif, type, vring, hdr_sz, |
| 606 | node->node_index); |
| 607 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 608 | else |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 609 | { |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 610 | if (vif->gso_enabled) |
| 611 | rv = |
| 612 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 613 | 1, 1, 0); |
| 614 | else if (vif->csum_offload_enabled) |
| 615 | rv = |
| 616 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 617 | 0, 1, 0); |
| 618 | else |
| 619 | rv = |
| 620 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 621 | 0, 0, 0); |
| 622 | |
| 623 | virtio_refill_vring_split (vm, vif, type, vring, hdr_sz, |
| 624 | node->node_index); |
| 625 | } |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 626 | return rv; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 627 | } |
| 628 | |
Filip Tehlar | 608996d | 2019-03-04 03:03:13 -0800 | [diff] [blame] | 629 | VLIB_NODE_FN (virtio_input_node) (vlib_main_t * vm, |
| 630 | vlib_node_runtime_t * node, |
| 631 | vlib_frame_t * frame) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 632 | { |
| 633 | u32 n_rx = 0; |
Damjan Marion | 9410053 | 2020-11-06 23:25:57 +0100 | [diff] [blame] | 634 | virtio_main_t *vim = &virtio_main; |
| 635 | vnet_hw_if_rxq_poll_vector_t *p, |
| 636 | *pv = vnet_hw_if_get_rxq_poll_vector (vm, node); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 637 | |
Damjan Marion | 9410053 | 2020-11-06 23:25:57 +0100 | [diff] [blame] | 638 | vec_foreach (p, pv) |
| 639 | { |
| 640 | virtio_if_t *vif; |
| 641 | vif = vec_elt_at_index (vim->interfaces, p->dev_instance); |
| 642 | if (vif->flags & VIRTIO_IF_FLAG_ADMIN_UP) |
| 643 | { |
| 644 | if (vif->type == VIRTIO_IF_TYPE_TAP) |
| 645 | n_rx += virtio_device_input_inline ( |
| 646 | vm, node, frame, vif, p->queue_id, VIRTIO_IF_TYPE_TAP); |
| 647 | else if (vif->type == VIRTIO_IF_TYPE_PCI) |
| 648 | n_rx += virtio_device_input_inline ( |
| 649 | vm, node, frame, vif, p->queue_id, VIRTIO_IF_TYPE_PCI); |
| 650 | else if (vif->type == VIRTIO_IF_TYPE_TUN) |
| 651 | n_rx += virtio_device_input_inline ( |
| 652 | vm, node, frame, vif, p->queue_id, VIRTIO_IF_TYPE_TUN); |
| 653 | } |
| 654 | } |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 655 | |
| 656 | return n_rx; |
| 657 | } |
| 658 | |
| 659 | /* *INDENT-OFF* */ |
| 660 | VLIB_REGISTER_NODE (virtio_input_node) = { |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 661 | .name = "virtio-input", |
| 662 | .sibling_of = "device-input", |
| 663 | .format_trace = format_virtio_input_trace, |
Damjan Marion | 7ca5aaa | 2019-09-24 18:10:49 +0200 | [diff] [blame] | 664 | .flags = VLIB_NODE_FLAG_TRACE_SUPPORTED, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 665 | .type = VLIB_NODE_TYPE_INPUT, |
| 666 | .state = VLIB_NODE_STATE_INTERRUPT, |
Mohsin Kazmi | ddd2183 | 2019-01-22 13:05:00 +0000 | [diff] [blame] | 667 | .n_errors = VIRTIO_INPUT_N_ERROR, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 668 | .error_strings = virtio_input_error_strings, |
| 669 | }; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 670 | /* *INDENT-ON* */ |
| 671 | |
| 672 | /* |
| 673 | * fd.io coding-style-patch-verification: ON |
| 674 | * |
| 675 | * Local Variables: |
| 676 | * eval: (c-set-style "gnu") |
| 677 | * End: |
| 678 | */ |