From bd70c2f2e39b85939714aa025355eac973b2451f Mon Sep 17 00:00:00 2001 From: Eyal Bari Date: Wed, 27 Sep 2017 21:43:51 +0300 Subject: L2-FIB:add mac learn events test fixes an issue where events were not sent if BD doesn't enable mac aging Change-Id: Iddc53cb5c45e560633e6c5cff2731dccfc70ad5b Signed-off-by: Eyal Bari (cherry picked from commit 24db0ec78fb651c4c585ebf30e07108240574045) --- src/vnet/l2/l2_fib.c | 105 ++++++++++++++++++++++------------------------ test/test_l2_fib.py | 18 ++++++++ test/vpp_papi_provider.py | 9 ++++ 3 files changed, 76 insertions(+), 56 deletions(-) diff --git a/src/vnet/l2/l2_fib.c b/src/vnet/l2/l2_fib.c index 9f4c823f..64b3275b 100644 --- a/src/vnet/l2/l2_fib.c +++ b/src/vnet/l2/l2_fib.c @@ -756,17 +756,21 @@ VLIB_CLI_COMMAND (l2fib_del_cli, static) = { void l2fib_start_ager_scan (vlib_main_t * vm) { - l2_bridge_domain_t *bd_config; - int enable = 0; + uword evt = L2_MAC_AGE_PROCESS_EVENT_ONE_PASS; /* check if there is at least one bd with mac aging enabled */ + l2_bridge_domain_t *bd_config; vec_foreach (bd_config, l2input_main.bd_configs) + { if (bd_config->bd_id != ~0 && bd_config->mac_age != 0) - enable = 1; + { + evt = L2_MAC_AGE_PROCESS_EVENT_START; + break; + } + } vlib_process_signal_event (vm, l2fib_mac_age_scanner_process_node.index, - enable ? L2_MAC_AGE_PROCESS_EVENT_START : - L2_MAC_AGE_PROCESS_EVENT_ONE_PASS, 0); + evt, 0); } /** @@ -1019,25 +1023,26 @@ l2fib_scan (vlib_main_t * vm, f64 start_time, u8 event_only) if (result.fields.age_not == 0) learn_count++; - if (PREDICT_FALSE (evt_idx >= fm->max_macs_in_event)) + if (client) { - /* event message full, send it and start a new one */ - if (q && (q->cursize < q->maxsize)) + if (PREDICT_FALSE (evt_idx >= fm->max_macs_in_event)) { - mp->n_macs = htonl (evt_idx); - vl_msg_api_send_shmem (q, (u8 *) & mp); - mp = allocate_mac_evt_buf (client, cl_idx); + /* event message full, send it and start a new one */ + if (q && (q->cursize < q->maxsize)) + { + mp->n_macs = htonl (evt_idx); + vl_msg_api_send_shmem (q, (u8 *) & mp); + mp = allocate_mac_evt_buf (client, cl_idx); + } + else + { + clib_warning ("MAC event to pid %d queue stuffed!" + " %d MAC entries lost", client, + evt_idx); + } + evt_idx = 0; } - else - { - clib_warning ("MAC event to pid %d queue stuffed!" - " %d MAC entries lost", client, evt_idx); - } - evt_idx = 0; - } - if (client) - { if (result.fields.lrn_evt) { /* copy mac entry to event msg */ @@ -1125,10 +1130,6 @@ l2fib_scan (vlib_main_t * vm, f64 start_time, u8 event_only) return delta_t + accum_t; } -/* Type of scan */ -#define SCAN_MAC_AGE 0 -#define SCAN_MAC_EVENT 1 - /* Maximum f64 value */ #define TIME_MAX (1.7976931348623157e+308) @@ -1140,22 +1141,16 @@ l2fib_mac_age_scanner_process (vlib_main_t * vm, vlib_node_runtime_t * rt, l2fib_main_t *fm = &l2fib_main; l2learn_main_t *lm = &l2learn_main; bool enabled = 0; - bool scan = SCAN_MAC_AGE; /* SCAN_FOR_AGE or SCAN_FOR_EVENT */ f64 start_time, next_age_scan_time = TIME_MAX; while (1) { - if (enabled) + if (lm->client_pid) + vlib_process_wait_for_event_or_clock (vm, fm->event_scan_delay); + else if (enabled) { - if (lm->client_pid) /* mac event client waiting */ - vlib_process_wait_for_event_or_clock (vm, fm->event_scan_delay); - else /* agin only */ - { - f64 t = next_age_scan_time - vlib_time_now (vm); - if (t < fm->event_scan_delay) - t = fm->event_scan_delay; - vlib_process_wait_for_event_or_clock (vm, t); - } + f64 t = next_age_scan_time - vlib_time_now (vm); + vlib_process_wait_for_event_or_clock (vm, t); } else vlib_process_wait_for_event (vm); @@ -1164,41 +1159,26 @@ l2fib_mac_age_scanner_process (vlib_main_t * vm, vlib_node_runtime_t * rt, vec_reset_length (event_data); start_time = vlib_time_now (vm); + enum + { SCAN_MAC_AGE, SCAN_MAC_EVENT, SCAN_DISABLE } scan = SCAN_MAC_AGE; switch (event_type) { case ~0: /* timer expired */ - if ((lm->client_pid == 0) || (start_time >= next_age_scan_time)) - { - scan = SCAN_MAC_AGE; - if (enabled) - next_age_scan_time = start_time + L2FIB_AGE_SCAN_INTERVAL; - else - next_age_scan_time = TIME_MAX; - } - else + if (lm->client_pid != 0 && start_time < next_age_scan_time) scan = SCAN_MAC_EVENT; break; case L2_MAC_AGE_PROCESS_EVENT_START: - scan = SCAN_MAC_AGE; - next_age_scan_time = start_time + L2FIB_AGE_SCAN_INTERVAL; enabled = 1; break; case L2_MAC_AGE_PROCESS_EVENT_STOP: enabled = 0; - next_age_scan_time = TIME_MAX; - l2fib_main.age_scan_duration = 0; - l2fib_main.evt_scan_duration = 0; - continue; + scan = SCAN_DISABLE; + break; case L2_MAC_AGE_PROCESS_EVENT_ONE_PASS: - scan = SCAN_MAC_AGE; - if (enabled) - next_age_scan_time = start_time + L2FIB_AGE_SCAN_INTERVAL; - else - next_age_scan_time = TIME_MAX; break; default: @@ -1208,7 +1188,20 @@ l2fib_mac_age_scanner_process (vlib_main_t * vm, vlib_node_runtime_t * rt, if (scan == SCAN_MAC_EVENT) l2fib_main.evt_scan_duration = l2fib_scan (vm, start_time, 1); else - l2fib_main.age_scan_duration = l2fib_scan (vm, start_time, 0); + { + if (scan == SCAN_MAC_AGE) + l2fib_main.age_scan_duration = l2fib_scan (vm, start_time, 0); + if (scan == SCAN_DISABLE) + { + l2fib_main.age_scan_duration = 0; + l2fib_main.evt_scan_duration = 0; + } + /* schedule next scan */ + if (enabled) + next_age_scan_time = start_time + L2FIB_AGE_SCAN_INTERVAL; + else + next_age_scan_time = TIME_MAX; + } } return 0; } diff --git a/test/test_l2_fib.py b/test/test_l2_fib.py index 9249a2ce..52bf9c86 100644 --- a/test/test_l2_fib.py +++ b/test/test_l2_fib.py @@ -519,6 +519,24 @@ class TestL2fib(VppTestCase): self.run_verify_negat_test(bd_id=1, dst_hosts=flushed) self.run_verify_negat_test(bd_id=2, dst_hosts=flushed) + def test_l2_fib_09(self): + """ L2 FIB test 9 - mac learning events + """ + self.create_hosts(10, subnet=39) + + self.vapi.want_macs_learn_events() + self.learn_hosts(bd_id=1, n_hosts_per_if=10) + + self.sleep(1) + self.logger.info(self.vapi.ppcli("show l2fib")) + evs = self.vapi.collect_events() + learned_macs = { + e.mac[i].mac_addr for e in evs for i in range(e.n_macs)} + macs = {h.bin_mac for swif_hs in self.learned_hosts.itervalues() + for h in swif_hs} + self.vapi.want_macs_learn_events(enable_disable=0) + self.assertEqual(len(learned_macs ^ macs), 0) + if __name__ == '__main__': unittest.main(testRunner=VppTestRunner) diff --git a/test/vpp_papi_provider.py b/test/vpp_papi_provider.py index 634dabea..b6759ec3 100644 --- a/test/vpp_papi_provider.py +++ b/test/vpp_papi_provider.py @@ -431,6 +431,15 @@ class VppPapiProvider(object): 'address': address, 'pid': os.getpid(), }) + def want_macs_learn_events(self, enable_disable=1, scan_delay=0, + max_macs_in_event=0, learn_limit=0): + return self.api(self.papi.want_l2_macs_events, + {'enable_disable': enable_disable, + 'scan_delay': scan_delay, + 'max_macs_in_event': max_macs_in_event, + 'learn_limit': learn_limit, + 'pid': os.getpid(), }) + def l2fib_add_del(self, mac, bd_id, sw_if_index, is_add=1, static_mac=0, filter_mac=0, bvi_mac=0): """Create/delete L2 FIB entry. -- cgit 1.2.3-korg