aboutsummaryrefslogtreecommitdiffstats
path: root/src/vnet/l2/l2_learn.h
blob: c1071450852d93ce4a2ac13aadfa00cbbe0834bd (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
/*
 * l2_learn.c : layer 2 learning using l2fib
 *
 * Copyright (c) 2014 Cisco and/or its affiliates.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at:
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef included_l2learn_h
#define included_l2learn_h

#include <vlib/vlib.h>
#include <vnet/ethernet/ethernet.h>


typedef struct
{

  /* Hash table */
  BVT (clib_bihash) * mac_table;

  /* number of dynamically learned mac entries */
  u32 global_learn_count;

  /* maximum number of dynamically learned mac entries */
  u32 global_learn_limit;

  /* client waiting for L2 MAC events for learned and aged MACs */
  u32 client_pid;
  u32 client_index;

  /* Next nodes for each feature */
  u32 feat_next_node_index[32];

  /* convenience variables */
  vlib_main_t *vlib_main;
  vnet_main_t *vnet_main;
} l2learn_main_t;

#define L2LEARN_DEFAULT_LIMIT (L2FIB_NUM_BUCKETS * 64)

extern l2learn_main_t l2learn_main;

extern vlib_node_registration_t l2fib_mac_age_scanner_process_node;

enum
{
  L2_MAC_AGE_PROCESS_EVENT_START = 1,
  L2_MAC_AGE_PROCESS_EVENT_STOP = 2,
  L2_MAC_AGE_PROCESS_EVENT_ONE_PASS = 3,
} l2_mac_age_process_event_t;

#endif

/*
 * fd.io coding-style-patch-verification: ON
 *
 * Local Variables:
 * eval: (c-set-style "gnu")
 * End:
 */
index != TCP_INVALID_SACK_HOLE_INDEX) return pool_elt_at_index (sb->holes, index); return 0; } always_inline sack_scoreboard_hole_t * scoreboard_next_hole (sack_scoreboard_t * sb, sack_scoreboard_hole_t * hole) { if (hole->next != TCP_INVALID_SACK_HOLE_INDEX) return pool_elt_at_index (sb->holes, hole->next); return 0; } always_inline sack_scoreboard_hole_t * scoreboard_prev_hole (sack_scoreboard_t * sb, sack_scoreboard_hole_t * hole) { if (hole->prev != TCP_INVALID_SACK_HOLE_INDEX) return pool_elt_at_index (sb->holes, hole->prev); return 0; } always_inline sack_scoreboard_hole_t * scoreboard_first_hole (sack_scoreboard_t * sb) { if (sb->head != TCP_INVALID_SACK_HOLE_INDEX) return pool_elt_at_index (sb->holes, sb->head); return 0; } always_inline sack_scoreboard_hole_t * scoreboard_last_hole (sack_scoreboard_t * sb) { if (sb->tail != TCP_INVALID_SACK_HOLE_INDEX) return pool_elt_at_index (sb->holes, sb->tail); return 0; } #if TCP_SCOREBOARD_TRACE #define tcp_scoreboard_trace_add(_tc, _ack) \ { \ static u64 _group = 0; \ sack_scoreboard_t *_sb = &_tc->sack_sb; \ sack_block_t *_sack, *_sacks; \ scoreboard_trace_elt_t *_elt; \ int i; \ _group++; \ _sacks = _tc->rcv_opts.sacks; \ for (i = 0; i < vec_len (_sacks); i++) \ { \ _sack = &_sacks[i]; \ vec_add2 (_sb->trace, _elt, 1); \ _elt->start = _sack->start; \ _elt->end = _sack->end; \ _elt->ack = _elt->end == _ack ? _ack : 0; \ _elt->snd_una_max = _elt->end == _ack ? _tc->snd_una_max : 0; \ _elt->group = _group; \ } \ } #else #define tcp_scoreboard_trace_add(_tc, _ack) #endif sack_scoreboard_hole_t *scoreboard_next_rxt_hole (sack_scoreboard_t * sb, sack_scoreboard_hole_t * start, u8 have_sent_1_smss, u8 * can_rescue, u8 * snd_limited); void scoreboard_clear (sack_scoreboard_t * sb); void scoreboard_clear_reneging (sack_scoreboard_t * sb, u32 start, u32 end); void scoreboard_init (sack_scoreboard_t * sb); void scoreboard_init_rxt (sack_scoreboard_t * sb, u32 snd_una); format_function_t format_tcp_scoreboard; /* Made public for unit testing only */ void tcp_update_sack_list (tcp_connection_t * tc, u32 start, u32 end); u32 tcp_sack_list_bytes (tcp_connection_t * tc); void tcp_rcv_sacks (tcp_connection_t * tc, u32 ack); u8 *tcp_scoreboard_replay (u8 * s, tcp_connection_t * tc, u8 verbose); u8 tcp_scoreboard_is_sane_post_recovery (tcp_connection_t * tc); #endif /* SRC_VNET_TCP_TCP_SACK_H_ */ /* * fd.io coding-style-patch-verification: ON * * Local Variables: * eval: (c-set-style "gnu") * End: */