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 | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 125 | memset (vlib_buffer_get_current (b), 0, hdr_sz); |
| 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 | } |
| 138 | CLIB_MEMORY_STORE_BARRIER (); |
| 139 | vring->avail->idx = avail; |
| 140 | vring->desc_next = next; |
| 141 | vring->desc_in_use = used; |
| 142 | |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 143 | if ((vring->used->flags & VRING_USED_F_NO_NOTIFY) == 0) |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 144 | { |
| 145 | virtio_kick (vm, vring, vif); |
| 146 | } |
Damjan Marion | e40231b | 2018-12-20 10:44:47 +0100 | [diff] [blame] | 147 | goto more; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 148 | } |
| 149 | |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 150 | static_always_inline void |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 151 | virtio_refill_vring_packed (vlib_main_t * vm, virtio_if_t * vif, |
| 152 | virtio_if_type_t type, virtio_vring_t * vring, |
| 153 | const int hdr_sz, u32 node_index) |
| 154 | { |
| 155 | u16 used, next, n_slots, n_refill, flags = 0, first_desc_flags; |
| 156 | u16 sz = vring->size; |
| 157 | |
| 158 | more: |
| 159 | used = vring->desc_in_use; |
| 160 | |
| 161 | if (sz == used) |
| 162 | return; |
| 163 | |
| 164 | /* deliver free buffers in chunks of 64 */ |
| 165 | n_refill = clib_min (sz - used, 64); |
| 166 | |
| 167 | next = vring->desc_next; |
| 168 | first_desc_flags = vring->packed_desc[next].flags; |
| 169 | n_slots = |
| 170 | vlib_buffer_alloc_to_ring_from_pool (vm, vring->buffers, next, |
| 171 | sz, n_refill, |
| 172 | vring->buffer_pool_index); |
| 173 | |
| 174 | if (PREDICT_FALSE (n_slots != n_refill)) |
| 175 | { |
| 176 | vlib_error_count (vm, node_index, |
| 177 | VIRTIO_INPUT_ERROR_BUFFER_ALLOC, n_refill - n_slots); |
| 178 | if (n_slots == 0) |
| 179 | return; |
| 180 | } |
| 181 | |
| 182 | while (n_slots) |
| 183 | { |
| 184 | vring_packed_desc_t *d = &vring->packed_desc[next]; |
| 185 | vlib_buffer_t *b = vlib_get_buffer (vm, vring->buffers[next]); |
| 186 | /* |
| 187 | * current_data may not be initialized with 0 and may contain |
| 188 | * previous offset. Here we want to make sure, it should be 0 |
| 189 | * initialized. |
| 190 | */ |
| 191 | b->current_data = -hdr_sz; |
| 192 | memset (vlib_buffer_get_current (b), 0, hdr_sz); |
| 193 | d->addr = |
| 194 | ((type == VIRTIO_IF_TYPE_PCI) ? vlib_buffer_get_current_pa (vm, |
| 195 | b) : |
| 196 | pointer_to_uword (vlib_buffer_get_current (b))); |
| 197 | d->len = vlib_buffer_get_default_data_size (vm) + hdr_sz; |
| 198 | |
| 199 | if (vring->avail_wrap_counter) |
| 200 | flags = (VRING_DESC_F_AVAIL | VRING_DESC_F_WRITE); |
| 201 | else |
| 202 | flags = (VRING_DESC_F_USED | VRING_DESC_F_WRITE); |
| 203 | |
| 204 | d->id = next; |
| 205 | if (vring->desc_next == next) |
| 206 | first_desc_flags = flags; |
| 207 | else |
| 208 | d->flags = flags; |
| 209 | |
| 210 | next++; |
| 211 | if (next >= sz) |
| 212 | { |
| 213 | next = 0; |
| 214 | vring->avail_wrap_counter ^= 1; |
| 215 | } |
| 216 | n_slots--; |
| 217 | used++; |
| 218 | } |
| 219 | CLIB_MEMORY_STORE_BARRIER (); |
| 220 | vring->packed_desc[vring->desc_next].flags = first_desc_flags; |
| 221 | vring->desc_next = next; |
| 222 | vring->desc_in_use = used; |
| 223 | CLIB_MEMORY_BARRIER (); |
| 224 | if (vring->device_event->flags != VRING_EVENT_F_DISABLE) |
| 225 | { |
| 226 | virtio_kick (vm, vring, vif); |
| 227 | } |
| 228 | |
| 229 | goto more; |
| 230 | } |
| 231 | |
| 232 | static_always_inline void |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 233 | 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] | 234 | u8 * l4_proto, u8 * l4_hdr_sz, virtio_if_type_t type) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 235 | { |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 236 | if (hdr->flags & VIRTIO_NET_HDR_F_NEEDS_CSUM) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 237 | { |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 238 | u16 ethertype = 0, l2hdr_sz = 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; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 284 | b0->flags |= |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 285 | (VNET_BUFFER_F_IS_IP4 | VNET_BUFFER_F_OFFLOAD_IP_CKSUM); |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 286 | b0->flags |= |
| 287 | (VNET_BUFFER_F_L2_HDR_OFFSET_VALID |
| 288 | | VNET_BUFFER_F_L3_HDR_OFFSET_VALID | |
| 289 | VNET_BUFFER_F_L4_HDR_OFFSET_VALID); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 290 | } |
| 291 | else if (PREDICT_TRUE (ethertype == ETHERNET_TYPE_IP6)) |
| 292 | { |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 293 | ip6_header_t *ip6 = |
| 294 | (ip6_header_t *) (vlib_buffer_get_current (b0) + l2hdr_sz); |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 295 | vnet_buffer (b0)->l4_hdr_offset = l2hdr_sz + sizeof (ip6_header_t); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 296 | /* FIXME IPv6 EH traversal */ |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 297 | *l4_proto = ip6->protocol; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 298 | b0->flags |= (VNET_BUFFER_F_IS_IP6 | |
| 299 | VNET_BUFFER_F_L2_HDR_OFFSET_VALID |
| 300 | | VNET_BUFFER_F_L3_HDR_OFFSET_VALID | |
| 301 | VNET_BUFFER_F_L4_HDR_OFFSET_VALID); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 302 | } |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 303 | if (*l4_proto == IP_PROTOCOL_TCP) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 304 | { |
| 305 | b0->flags |= VNET_BUFFER_F_OFFLOAD_TCP_CKSUM; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 306 | tcp_header_t *tcp = (tcp_header_t *) (vlib_buffer_get_current (b0) + |
| 307 | vnet_buffer |
| 308 | (b0)->l4_hdr_offset); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 309 | *l4_hdr_sz = tcp_header_bytes (tcp); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 310 | } |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 311 | else if (*l4_proto == IP_PROTOCOL_UDP) |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 312 | { |
| 313 | b0->flags |= VNET_BUFFER_F_OFFLOAD_UDP_CKSUM; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 314 | udp_header_t *udp = (udp_header_t *) (vlib_buffer_get_current (b0) + |
| 315 | vnet_buffer |
| 316 | (b0)->l4_hdr_offset); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 317 | *l4_hdr_sz = sizeof (*udp); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 318 | } |
| 319 | } |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 320 | } |
| 321 | |
| 322 | static_always_inline void |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 323 | 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] | 324 | u8 l4_proto, u8 l4_hdr_sz) |
| 325 | { |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 326 | if (hdr->gso_type == VIRTIO_NET_HDR_GSO_TCPV4) |
| 327 | { |
| 328 | ASSERT (hdr->flags & VIRTIO_NET_HDR_F_NEEDS_CSUM); |
| 329 | vnet_buffer2 (b0)->gso_size = hdr->gso_size; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 330 | vnet_buffer2 (b0)->gso_l4_hdr_sz = l4_hdr_sz; |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 331 | b0->flags |= VNET_BUFFER_F_GSO | VNET_BUFFER_F_IS_IP4; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 332 | } |
| 333 | if (hdr->gso_type == VIRTIO_NET_HDR_GSO_TCPV6) |
| 334 | { |
| 335 | ASSERT (hdr->flags & VIRTIO_NET_HDR_F_NEEDS_CSUM); |
| 336 | vnet_buffer2 (b0)->gso_size = hdr->gso_size; |
Mohsin Kazmi | 157a4ab | 2019-12-06 15:47:48 +0100 | [diff] [blame] | 337 | vnet_buffer2 (b0)->gso_l4_hdr_sz = l4_hdr_sz; |
Mohsin Kazmi | 72e7312 | 2019-10-22 13:33:13 +0200 | [diff] [blame] | 338 | b0->flags |= VNET_BUFFER_F_GSO | VNET_BUFFER_F_IS_IP6; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 339 | } |
| 340 | } |
| 341 | |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 342 | static_always_inline u16 |
| 343 | virtio_n_left_to_process (virtio_vring_t * vring, const int packed) |
| 344 | { |
| 345 | if (packed) |
| 346 | return vring->desc_in_use; |
| 347 | else |
| 348 | return vring->used->idx - vring->last_used_idx; |
| 349 | } |
| 350 | |
| 351 | static_always_inline u16 |
| 352 | virtio_get_slot_id (virtio_vring_t * vring, const int packed, u16 last, |
| 353 | u16 mask) |
| 354 | { |
| 355 | if (packed) |
| 356 | return vring->packed_desc[last].id; |
| 357 | else |
| 358 | return vring->used->ring[last & mask].id; |
| 359 | } |
| 360 | |
| 361 | static_always_inline u16 |
| 362 | virtio_get_len (virtio_vring_t * vring, const int packed, const int hdr_sz, |
| 363 | u16 last, u16 mask) |
| 364 | { |
| 365 | if (packed) |
| 366 | return vring->packed_desc[last].len - hdr_sz; |
| 367 | else |
| 368 | return vring->used->ring[last & mask].len - hdr_sz; |
| 369 | } |
| 370 | |
| 371 | #define increment_last(last, packed, vring) \ |
| 372 | do { \ |
| 373 | last++; \ |
| 374 | if (packed && last >= vring->size) \ |
| 375 | { \ |
| 376 | last = 0; \ |
| 377 | vring->used_wrap_counter ^= 1; \ |
| 378 | } \ |
| 379 | } while (0) |
| 380 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 381 | static_always_inline uword |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 382 | virtio_device_input_gso_inline (vlib_main_t * vm, vlib_node_runtime_t * node, |
| 383 | vlib_frame_t * frame, virtio_if_t * vif, |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 384 | virtio_vring_t * vring, virtio_if_type_t type, |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 385 | int gso_enabled, int checksum_offload_enabled, |
| 386 | int packed) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 387 | { |
| 388 | vnet_main_t *vnm = vnet_get_main (); |
Damjan Marion | 067cd62 | 2018-07-11 12:47:43 +0200 | [diff] [blame] | 389 | u32 thread_index = vm->thread_index; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 390 | uword n_trace = vlib_get_trace_count (vm, node); |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 391 | u32 next_index; |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 392 | const int hdr_sz = vif->virtio_net_hdr_sz; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 393 | u32 *to_next = 0; |
| 394 | u32 n_rx_packets = 0; |
| 395 | u32 n_rx_bytes = 0; |
| 396 | u16 mask = vring->size - 1; |
| 397 | u16 last = vring->last_used_idx; |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 398 | u16 n_left = virtio_n_left_to_process (vring, packed); |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 399 | vlib_buffer_t bt; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 400 | |
| 401 | if (n_left == 0) |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 402 | return 0; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 403 | |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 404 | if (type == VIRTIO_IF_TYPE_TUN) |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 405 | { |
| 406 | next_index = VNET_DEVICE_INPUT_NEXT_IP4_INPUT; |
| 407 | } |
| 408 | else |
| 409 | { |
| 410 | next_index = VNET_DEVICE_INPUT_NEXT_ETHERNET_INPUT; |
| 411 | if (PREDICT_FALSE (vif->per_interface_next_index != ~0)) |
| 412 | next_index = vif->per_interface_next_index; |
| 413 | |
| 414 | /* only for l2, redirect if feature path enabled */ |
| 415 | vnet_feature_start_device_input_x1 (vif->sw_if_index, &next_index, &bt); |
| 416 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 417 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 418 | while (n_left) |
| 419 | { |
| 420 | u32 n_left_to_next; |
| 421 | u32 next0 = next_index; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 422 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 423 | vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next); |
| 424 | |
| 425 | while (n_left && n_left_to_next) |
| 426 | { |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 427 | if (packed) |
| 428 | { |
| 429 | vring_packed_desc_t *d = &vring->packed_desc[last]; |
| 430 | u16 flags = d->flags; |
| 431 | if ((flags & VRING_DESC_F_AVAIL) != |
| 432 | (vring->used_wrap_counter << 7) |
| 433 | || (flags & VRING_DESC_F_USED) != |
| 434 | (vring->used_wrap_counter << 15)) |
| 435 | { |
| 436 | n_left = 0; |
| 437 | break; |
| 438 | } |
| 439 | } |
Mohsin Kazmi | 516e4ed | 2020-02-24 15:54:24 +0100 | [diff] [blame] | 440 | u8 l4_proto = 0, l4_hdr_sz = 0; |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 441 | u16 num_buffers = 1; |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 442 | virtio_net_hdr_v1_t *hdr; |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 443 | u16 slot = virtio_get_slot_id (vring, packed, last, mask); |
| 444 | u16 len = virtio_get_len (vring, packed, hdr_sz, last, mask); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 445 | u32 bi0 = vring->buffers[slot]; |
| 446 | vlib_buffer_t *b0 = vlib_get_buffer (vm, bi0); |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 447 | hdr = vlib_buffer_get_current (b0); |
Mohsin Kazmi | a7a2281 | 2020-08-31 17:17:16 +0200 | [diff] [blame] | 448 | if (hdr_sz == sizeof (virtio_net_hdr_v1_t)) |
Mohsin Kazmi | d6c15af | 2018-10-23 18:00:47 +0200 | [diff] [blame] | 449 | num_buffers = hdr->num_buffers; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 450 | |
Mohsin Kazmi | 8975dbd | 2020-06-24 16:19:19 +0200 | [diff] [blame] | 451 | b0->flags = VLIB_BUFFER_TOTAL_LENGTH_VALID; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 452 | b0->current_data = 0; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 453 | b0->current_length = len; |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 454 | |
Mohsin Kazmi | 6d4af89 | 2020-01-03 15:11:53 +0000 | [diff] [blame] | 455 | if (checksum_offload_enabled) |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 456 | virtio_needs_csum (b0, hdr, &l4_proto, &l4_hdr_sz, type); |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 457 | |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 458 | if (gso_enabled) |
Benoît Ganne | 15d7fd0 | 2019-11-26 17:59:41 +0100 | [diff] [blame] | 459 | fill_gso_buffer_flags (b0, hdr, l4_proto, l4_hdr_sz); |
Andrew Yourtchenko | 6a7cff7 | 2018-10-12 16:09:22 +0200 | [diff] [blame] | 460 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 461 | vnet_buffer (b0)->sw_if_index[VLIB_RX] = vif->sw_if_index; |
| 462 | vnet_buffer (b0)->sw_if_index[VLIB_TX] = (u32) ~ 0; |
| 463 | |
| 464 | /* if multisegment packet */ |
| 465 | if (PREDICT_FALSE (num_buffers > 1)) |
| 466 | { |
| 467 | vlib_buffer_t *pb, *cb; |
| 468 | pb = b0; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 469 | b0->total_length_not_including_first_buffer = 0; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 470 | while (num_buffers > 1) |
| 471 | { |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 472 | increment_last (last, packed, vring); |
| 473 | u16 cslot = virtio_get_slot_id (vring, packed, last, mask); |
Mohsin Kazmi | a17381a | 2020-12-03 11:35:23 +0100 | [diff] [blame] | 474 | /* hdr size is 0 after 1st packet in chain buffers */ |
| 475 | u16 clen = virtio_get_len (vring, packed, 0, last, mask); |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 476 | u32 cbi = vring->buffers[cslot]; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 477 | cb = vlib_get_buffer (vm, cbi); |
| 478 | |
| 479 | /* current buffer */ |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 480 | cb->current_length = clen; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 481 | |
| 482 | /* previous buffer */ |
| 483 | pb->next_buffer = cbi; |
| 484 | pb->flags |= VLIB_BUFFER_NEXT_PRESENT; |
| 485 | |
| 486 | /* first buffer */ |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 487 | b0->total_length_not_including_first_buffer += clen; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 488 | |
| 489 | pb = cb; |
| 490 | vring->desc_in_use--; |
| 491 | num_buffers--; |
| 492 | n_left--; |
| 493 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 494 | len += b0->total_length_not_including_first_buffer; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 495 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 496 | |
| 497 | if (type == VIRTIO_IF_TYPE_TUN) |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 498 | { |
| 499 | switch (b0->data[0] & 0xf0) |
| 500 | { |
| 501 | case 0x40: |
| 502 | next0 = VNET_DEVICE_INPUT_NEXT_IP4_INPUT; |
| 503 | break; |
| 504 | case 0x60: |
| 505 | next0 = VNET_DEVICE_INPUT_NEXT_IP6_INPUT; |
| 506 | break; |
| 507 | default: |
| 508 | next0 = VNET_DEVICE_INPUT_NEXT_DROP; |
| 509 | break; |
| 510 | } |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 511 | |
| 512 | if (PREDICT_FALSE (vif->per_interface_next_index != ~0)) |
| 513 | next0 = vif->per_interface_next_index; |
Mohsin Kazmi | 206acf8 | 2020-04-06 14:19:54 +0200 | [diff] [blame] | 514 | } |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 515 | else |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 516 | { |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 517 | /* copy feature arc data from template */ |
| 518 | b0->current_config_index = bt.current_config_index; |
| 519 | vnet_buffer (b0)->feature_arc_index = |
| 520 | vnet_buffer (&bt)->feature_arc_index; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 521 | } |
Damjan Marion | 06c194d | 2019-11-13 10:12:53 +0100 | [diff] [blame] | 522 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 523 | /* trace */ |
| 524 | VLIB_BUFFER_TRACE_TRAJECTORY_INIT (b0); |
| 525 | |
Benoît Ganne | 9a3973e | 2020-10-02 19:36:57 +0200 | [diff] [blame] | 526 | if (PREDICT_FALSE (n_trace > 0 && vlib_trace_buffer (vm, node, next0, b0, /* follow_chain */ |
| 527 | 1))) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 528 | { |
| 529 | virtio_input_trace_t *tr; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 530 | vlib_set_trace_count (vm, node, --n_trace); |
| 531 | tr = vlib_add_trace (vm, node, b0, sizeof (*tr)); |
| 532 | tr->next_index = next0; |
| 533 | tr->hw_if_index = vif->hw_if_index; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 534 | tr->len = len; |
Dave Barach | 178cf49 | 2018-11-13 16:34:13 -0500 | [diff] [blame] | 535 | clib_memcpy_fast (&tr->hdr, hdr, hdr_sz); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 536 | } |
| 537 | |
| 538 | /* enqueue buffer */ |
| 539 | to_next[0] = bi0; |
| 540 | vring->desc_in_use--; |
| 541 | to_next += 1; |
| 542 | n_left_to_next--; |
| 543 | n_left--; |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 544 | increment_last (last, packed, vring); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 545 | |
Damjan Marion | d96b28a | 2020-10-19 17:15:58 +0200 | [diff] [blame] | 546 | /* only tun interfaces may have different next index */ |
| 547 | if (type == VIRTIO_IF_TYPE_TUN) |
| 548 | vlib_validate_buffer_enqueue_x1 (vm, node, next_index, to_next, |
| 549 | n_left_to_next, bi0, next0); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 550 | |
| 551 | /* next packet */ |
| 552 | n_rx_packets++; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 553 | n_rx_bytes += len; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 554 | } |
| 555 | vlib_put_next_frame (vm, node, next_index, n_left_to_next); |
| 556 | } |
| 557 | vring->last_used_idx = last; |
| 558 | |
| 559 | vlib_increment_combined_counter (vnm->interface_main.combined_sw_if_counters |
| 560 | + VNET_INTERFACE_COUNTER_RX, thread_index, |
Steven Luong | efa119d | 2019-08-30 10:49:44 -0700 | [diff] [blame] | 561 | vif->sw_if_index, n_rx_packets, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 562 | n_rx_bytes); |
| 563 | |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 564 | return n_rx_packets; |
| 565 | } |
| 566 | |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 567 | static_always_inline uword |
| 568 | virtio_device_input_inline (vlib_main_t * vm, vlib_node_runtime_t * node, |
| 569 | vlib_frame_t * frame, virtio_if_t * vif, u16 qid, |
| 570 | virtio_if_type_t type) |
| 571 | { |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 572 | virtio_vring_t *vring = vec_elt_at_index (vif->rxq_vrings, qid); |
| 573 | const int hdr_sz = vif->virtio_net_hdr_sz; |
| 574 | u16 txq_id = vm->thread_index % vif->num_txqs; |
| 575 | virtio_vring_t *txq_vring = vec_elt_at_index (vif->txq_vrings, txq_id); |
| 576 | uword rv; |
| 577 | |
| 578 | if (clib_spinlock_trylock_if_init (&txq_vring->lockp)) |
| 579 | { |
| 580 | if (vif->packet_coalesce) |
| 581 | vnet_gro_flow_table_schedule_node_on_dispatcher |
| 582 | (vm, txq_vring->flow_table); |
| 583 | else if (vif->packet_buffering) |
| 584 | virtio_vring_buffering_schedule_node_on_dispatcher |
| 585 | (vm, txq_vring->buffering); |
| 586 | clib_spinlock_unlock_if_init (&txq_vring->lockp); |
| 587 | } |
| 588 | |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 589 | if (vif->is_packed) |
| 590 | { |
| 591 | if (vring->device_event->flags != VRING_EVENT_F_DISABLE) |
| 592 | virtio_kick (vm, vring, vif); |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 593 | |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 594 | if (vif->gso_enabled) |
| 595 | rv = |
| 596 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 597 | 1, 1, 1); |
| 598 | else if (vif->csum_offload_enabled) |
| 599 | rv = |
| 600 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 601 | 0, 1, 1); |
| 602 | else |
| 603 | rv = |
| 604 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 605 | 0, 0, 1); |
| 606 | |
| 607 | virtio_refill_vring_packed (vm, vif, type, vring, hdr_sz, |
| 608 | node->node_index); |
| 609 | } |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 610 | else |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 611 | { |
| 612 | if ((vring->used->flags & VRING_USED_F_NO_NOTIFY) == 0 && |
| 613 | vring->last_kick_avail_idx != vring->avail->idx) |
| 614 | virtio_kick (vm, vring, vif); |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 615 | |
Mohsin Kazmi | b977d3f | 2020-11-16 16:49:30 +0100 | [diff] [blame] | 616 | if (vif->gso_enabled) |
| 617 | rv = |
| 618 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 619 | 1, 1, 0); |
| 620 | else if (vif->csum_offload_enabled) |
| 621 | rv = |
| 622 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 623 | 0, 1, 0); |
| 624 | else |
| 625 | rv = |
| 626 | virtio_device_input_gso_inline (vm, node, frame, vif, vring, type, |
| 627 | 0, 0, 0); |
| 628 | |
| 629 | virtio_refill_vring_split (vm, vif, type, vring, hdr_sz, |
| 630 | node->node_index); |
| 631 | } |
Damjan Marion | 4769ed9 | 2020-10-18 14:00:43 +0200 | [diff] [blame] | 632 | return rv; |
Mohsin Kazmi | 38b0968 | 2020-06-03 18:20:17 +0200 | [diff] [blame] | 633 | } |
| 634 | |
Filip Tehlar | 608996d | 2019-03-04 03:03:13 -0800 | [diff] [blame] | 635 | VLIB_NODE_FN (virtio_input_node) (vlib_main_t * vm, |
| 636 | vlib_node_runtime_t * node, |
| 637 | vlib_frame_t * frame) |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 638 | { |
| 639 | u32 n_rx = 0; |
Damjan Marion | 9410053 | 2020-11-06 23:25:57 +0100 | [diff] [blame] | 640 | virtio_main_t *vim = &virtio_main; |
| 641 | vnet_hw_if_rxq_poll_vector_t *p, |
| 642 | *pv = vnet_hw_if_get_rxq_poll_vector (vm, node); |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 643 | |
Damjan Marion | 9410053 | 2020-11-06 23:25:57 +0100 | [diff] [blame] | 644 | vec_foreach (p, pv) |
| 645 | { |
| 646 | virtio_if_t *vif; |
| 647 | vif = vec_elt_at_index (vim->interfaces, p->dev_instance); |
| 648 | if (vif->flags & VIRTIO_IF_FLAG_ADMIN_UP) |
| 649 | { |
| 650 | if (vif->type == VIRTIO_IF_TYPE_TAP) |
| 651 | n_rx += virtio_device_input_inline ( |
| 652 | vm, node, frame, vif, p->queue_id, VIRTIO_IF_TYPE_TAP); |
| 653 | else if (vif->type == VIRTIO_IF_TYPE_PCI) |
| 654 | n_rx += virtio_device_input_inline ( |
| 655 | vm, node, frame, vif, p->queue_id, VIRTIO_IF_TYPE_PCI); |
| 656 | else if (vif->type == VIRTIO_IF_TYPE_TUN) |
| 657 | n_rx += virtio_device_input_inline ( |
| 658 | vm, node, frame, vif, p->queue_id, VIRTIO_IF_TYPE_TUN); |
| 659 | } |
| 660 | } |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 661 | |
| 662 | return n_rx; |
| 663 | } |
| 664 | |
| 665 | /* *INDENT-OFF* */ |
| 666 | VLIB_REGISTER_NODE (virtio_input_node) = { |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 667 | .name = "virtio-input", |
| 668 | .sibling_of = "device-input", |
| 669 | .format_trace = format_virtio_input_trace, |
Damjan Marion | 7ca5aaa | 2019-09-24 18:10:49 +0200 | [diff] [blame] | 670 | .flags = VLIB_NODE_FLAG_TRACE_SUPPORTED, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 671 | .type = VLIB_NODE_TYPE_INPUT, |
| 672 | .state = VLIB_NODE_STATE_INTERRUPT, |
Mohsin Kazmi | ddd2183 | 2019-01-22 13:05:00 +0000 | [diff] [blame] | 673 | .n_errors = VIRTIO_INPUT_N_ERROR, |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 674 | .error_strings = virtio_input_error_strings, |
| 675 | }; |
Damjan Marion | 8389fb9 | 2017-10-13 18:29:53 +0200 | [diff] [blame] | 676 | /* *INDENT-ON* */ |
| 677 | |
| 678 | /* |
| 679 | * fd.io coding-style-patch-verification: ON |
| 680 | * |
| 681 | * Local Variables: |
| 682 | * eval: (c-set-style "gnu") |
| 683 | * End: |
| 684 | */ |