68 if (flags & L2FIB_ENTRY_RESULT_FLAG_##a) \ 69 s = format (s, "%s ", t); \ 81 tmp = clib_net_to_host_u64 (tmp);
83 tmp = clib_host_to_net_u64 (tmp);
94 if (sw_if_index == ~0)
100 return format (s,
"Stale");
121 result.
raw = kvp->value;
129 return (BIHASH_WALK_CONTINUE);
164 s =
format (s,
"%3d/%-3d", bd_sn, if_sn);
194 "%=19s%=7s%=7s%=8s%=9s%=7s%=7s%=5s%=30s",
195 "Mac-Address",
"BD-Idx",
"If-Idx",
196 "BSN-ISN",
"Age(min)",
"static",
"filter",
197 "bvi",
"Interface-Name");
201 result.
raw = kvp->value;
209 if (ctx->
learn && l2fib_entry_result_is_set_AGE_NOT (&result))
210 return (BIHASH_WALK_CONTINUE);
212 if (ctx->
add && !l2fib_entry_result_is_set_AGE_NOT (&result))
213 return (BIHASH_WALK_CONTINUE);
218 if (l2fib_entry_result_is_set_AGE_NOT (&result))
220 else if (bd_config->
mac_age == 0)
225 delta += delta < 0 ? 256 : 0;
226 s =
format (s,
"%d", delta);
230 "%=19U%=7d%=7d %U%=9v%=7s%=7s%=5s%=30U",
233 result.
fields.sw_if_index == ~0
234 ? -1 : result.
fields.sw_if_index,
236 l2fib_entry_result_is_set_STATIC (&result) ?
"*" :
"-",
237 l2fib_entry_result_is_set_FILTER (&result) ?
"*" :
"-",
238 l2fib_entry_result_is_set_BVI (&result) ?
"*" :
"-",
244 return (BIHASH_WALK_CONTINUE);
272 else if (
unformat (input,
"verbose"))
290 else if (
unformat (input,
"bd_id %d", &bd_id))
300 "bridge domain id %d doesn't exist\n",
322 "Last scan time: %.4esec Learn limit: %d ",
327 "Last e-scan time: %.4esec Delay: %.2esec " 328 "Max macs in event: %d",
335 BV (format_bihash), &msm->mac_table, 1 );
363 .path =
"show l2fib",
364 .short_help =
"show l2fib [all] | [bd_id <nn> | bd_index <nn>] [learn | add] | [raw]",
423 .path =
"clear l2fib",
424 .short_help =
"clear l2fib",
448 __attribute__ ((unused))
u32 bucket_contents;
451 BVT (clib_bihash_kv) kv;
461 if (BV (clib_bihash_search) (&fm->mac_table, &kv, &kv))
464 result.
raw = kv.value;
465 if ((!l2fib_entry_result_is_set_AGE_NOT (&result))
476 l2fib_entry_result_set_AGE_NOT (&result);
478 kv.value = result.
raw;
513 if (!
unformat (input,
"%d", &bd_id))
542 flags |= L2FIB_ENTRY_RESULT_FLAG_STATIC;
544 flags |= (L2FIB_ENTRY_RESULT_FLAG_STATIC | L2FIB_ENTRY_RESULT_FLAG_BVI);
589 .short_help =
"l2fib add <mac> <bridge-domain-id> filter | <intf> [static | bvi]",
599 u8 mac[6], save_mac[6];
619 else if (
unformat (input,
"count %d", &count))
628 if (is_add == 0 && is_del == 0 && is_check == 0)
630 "noop: pick at least one of (add,del,check)");
636 for (i = 0; i <
count; i++)
646 BVT (clib_bihash_kv) kv;
654 for (i = 0; i <
count; i++)
657 if (BV (clib_bihash_search) (&mp->mac_table, &kv, &kv))
670 for (i = 0; i <
count; i++)
719 .path =
"test l2fib",
720 .short_help =
"test l2fib [add|del|check] mac <base-addr> count <nn>",
736 BVT (clib_bihash_kv) kv;
744 if (BV (clib_bihash_search) (&mp->mac_table, &kv, &kv))
747 result.
raw = kv.value;
750 if ((sw_if_index != 0) && (sw_if_index != result.
fields.sw_if_index))
754 if ((!l2fib_entry_result_is_set_AGE_NOT (&result)) &&
786 if (!
unformat (input,
"%d", &bd_id))
823 .short_help =
"l2fib del <mac> <bridge-domain-id> []",
936 .path =
"l2fib flush-mac all",
937 .short_help =
"l2fib flush-mac all",
952 .path =
"l2fib flush-mac interface",
953 .short_help =
"l2fib flush-mac interface <if-name>",
972 if (!
unformat (input,
"%d", &bd_id))
1001 .path =
"l2fib flush-mac bridge-domain",
1002 .short_help =
"l2fib flush-mac bridge-domain <bd-id>",
1019 BVT (clib_bihash) * get_mac_table (
void)
1022 return &mp->mac_table;
1031 mp->_vl_msg_id = htons (VL_API_L2_MACS_EVENT);
1032 mp->
pid = htonl (client);
1043 BVT (clib_bihash) *
h = &fm->mac_table;
1045 f64 last_start = start_time;
1049 u32 learn_count = 0;
1056 if (alloc_arena (
h) == 0)
1065 for (i = 0; i <
h->nbuckets; i++)
1069 if (delta_t > 20e-6)
1076 if (i < (
h->nbuckets - 3))
1078 BVT (clib_bihash_bucket) *
b =
1079 BV (clib_bihash_get_bucket) (
h, i + 3);
1081 b = BV (clib_bihash_get_bucket) (
h, i + 1);
1082 if (!BV (clib_bihash_bucket_is_empty) (
b))
1090 BVT (clib_bihash_bucket) *
b = BV (clib_bihash_get_bucket) (
h,
i);
1091 if (BV (clib_bihash_bucket_is_empty) (
b))
1094 for (j = 0; j < (1 <<
b->log2_pages); j++)
1098 if (v->kvp[k].key == ~0ULL && v->kvp[k].value == ~0ULL)
1104 if (!l2fib_entry_result_is_set_AGE_NOT (&result))
1114 mp->
n_macs = htonl (evt_idx);
1122 " %d MAC entries lost", client,
1128 if (l2fib_entry_result_is_set_LRN_EVT (&result))
1133 mp->
mac[evt_idx].action =
1134 l2fib_entry_result_is_set_LRN_MOV (&result) ?
1137 mp->
mac[evt_idx].action =
1138 htonl (mp->
mac[evt_idx].action);
1139 mp->
mac[evt_idx].sw_if_index =
1140 htonl (result.
fields.sw_if_index);
1142 l2fib_entry_result_clear_LRN_EVT (&result);
1143 l2fib_entry_result_clear_LRN_MOV (&result);
1144 BVT (clib_bihash_kv) kv;
1146 kv.value = result.
raw;
1153 if (event_only || l2fib_entry_result_is_set_AGE_NOT (&result))
1160 if (result.
fields.sn != sn)
1169 i16 delta = (
u8) (start_time / 60) - result.
fields.timestamp;
1170 delta += delta < 0 ? 256 : 0;
1172 if (delta < bd_config->mac_age)
1181 mp->
mac[evt_idx].action =
1183 mp->
mac[evt_idx].action = htonl (mp->
mac[evt_idx].action);
1184 mp->
mac[evt_idx].sw_if_index =
1185 htonl (result.
fields.sw_if_index);
1189 BVT (clib_bihash_kv) kv;
1197 if (BV (clib_bihash_bucket_is_empty) (
b))
1216 mp->
n_macs = htonl (evt_idx);
1223 " %d MAC entries lost", client, evt_idx);
1230 return delta_t + accum_t;
1237 uword event_type, *event_data = 0;
1260 { SCAN_MAC_AGE, SCAN_MAC_EVENT, SCAN_DISABLE } scan = SCAN_MAC_AGE;
1265 if (lm->
client_pid != 0 && start_time < next_age_scan_time)
1266 scan = SCAN_MAC_EVENT;
1275 scan = SCAN_DISABLE;
1285 if (scan == SCAN_MAC_EVENT)
1289 if (scan == SCAN_MAC_AGE)
1291 if (scan == SCAN_DISABLE)
1310 .name =
"l2fib-mac-age-scanner-process",
1346 uword table_size = ~0;
1354 else if (
unformat (input,
"num-buckets %u", &n_buckets))
1361 if (n_buckets != ~0)
1368 if (table_size != ~0)
static_always_inline void * allocate_mac_evt_buf(u32 client, u32 client_index)
u16 l2fib_seq_num_t
A combined representation of the sequence number associated with the interface and the BD...
static clib_error_t * l2fib_test_command_fn(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
struct l2fib_entry_result_t_::@471::@473 fields
l2_input_config_t * configs
u8 * format_vnet_sw_if_index_name_with_NA(u8 *s, va_list *args)
Format sw_if_index.
static f64 vlib_process_wait_for_event_or_clock(vlib_main_t *vm, f64 dt)
Suspend a cooperative multi-tasking thread Waits for an event, or for the indicated number of seconds...
#define BIHASH_KVP_PER_PAGE
vl_api_wireguard_peer_flags_t flags
static uword * vlib_process_wait_for_event(vlib_main_t *vm)
vnet_main_t * vnet_get_main(void)
void clib_bihash_free(clib_bihash *h)
Destroy a bounded index extensible hash table.
#define clib_memcpy_fast(a, b, c)
clib_memset(h->entries, 0, sizeof(h->entries[0]) *entries)
static f64 vlib_time_now(vlib_main_t *vm)
static void vl_api_send_msg(vl_api_registration_t *rp, u8 *elem)
clib_error_t * l2fib_init(vlib_main_t *vm)
#define vec_add1(V, E)
Add 1 element to end of vector (unspecified alignment).
static int l2fib_show_walk_cb(BVT(clib_bihash_kv) *kvp, void *arg)
#define L2FIB_MEMORY_SIZE
unformat_function_t unformat_vnet_sw_interface
enum l2fib_entry_result_flags_t_ l2fib_entry_result_flags_t
void * vl_msg_api_alloc(int nbytes)
static clib_error_t * l2fib_del(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
Delete an entry from the L2FIB.
u8 * format_l2fib_entry_result_flags(u8 *s, va_list *args)
#define vec_reset_length(v)
Reset vector length to zero NULL-pointer tolerant.
static clib_error_t * lfib_config(vlib_main_t *vm, unformat_input_t *input)
static uword vlib_process_suspend(vlib_main_t *vm, f64 dt)
Suspend a vlib cooperative multi-tasking thread for a period of time.
static int vl_api_can_send_msg(vl_api_registration_t *rp)
#define L2FIB_AGE_SCAN_INTERVAL
l2learn_main_t l2learn_main
#define static_always_inline
u8 * format_ethernet_address(u8 *s, va_list *args)
int clib_bihash_add_del(clib_bihash *h, clib_bihash_kv *add_v, int is_add)
Add or delete a (key,value) pair from a bi-hash table.
#define VLIB_INIT_FUNCTION(x)
static uword vlib_process_get_events(vlib_main_t *vm, uword **data_vector)
Return the first event type which has occurred and a vector of per-event data of that type...
description fragment has unexpected format
#define vec_elt_at_index(v, i)
Get vector value at index i checking that i is in bounds.
#define clib_error_return(e, args...)
void l2fib_add_entry(const u8 *mac, u32 bd_index, u32 sw_if_index, l2fib_entry_result_flags_t flags)
Add an entry to the l2fib.
uword mac_table_memory_size
L2 MAC event for a list of learned or aged MACs.
uword * bd_index_by_bd_id
static int l2fib_dump_walk_cb(BVT(clib_bihash_kv) *kvp, void *arg)
void l2fib_start_ager_scan(vlib_main_t *vm)
Kick off ager to scan MACs to age/delete MAC entries.
format_function_t format_vnet_sw_interface_name
struct l2fib_dump_walk_ctx_t_ l2fib_dump_walk_ctx_t
void clib_bihash_foreach_key_value_pair(clib_bihash *h, clib_bihash_foreach_key_value_pair_cb *callback, void *arg)
Visit active (key,value) pairs in a bi-hash table.
static void vlib_process_signal_event(vlib_main_t *vm, uword node_index, uword type_opaque, uword data)
void l2fib_flush_bd_mac(vlib_main_t *vm, u32 bd_index)
Flush all non static MACs in a bridge domain.
#define VLIB_CONFIG_FUNCTION(x, n,...)
void l2fib_flush_all_mac(vlib_main_t *vm)
Flush all non static MACs - flushes all valid BDs.
l2fib_entry_key_t * l2fe_key
#define L2FIB_NUM_BUCKETS
static_always_inline f64 l2fib_scan(vlib_main_t *vm, f64 start_time, u8 event_only)
void clib_bihash_init(clib_bihash *h, char *name, u32 nbuckets, uword memory_size)
initialize a bounded index extensible hash table
static u32 bd_is_valid(l2_bridge_domain_t *bd_config)
static clib_error_t * clear_l2fib(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
Clear all entries in L2FIB.
clib_error_t * l2fib_sw_interface_up_down(vnet_main_t *vnm, u32 sw_if_index, u32 flags)
static clib_error_t * show_l2fib(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
Display the contents of the l2fib.
An API client registration, only in vpp/vlib.
#define VLIB_REGISTER_NODE(x,...)
static clib_error_t * l2fib_flush_mac_all(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
Flush all MACs, except static ones The CLI format is: l2fib flush-mac all.
u32 l2fib_del_entry(const u8 *mac, u32 bd_index, u32 sw_if_index)
Delete an entry from the l2fib.
#define CLIB_PREFETCH(addr, size, type)
static void incr_mac_address(u8 *mac)
sll srl srl sll sra u16x4 i
#define vec_free(V)
Free vector's memory (no header).
static clib_error_t * l2fib_flush_mac_int(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
Flush MACs, except static ones, associated with an interface The CLI format is: l2fib flush-mac inter...
#define clib_warning(format, args...)
static u64 l2fib_make_key(const u8 *mac_address, u16 bd_index)
void l2fib_clear_table(void)
static l2fib_seq_num_t l2fib_cur_seq_num(u32 bd_index, u32 sw_if_index)
static vl_api_registration_t * vl_api_client_index_to_registration(u32 index)
#define VLIB_CLI_COMMAND(x,...)
uword unformat_ethernet_address(unformat_input_t *input, va_list *args)
void vlib_cli_output(vlib_main_t *vm, char *fmt,...)
static uword l2fib_mac_age_scanner_process(vlib_main_t *vm, vlib_node_runtime_t *rt, vlib_frame_t *f)
vl_api_mac_entry_t mac[n_macs]
VNET_SW_INTERFACE_ADMIN_UP_DOWN_FUNCTION(l2fib_sw_interface_up_down)
static uword is_pow2(uword x)
void vl_msg_api_free(void *)
template key/value backing page structure
static clib_error_t * l2fib_flush_mac_bd(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
Flush bridge-domain MACs except static ones.
#define vec_len(v)
Number of elements in vector (rvalue-only, NULL tolerant)
l2fib_entry_result_t * l2fe_res
l2_bridge_domain_t * bd_configs
static void l2fib_add_filter_entry(const u8 *mac, u32 bd_index)
static_always_inline l2fib_seq_num_t l2_fib_mk_seq_num(u8 bd_sn, u8 if_sn)
void l2fib_table_dump(u32 bd_index, l2fib_entry_key_t **l2fe_key, l2fib_entry_result_t **l2fe_res)
void l2_fib_extract_seq_num(l2fib_seq_num_t sn, u8 *bd_sn, u8 *if_sn)
#define vec_foreach(var, vec)
Vector iterator.
u8 * format_l2_fib_seq_num(u8 *s, va_list *a)
struct l2fib_entry_key_t::@467::@469 fields
static void * clib_bihash_get_value(clib_bihash *h, uword offset)
Get pointer to value page given its clib mheap offset.
uword mac_table_n_buckets
void l2fib_table_init(void)
#define CLIB_CACHE_LINE_BYTES
static clib_error_t * l2fib_add(vlib_main_t *vm, unformat_input_t *input, vlib_cli_command_t *cmd)
Add an entry to the L2FIB.
void l2fib_flush_int_mac(vlib_main_t *vm, u32 sw_if_index)
Flush all non static MACs from an interface.
static vnet_sw_interface_t * vnet_get_sw_interface_or_null(vnet_main_t *vnm, u32 sw_if_index)
struct l2fib_show_walk_ctx_t_ l2fib_show_walk_ctx_t
vl_api_interface_index_t sw_if_index
const char *const const char *const raw