FD.io VPP  v17.01-9-ge7dcee4
Vector Packet Processing
mac_swap.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 #include <vlib/vlib.h>
16 #include <vnet/pg/pg.h>
17 #include <vnet/ethernet/ethernet.h>
18 #include <vppinfra/error.h>
19 #include <vnet/devices/pci/ige.h>
20 #include <vnet/devices/pci/ixge.h>
21 #include <vnet/devices/pci/ixgev.h>
22 
23 typedef struct
24 {
27 
28  /* Hash table to map sw_if_index to next node index */
30 
31  /* convenience */
35 
36 typedef struct
37 {
38  u8 src[6];
39  u8 dst[6];
42 } swap_trace_t;
43 
44 /* packet trace format function */
45 static u8 *
46 format_swap_trace (u8 * s, va_list * args)
47 {
48  CLIB_UNUSED (vlib_main_t * vm) = va_arg (*args, vlib_main_t *);
49  CLIB_UNUSED (vlib_node_t * node) = va_arg (*args, vlib_node_t *);
50  swap_trace_t *t = va_arg (*args, swap_trace_t *);
51 
52  s = format (s, "SWAP: dst now %U src now %U sw_if_index %d next_index %d",
55  return s;
56 }
57 
58 #define foreach_hw_driver_next \
59  _(IP4) \
60  _(IP6) \
61  _(ETHERNET)
62 
64 
66 
67 #define foreach_mac_swap_error \
68 _(SWAPS, "mac addresses swapped")
69 
70 typedef enum
71 {
72 #define _(sym,str) MAC_SWAP_ERROR_##sym,
74 #undef _
77 
78 static char *mac_swap_error_strings[] = {
79 #define _(sym,string) string,
81 #undef _
82 };
83 
84 /*
85  * To drop a pkt and increment one of the previous counters:
86  *
87  * set b0->error = error_node->errors[RANDOM_ERROR_SAMPLE];
88  * set next0 to a disposition index bound to "error-drop".
89  *
90  * To manually increment the specific counter MAC_SWAP_ERROR_SAMPLE:
91  *
92  * vlib_node_t *n = vlib_get_node (vm, mac_swap.index);
93  * u32 node_counter_base_index = n->error_heap_index;
94  * vlib_error_main_t * em = &vm->error_main;
95  * em->counters[node_counter_base_index + MAC_SWAP_ERROR_SAMPLE] += 1;
96  *
97  */
98 
99 typedef enum
100 {
104 
105 static uword
107  vlib_node_runtime_t * node, vlib_frame_t * frame)
108 {
109  u32 n_left_from, *from, *to_next;
110  mac_swap_next_t next_index;
112  vlib_node_t *n = vlib_get_node (vm, mac_swap_node.index);
113  u32 node_counter_base_index = n->error_heap_index;
114  vlib_error_main_t *em = &vm->error_main;
115 
116  from = vlib_frame_vector_args (frame);
117  n_left_from = frame->n_vectors;
118  next_index = node->cached_next_index;
119 
120  while (n_left_from > 0)
121  {
122  u32 n_left_to_next;
123 
124  vlib_get_next_frame (vm, node, next_index, to_next, n_left_to_next);
125 
126  while (n_left_from >= 4 && n_left_to_next >= 2)
127  {
128  u32 bi0, bi1;
129  vlib_buffer_t *b0, *b1;
130  u32 next0, next1;
131  u32 sw_if_index0, sw_if_index1;
132  uword *p0, *p1;
133  u64 tmp0a, tmp0b;
134  u64 tmp1a, tmp1b;
135  ethernet_header_t *h0, *h1;
136 
137 
138  /* Prefetch next iteration. */
139  {
140  vlib_buffer_t *p2, *p3;
141 
142  p2 = vlib_get_buffer (vm, from[2]);
143  p3 = vlib_get_buffer (vm, from[3]);
144 
145  vlib_prefetch_buffer_header (p2, LOAD);
146  vlib_prefetch_buffer_header (p3, LOAD);
147 
150  }
151 
152  to_next[0] = bi0 = from[0];
153  to_next[1] = bi1 = from[1];
154  from += 2;
155  to_next += 2;
156  n_left_from -= 2;
157  n_left_to_next -= 2;
158 
159  b0 = vlib_get_buffer (vm, bi0);
160  b1 = vlib_get_buffer (vm, bi1);
161 
162  sw_if_index0 = vnet_buffer (b0)->sw_if_index[VLIB_RX];
163  next0 = msm->cached_next_index;
164  sw_if_index1 = vnet_buffer (b1)->sw_if_index[VLIB_RX];
165  next1 = msm->cached_next_index;
166 
167  if (PREDICT_FALSE (msm->cached_sw_if_index != sw_if_index0))
168  {
169  p0 =
170  hash_get (msm->next_node_index_by_sw_if_index, sw_if_index0);
171  if (p0 == 0)
172  {
173  vnet_hw_interface_t *hw0;
174 
176  sw_if_index0);
177 
178  next0 = vlib_node_add_next (msm->vlib_main,
179  mac_swap_node.index,
180  hw0->output_node_index);
182  sw_if_index0, next0);
183  }
184  else
185  next0 = p0[0];
186  msm->cached_sw_if_index = sw_if_index0;
187  msm->cached_next_index = next0;
188  next1 = next0;
189  }
190  if (PREDICT_FALSE (msm->cached_sw_if_index != sw_if_index1))
191  {
192  p1 =
193  hash_get (msm->next_node_index_by_sw_if_index, sw_if_index1);
194  if (p1 == 0)
195  {
196  vnet_hw_interface_t *hw1;
197 
199  sw_if_index1);
200 
201  next1 = vlib_node_add_next (msm->vlib_main,
202  mac_swap_node.index,
203  hw1->output_node_index);
205  sw_if_index1, next1);
206  }
207  else
208  next1 = p1[0];
209  msm->cached_sw_if_index = sw_if_index1;
210  msm->cached_next_index = next1;
211  }
212 
213  em->counters[node_counter_base_index + MAC_SWAP_ERROR_SWAPS] += 2;
214 
215  /* reset buffer so we always point at the MAC hdr */
216  vlib_buffer_reset (b0);
217  vlib_buffer_reset (b1);
218  h0 = vlib_buffer_get_current (b0);
219  h1 = vlib_buffer_get_current (b1);
220 
221  /* Swap 2 x src and dst mac addresses using 8-byte load/stores */
222  tmp0a = clib_net_to_host_u64 (((u64 *) (h0->dst_address))[0]);
223  tmp1a = clib_net_to_host_u64 (((u64 *) (h1->dst_address))[0]);
224  tmp0b = clib_net_to_host_u64 (((u64 *) (h0->src_address))[0]);
225  tmp1b = clib_net_to_host_u64 (((u64 *) (h1->src_address))[0]);
226  ((u64 *) (h0->dst_address))[0] = clib_host_to_net_u64 (tmp0b);
227  ((u64 *) (h1->dst_address))[0] = clib_host_to_net_u64 (tmp1b);
228  /* Move the ethertype from "b" to "a" */
229  tmp0a &= ~(0xFFFF);
230  tmp1a &= ~(0xFFFF);
231  tmp0a |= tmp0b & 0xFFFF;
232  ((u64 *) (h0->src_address))[0] = clib_host_to_net_u64 (tmp0a);
233  tmp1a |= tmp1b & 0xFFFF;
234  ((u64 *) (h1->src_address))[0] = clib_host_to_net_u64 (tmp1a);
235 
236  if (PREDICT_FALSE ((node->flags & VLIB_NODE_FLAG_TRACE)))
237  {
238  if (b0->flags & VLIB_BUFFER_IS_TRACED)
239  {
240  swap_trace_t *t =
241  vlib_add_trace (vm, node, b0, sizeof (*t));
242  clib_memcpy (t->src, h0->src_address, 6);
243  clib_memcpy (t->dst, h0->dst_address, 6);
244  t->sw_if_index = sw_if_index0;
245  t->next_index = next0;
246  }
247  if (b1->flags & VLIB_BUFFER_IS_TRACED)
248  {
249  swap_trace_t *t =
250  vlib_add_trace (vm, node, b1, sizeof (*t));
251  clib_memcpy (t->src, h1->src_address, 6);
252  clib_memcpy (t->dst, h1->dst_address, 6);
253  t->sw_if_index = sw_if_index1;
254  t->next_index = next1;
255  }
256  }
257 
258  vlib_validate_buffer_enqueue_x2 (vm, node, next_index,
259  to_next, n_left_to_next,
260  bi0, bi1, next0, next1);
261  }
262 
263  while (n_left_from > 0 && n_left_to_next > 0)
264  {
265  u32 bi0;
266  vlib_buffer_t *b0;
267  u32 next0;
268  u32 sw_if_index0;
269  uword *p0;
270  u64 tmp0a, tmp0b;
271  ethernet_header_t *h0;
272 
273  bi0 = from[0];
274  to_next[0] = bi0;
275  from += 1;
276  to_next += 1;
277  n_left_from -= 1;
278  n_left_to_next -= 1;
279 
280  b0 = vlib_get_buffer (vm, bi0);
281 
282  sw_if_index0 = vnet_buffer (b0)->sw_if_index[VLIB_RX];
283  next0 = msm->cached_next_index;
284 
285  if (PREDICT_FALSE (msm->cached_sw_if_index != sw_if_index0))
286  {
287  p0 =
288  hash_get (msm->next_node_index_by_sw_if_index, sw_if_index0);
289  if (p0 == 0)
290  {
291  vnet_hw_interface_t *hw0;
292 
294  sw_if_index0);
295 
296  next0 = vlib_node_add_next (msm->vlib_main,
297  mac_swap_node.index,
298  hw0->output_node_index);
300  sw_if_index0, next0);
301  }
302  else
303  next0 = p0[0];
304  msm->cached_sw_if_index = sw_if_index0;
305  msm->cached_next_index = next0;
306  }
307 
308  em->counters[node_counter_base_index + MAC_SWAP_ERROR_SWAPS] += 1;
309 
310  /* reset buffer so we always point at the MAC hdr */
311  vlib_buffer_reset (b0);
312  h0 = vlib_buffer_get_current (b0);
313 
314  /* Exchange src and dst, preserve the ethertype */
315  tmp0a = clib_net_to_host_u64 (((u64 *) (h0->dst_address))[0]);
316  tmp0b = clib_net_to_host_u64 (((u64 *) (h0->src_address))[0]);
317  ((u64 *) (h0->dst_address))[0] = clib_host_to_net_u64 (tmp0b);
318  tmp0a &= ~(0xFFFF);
319  tmp0a |= tmp0b & 0xFFFF;
320  ((u64 *) (h0->src_address))[0] = clib_host_to_net_u64 (tmp0a);
321 
322  /* ship it */
324  && (b0->flags & VLIB_BUFFER_IS_TRACED)))
325  {
326  swap_trace_t *t = vlib_add_trace (vm, node, b0, sizeof (*t));
327  clib_memcpy (t->src, h0->src_address, 6);
328  clib_memcpy (t->dst, h0->dst_address, 6);
329  t->sw_if_index = sw_if_index0;
330  t->next_index = next0;
331  }
332 
333  vlib_validate_buffer_enqueue_x1 (vm, node, next_index,
334  to_next, n_left_to_next,
335  bi0, next0);
336  }
337 
338  vlib_put_next_frame (vm, node, next_index, n_left_to_next);
339  }
340 
341  return frame->n_vectors;
342 }
343 
344 /* *INDENT-OFF* */
346  .function = mac_swap_node_fn,
347  .name = "mac-swap",
348  .vector_size = sizeof (u32),
349  .format_trace = format_swap_trace,
351 
352  .n_errors = ARRAY_LEN(mac_swap_error_strings),
353  .error_strings = mac_swap_error_strings,
354 
355  .n_next_nodes = MAC_SWAP_N_NEXT,
356 
357  /* edit / add dispositions here */
358  .next_nodes = {
359  [MAC_SWAP_NEXT_DROP] = "error-drop",
360  },
361 };
362 /* *INDENT-ON* */
363 
364 clib_error_t *
366 {
368 
369  msm->next_node_index_by_sw_if_index = hash_create (0, sizeof (uword));
370  msm->cached_next_index = (u32) ~ 0;
371  msm->cached_sw_if_index = (u32) ~ 0;
372  msm->vlib_main = vm;
373  msm->vnet_main = vnet_get_main ();
374 
375  /* Driver RX nodes send pkts here... */
376 #define _(a) ixge_set_next_node (IXGE_RX_NEXT_##a##_INPUT, "mac-swap");
378 #undef _
379 #define _(a) ixgev_set_next_node (IXGEV_RX_NEXT_##a##_INPUT, "mac-swap");
381 #undef _
382 #define _(a) ige_set_next_node (IGE_RX_NEXT_##a##_INPUT, "mac-swap");
384 #undef _
385  return 0;
386 }
387 
389 
390 
391 /*
392  * fd.io coding-style-patch-verification: ON
393  *
394  * Local Variables:
395  * eval: (c-set-style "gnu")
396  * End:
397  */
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:459
u32 error_heap_index
Definition: node.h:278
#define hash_set(h, key, value)
Definition: hash.h:254
#define CLIB_UNUSED(x)
Definition: clib.h:79
bad routing header type(not 4)") sr_error (NO_MORE_SEGMENTS
static vnet_hw_interface_t * vnet_get_sup_hw_interface(vnet_main_t *vnm, u32 sw_if_index)
u8 src_address[6]
Definition: packet.h:54
struct _vlib_node_registration vlib_node_registration_t
u8 src[6]
Definition: mac_swap.c:38
static uword vlib_node_add_next(vlib_main_t *vm, uword node, uword next_node)
Definition: node_funcs.h:1063
u8 dst[6]
Definition: mac_swap.c:39
u32 cached_sw_if_index
Definition: mac_swap.c:26
#define foreach_hw_driver_next
Definition: mac_swap.c:58
vnet_main_t * vnet_get_main(void)
Definition: misc.c:46
u8 * format_ethernet_address(u8 *s, va_list *args)
Definition: format.c:44
#define VLIB_INIT_FUNCTION(x)
Definition: init.h:111
static void * vlib_buffer_get_current(vlib_buffer_t *b)
Get pointer to current data to process.
Definition: buffer.h:194
u8 dst_address[6]
Definition: packet.h:53
#define foreach_mac_swap_error
Definition: mac_swap.c:67
unsigned long u64
Definition: types.h:89
static u8 * format_swap_trace(u8 *s, va_list *args)
Definition: mac_swap.c:46
mac_swap_main_t mac_swap_main
Definition: mac_swap.c:63
#define hash_get(h, key)
Definition: hash.h:248
clib_error_t * mac_swap_init(vlib_main_t *vm)
Definition: mac_swap.c:365
vlib_error_main_t error_main
Definition: main.h:124
#define PREDICT_FALSE(x)
Definition: clib.h:97
#define vlib_validate_buffer_enqueue_x2(vm, node, next_index, to_next, n_left_to_next, bi0, bi1, next0, next1)
Finish enqueueing two buffers forward in the graph.
Definition: buffer_node.h:70
static void vlib_buffer_reset(vlib_buffer_t *b)
Reset current header & length to state they were in when packet was received.
Definition: buffer.h:221
#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:216
#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:350
u32 cached_next_index
Definition: mac_swap.c:25
u64 * counters
Definition: error.h:78
vlib_main_t * vlib_main
Definition: mac_swap.c:32
u16 n_vectors
Definition: node.h:344
#define CLIB_PREFETCH(addr, size, type)
Definition: cache.h:82
vnet_main_t * vnet_main
Definition: mac_swap.c:33
#define clib_memcpy(a, b, c)
Definition: string.h:69
#define ARRAY_LEN(x)
Definition: clib.h:59
mac_swap_next_t
Definition: mac_swap.c:99
#define hash_create(elts, value_bytes)
Definition: hash.h:658
u16 cached_next_index
Definition: node.h:463
unsigned int u32
Definition: types.h:88
#define vnet_buffer(b)
Definition: buffer.h:361
static vlib_node_registration_t mac_swap_node
(constructor) VLIB_REGISTER_NODE (mac_swap_node)
Definition: mac_swap.c:65
#define VLIB_NODE_FLAG_TRACE
Definition: node.h:259
mac_swap_error_t
Definition: mac_swap.c:70
#define VLIB_BUFFER_IS_TRACED
Definition: buffer.h:95
u32 sw_if_index
Definition: mac_swap.c:40
u64 uword
Definition: types.h:112
static void * vlib_add_trace(vlib_main_t *vm, vlib_node_runtime_t *r, vlib_buffer_t *b, u32 n_data_bytes)
Definition: trace_funcs.h:55
static char * mac_swap_error_strings[]
Definition: mac_swap.c:78
unsigned char u8
Definition: types.h:56
static void * vlib_frame_vector_args(vlib_frame_t *f)
Get pointer to frame vector data.
Definition: node_funcs.h:253
#define vlib_prefetch_buffer_header(b, type)
Prefetch buffer metadata.
Definition: buffer.h:170
#define VLIB_REGISTER_NODE(x,...)
Definition: node.h:143
u8 * format(u8 *s, const char *fmt,...)
Definition: format.c:418
u8 data[0]
Packet data.
Definition: buffer.h:158
static vlib_node_t * vlib_get_node(vlib_main_t *vm, u32 i)
Get vlib node by index.
Definition: node_funcs.h:58
static uword mac_swap_node_fn(vlib_main_t *vm, vlib_node_runtime_t *node, vlib_frame_t *frame)
Definition: mac_swap.c:106
#define CLIB_CACHE_LINE_BYTES
Definition: cache.h:67
u32 flags
buffer flags: VLIB_BUFFER_IS_TRACED: trace this buffer.
Definition: buffer.h:85
static vlib_buffer_t * vlib_get_buffer(vlib_main_t *vm, u32 buffer_index)
Translate buffer index into buffer pointer.
Definition: buffer_funcs.h:57
u32 next_index
Definition: mac_swap.c:41
Definition: defs.h:46
uword * next_node_index_by_sw_if_index
Definition: mac_swap.c:29