FD.io VPP  v19.04.4-rc0-5-ge88582fac
Vector Packet Processing
icmp4.c
Go to the documentation of this file.
1 /*
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:
6  *
7  * http://www.apache.org/licenses/LICENSE-2.0
8  *
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.
14  */
15 /*
16  * ip/icmp4.c: ipv4 icmp
17  *
18  * Copyright (c) 2008 Eliot Dresselhaus
19  *
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:
27  *
28  * The above copyright notice and this permission notice shall be
29  * included in all copies or substantial portions of the Software.
30  *
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.
38  */
39 
40 #include <vlib/vlib.h>
41 #include <vnet/ip/ip.h>
42 #include <vnet/pg/pg.h>
43 
44 
45 static char *icmp_error_strings[] = {
46 #define _(f,s) s,
48 #undef _
49 };
50 
51 static u8 *
52 format_ip4_icmp_type_and_code (u8 * s, va_list * args)
53 {
54  icmp4_type_t type = va_arg (*args, int);
55  u8 code = va_arg (*args, int);
56  char *t = 0;
57 
58 #define _(n,f) case n: t = #f; break;
59 
60  switch (type)
61  {
63 
64  default:
65  break;
66  }
67 
68 #undef _
69 
70  if (!t)
71  return format (s, "unknown 0x%x", type);
72 
73  s = format (s, "%s", t);
74 
75  t = 0;
76  switch ((type << 8) | code)
77  {
78 #define _(a,n,f) case (ICMP4_##a << 8) | (n): t = #f; break;
79 
81 
82 #undef _
83  }
84 
85  if (t)
86  s = format (s, " %s", t);
87 
88  return s;
89 }
90 
91 static u8 *
92 format_ip4_icmp_header (u8 * s, va_list * args)
93 {
94  icmp46_header_t *icmp = va_arg (*args, icmp46_header_t *);
95  u32 max_header_bytes = va_arg (*args, u32);
96 
97  /* Nothing to do. */
98  if (max_header_bytes < sizeof (icmp[0]))
99  return format (s, "ICMP header truncated");
100 
101  s = format (s, "ICMP %U checksum 0x%x",
102  format_ip4_icmp_type_and_code, icmp->type, icmp->code,
103  clib_net_to_host_u16 (icmp->checksum));
104 
105  return s;
106 }
107 
108 static u8 *
109 format_icmp_input_trace (u8 * s, va_list * va)
110 {
111  CLIB_UNUSED (vlib_main_t * vm) = va_arg (*va, vlib_main_t *);
112  CLIB_UNUSED (vlib_node_t * node) = va_arg (*va, vlib_node_t *);
113  icmp_input_trace_t *t = va_arg (*va, icmp_input_trace_t *);
114 
115  s = format (s, "%U",
116  format_ip4_header, t->packet_data, sizeof (t->packet_data));
117 
118  return s;
119 }
120 
121 typedef enum
122 {
126 
127 typedef struct
128 {
130 
132 
133  /* Vector dispatch table indexed by [icmp type]. */
134  u8 ip4_input_next_index_by_type[256];
135 } icmp4_main_t;
136 
138 
139 static uword
141  vlib_node_runtime_t * node, vlib_frame_t * frame)
142 {
143  icmp4_main_t *im = &icmp4_main;
144  uword n_packets = frame->n_vectors;
145  u32 *from, *to_next;
146  u32 n_left_from, n_left_to_next, next;
147 
148  from = vlib_frame_vector_args (frame);
149  n_left_from = n_packets;
150  next = node->cached_next_index;
151 
152  if (node->flags & VLIB_NODE_FLAG_TRACE)
153  vlib_trace_frame_buffers_only (vm, node, from, frame->n_vectors,
154  /* stride */ 1,
155  sizeof (icmp_input_trace_t));
156 
157  while (n_left_from > 0)
158  {
159  vlib_get_next_frame (vm, node, next, to_next, n_left_to_next);
160 
161  while (n_left_from > 0 && n_left_to_next > 0)
162  {
163  vlib_buffer_t *p0;
164  ip4_header_t *ip0;
165  icmp46_header_t *icmp0;
166  icmp4_type_t type0;
167  u32 bi0, next0;
168 
169  if (PREDICT_TRUE (n_left_from > 2))
170  {
171  vlib_prefetch_buffer_with_index (vm, from[2], LOAD);
172  p0 = vlib_get_buffer (vm, from[1]);
173  ip0 = vlib_buffer_get_current (p0);
175  }
176 
177  bi0 = to_next[0] = from[0];
178 
179  from += 1;
180  n_left_from -= 1;
181  to_next += 1;
182  n_left_to_next -= 1;
183 
184  p0 = vlib_get_buffer (vm, bi0);
185  ip0 = vlib_buffer_get_current (p0);
186  icmp0 = ip4_next_header (ip0);
187  type0 = icmp0->type;
188  next0 = im->ip4_input_next_index_by_type[type0];
189 
190  p0->error = node->errors[ICMP4_ERROR_UNKNOWN_TYPE];
191  if (PREDICT_FALSE (next0 != next))
192  {
193  vlib_put_next_frame (vm, node, next, n_left_to_next + 1);
194  next = next0;
195  vlib_get_next_frame (vm, node, next, to_next, n_left_to_next);
196  to_next[0] = bi0;
197  to_next += 1;
198  n_left_to_next -= 1;
199  }
200  }
201 
202  vlib_put_next_frame (vm, node, next, n_left_to_next);
203  }
204 
205  return frame->n_vectors;
206 }
207 
208 /* *INDENT-OFF* */
210  .function = ip4_icmp_input,
211  .name = "ip4-icmp-input",
212 
213  .vector_size = sizeof (u32),
214 
215  .format_trace = format_icmp_input_trace,
216 
217  .n_errors = ARRAY_LEN (icmp_error_strings),
218  .error_strings = icmp_error_strings,
219 
220  .n_next_nodes = 1,
221  .next_nodes = {
222  [ICMP_INPUT_NEXT_ERROR] = "ip4-punt",
223  },
224 };
225 /* *INDENT-ON* */
226 
227 static uword
229  vlib_node_runtime_t * node, vlib_frame_t * frame)
230 {
231  uword n_packets = frame->n_vectors;
232  u32 *from, *to_next;
233  u32 n_left_from, n_left_to_next, next;
234  ip4_main_t *i4m = &ip4_main;
235  u16 *fragment_ids, *fid;
236  u8 host_config_ttl = i4m->host_config.ttl;
237 
238  from = vlib_frame_vector_args (frame);
239  n_left_from = n_packets;
240  next = node->cached_next_index;
241 
242  if (node->flags & VLIB_NODE_FLAG_TRACE)
243  vlib_trace_frame_buffers_only (vm, node, from, frame->n_vectors,
244  /* stride */ 1,
245  sizeof (icmp_input_trace_t));
246 
247  /* Get random fragment IDs for replies. */
248  fid = fragment_ids = clib_random_buffer_get_data (&vm->random_buffer,
249  n_packets *
250  sizeof (fragment_ids[0]));
251 
252  while (n_left_from > 0)
253  {
254  vlib_get_next_frame (vm, node, next, to_next, n_left_to_next);
255 
256  while (n_left_from > 2 && n_left_to_next > 2)
257  {
258  vlib_buffer_t *p0, *p1;
259  ip4_header_t *ip0, *ip1;
260  icmp46_header_t *icmp0, *icmp1;
261  u32 bi0, src0, dst0;
262  u32 bi1, src1, dst1;
263  ip_csum_t sum0, sum1;
264 
265  bi0 = to_next[0] = from[0];
266  bi1 = to_next[1] = from[1];
267 
268  from += 2;
269  n_left_from -= 2;
270  to_next += 2;
271  n_left_to_next -= 2;
272 
273  p0 = vlib_get_buffer (vm, bi0);
274  p1 = vlib_get_buffer (vm, bi1);
275  ip0 = vlib_buffer_get_current (p0);
276  ip1 = vlib_buffer_get_current (p1);
277  icmp0 = ip4_next_header (ip0);
278  icmp1 = ip4_next_header (ip1);
279 
280  vnet_buffer (p0)->sw_if_index[VLIB_RX] =
282  vnet_buffer (p1)->sw_if_index[VLIB_RX] =
284 
285  /* Update ICMP checksum. */
286  sum0 = icmp0->checksum;
287  sum1 = icmp1->checksum;
288 
289  ASSERT (icmp0->type == ICMP4_echo_request);
290  ASSERT (icmp1->type == ICMP4_echo_request);
291  sum0 = ip_csum_update (sum0, ICMP4_echo_request, ICMP4_echo_reply,
292  icmp46_header_t, type);
293  sum1 = ip_csum_update (sum1, ICMP4_echo_request, ICMP4_echo_reply,
294  icmp46_header_t, type);
295  icmp0->type = ICMP4_echo_reply;
296  icmp1->type = ICMP4_echo_reply;
297 
298  icmp0->checksum = ip_csum_fold (sum0);
299  icmp1->checksum = ip_csum_fold (sum1);
300 
301  src0 = ip0->src_address.data_u32;
302  src1 = ip1->src_address.data_u32;
303  dst0 = ip0->dst_address.data_u32;
304  dst1 = ip1->dst_address.data_u32;
305 
306  /* Swap source and destination address.
307  Does not change checksum. */
308  ip0->src_address.data_u32 = dst0;
309  ip1->src_address.data_u32 = dst1;
310  ip0->dst_address.data_u32 = src0;
311  ip1->dst_address.data_u32 = src1;
312 
313  /* Update IP checksum. */
314  sum0 = ip0->checksum;
315  sum1 = ip1->checksum;
316 
317  sum0 = ip_csum_update (sum0, ip0->ttl, host_config_ttl,
318  ip4_header_t, ttl);
319  sum1 = ip_csum_update (sum1, ip1->ttl, host_config_ttl,
320  ip4_header_t, ttl);
321  ip0->ttl = host_config_ttl;
322  ip1->ttl = host_config_ttl;
323 
324  /* New fragment id. */
325  sum0 = ip_csum_update (sum0, ip0->fragment_id, fid[0],
326  ip4_header_t, fragment_id);
327  sum1 = ip_csum_update (sum1, ip1->fragment_id, fid[1],
328  ip4_header_t, fragment_id);
329  ip0->fragment_id = fid[0];
330  ip1->fragment_id = fid[1];
331  fid += 2;
332 
333  ip0->checksum = ip_csum_fold (sum0);
334  ip1->checksum = ip_csum_fold (sum1);
335 
336  ASSERT (ip0->checksum == ip4_header_checksum (ip0));
337  ASSERT (ip1->checksum == ip4_header_checksum (ip1));
338 
339  p0->flags |= VNET_BUFFER_F_LOCALLY_ORIGINATED;
340  p1->flags |= VNET_BUFFER_F_LOCALLY_ORIGINATED;
341  }
342 
343  while (n_left_from > 0 && n_left_to_next > 0)
344  {
345  vlib_buffer_t *p0;
346  ip4_header_t *ip0;
347  icmp46_header_t *icmp0;
348  u32 bi0, src0, dst0;
349  ip_csum_t sum0;
350 
351  bi0 = to_next[0] = from[0];
352 
353  from += 1;
354  n_left_from -= 1;
355  to_next += 1;
356  n_left_to_next -= 1;
357 
358  p0 = vlib_get_buffer (vm, bi0);
359  ip0 = vlib_buffer_get_current (p0);
360  icmp0 = ip4_next_header (ip0);
361 
362  vnet_buffer (p0)->sw_if_index[VLIB_RX] =
364 
365  /* Update ICMP checksum. */
366  sum0 = icmp0->checksum;
367 
368  ASSERT (icmp0->type == ICMP4_echo_request);
369  sum0 = ip_csum_update (sum0, ICMP4_echo_request, ICMP4_echo_reply,
370  icmp46_header_t, type);
371  icmp0->type = ICMP4_echo_reply;
372  icmp0->checksum = ip_csum_fold (sum0);
373 
374  src0 = ip0->src_address.data_u32;
375  dst0 = ip0->dst_address.data_u32;
376  ip0->src_address.data_u32 = dst0;
377  ip0->dst_address.data_u32 = src0;
378 
379  /* Update IP checksum. */
380  sum0 = ip0->checksum;
381 
382  sum0 = ip_csum_update (sum0, ip0->ttl, host_config_ttl,
383  ip4_header_t, ttl);
384  ip0->ttl = host_config_ttl;
385 
386  sum0 = ip_csum_update (sum0, ip0->fragment_id, fid[0],
387  ip4_header_t, fragment_id);
388  ip0->fragment_id = fid[0];
389  fid += 1;
390 
391  ip0->checksum = ip_csum_fold (sum0);
392 
393  ASSERT (ip0->checksum == ip4_header_checksum (ip0));
394 
395  p0->flags |= VNET_BUFFER_F_LOCALLY_ORIGINATED;
396  }
397 
398  vlib_put_next_frame (vm, node, next, n_left_to_next);
399  }
400 
402  ICMP4_ERROR_ECHO_REPLIES_SENT, frame->n_vectors);
403 
404  return frame->n_vectors;
405 }
406 
407 /* *INDENT-OFF* */
409  .function = ip4_icmp_echo_request,
410  .name = "ip4-icmp-echo-request",
411 
412  .vector_size = sizeof (u32),
413 
414  .format_trace = format_icmp_input_trace,
415 
416  .n_next_nodes = 1,
417  .next_nodes = {
418  [0] = "ip4-load-balance",
419  },
420 };
421 /* *INDENT-ON* */
422 
423 typedef enum
424 {
429 
430 void
432 {
433  vnet_buffer (b)->ip.icmp.type = type;
434  vnet_buffer (b)->ip.icmp.code = code;
435  vnet_buffer (b)->ip.icmp.data = data;
436 }
437 
438 static u8
440 {
441  switch (type)
442  {
443  case ICMP4_destination_unreachable:
444  return ICMP4_ERROR_DEST_UNREACH_SENT;
445  case ICMP4_time_exceeded:
446  return ICMP4_ERROR_TTL_EXPIRE_SENT;
447  case ICMP4_parameter_problem:
448  return ICMP4_ERROR_PARAM_PROBLEM_SENT;
449  default:
450  return ICMP4_ERROR_DROP;
451  }
452 }
453 
454 static uword
456  vlib_node_runtime_t * node, vlib_frame_t * frame)
457 {
458  u32 *from, *to_next;
459  uword n_left_from, n_left_to_next;
460  ip4_icmp_error_next_t next_index;
461  ip4_main_t *im = &ip4_main;
462  ip_lookup_main_t *lm = &im->lookup_main;
463 
464  from = vlib_frame_vector_args (frame);
465  n_left_from = frame->n_vectors;
466  next_index = node->cached_next_index;
467 
468  if (node->flags & VLIB_NODE_FLAG_TRACE)
469  vlib_trace_frame_buffers_only (vm, node, from, frame->n_vectors,
470  /* stride */ 1,
471  sizeof (icmp_input_trace_t));
472 
473  while (n_left_from > 0)
474  {
475  vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next);
476 
477  while (n_left_from > 0 && n_left_to_next > 0)
478  {
479  /*
480  * Duplicate first buffer and free the original chain. Keep
481  * as much of the original packet as possible, within the
482  * minimum MTU. We chat "a little" here by keeping whatever
483  * is available in the first buffer.
484  */
485 
486  u32 pi0 = ~0;
487  u32 org_pi0 = from[0];
489  u8 error0 = ICMP4_ERROR_NONE;
490  vlib_buffer_t *p0, *org_p0;
491  ip4_header_t *ip0, *out_ip0;
492  icmp46_header_t *icmp0;
493  u32 sw_if_index0, if_add_index0;
494  ip_csum_t sum;
495 
496  org_p0 = vlib_get_buffer (vm, org_pi0);
497  p0 = vlib_buffer_copy_no_chain (vm, org_p0, &pi0);
498  if (!p0 || pi0 == ~0) /* Out of buffers */
499  continue;
500 
501  /* Speculatively enqueue p0 to the current next frame */
502  to_next[0] = pi0;
503  from += 1;
504  to_next += 1;
505  n_left_from -= 1;
506  n_left_to_next -= 1;
507 
508  ip0 = vlib_buffer_get_current (p0);
509  sw_if_index0 = vnet_buffer (p0)->sw_if_index[VLIB_RX];
510 
511  /* Add IP header and ICMPv4 header including a 4 byte data field */
513  -sizeof (ip4_header_t) -
514  sizeof (icmp46_header_t) - 4);
515 
516  p0->current_length =
517  p0->current_length > 576 ? 576 : p0->current_length;
518  out_ip0 = vlib_buffer_get_current (p0);
519  icmp0 = (icmp46_header_t *) & out_ip0[1];
520 
521  /* Fill ip header fields */
522  out_ip0->ip_version_and_header_length = 0x45;
523  out_ip0->tos = 0;
524  out_ip0->length = clib_host_to_net_u16 (p0->current_length);
525  out_ip0->fragment_id = 0;
526  out_ip0->flags_and_fragment_offset = 0;
527  out_ip0->ttl = 0xff;
528  out_ip0->protocol = IP_PROTOCOL_ICMP;
529  out_ip0->dst_address = ip0->src_address;
530  if_add_index0 = ~0;
532  > sw_if_index0))
533  if_add_index0 =
534  lm->if_address_pool_index_by_sw_if_index[sw_if_index0];
535  if (PREDICT_TRUE (if_add_index0 != ~0))
536  {
537  ip_interface_address_t *if_add =
538  pool_elt_at_index (lm->if_address_pool, if_add_index0);
539  ip4_address_t *if_ip =
541  out_ip0->src_address = *if_ip;
542  }
543  else
544  {
545  /* interface has no IP4 address - should not happen */
546  next0 = IP4_ICMP_ERROR_NEXT_DROP;
547  error0 = ICMP4_ERROR_DROP;
548  }
549  out_ip0->checksum = ip4_header_checksum (out_ip0);
550 
551  /* Fill icmp header fields */
552  icmp0->type = vnet_buffer (p0)->ip.icmp.type;
553  icmp0->code = vnet_buffer (p0)->ip.icmp.code;
554  *((u32 *) (icmp0 + 1)) =
555  clib_host_to_net_u32 (vnet_buffer (p0)->ip.icmp.data);
556  icmp0->checksum = 0;
557  sum =
558  ip_incremental_checksum (0, icmp0,
559  p0->current_length -
560  sizeof (ip4_header_t));
561  icmp0->checksum = ~ip_csum_fold (sum);
562 
563  /* Update error status */
564  if (error0 == ICMP4_ERROR_NONE)
565  error0 = icmp4_icmp_type_to_error (icmp0->type);
566 
567  vlib_error_count (vm, node->node_index, error0, 1);
568 
569  /* Verify speculative enqueue, maybe switch current next frame */
570  vlib_validate_buffer_enqueue_x1 (vm, node, next_index,
571  to_next, n_left_to_next,
572  pi0, next0);
573  }
574  vlib_put_next_frame (vm, node, next_index, n_left_to_next);
575  }
576 
577  /*
578  * push the original buffers to error-drop, so that
579  * they can get the error counters handled, then freed
580  */
582  vlib_frame_vector_args (frame),
584  frame->n_vectors);
585 
586  return frame->n_vectors;
587 }
588 
589 /* *INDENT-OFF* */
591  .function = ip4_icmp_error,
592  .name = "ip4-icmp-error",
593  .vector_size = sizeof (u32),
594 
595  .n_errors = ARRAY_LEN (icmp_error_strings),
596  .error_strings = icmp_error_strings,
597 
598  .n_next_nodes = IP4_ICMP_ERROR_N_NEXT,
599  .next_nodes = {
600  [IP4_ICMP_ERROR_NEXT_DROP] = "ip4-drop",
601  [IP4_ICMP_ERROR_NEXT_LOOKUP] = "ip4-lookup",
602  },
603 
604  .format_trace = format_icmp_input_trace,
605 };
606 /* *INDENT-ON* */
607 
608 
609 static uword
611 {
612  icmp46_header_t *h = va_arg (*args, icmp46_header_t *);
613  icmp4_main_t *cm = &icmp4_main;
614  u32 i;
615 
617  cm->type_and_code_by_name, &i))
618  {
619  h->type = (i >> 8) & 0xff;
620  h->code = (i >> 0) & 0xff;
621  }
623  cm->type_by_name, &i))
624  {
625  h->type = i;
626  h->code = 0;
627  }
628  else
629  return 0;
630 
631  return 1;
632 }
633 
634 static void
636  pg_stream_t * s,
637  pg_edit_group_t * g, u32 * packets, u32 n_packets)
638 {
640  u32 ip_offset, icmp_offset;
641 
642  icmp_offset = g->start_byte_offset;
643  ip_offset = (g - 1)->start_byte_offset;
644 
645  while (n_packets >= 1)
646  {
647  vlib_buffer_t *p0;
648  ip4_header_t *ip0;
649  icmp46_header_t *icmp0;
650  u32 len0;
651 
652  p0 = vlib_get_buffer (vm, packets[0]);
653  n_packets -= 1;
654  packets += 1;
655 
656  ASSERT (p0->current_data == 0);
657  ip0 = (void *) (p0->data + ip_offset);
658  icmp0 = (void *) (p0->data + icmp_offset);
659 
660  /* if IP length has been specified, then calculate the length based on buffer */
661  if (ip0->length == 0)
662  len0 = vlib_buffer_length_in_chain (vm, p0) - icmp_offset;
663  else
664  len0 = clib_net_to_host_u16 (ip0->length) - icmp_offset;
665 
666  icmp0->checksum =
667  ~ip_csum_fold (ip_incremental_checksum (0, icmp0, len0));
668  }
669 }
670 
671 typedef struct
672 {
676 
677 always_inline void
679 {
680  /* Initialize fields that are not bit fields in the IP header. */
681 #define _(f) pg_edit_init (&p->f, icmp46_header_t, f);
682  _(type);
683  _(code);
684  _(checksum);
685 #undef _
686 }
687 
688 static uword
689 unformat_pg_icmp_header (unformat_input_t * input, va_list * args)
690 {
691  pg_stream_t *s = va_arg (*args, pg_stream_t *);
693  u32 group_index;
694 
695  p = pg_create_edit_group (s, sizeof (p[0]), sizeof (icmp46_header_t),
696  &group_index);
698 
700 
701  {
702  icmp46_header_t tmp;
703 
704  if (!unformat (input, "ICMP %U", unformat_icmp_type_and_code, &tmp))
705  goto error;
706 
707  pg_edit_set_fixed (&p->type, tmp.type);
708  pg_edit_set_fixed (&p->code, tmp.code);
709  }
710 
711  /* Parse options. */
712  while (1)
713  {
714  if (unformat (input, "checksum %U",
716  ;
717 
718  /* Can't parse input: try next protocol level. */
719  else
720  break;
721  }
722 
723  if (!unformat_user (input, unformat_pg_payload, s))
724  goto error;
725 
727  {
728  pg_edit_group_t *g = pg_stream_get_group (s, group_index);
730  g->edit_function_opaque = 0;
731  }
732 
733  return 1;
734 
735 error:
736  /* Free up any edits we may have added. */
737  pg_free_edit_group (s);
738  return 0;
739 }
740 
741 void
743 {
744  icmp4_main_t *im = &icmp4_main;
745 
746  ASSERT ((int) type < ARRAY_LEN (im->ip4_input_next_index_by_type));
748  = vlib_node_add_next (vm, ip4_icmp_input_node.index, node_index);
749 }
750 
751 static clib_error_t *
753 {
754  ip_main_t *im = &ip_main;
755  ip_protocol_info_t *pi;
756  icmp4_main_t *cm = &icmp4_main;
757  clib_error_t *error;
758 
760 
761  if (error)
762  return error;
763 
764  pi = ip_get_protocol_info (im, IP_PROTOCOL_ICMP);
767 
768  cm->type_by_name = hash_create_string (0, sizeof (uword));
769 #define _(n,t) hash_set_mem (cm->type_by_name, #t, (n));
771 #undef _
772 
773  cm->type_and_code_by_name = hash_create_string (0, sizeof (uword));
774 #define _(a,n,t) hash_set_mem (cm->type_by_name, #t, (n) | (ICMP4_##a << 8));
776 #undef _
777 
780  sizeof (cm->ip4_input_next_index_by_type));
781 
782  ip4_icmp_register_type (vm, ICMP4_echo_request,
784 
785  return 0;
786 }
787 
789 
790 /*
791  * fd.io coding-style-patch-verification: ON
792  *
793  * Local Variables:
794  * eval: (c-set-style "gnu")
795  * End:
796  */
u32 flags
buffer flags: VLIB_BUFFER_FREE_LIST_INDEX_MASK: bits used to store free list index, VLIB_BUFFER_IS_TRACED: trace this buffer.
Definition: buffer.h:124
Definition: edit.h:64
ip4_icmp_error_next_t
Definition: icmp4.c:423
static uword ip4_icmp_error(vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame)
Definition: icmp4.c:455
#define CLIB_UNUSED(x)
Definition: clib.h:82
ip4_address_t src_address
Definition: ip4_packet.h:170
ip_interface_address_t * if_address_pool
Pool of addresses that are assigned to interfaces.
Definition: lookup.h:125
static u8 * format_icmp_input_trace(u8 *s, va_list *va)
Definition: icmp4.c:109
Definition: pg.h:313
static void pg_edit_set_fixed(pg_edit_t *e, u64 value)
Definition: edit.h:153
format_function_t format_ip4_header
Definition: format.h:83
#define PREDICT_TRUE(x)
Definition: clib.h:112
i16 current_data
signed offset in data[], pre_data[] that we are currently processing.
Definition: buffer.h:110
static void vlib_error_count(vlib_main_t *vm, uword node_index, uword counter, uword increment)
Definition: error_funcs.h:57
clib_memset(h->entries, 0, sizeof(h->entries[0]) *entries)
static void * clib_random_buffer_get_data(clib_random_buffer_t *b, uword n_bytes)
Definition: random_buffer.h:78
void(* edit_function)(struct pg_main_t *pg, struct pg_stream_t *s, struct pg_edit_group_t *g, u32 *buffers, u32 n_buffers)
Definition: pg.h:73
static char * icmp_error_strings[]
Definition: icmp4.c:45
u16 current_length
Nbytes between current data and the end of this buffer.
Definition: buffer.h:113
u8 data[0]
Packet data.
Definition: buffer.h:181
int i
uword unformat_user(unformat_input_t *input, unformat_function_t *func,...)
Definition: unformat.c:983
uword unformat_pg_edit(unformat_input_t *input, va_list *args)
Definition: edit.c:106
ip_lookup_main_t lookup_main
Definition: ip4.h:98
uword ip_csum_t
Definition: ip_packet.h:181
u8 * format(u8 *s, const char *fmt,...)
Definition: format.c:424
u16 flags_and_fragment_offset
Definition: ip4_packet.h:151
u8 data[128]
Definition: ipsec.api:248
Definition: ip.h:109
vlib_error_t * errors
Vector of errors for this node.
Definition: node.h:468
static uword vlib_buffer_length_in_chain(vlib_main_t *vm, vlib_buffer_t *b)
Get length in bytes of the buffer chain.
Definition: buffer_funcs.h:366
pg_edit_t code
Definition: icmp4.c:673
static uword vlib_node_add_next(vlib_main_t *vm, uword node, uword next_node)
Definition: node_funcs.h:1092
unsigned char u8
Definition: types.h:56
u32 start_byte_offset
Definition: pg.h:67
static pg_edit_group_t * pg_stream_get_group(pg_stream_t *s, u32 group_index)
Definition: pg.h:222
unformat_function_t * unformat_pg_edit
Definition: ip.h:90
#define vlib_prefetch_buffer_with_index(vm, bi, type)
Prefetch buffer metadata by buffer index The first 64 bytes of buffer contains most header informatio...
Definition: buffer_funcs.h:440
#define VLIB_INIT_FUNCTION(x)
Definition: init.h:163
u32 local_interface_sw_if_index
Definition: vnet.h:54
#define always_inline
Definition: clib.h:98
static uword unformat_icmp_type_and_code(unformat_input_t *input, va_list *args)
Definition: icmp4.c:610
ip4_address_t dst_address
Definition: ip4_packet.h:170
uword unformat_pg_payload(unformat_input_t *input, va_list *args)
Definition: edit.c:127
pg_edit_type_t type
Definition: edit.h:66
static_always_inline void vlib_buffer_enqueue_to_single_next(vlib_main_t *vm, vlib_node_runtime_t *node, u32 *buffers, u16 next_index, u32 count)
Definition: buffer_node.h:452
static void * ip4_next_header(ip4_header_t *i)
Definition: ip4_packet.h:241
unsigned int u32
Definition: types.h:88
static void * pg_create_edit_group(pg_stream_t *s, int n_edit_bytes, int n_packet_bytes, u32 *group_index)
Definition: pg.h:228
#define vlib_call_init_function(vm, x)
Definition: init.h:260
struct ip4_main_t::@212 host_config
Template information for VPP generated packets.
#define hash_create_string(elts, value_bytes)
Definition: hash.h:690
vlib_error_t error
Error code for buffers to be enqueued to error handler.
Definition: buffer.h:136
void ip4_icmp_register_type(vlib_main_t *vm, icmp4_type_t type, u32 node_index)
Definition: icmp4.c:742
static clib_error_t * icmp4_init(vlib_main_t *vm)
Definition: icmp4.c:752
static vlib_buffer_t * vlib_buffer_copy_no_chain(vlib_main_t *vm, vlib_buffer_t *b, u32 *di)
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
Definition: pool.h:514
static ip_protocol_info_t * ip_get_protocol_info(ip_main_t *im, u32 protocol)
Definition: ip.h:136
pg_edit_t type
Definition: icmp4.c:673
format_function_t * format_header
Definition: ip.h:81
struct _unformat_input_t unformat_input_t
unsigned short u16
Definition: types.h:57
static void * vlib_buffer_get_current(vlib_buffer_t *b)
Get pointer to current data to process.
Definition: buffer.h:229
static uword unformat_pg_icmp_header(unformat_input_t *input, va_list *args)
Definition: icmp4.c:689
#define PREDICT_FALSE(x)
Definition: clib.h:111
vnet_main_t vnet_main
Definition: misc.c:43
static u8 * format_ip4_icmp_type_and_code(u8 *s, va_list *args)
Definition: icmp4.c:52
u32 node_index
Node index.
Definition: node.h:494
icmp4_main_t icmp4_main
Definition: icmp4.c:137
#define vlib_validate_buffer_enqueue_x1(vm, node, next_index, to_next, n_left_to_next, bi0, next0)
Finish enqueueing one buffer forward in the graph.
Definition: buffer_node.h:218
#define vlib_get_next_frame(vm, node, next_index, vectors, n_vectors_left)
Get pointer to next frame vector data by (vlib_node_runtime_t, next_index).
Definition: node_funcs.h:338
static void icmp4_pg_edit_function(pg_main_t *pg, pg_stream_t *s, pg_edit_group_t *g, u32 *packets, u32 n_packets)
Definition: icmp4.c:635
#define VLIB_REGISTER_NODE(x,...)
Definition: node.h:169
clib_error_t * ip_main_init(vlib_main_t *vm)
Definition: ip_init.c:45
u16 n_vectors
Definition: node.h:395
#define CLIB_PREFETCH(addr, size, type)
Definition: cache.h:80
vlib_main_t * vm
Definition: buffer.c:312
ip_main_t ip_main
Definition: ip_init.c:42
static u8 * format_ip4_icmp_header(u8 *s, va_list *args)
Definition: icmp4.c:92
void icmp4_error_set_vnet_buffer(vlib_buffer_t *b, u8 type, u8 code, u32 data)
Definition: icmp4.c:431
static ip_csum_t ip_incremental_checksum(ip_csum_t sum, void *_data, uword n_bytes)
Definition: ip_packet.h:254
uword * type_by_name
Definition: icmp4.c:131
uword * type_and_code_by_name
Definition: icmp4.c:129
icmp4_type_t
icmp_input_next_t
Definition: icmp4.c:121
#define ARRAY_LEN(x)
Definition: clib.h:62
void vlib_put_next_frame(vlib_main_t *vm, vlib_node_runtime_t *r, u32 next_index, u32 n_vectors_left)
Release pointer to next frame vector data.
Definition: main.c:458
static uword ip4_icmp_echo_request(vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame)
Definition: icmp4.c:228
pg_edit_t checksum
Definition: icmp4.c:674
u32 * if_address_pool_index_by_sw_if_index
Head of doubly linked list of interface addresses for each software interface.
Definition: lookup.h:132
u16 cached_next_index
Next frame index that vector arguments were last enqueued to last time this node ran.
Definition: node.h:513
#define ASSERT(truth)
static vlib_node_registration_t ip4_icmp_echo_request_node
(constructor) VLIB_REGISTER_NODE (ip4_icmp_echo_request_node)
Definition: icmp4.c:408
IPv4 main type.
Definition: ip4.h:96
uword unformat_vlib_number_by_name(unformat_input_t *input, va_list *args)
Definition: format.c:157
static void pg_free_edit_group(pg_stream_t *s)
Definition: pg.h:281
static void vlib_buffer_advance(vlib_buffer_t *b, word l)
Advance current data pointer by the supplied (signed!) amount.
Definition: buffer.h:248
uword edit_function_opaque
Definition: pg.h:79
Definition: pg.h:94
static vlib_main_t * vlib_get_main(void)
Definition: global_funcs.h:23
void vlib_trace_frame_buffers_only(vlib_main_t *vm, vlib_node_runtime_t *node, u32 *buffers, uword n_buffers, uword next_buffer_stride, uword n_buffer_data_bytes_in_trace)
Definition: trace.c:47
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
VLIB buffer representation.
Definition: buffer.h:102
u64 uword
Definition: types.h:112
static void * vlib_frame_vector_args(vlib_frame_t *f)
Get pointer to frame vector data.
Definition: node_funcs.h:244
#define ip_csum_update(sum, old, new, type, field)
Definition: ip_packet.h:231
vlib_node_registration_t ip4_icmp_error_node
(constructor) VLIB_REGISTER_NODE (ip4_icmp_error_node)
Definition: icmp4.c:590
uword unformat_pg_number(unformat_input_t *input, va_list *args)
Definition: edit.c:85
static vlib_node_registration_t ip4_icmp_input_node
(constructor) VLIB_REGISTER_NODE (ip4_icmp_input_node)
Definition: icmp4.c:209
#define vnet_buffer(b)
Definition: buffer.h:369
ip4_main_t ip4_main
Global ip4 main structure.
Definition: ip4_forward.c:905
u8 ip4_input_next_index_by_type[256]
Definition: icmp4.c:134
u16 flags
Copy of main node flags.
Definition: node.h:507
u8 packet_data[64]
Definition: icmp4.h:43
u8 ip_version_and_header_length
Definition: ip4_packet.h:138
static void * ip_interface_address_get_address(ip_lookup_main_t *lm, ip_interface_address_t *a)
Definition: lookup.h:175
static uword ip4_icmp_input(vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame)
Definition: icmp4.c:140
#define VLIB_NODE_FLAG_TRACE
Definition: node.h:301
static u8 icmp4_icmp_type_to_error(u8 type)
Definition: icmp4.c:439
#define CLIB_CACHE_LINE_BYTES
Definition: cache.h:59
static void pg_icmp_header_init(pg_icmp46_header_t *p)
Definition: icmp4.c:678
u8 ttl
TTL to use for host generated packets.
Definition: ip4.h:145
static vlib_buffer_t * vlib_get_buffer(vlib_main_t *vm, u32 buffer_index)
Translate buffer index into buffer pointer.
Definition: buffer_funcs.h:85
static u16 ip4_header_checksum(ip4_header_t *i)
Definition: ip4_packet.h:247
clib_random_buffer_t random_buffer
Definition: main.h:191
static u16 ip_csum_fold(ip_csum_t c)
Definition: ip_packet.h:237
uword unformat(unformat_input_t *i, const char *fmt,...)
Definition: unformat.c:972
Definition: defs.h:46