FD.io VPP  v19.01.3-6-g70449b9b9
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  u32 pi0 = from[0];
481  u8 error0 = ICMP4_ERROR_NONE;
482  vlib_buffer_t *p0;
483  ip4_header_t *ip0, *out_ip0;
484  icmp46_header_t *icmp0;
485  u32 sw_if_index0, if_add_index0;
486  ip_csum_t sum;
487 
488  /* Speculatively enqueue p0 to the current next frame */
489  to_next[0] = pi0;
490  from += 1;
491  to_next += 1;
492  n_left_from -= 1;
493  n_left_to_next -= 1;
494 
495  p0 = vlib_get_buffer (vm, pi0);
496  ip0 = vlib_buffer_get_current (p0);
497  sw_if_index0 = vnet_buffer (p0)->sw_if_index[VLIB_RX];
498 
499  /*
500  * RFC1812 says to keep as much of the original packet as
501  * possible within the minimum MTU (576). We cheat "a little"
502  * here by keeping whatever fits in the first buffer, to be more
503  * efficient
504  */
506  {
507  /* clear current_length of all other buffers in chain */
508  vlib_buffer_t *b = p0;
510  while (b->flags & VLIB_BUFFER_NEXT_PRESENT)
511  {
512  b = vlib_get_buffer (vm, b->next_buffer);
513  b->current_length = 0;
514  }
515  }
516 
517  /* Add IP header and ICMPv4 header including a 4 byte data field */
519  -sizeof (ip4_header_t) -
520  sizeof (icmp46_header_t) - 4);
521 
522  p0->current_length =
523  p0->current_length > 576 ? 576 : p0->current_length;
524 
525  out_ip0 = vlib_buffer_get_current (p0);
526  icmp0 = (icmp46_header_t *) & out_ip0[1];
527 
528  /* Fill ip header fields */
529  out_ip0->ip_version_and_header_length = 0x45;
530  out_ip0->tos = 0;
531  out_ip0->length = clib_host_to_net_u16 (p0->current_length);
532  out_ip0->fragment_id = 0;
533  out_ip0->flags_and_fragment_offset = 0;
534  out_ip0->ttl = 0xff;
535  out_ip0->protocol = IP_PROTOCOL_ICMP;
536  out_ip0->dst_address = ip0->src_address;
537  if_add_index0 = ~0;
539  > sw_if_index0))
540  if_add_index0 =
541  lm->if_address_pool_index_by_sw_if_index[sw_if_index0];
542  if (PREDICT_TRUE (if_add_index0 != ~0))
543  {
544  ip_interface_address_t *if_add =
545  pool_elt_at_index (lm->if_address_pool, if_add_index0);
546  ip4_address_t *if_ip =
548  out_ip0->src_address = *if_ip;
549  }
550  else
551  {
552  /* interface has no IP4 address - should not happen */
553  next0 = IP4_ICMP_ERROR_NEXT_DROP;
554  error0 = ICMP4_ERROR_DROP;
555  }
556  out_ip0->checksum = ip4_header_checksum (out_ip0);
557 
558  /* Fill icmp header fields */
559  icmp0->type = vnet_buffer (p0)->ip.icmp.type;
560  icmp0->code = vnet_buffer (p0)->ip.icmp.code;
561  *((u32 *) (icmp0 + 1)) =
562  clib_host_to_net_u32 (vnet_buffer (p0)->ip.icmp.data);
563  icmp0->checksum = 0;
564  sum =
565  ip_incremental_checksum (0, icmp0,
566  p0->current_length -
567  sizeof (ip4_header_t));
568  icmp0->checksum = ~ip_csum_fold (sum);
569 
570  /* Update error status */
571  if (error0 == ICMP4_ERROR_NONE)
572  error0 = icmp4_icmp_type_to_error (icmp0->type);
573  vlib_error_count (vm, node->node_index, error0, 1);
574 
575  /* Verify speculative enqueue, maybe switch current next frame */
576  vlib_validate_buffer_enqueue_x1 (vm, node, next_index,
577  to_next, n_left_to_next,
578  pi0, next0);
579  }
580  vlib_put_next_frame (vm, node, next_index, n_left_to_next);
581  }
582 
583  return frame->n_vectors;
584 }
585 
586 /* *INDENT-OFF* */
588  .function = ip4_icmp_error,
589  .name = "ip4-icmp-error",
590  .vector_size = sizeof (u32),
591 
592  .n_errors = ARRAY_LEN (icmp_error_strings),
593  .error_strings = icmp_error_strings,
594 
595  .n_next_nodes = IP4_ICMP_ERROR_N_NEXT,
596  .next_nodes = {
597  [IP4_ICMP_ERROR_NEXT_DROP] = "ip4-drop",
598  [IP4_ICMP_ERROR_NEXT_LOOKUP] = "ip4-lookup",
599  },
600 
601  .format_trace = format_icmp_input_trace,
602 };
603 /* *INDENT-ON* */
604 
605 
606 static uword
608 {
609  icmp46_header_t *h = va_arg (*args, icmp46_header_t *);
610  icmp4_main_t *cm = &icmp4_main;
611  u32 i;
612 
614  cm->type_and_code_by_name, &i))
615  {
616  h->type = (i >> 8) & 0xff;
617  h->code = (i >> 0) & 0xff;
618  }
620  cm->type_by_name, &i))
621  {
622  h->type = i;
623  h->code = 0;
624  }
625  else
626  return 0;
627 
628  return 1;
629 }
630 
631 static void
633  pg_stream_t * s,
634  pg_edit_group_t * g, u32 * packets, u32 n_packets)
635 {
637  u32 ip_offset, icmp_offset;
638 
639  icmp_offset = g->start_byte_offset;
640  ip_offset = (g - 1)->start_byte_offset;
641 
642  while (n_packets >= 1)
643  {
644  vlib_buffer_t *p0;
645  ip4_header_t *ip0;
646  icmp46_header_t *icmp0;
647  u32 len0;
648 
649  p0 = vlib_get_buffer (vm, packets[0]);
650  n_packets -= 1;
651  packets += 1;
652 
653  ASSERT (p0->current_data == 0);
654  ip0 = (void *) (p0->data + ip_offset);
655  icmp0 = (void *) (p0->data + icmp_offset);
656 
657  /* if IP length has been specified, then calculate the length based on buffer */
658  if (ip0->length == 0)
659  len0 = vlib_buffer_length_in_chain (vm, p0) - icmp_offset;
660  else
661  len0 = clib_net_to_host_u16 (ip0->length) - icmp_offset;
662 
663  icmp0->checksum =
664  ~ip_csum_fold (ip_incremental_checksum (0, icmp0, len0));
665  }
666 }
667 
668 typedef struct
669 {
673 
674 always_inline void
676 {
677  /* Initialize fields that are not bit fields in the IP header. */
678 #define _(f) pg_edit_init (&p->f, icmp46_header_t, f);
679  _(type);
680  _(code);
681  _(checksum);
682 #undef _
683 }
684 
685 static uword
686 unformat_pg_icmp_header (unformat_input_t * input, va_list * args)
687 {
688  pg_stream_t *s = va_arg (*args, pg_stream_t *);
690  u32 group_index;
691 
692  p = pg_create_edit_group (s, sizeof (p[0]), sizeof (icmp46_header_t),
693  &group_index);
695 
697 
698  {
699  icmp46_header_t tmp;
700 
701  if (!unformat (input, "ICMP %U", unformat_icmp_type_and_code, &tmp))
702  goto error;
703 
704  pg_edit_set_fixed (&p->type, tmp.type);
705  pg_edit_set_fixed (&p->code, tmp.code);
706  }
707 
708  /* Parse options. */
709  while (1)
710  {
711  if (unformat (input, "checksum %U",
713  ;
714 
715  /* Can't parse input: try next protocol level. */
716  else
717  break;
718  }
719 
720  if (!unformat_user (input, unformat_pg_payload, s))
721  goto error;
722 
724  {
725  pg_edit_group_t *g = pg_stream_get_group (s, group_index);
727  g->edit_function_opaque = 0;
728  }
729 
730  return 1;
731 
732 error:
733  /* Free up any edits we may have added. */
734  pg_free_edit_group (s);
735  return 0;
736 }
737 
738 void
740 {
741  icmp4_main_t *im = &icmp4_main;
742 
743  ASSERT ((int) type < ARRAY_LEN (im->ip4_input_next_index_by_type));
745  = vlib_node_add_next (vm, ip4_icmp_input_node.index, node_index);
746 }
747 
748 static clib_error_t *
750 {
751  ip_main_t *im = &ip_main;
752  ip_protocol_info_t *pi;
753  icmp4_main_t *cm = &icmp4_main;
754  clib_error_t *error;
755 
757 
758  if (error)
759  return error;
760 
761  pi = ip_get_protocol_info (im, IP_PROTOCOL_ICMP);
764 
765  cm->type_by_name = hash_create_string (0, sizeof (uword));
766 #define _(n,t) hash_set_mem (cm->type_by_name, #t, (n));
768 #undef _
769 
770  cm->type_and_code_by_name = hash_create_string (0, sizeof (uword));
771 #define _(a,n,t) hash_set_mem (cm->type_by_name, #t, (n) | (ICMP4_##a << 8));
773 #undef _
774 
777  sizeof (cm->ip4_input_next_index_by_type));
778 
779  ip4_icmp_register_type (vm, ICMP4_echo_request,
781 
782  return 0;
783 }
784 
786 
787 /*
788  * fd.io coding-style-patch-verification: ON
789  *
790  * Local Variables:
791  * eval: (c-set-style "gnu")
792  * End:
793  */
Definition: edit.h:64
struct ip4_main_t::@202 host_config
Template information for VPP generated packets.
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:314
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
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
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:419
u16 flags_and_fragment_offset
Definition: ip4_packet.h:151
Definition: ip.h:109
vlib_error_t * errors
Vector of errors for this node.
Definition: node.h:493
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:267
pg_edit_t code
Definition: icmp4.c:670
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:223
unformat_function_t * unformat_pg_edit
Definition: ip.h:90
i16 current_data
signed offset in data[], pre_data[] that we are currently processing.
Definition: buffer.h:110
#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:341
#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:607
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 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:229
#define vlib_call_init_function(vm, x)
Definition: init.h:260
#define hash_create_string(elts, value_bytes)
Definition: hash.h:690
void ip4_icmp_register_type(vlib_main_t *vm, icmp4_type_t type, u32 node_index)
Definition: icmp4.c:739
static clib_error_t * icmp4_init(vlib_main_t *vm)
Definition: icmp4.c:749
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
Definition: pool.h:511
static ip_protocol_info_t * ip_get_protocol_info(ip_main_t *im, u32 protocol)
Definition: ip.h:136
u16 current_length
Nbytes between current data and the end of this buffer.
Definition: buffer.h:114
pg_edit_t type
Definition: icmp4.c:670
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:214
static uword unformat_pg_icmp_header(unformat_input_t *input, va_list *args)
Definition: icmp4.c:686
#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:518
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
vlib_error_t error
Error code for buffers to be enqueued to error handler.
Definition: buffer.h:139
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:632
#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:420
#define CLIB_PREFETCH(addr, size, type)
Definition: cache.h:79
vlib_main_t * vm
Definition: buffer.c:301
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:452
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:671
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:537
#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
u32 next_buffer
Next buffer for this linked-list of buffers.
Definition: buffer.h:130
static void pg_free_edit_group(pg_stream_t *s)
Definition: pg.h:282
static void vlib_buffer_advance(vlib_buffer_t *b, word l)
Advance current data pointer by the supplied (signed!) amount.
Definition: buffer.h:233
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
u32 total_length_not_including_first_buffer
Only valid for first buffer in chain.
Definition: buffer.h:156
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)
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:587
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:368
ip4_main_t ip4_main
Global ip4 main structure.
Definition: ip4_forward.c:903
u8 data[0]
Packet data.
Definition: buffer.h:176
u8 ip4_input_next_index_by_type[256]
Definition: icmp4.c:134
u16 flags
Copy of main node flags.
Definition: node.h:531
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:326
static u8 icmp4_icmp_type_to_error(u8 type)
Definition: icmp4.c:439
#define CLIB_CACHE_LINE_BYTES
Definition: cache.h:59
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:117
static void pg_icmp_header_init(pg_icmp46_header_t *p)
Definition: icmp4.c:675
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:62
static u16 ip4_header_checksum(ip4_header_t *i)
Definition: ip4_packet.h:247
clib_random_buffer_t random_buffer
Definition: main.h:173
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