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> |
| 29 | #include <vnet/devices/devices.h> |
| 30 | #include <vnet/feature/feature.h> |
Mohsin Kazmi | 9e2a785 | 2020-08-13 18:57:26 +0200 | [diff] [blame] | 31 | #include <vnet/gso/gro_func.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 | |
| 37 | |
| 38 | #define foreach_virtio_input_error \ |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 39 | _(BUFFER_ALLOC, "buffer alloc error") \ |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 40 | _(UNKNOWN, "unknown") |
| 41 | |
| 42 | typedef enum |
| 43 | { |
Mohsin Kazmi | ddd2183 | 2019-01-22 13:05:00 +0000 | [diff] [blame] | 44 | #define _(f,s) VIRTIO_INPUT_ERROR_##f, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 45 | foreach_virtio_input_error |
| 46 | #undef _ |
Mohsin Kazmi | ddd2183 | 2019-01-22 13:05:00 +0000 | [diff] [blame] | 47 | VIRTIO_INPUT_N_ERROR, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 48 | } virtio_input_error_t; |
| 49 | |
| 50 | static char *virtio_input_error_strings[] = { |
| 51 | #define _(n,s) s, |
| 52 | foreach_virtio_input_error |
| 53 | #undef _ |
| 54 | }; |
| 55 | |
| 56 | typedef struct |
| 57 | { |
| 58 | u32 next_index; |
| 59 | u32 hw_if_index; |
| 60 | u16 ring; |
| 61 | u16 len; |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 62 | virtio_net_hdr_v1_t hdr; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 63 | } virtio_input_trace_t; |
| 64 | |
| 65 | static u8 * |
| 66 | format_virtio_input_trace (u8 * s, va_list * args) |
| 67 | { |
| 68 | CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *); |
| 69 | CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *); |
| 70 | virtio_input_trace_t *t = va_arg (*args, virtio_input_trace_t *); |
| 71 | u32 indent = format_get_indent (s); |
| 72 | |
| 73 | s = format (s, "virtio: hw_if_index %d next-index %d vring %u len %u", |
| 74 | t->hw_if_index, t->next_index, t->ring, t->len); |
| 75 | s = format (s, "\n%Uhdr: flags 0x%02x gso_type 0x%02x hdr_len %u " |
| 76 | "gso_size %u csum_start %u csum_offset %u num_buffers %u", |
| 77 | format_white_space, indent + 2, |
| 78 | t->hdr.flags, t->hdr.gso_type, t->hdr.hdr_len, t->hdr.gso_size, |
| 79 | t->hdr.csum_start, t->hdr.csum_offset, t->hdr.num_buffers); |
| 80 | return s; |
| 81 | } |
| 82 | |
| 83 | static_always_inline void |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 84 | virtio_refill_vring_split (vlib_main_t * vm, virtio_if_t * vif, |
| 85 | virtio_if_type_t type, virtio_vring_t * vring, |
| 86 | const int hdr_sz, u32 node_index) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 87 | { |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 88 | u16 used, next, avail, n_slots, n_refill; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 89 | u16 sz = vring->size; |
| 90 | u16 mask = sz - 1; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 91 | |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 92 | more: |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 93 | used = vring->desc_in_use; |
| 94 | |
| 95 | if (sz - used < sz / 8) |
| 96 | return; |
| 97 | |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 98 | /* deliver free buffers in chunks of 64 */ |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 99 | n_refill = clib_min (sz - used, 64); |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 100 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 101 | next = vring->desc_next; |
| 102 | avail = vring->avail->idx; |
Mohsin Kazmi | 80659b4 | 2019-01-31 13:18:00 +0000 | [diff] [blame] | 103 | n_slots = |
| 104 | vlib_buffer_alloc_to_ring_from_pool (vm, vring->buffers, next, |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 105 | vring->size, n_refill, |
Mohsin Kazmi | 80659b4 | 2019-01-31 13:18:00 +0000 | [diff] [blame] | 106 | vring->buffer_pool_index); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 107 | |
Mohsin Kazmi | 543ed86 | 2020-07-22 17:15:10 +0200 | [diff] [blame] | 108 | if (PREDICT_FALSE (n_slots != n_refill)) |
| 109 | { |
| 110 | vlib_error_count (vm, node_index, |
| 111 | VIRTIO_INPUT_ERROR_BUFFER_ALLOC, n_refill - n_slots); |
| 112 | if (n_slots == 0) |
| 113 | return; |
| 114 | } |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 115 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 116 | while (n_slots) |
| 117 | { |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 118 | vring_desc_t *d = &vring->desc[next];; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 119 | vlib_buffer_t *b = vlib_get_buffer (vm, vring->buffers[next]); |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 120 | /* |
| 121 | * current_data may not be initialized with 0 and may contain |
| 122 | * previous offset. Here we want to make sure, it should be 0 |
| 123 | * initialized. |
| 124 | */ |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 125 | b->current_data = -hdr_sz; |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 126 | memset (vlib_buffer_get_current (b), 0, hdr_sz); |
| 127 | d->addr = |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 128 | ((type == VIRTIO_IF_TYPE_PCI) ? vlib_buffer_get_current_pa (vm, |
| 129 | b) : |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 130 | pointer_to_uword (vlib_buffer_get_current (b))); |
Damjan Marion | 8934a04 | 2019-02-09 23:29:26 +0100 | [diff] [blame] | 131 | d->len = vlib_buffer_get_default_data_size (vm) + hdr_sz; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 132 | d->flags = VRING_DESC_F_WRITE; |
| 133 | vring->avail->ring[avail & mask] = next; |
| 134 | avail++; |
| 135 | next = (next + 1) & mask; |
| 136 | n_slots--; |
| 137 | used++; |
| 138 | } |
| 139 | CLIB_MEMORY_STORE_BARRIER (); |
| 140 | vring->avail->idx = avail; |
| 141 | vring->desc_next = next; |
| 142 | vring->desc_in_use = used; |
| 143 | |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 144 | if ((vring->used->flags & VRING_USED_F_NO_NOTIFY) == 0) |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 145 | { |
| 146 | virtio_kick (vm, vring, vif); |
| 147 | } |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 148 | goto more; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 149 | } |
| 150 | |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 151 | static_always_inline void |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 152 | virtio_refill_vring_packed (vlib_main_t * vm, virtio_if_t * vif, |
| 153 | virtio_if_type_t type, virtio_vring_t * vring, |
| 154 | const int hdr_sz, u32 node_index) |
| 155 | { |
| 156 | u16 used, next, n_slots, n_refill, flags = 0, first_desc_flags; |
| 157 | u16 sz = vring->size; |
| 158 | |
| 159 | more: |
| 160 | used = vring->desc_in_use; |
| 161 | |
| 162 | if (sz == used) |
| 163 | return; |
| 164 | |
| 165 | /* deliver free buffers in chunks of 64 */ |
| 166 | n_refill = clib_min (sz - used, 64); |
| 167 | |
| 168 | next = vring->desc_next; |
| 169 | first_desc_flags = vring->packed_desc[next].flags; |
| 170 | n_slots = |
| 171 | vlib_buffer_alloc_to_ring_from_pool (vm, vring->buffers, next, |
| 172 | sz, n_refill, |
| 173 | vring->buffer_pool_index); |
| 174 | |
| 175 | if (PREDICT_FALSE (n_slots != n_refill)) |
| 176 | { |
| 177 | vlib_error_count (vm, node_index, |
| 178 | VIRTIO_INPUT_ERROR_BUFFER_ALLOC, n_refill - n_slots); |
| 179 | if (n_slots == 0) |
| 180 | return; |
| 181 | } |
| 182 | |
| 183 | while (n_slots) |
| 184 | { |
| 185 | vring_packed_desc_t *d = &vring->packed_desc[next]; |
| 186 | vlib_buffer_t *b = vlib_get_buffer (vm, vring->buffers[next]); |
| 187 | /* |
| 188 | * current_data may not be initialized with 0 and may contain |
| 189 | * previous offset. Here we want to make sure, it should be 0 |
| 190 | * initialized. |
| 191 | */ |
| 192 | b->current_data = -hdr_sz; |
| 193 | memset (vlib_buffer_get_current (b), 0, hdr_sz); |
| 194 | d->addr = |
| 195 | ((type == VIRTIO_IF_TYPE_PCI) ? vlib_buffer_get_current_pa (vm, |
| 196 | b) : |
| 197 | pointer_to_uword (vlib_buffer_get_current (b))); |
| 198 | d->len = vlib_buffer_get_default_data_size (vm) + hdr_sz; |
| 199 | |
| 200 | if (vring->avail_wrap_counter) |
| 201 | flags = (VRING_DESC_F_AVAIL | VRING_DESC_F_WRITE); |
| 202 | else |
| 203 | flags = (VRING_DESC_F_USED | VRING_DESC_F_WRITE); |
| 204 | |
| 205 | d->id = next; |
| 206 | if (vring->desc_next == next) |
| 207 | first_desc_flags = flags; |
| 208 | else |
| 209 | d->flags = flags; |
| 210 | |
| 211 | next++; |
| 212 | if (next >= sz) |
| 213 | { |
| 214 | next = 0; |
| 215 | vring->avail_wrap_counter ^= 1; |
| 216 | } |
| 217 | n_slots--; |
| 218 | used++; |
| 219 | } |
| 220 | CLIB_MEMORY_STORE_BARRIER (); |
| 221 | vring->packed_desc[vring->desc_next].flags = first_desc_flags; |
| 222 | vring->desc_next = next; |
| 223 | vring->desc_in_use = used; |
| 224 | CLIB_MEMORY_BARRIER (); |
| 225 | if (vring->device_event->flags != VRING_EVENT_F_DISABLE) |
| 226 | { |
| 227 | virtio_kick (vm, vring, vif); |
| 228 | } |
| 229 | |
| 230 | goto more; |
| 231 | } |
| 232 | |
| 233 | static_always_inline void |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 234 | 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] | 235 | u8 * l4_proto, u8 * l4_hdr_sz, virtio_if_type_t type) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 236 | { |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 237 | if (hdr->flags & VIRTIO_NET_HDR_F_NEEDS_CSUM) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 238 | { |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 239 | u16 ethertype = 0, l2hdr_sz = 0; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 240 | |
| 241 | if (type == VIRTIO_IF_TYPE_TUN) |
| 242 | { |
| 243 | switch (b0->data[0] & 0xf0) |
| 244 | { |
| 245 | case 0x40: |
| 246 | ethertype = ETHERNET_TYPE_IP4; |
| 247 | break; |
| 248 | case 0x60: |
| 249 | ethertype = ETHERNET_TYPE_IP6; |
| 250 | break; |
| 251 | } |
| 252 | } |
| 253 | else |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 254 | { |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 255 | ethernet_header_t *eh = |
| 256 | (ethernet_header_t *) vlib_buffer_get_current (b0); |
| 257 | ethertype = clib_net_to_host_u16 (eh->type); |
| 258 | l2hdr_sz = sizeof (ethernet_header_t); |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 259 | |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 260 | if (ethernet_frame_is_tagged (ethertype)) |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 261 | { |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 262 | ethernet_vlan_header_t *vlan = |
| 263 | (ethernet_vlan_header_t *) (eh + 1); |
| 264 | |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 265 | ethertype = clib_net_to_host_u16 (vlan->type); |
| 266 | l2hdr_sz += sizeof (*vlan); |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 267 | if (ethertype == ETHERNET_TYPE_VLAN) |
| 268 | { |
| 269 | vlan++; |
| 270 | ethertype = clib_net_to_host_u16 (vlan->type); |
| 271 | l2hdr_sz += sizeof (*vlan); |
| 272 | } |
| 273 | } |
| 274 | } |
Mohsin Kazmi | 14bea1b | 2019-07-29 11:39:26 +0200 | [diff] [blame] | 275 | |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 276 | vnet_buffer (b0)->l2_hdr_offset = 0; |
| 277 | vnet_buffer (b0)->l3_hdr_offset = l2hdr_sz; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 278 | |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 279 | if (PREDICT_TRUE (ethertype == ETHERNET_TYPE_IP4)) |
| 280 | { |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 281 | ip4_header_t *ip4 = |
| 282 | (ip4_header_t *) (vlib_buffer_get_current (b0) + l2hdr_sz); |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 283 | 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] | 284 | *l4_proto = ip4->protocol; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 285 | b0->flags |= |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 286 | (VNET_BUFFER_F_IS_IP4 | VNET_BUFFER_F_OFFLOAD_IP_CKSUM); |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 287 | b0->flags |= |
| 288 | (VNET_BUFFER_F_L2_HDR_OFFSET_VALID |
| 289 | | VNET_BUFFER_F_L3_HDR_OFFSET_VALID | |
| 290 | VNET_BUFFER_F_L4_HDR_OFFSET_VALID); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 291 | } |
| 292 | else if (PREDICT_TRUE (ethertype == ETHERNET_TYPE_IP6)) |
| 293 | { |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 294 | ip6_header_t *ip6 = |
| 295 | (ip6_header_t *) (vlib_buffer_get_current (b0) + l2hdr_sz); |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 296 | vnet_buffer (b0)->l4_hdr_offset = l2hdr_sz + sizeof (ip6_header_t); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 297 | /* FIXME IPv6 EH traversal */ |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 298 | *l4_proto = ip6->protocol; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 299 | b0->flags |= (VNET_BUFFER_F_IS_IP6 | |
| 300 | VNET_BUFFER_F_L2_HDR_OFFSET_VALID |
| 301 | | VNET_BUFFER_F_L3_HDR_OFFSET_VALID | |
| 302 | VNET_BUFFER_F_L4_HDR_OFFSET_VALID); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 303 | } |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 304 | if (*l4_proto == IP_PROTOCOL_TCP) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 305 | { |
| 306 | b0->flags |= VNET_BUFFER_F_OFFLOAD_TCP_CKSUM; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 307 | tcp_header_t *tcp = (tcp_header_t *) (vlib_buffer_get_current (b0) + |
| 308 | vnet_buffer |
| 309 | (b0)->l4_hdr_offset); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 310 | *l4_hdr_sz = tcp_header_bytes (tcp); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 311 | } |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 312 | else if (*l4_proto == IP_PROTOCOL_UDP) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 313 | { |
| 314 | b0->flags |= VNET_BUFFER_F_OFFLOAD_UDP_CKSUM; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 315 | udp_header_t *udp = (udp_header_t *) (vlib_buffer_get_current (b0) + |
| 316 | vnet_buffer |
| 317 | (b0)->l4_hdr_offset); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 318 | *l4_hdr_sz = sizeof (*udp); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 319 | } |
| 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 | { |
| 592 | if (vring->device_event->flags != VRING_EVENT_F_DISABLE) |
| 593 | virtio_kick (vm, vring, vif); |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 594 | |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 595 | if (vif->gso_enabled) |
| 596 | rv = |
| 597 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 598 | 1, 1, 1); |
| 599 | else if (vif->csum_offload_enabled) |
| 600 | rv = |
| 601 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 602 | 0, 1, 1); |
| 603 | else |
| 604 | rv = |
| 605 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 606 | 0, 0, 1); |
| 607 | |
| 608 | virtio_refill_vring_packed (vm, vif, type, vring, hdr_sz, |
| 609 | node->node_index); |
| 610 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 611 | else |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 612 | { |
| 613 | if ((vring->used->flags & VRING_USED_F_NO_NOTIFY) == 0 && |
| 614 | vring->last_kick_avail_idx != vring->avail->idx) |
| 615 | virtio_kick (vm, vring, vif); |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 616 | |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 617 | if (vif->gso_enabled) |
| 618 | rv = |
| 619 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 620 | 1, 1, 0); |
| 621 | else if (vif->csum_offload_enabled) |
| 622 | rv = |
| 623 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 624 | 0, 1, 0); |
| 625 | else |
| 626 | rv = |
| 627 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 628 | 0, 0, 0); |
| 629 | |
| 630 | virtio_refill_vring_split (vm, vif, type, vring, hdr_sz, |
| 631 | node->node_index); |
| 632 | } |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 633 | return rv; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 634 | } |
| 635 | |
Filip Tehlar | 608996d | 2019-03-04 03:03:13 -0800 | [diff] [blame] | 636 | VLIB_NODE_FN (virtio_input_node) (vlib_main_t * vm, |
| 637 | vlib_node_runtime_t * node, |
| 638 | vlib_frame_t * frame) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 639 | { |
| 640 | u32 n_rx = 0; |
| 641 | virtio_main_t *nm = &virtio_main; |
| 642 | vnet_device_input_runtime_t *rt = (void *) node->runtime_data; |
| 643 | vnet_device_and_queue_t *dq; |
| 644 | |
| 645 | foreach_device_and_queue (dq, rt->devices_and_queues) |
| 646 | { |
Mohsin Kazmi | 09a3bc5 | 2019-04-02 11:45:08 +0000 | [diff] [blame] | 647 | virtio_if_t *vif; |
| 648 | vif = vec_elt_at_index (nm->interfaces, dq->dev_instance); |
| 649 | if (vif->flags & VIRTIO_IF_FLAG_ADMIN_UP) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 650 | { |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 651 | if (vif->type == VIRTIO_IF_TYPE_TAP) |
Mohsin Kazmi | 09a3bc5 | 2019-04-02 11:45:08 +0000 | [diff] [blame] | 652 | n_rx += virtio_device_input_inline (vm, node, frame, vif, |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 653 | dq->queue_id, |
| 654 | VIRTIO_IF_TYPE_TAP); |
| 655 | else if (vif->type == VIRTIO_IF_TYPE_PCI) |
Mohsin Kazmi | 6d4af89 | 2020-01-03 15:11:53 +0000 | [diff] [blame] | 656 | n_rx += virtio_device_input_inline (vm, node, frame, vif, |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 657 | dq->queue_id, |
| 658 | VIRTIO_IF_TYPE_PCI); |
| 659 | else if (vif->type == VIRTIO_IF_TYPE_TUN) |
Mohsin Kazmi | 09a3bc5 | 2019-04-02 11:45:08 +0000 | [diff] [blame] | 660 | n_rx += virtio_device_input_inline (vm, node, frame, vif, |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 661 | dq->queue_id, |
| 662 | VIRTIO_IF_TYPE_TUN); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 663 | } |
| 664 | } |
| 665 | |
| 666 | return n_rx; |
| 667 | } |
| 668 | |
| 669 | /* *INDENT-OFF* */ |
| 670 | VLIB_REGISTER_NODE (virtio_input_node) = { |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 671 | .name = "virtio-input", |
| 672 | .sibling_of = "device-input", |
| 673 | .format_trace = format_virtio_input_trace, |
Damjan Marion | 7ca5aaa | 2019-09-24 18:10:49 +0200 | [diff] [blame] | 674 | .flags = VLIB_NODE_FLAG_TRACE_SUPPORTED, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 675 | .type = VLIB_NODE_TYPE_INPUT, |
| 676 | .state = VLIB_NODE_STATE_INTERRUPT, |
Mohsin Kazmi | ddd2183 | 2019-01-22 13:05:00 +0000 | [diff] [blame] | 677 | .n_errors = VIRTIO_INPUT_N_ERROR, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 678 | .error_strings = virtio_input_error_strings, |
| 679 | }; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 680 | /* *INDENT-ON* */ |
| 681 | |
| 682 | /* |
| 683 | * fd.io coding-style-patch-verification: ON |
| 684 | * |
| 685 | * Local Variables: |
| 686 | * eval: (c-set-style "gnu") |
| 687 | * End: |
| 688 | */ |