VLAN keyword in platform config file will now make all traffic be sent over vlan

Signed-off-by: Ido Barnea <ibarnea@cisco.com>

3 files changed, 112 insertions, 0 deletions

diff --git a/scripts/automation/regression/setups/trex25/benchmark.yaml b/scripts/automation/regression/setups/trex25/benchmark.yaml
index 2c677b81..7f357ce1 100644
--- a/scripts/automation/regression/setups/trex25/benchmark.yaml
+++ b/scripts/automation/regression/setups/trex25/benchmark.yaml
@@ -107,6 +107,10 @@ test_client_cfg_vlan:
     cores               : 1
     multiplier          : 10
 
+test_platform_cfg_vlan:
+    cores               : 1
+    multiplier          : 10
+
 test_rx_check_http: &rx_http
     multiplier          : 8800
     cores               : 1
diff --git a/scripts/automation/regression/stateful_tests/trex_vlan_test.py b/scripts/automation/regression/stateful_tests/trex_vlan_test.py
new file mode 100644
index 00000000..13d89565
--- /dev/null
+++ b/scripts/automation/regression/stateful_tests/trex_vlan_test.py
@@ -0,0 +1,83 @@
+#!/router/bin/python
+from .trex_general_test import CTRexGeneral_Test, CTRexScenario
+from .tests_exceptions import *
+import time
+from CPlatform import CStaticRouteConfig
+
+class CTRexVlan_Test(CTRexGeneral_Test):#(unittest.TestCase):
+    """This class defines test for vlan platform configutation file"""
+    def __init__(self, *args, **kwargs):
+        super(CTRexVlan_Test, self).__init__(*args, **kwargs)
+        self.unsupported_modes = ['loopback'] # We test on routers
+
+    def setUp(self):
+        super(CTRexVlan_Test, self).setUp() # launch super test class setUp process
+
+    def test_platform_cfg_vlan(self):
+        if self.is_loopback:
+            self.skip('Not relevant on loopback')
+
+        if not CTRexScenario.router_cfg['no_dut_config']:
+            self.router.configure_basic_interfaces(vlan = True)
+            self.router.config_pbr(mode = "config", vlan = True)
+
+        mult = self.get_benchmark_param('multiplier')
+        core = self.get_benchmark_param('cores')
+
+        self.create_vlan_conf_file()
+
+        ret = self.trex.start_trex (
+            c = core,
+            m = mult,
+            d = 60,
+            f = 'cap2/dns.yaml',
+            cfg = '/tmp/trex_files/trex_cfg_vlan.yaml',
+            l = 100,
+            limit_ports = 4)
+
+        trex_res = self.trex.sample_to_run_finish()
+        print("\nLATEST RESULT OBJECT:")
+        print(trex_res)
+        self.check_general_scenario_results(trex_res, check_latency = True)
+
+    def tearDown(self):
+        pass
+
+    # Add vlan to platform config file
+    # write the result to new config file in /tmp, to be used by the test
+    def create_vlan_conf_file(self):
+
+        remote_cfg_file = self.trex.get_trex_config()
+        out = open("/tmp/trex_cfg_vlan.yaml", "w")
+        insert_vlan = False
+        vlan_val_1 = "100"
+        vlan_val_2 = "200"
+        vlan_val = vlan_val_1
+
+        for line in remote_cfg_file.split("\n"):
+            out.write (line + "\n")
+            # when we see "port_info" start inserting, until port_info section end
+            if "port_info" in line.lstrip():
+                num_space_port_info = len(line) - len(line.lstrip())
+                insert_vlan = True
+                continue
+
+            if insert_vlan:
+                num_space = len(line) - len(line.lstrip())
+                if num_space == num_space_port_info:
+                    insert_vlan = False
+                    continue
+                if len(line.lstrip()) > 0 and line.lstrip()[0] == '-':
+                    # insert vlan for each port (every time a section start with '-'
+                    num_space = len(line) - len(line.lstrip(' -'))
+                    # need to insert in the same indentation as other lines in the section
+                    out.write(num_space* " " + "vlan: " + vlan_val + "\n")
+                    if vlan_val == vlan_val_1:
+                        vlan_val = vlan_val_2                            
+                    else:
+                        vlan_val = vlan_val_1
+        out.close()
+        self.trex.push_files("/tmp/trex_cfg_vlan.yaml");
+                        
+if __name__ == "__main__":
+    pass
diff --git a/scripts/automation/trex_control_plane/stf/trex_stf_lib/trex_client.py b/scripts/automation/trex_control_plane/stf/trex_stf_lib/trex_client.py
index 490e3b7a..43504c96 100755
--- a/scripts/automation/trex_control_plane/stf/trex_stf_lib/trex_client.py
+++ b/scripts/automation/trex_control_plane/stf/trex_stf_lib/trex_client.py
@@ -889,6 +889,31 @@ class CTRexClient(object):
         finally:
             self.prompt_verbose_data()
 
+    def get_trex_config(self):
+        """
+        Get Trex config file (/etc/trex_cfg.yaml).
+
+        :return:
+            String representation of TRex config file
+
+        :raises:
+            + :exc:`trex_exceptions.TRexRequestDenied`, in case file could not be read.
+            + ProtocolError, in case of error in JSON-RPC protocol.
+
+        """
+        try:
+            res = binascii.a2b_base64(self.server.get_trex_config())
+            if type(res) is bytes:
+                return res.decode()
+            return res
+        except AppError as err:
+            self._handle_AppError_exception(err.args[0])
+        except ProtocolError:
+            raise
+        finally:
+            self.prompt_verbose_data()
+
+
     def push_files (self, filepaths):
         """
         Pushes a file (or a list of files) to store locally on server.