Add traffic retry to override the virtual environment stability issue

Add traffic retry in everflow multi binding acl case to override the
virtual environment stability issue

Change-Id: I825ee8981d59a3692384106df62a135b5506660f
Signed-off-by: echuawu <[email protected]>

Author: echuawu

tests/everflow/test_everflow_testbed.py

@@ -14,6 +14,7 @@
 import ptf.packet as scapy
 from tests.ptf_runner import ptf_runner
 from .everflow_test_utilities import TARGET_SERVER_IP, BaseEverflowTest, DOWN_STREAM, UP_STREAM, DEFAULT_SERVER_IP
+from retry.api import retry_call
 # Module-level fixtures
 from tests.common.fixtures.ptfhost_utils import copy_ptftests_directory                                   # noqa: F401
 from tests.common.fixtures.ptfhost_utils import copy_acstests_directory                                   # noqa: F401
@@ -239,15 +240,26 @@ def test_everflow_multi_binding_acl(self, setup_info, setup_mirror_session,
         random_upstream_intf = random.choice(list(upstream_links_for_unselected_dut.keys()))
         rx_port_ptf_id = upstream_links_for_unselected_dut[random_upstream_intf]["ptf_port_id"]
         tx_port_ptf_id = setup_info[dest_port_type]["dest_port_ptf_id"][0]
-        self._run_everflow_test_scenarios(
-            ptfadapter,
-            setup_info,
-            setup_mirror_session,
-            everflow_dut,
-            rx_port_ptf_id,
-            [tx_port_ptf_id],
-            dest_port_type,
-            multi_binding_acl=True
+        # Adding retries is required by MSFT to overcome the issue of random packet loss on their simulator
+        retry_call(
+            self._run_everflow_test_scenarios,
+            fargs=(
+                ptfadapter,
+                setup_info,
+                mux_config,
+                setup_mirror_session,
+                everflow_dut,
+                rx_port_ptf_id,
+                [tx_port_ptf_id],
+                dest_port_type
+            ),
+            fkwargs={
+                'multi_binding_acl': True
+            },
+            exceptions=Exception,
+            tries=5,
+            delay=10,
+            logger=logger
         )
 
     def test_everflow_basic_forwarding(self, setup_info, setup_mirror_session,              # noqa F811