2 * Copyright (c) 2015 Cisco and/or its affiliates.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
7 * http://www.apache.org/licenses/LICENSE-2.0
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
16 * ip/ip4_input.c: IP v4 input node
18 * Copyright (c) 2008 Eliot Dresselhaus
20 * Permission is hereby granted, free of charge, to any person obtaining
21 * a copy of this software and associated documentation files (the
22 * "Software"), to deal in the Software without restriction, including
23 * without limitation the rights to use, copy, modify, merge, publish,
24 * distribute, sublicense, and/or sell copies of the Software, and to
25 * permit persons to whom the Software is furnished to do so, subject to
26 * the following conditions:
28 * The above copyright notice and this permission notice shall be
29 * included in all copies or substantial portions of the Software.
31 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
32 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
33 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
34 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
35 * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
36 * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
37 * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
40 #include <vnet/ip/ip4_input.h>
41 #include <vnet/ethernet/ethernet.h>
42 #include <vnet/ppp/ppp.h>
43 #include <vnet/hdlc/hdlc.h>
44 #include <vnet/util/throttle.h>
52 format_ip4_input_trace (u8 * s, va_list * va)
54 CLIB_UNUSED (vlib_main_t * vm) = va_arg (*va, vlib_main_t *);
55 CLIB_UNUSED (vlib_node_t * node) = va_arg (*va, vlib_node_t *);
56 ip4_input_trace_t *t = va_arg (*va, ip4_input_trace_t *);
59 format_ip4_header, t->packet_data, sizeof (t->packet_data));
64 static_always_inline u32
65 ip4_input_set_next (u32 sw_if_index, vlib_buffer_t * b, int arc_enabled)
67 ip4_main_t *im = &ip4_main;
68 ip_lookup_main_t *lm = &im->lookup_main;
72 ip4_header_t *ip = vlib_buffer_get_current (b);
74 if (PREDICT_FALSE (ip4_address_is_multicast (&ip->dst_address)))
76 next = IP4_INPUT_NEXT_LOOKUP_MULTICAST;
77 arc = lm->mcast_feature_arc_index;
81 next = IP4_INPUT_NEXT_LOOKUP;
82 arc = lm->ucast_feature_arc_index;
86 vnet_feature_arc_start (arc, sw_if_index, &next, b);
91 static_always_inline void
92 ip4_input_check_sw_if_index (vlib_main_t * vm,
93 vlib_simple_counter_main_t * cm, u32 sw_if_index,
94 u32 * last_sw_if_index, u32 * cnt,
97 ip4_main_t *im = &ip4_main;
98 ip_lookup_main_t *lm = &im->lookup_main;
100 if (*last_sw_if_index == sw_if_index)
106 thread_index = vm->thread_index;
108 vlib_increment_simple_counter (cm, thread_index, *last_sw_if_index, *cnt);
110 *last_sw_if_index = sw_if_index;
112 if (vnet_have_features (lm->ucast_feature_arc_index, sw_if_index) ||
113 vnet_have_features (lm->mcast_feature_arc_index, sw_if_index))
119 /* Validate IP v4 packets and pass them either to forwarding code
120 or drop/punt exception packets. */
122 ip4_input_inline (vlib_main_t * vm,
123 vlib_node_runtime_t * node,
124 vlib_frame_t * frame, int verify_checksum)
126 vnet_main_t *vnm = vnet_get_main ();
127 u32 n_left_from, *from;
128 u32 thread_index = vm->thread_index;
129 vlib_node_runtime_t *error_node =
130 vlib_node_get_runtime (vm, ip4_input_node.index);
131 vlib_simple_counter_main_t *cm;
132 vlib_buffer_t *bufs[VLIB_FRAME_SIZE], **b;
134 u16 nexts[VLIB_FRAME_SIZE], *next;
136 u32 last_sw_if_index = ~0;
140 from = vlib_frame_vector_args (frame);
141 n_left_from = frame->n_vectors;
143 if (node->flags & VLIB_NODE_FLAG_TRACE)
144 vlib_trace_frame_buffers_only (vm, node, from, frame->n_vectors,
146 sizeof (ip4_input_trace_t));
148 cm = vec_elt_at_index (vnm->interface_main.sw_if_counters,
149 VNET_INTERFACE_COUNTER_IP4);
151 vlib_get_buffers (vm, from, bufs, n_left_from);
154 while (n_left_from >= 4)
158 /* Prefetch next iteration. */
159 if (n_left_from >= 12)
161 vlib_prefetch_buffer_header (b[8], LOAD);
162 vlib_prefetch_buffer_header (b[9], LOAD);
163 vlib_prefetch_buffer_header (b[10], LOAD);
164 vlib_prefetch_buffer_header (b[11], LOAD);
166 vlib_prefetch_buffer_data (b[4], LOAD);
167 vlib_prefetch_buffer_data (b[5], LOAD);
168 vlib_prefetch_buffer_data (b[6], LOAD);
169 vlib_prefetch_buffer_data (b[7], LOAD);
172 vnet_buffer (b[0])->ip.adj_index[VLIB_RX] = ~0;
173 vnet_buffer (b[1])->ip.adj_index[VLIB_RX] = ~0;
174 vnet_buffer (b[2])->ip.adj_index[VLIB_RX] = ~0;
175 vnet_buffer (b[3])->ip.adj_index[VLIB_RX] = ~0;
177 sw_if_index[0] = vnet_buffer (b[0])->sw_if_index[VLIB_RX];
178 sw_if_index[1] = vnet_buffer (b[1])->sw_if_index[VLIB_RX];
179 sw_if_index[2] = vnet_buffer (b[2])->sw_if_index[VLIB_RX];
180 sw_if_index[3] = vnet_buffer (b[3])->sw_if_index[VLIB_RX];
182 x |= sw_if_index[0] ^ last_sw_if_index;
183 x |= sw_if_index[1] ^ last_sw_if_index;
184 x |= sw_if_index[2] ^ last_sw_if_index;
185 x |= sw_if_index[3] ^ last_sw_if_index;
187 if (PREDICT_TRUE (x == 0))
189 /* we deal with 4 more packets sharing the same sw_if_index
190 with the previous one, so we can optimize */
194 next[0] = ip4_input_set_next (sw_if_index[0], b[0], 1);
195 next[1] = ip4_input_set_next (sw_if_index[1], b[1], 1);
196 next[2] = ip4_input_set_next (sw_if_index[2], b[2], 1);
197 next[3] = ip4_input_set_next (sw_if_index[3], b[3], 1);
201 next[0] = ip4_input_set_next (sw_if_index[0], b[0], 0);
202 next[1] = ip4_input_set_next (sw_if_index[1], b[1], 0);
203 next[2] = ip4_input_set_next (sw_if_index[2], b[2], 0);
204 next[3] = ip4_input_set_next (sw_if_index[3], b[3], 0);
209 ip4_input_check_sw_if_index (vm, cm, sw_if_index[0],
210 &last_sw_if_index, &cnt, &arc_enabled);
211 ip4_input_check_sw_if_index (vm, cm, sw_if_index[1],
212 &last_sw_if_index, &cnt, &arc_enabled);
213 ip4_input_check_sw_if_index (vm, cm, sw_if_index[2],
214 &last_sw_if_index, &cnt, &arc_enabled);
215 ip4_input_check_sw_if_index (vm, cm, sw_if_index[3],
216 &last_sw_if_index, &cnt, &arc_enabled);
218 next[0] = ip4_input_set_next (sw_if_index[0], b[0], 1);
219 next[1] = ip4_input_set_next (sw_if_index[1], b[1], 1);
220 next[2] = ip4_input_set_next (sw_if_index[2], b[2], 1);
221 next[3] = ip4_input_set_next (sw_if_index[3], b[3], 1);
224 ip[0] = vlib_buffer_get_current (b[0]);
225 ip[1] = vlib_buffer_get_current (b[1]);
226 ip[2] = vlib_buffer_get_current (b[2]);
227 ip[3] = vlib_buffer_get_current (b[3]);
229 ip4_input_check_x4 (vm, error_node, b, ip, next, verify_checksum);
239 vnet_buffer (b[0])->ip.adj_index[VLIB_RX] = ~0;
240 sw_if_index[0] = vnet_buffer (b[0])->sw_if_index[VLIB_RX];
241 ip4_input_check_sw_if_index (vm, cm, sw_if_index[0], &last_sw_if_index,
243 next0 = ip4_input_set_next (sw_if_index[0], b[0], arc_enabled);
244 ip[0] = vlib_buffer_get_current (b[0]);
245 ip4_input_check_x1 (vm, error_node, b[0], ip[0], &next0,
255 vlib_increment_simple_counter (cm, thread_index, last_sw_if_index, cnt);
256 vlib_buffer_enqueue_to_next (vm, node, from, nexts, frame->n_vectors);
257 return frame->n_vectors;
260 /** \brief IPv4 input node.
263 This is the IPv4 input node: validates ip4 header checksums,
264 verifies ip header lengths, discards pkts with expired TTLs,
265 and sends pkts to the set of ip feature nodes configured on
268 @param vm vlib_main_t corresponding to the current thread
269 @param node vlib_node_runtime_t
270 @param frame vlib_frame_t whose contents should be dispatched
272 @par Graph mechanics: buffer metadata, next index usage
275 - vnet_feature_config_main_t cm corresponding to each pkt's dst address unicast /
277 - <code>b->current_config_index</code> corresponding to each pkt's
279 - This sets the per-packet graph trajectory, ensuring that
280 each packet visits the per-interface features in order.
282 - <code>vnet_buffer(b)->sw_if_index[VLIB_RX]</code>
283 - Indicates the @c sw_if_index value of the interface that the
284 packet was received on.
287 - <code>vnet_buffer(b)->ip.adj_index[VLIB_TX]</code>
288 - The lookup result adjacency index.
290 <em>Next Indices:</em>
291 - Dispatches pkts to the (first) feature node:
292 <code> vnet_get_config_data (... &next0 ...); </code>
295 VLIB_NODE_FN (ip4_input_node) (vlib_main_t * vm, vlib_node_runtime_t * node,
296 vlib_frame_t * frame)
298 return ip4_input_inline (vm, node, frame, /* verify_checksum */ 1);
301 VLIB_NODE_FN (ip4_input_no_checksum_node) (vlib_main_t * vm,
302 vlib_node_runtime_t * node,
303 vlib_frame_t * frame)
305 return ip4_input_inline (vm, node, frame, /* verify_checksum */ 0);
308 #ifndef CLIB_MARCH_VARIANT
309 char *ip4_error_strings[] = {
310 #define _(sym,string) string,
317 VLIB_REGISTER_NODE (ip4_input_node) = {
319 .vector_size = sizeof (u32),
320 .protocol_hint = VLIB_NODE_PROTO_HINT_IP4,
322 .n_errors = IP4_N_ERROR,
323 .error_strings = ip4_error_strings,
325 .n_next_nodes = IP4_INPUT_N_NEXT,
327 [IP4_INPUT_NEXT_DROP] = "error-drop",
328 [IP4_INPUT_NEXT_PUNT] = "error-punt",
329 [IP4_INPUT_NEXT_OPTIONS] = "ip4-options",
330 [IP4_INPUT_NEXT_LOOKUP] = "ip4-lookup",
331 [IP4_INPUT_NEXT_LOOKUP_MULTICAST] = "ip4-mfib-forward-lookup",
332 [IP4_INPUT_NEXT_ICMP_ERROR] = "ip4-icmp-error",
333 [IP4_INPUT_NEXT_REASSEMBLY] = "ip4-reassembly",
336 .format_buffer = format_ip4_header,
337 .format_trace = format_ip4_input_trace,
340 VLIB_REGISTER_NODE (ip4_input_no_checksum_node) = {
341 .name = "ip4-input-no-checksum",
342 .vector_size = sizeof (u32),
344 .sibling_of = "ip4-input",
345 .format_buffer = format_ip4_header,
346 .format_trace = format_ip4_input_trace,
350 static clib_error_t *
351 ip4_init (vlib_main_t * vm)
355 ethernet_register_input_type (vm, ETHERNET_TYPE_IP4, ip4_input_node.index);
356 ppp_register_input_protocol (vm, PPP_PROTOCOL_ip4, ip4_input_node.index);
357 hdlc_register_input_protocol (vm, HDLC_PROTOCOL_ip4, ip4_input_node.index);
360 extern vlib_node_registration_t ip4_input_no_checksum_node;
362 pn = pg_get_node (ip4_input_node.index);
363 pn->unformat_edit = unformat_pg_ip4_header;
364 pn = pg_get_node (ip4_input_no_checksum_node.index);
365 pn->unformat_edit = unformat_pg_ip4_header;
368 if ((error = vlib_call_init_function (vm, ip4_cli_init)))
371 if ((error = vlib_call_init_function (vm, ip4_source_check_init)))
374 if ((error = vlib_call_init_function
375 (vm, ip4_source_and_port_range_check_init)))
378 /* Set flow hash to something non-zero. */
379 ip4_main.flow_hash_seed = 0xdeadbeef;
381 /* Default TTL for packets we generate. */
382 ip4_main.host_config.ttl = 64;
387 VLIB_INIT_FUNCTION (ip4_init);
389 static clib_error_t *
390 ip4_main_loop_enter (vlib_main_t * vm)
392 ip4_main_t *im = &ip4_main;
393 vlib_thread_main_t *tm = &vlib_thread_main;
394 u32 n_vlib_mains = tm->n_vlib_mains;
396 throttle_init (&im->arp_throttle, n_vlib_mains, 1e-3);
401 VLIB_MAIN_LOOP_ENTER_FUNCTION (ip4_main_loop_enter);
404 * fd.io coding-style-patch-verification: ON
407 * eval: (c-set-style "gnu")