[dts] [PATCH] tests: add hotplug on multi-processes test suite

[Tu, Lijuan]

Hi xueqin,

This patch was applied on Nov 27th, thanks.

> -----Original Message-----
> From: dts [mailto:dts-bounces at dpdk.org] On Behalf Of Xueqin Lin
> Sent: Tuesday, November 27, 2018 1:30 PM
> To: dts at dpdk.org
> Cc: Lin, Xueqin <xueqin.lin at intel.com>
> Subject: [dts] [PATCH] tests: add hotplug on multi-processes test suite
> 
> From: "xueqin.lin" <xueqin.lin at intel.com>
> 
> Signed-off-by: Xueqin Lin <xueqin.lin at intel.com>
> 
> ---
>  tests/TestSuite_hotplug_mp.py | 310
> ++++++++++++++++++++++++++++++++++++++++++
>  1 file changed, 310 insertions(+)
>  create mode 100644 tests/TestSuite_hotplug_mp.py
> 
> diff --git a/tests/TestSuite_hotplug_mp.py b/tests/TestSuite_hotplug_mp.py
> new file mode 100644 index 0000000..20f914a
> --- /dev/null
> +++ b/tests/TestSuite_hotplug_mp.py
> @@ -0,0 +1,310 @@
> +# <COPYRIGHT_TAG>
> +
> +"""
> +DPDK Test suite.
> +Hotplug Multi-process Test.
> +"""
> +
> +import utils
> +import time
> +from test_case import TestCase
> +
> +test_loop = 2
> +
> +
> +class TestHotplugMp(TestCase):
> +
> +    def set_up_all(self):
> +        """
> +        Run at the start of each test suite.
> +        """
> +        self.dut_ports = self.dut.get_ports(self.nic)
> +        self.verify(len(self.dut_ports) >= 1, "Insufficient ports")
> +        self.intf0 = self.dut.ports_info[0]['intf']
> +        self.pci0 = self.dut.ports_info[0]['pci']
> +        out =
> self.dut.build_dpdk_apps("./examples/multi_process/hotplug_mp")
> +        self.verify('Error' not in out, "Compilation failed")
> +        # Start one new session to run primary process
> +        self.session_pri = self.dut.new_session()
> +        # Start two new sessions to run secondary process
> +        self.session_sec_1 = self.dut.new_session()
> +        self.session_sec_2 = self.dut.new_session()
> +        if self.drivername != "":
> +            self.dut.bind_interfaces_linux(self.kdriver)
> +
> +    def set_up(self):
> +        """
> +        Run before each test case.
> +        """
> +        pass
> +
> +    def multi_process_setup(self):
> +        """
> +        Setup primary process and two secondary processes.
> +        """
> +        out = self.session_pri.send_expect(
> +            "./examples/multi_process/hotplug_mp/%s/hotplug_mp
> --proc-type=auto"
> +            % self.target, "example>")
> +        self.verify("Auto-detected process type: PRIMARY" in out,
> +                    "Failed to setup primary process!")
> +        for out in [self.session_sec_1.send_expect(
> +
> "./examples/multi_process/hotplug_mp/%s/hotplug_mp --proc-type=auto"
> +                        % self.target, "example>"),
> +                    self.session_sec_2.send_expect(
> +
> "./examples/multi_process/hotplug_mp/%s/hotplug_mp --proc-type=auto"
> +                        % self.target, "example>")]:
> +            self.verify("Auto-detected process type: SECONDARY" in out,
> +                        "Failed to setup secondary process!")
> +
> +    def multi_process_quit(self):
> +        """
> +        Quit primary process and two secondary processes.
> +        """
> +        self.session_sec_1.send_expect("quit", "#")
> +        self.session_sec_2.send_expect("quit", "#")
> +        self.session_pri.send_expect("quit", "#")
> +
> +    def verify_devlist(self, dev="0000:00:00.0", flg_exist=1):
> +        """
> +        Check device list to verify if exist the device.
> +        """
> +        for out in [self.session_pri.send_expect("list", "example>", 100),
> +                    self.session_sec_1.send_expect("list", "example>",
> 100),
> +                    self.session_sec_2.send_expect("list", "example>",
> 100)]:
> +            self.verify("list all etherdev" in out,
> +                        "Failed to list device on multi-process!")
> +            if flg_exist == 1:
> +                self.verify(dev in out, "Fail that don't have the device!")
> +            if flg_exist == 0:
> +                self.verify(dev not in out, "Fail that have the
> + device!")
> +
> +    def attach_detach(self, process="pri", is_dev=1, opt_plug="plugin",
> flg_loop=0, dev="0000:00:00.0"):
> +        """
> +        Attach or detach physical/virtual device from primary/secondary
> +        process.
> +        process: define primary or secondary process.
> +        is_dev: define physical device as 1, virtual device as 0.
> +        opt_plug: define plug options as below
> +                  plugin: plug in device
> +                  plugout: plug out device
> +                  hotplug: plug in then plug out device from primary or
> +                           secondary process
> +                  crossplug: plug in from primary process then plug out
> from
> +                             secondary process, or plug in from
> secondary
> +                             process then plug out from primary
> +        flg_loop: define loop test flag
> +        dev: define physical device PCI "0000:00:00.0" or virtual device
> +             "net_af_packet"
> +        """
> +
> +        if opt_plug == "plugin":
> +            self.verify_devlist(dev, flg_exist=0)
> +            for i in range(test_loop):
> +                if process == "pri":
> +                    if is_dev == 0:
> +                        self.session_pri.send_expect(
> +                            "attach %s,iface=%s"
> +                            % (dev, self.intf0), "example>", 100)
> +                    else:
> +                        self.session_pri.send_expect(
> +                            "attach %s" % dev, "example>", 100)
> +                if process == "sec":
> +                    if is_dev == 0:
> +                        self.session_sec_1.send_expect(
> +                            "attach %s,iface=%s"
> +                            % (dev, self.intf0), "example>", 100)
> +                    else:
> +                        self.session_sec_1.send_expect(
> +                            "attach %s" % dev, "example>", 100)
> +                if flg_loop == 0:
> +                    break
> +
> +            self.verify_devlist(dev, flg_exist=1)
> +
> +        if opt_plug == "plugout":
> +            self.verify_devlist(dev, flg_exist=1)
> +            for i in range(test_loop):
> +                if process == "pri":
> +                    self.session_pri.send_expect(
> +                        "detach %s" % dev, "example>", 100)
> +                if process == "sec":
> +                    self.session_sec_1.send_expect(
> +                        "detach %s" % dev, "example>", 100)
> +                if flg_loop == 0:
> +                    break
> +
> +            self.verify_devlist(dev, flg_exist=0)
> +
> +    def attach_detach_dev(self, process="pri", opt_plug="plugin",
> flg_loop=0, dev="0000:00:00.0"):
> +        """
> +        Attach or detach physical device from primary/secondary
> process.
> +        """
> +        # Scan port status when example setup, list ports that have been
> +        #  bound to pmd
> +        if opt_plug in ["plugin", "hotplug", "crossplug"]:
> +            self.multi_process_setup()
> +            self.dut.bind_interfaces_linux(self.drivername)
> +        elif opt_plug == "plugout":
> +            self.dut.bind_interfaces_linux(self.drivername)
> +            self.multi_process_setup()
> +
> +        if opt_plug in ["plugin", "plugout"]:
> +            self.attach_detach(process, 1, opt_plug, flg_loop, dev)
> +        elif opt_plug in ["hotplug", "crossplug"]:
> +            for i in range(test_loop):
> +                self.attach_detach(process, 1, "plugin", flg_loop, dev)
> +                if opt_plug == "crossplug":
> +                    if process == "pri":
> +                        cross_proc = "sec"
> +                    elif process == "sec":
> +                        cross_proc = "pri"
> +                    self.attach_detach(cross_proc, 1, "plugout",
> flg_loop, dev)
> +                else:
> +                    self.attach_detach(process, 1, "plugout", flg_loop,
> + dev)
> +
> +        self.multi_process_quit()
> +        self.dut.bind_interfaces_linux(self.kdriver)
> +
> +    def attach_detach_vdev(self, process="pri", opt_plug="plugin",
> flg_loop=0, dev="net_af_packet"):
> +        """
> +        Attach or detach virtual device from primary/secondary process.
> +        Check port interface is at link up status before hotplug test.
> +        If link not up, may have below error:
> +        rte_pmd_init_internals(): net_af_packet: ioctl failed
> (SIOCGIFINDEX)
> +        EAL: Driver cannot attach the device (net_af_packet)
> +        """
> +        self.dut.send_expect("ifconfig %s up" % self.intf0, "#")
> +        time.sleep(5)
> +        out = self.dut.send_expect("ethtool %s" % self.intf0, "#")
> +        self.verify("Link detected: yes" in out, "Wrong link status")
> +
> +        self.multi_process_setup()
> +        for i in range(test_loop):
> +            self.attach_detach(process, 0, "plugin", flg_loop, dev)
> +            if opt_plug in ["plugout", "hotplug", "crossplug"]:
> +                if opt_plug == "crossplug":
> +                    if process == "pri":
> +                        cross_proc = "sec"
> +                    elif process == "sec":
> +                        cross_proc = "pri"
> +                    self.attach_detach(cross_proc, 0, "plugout",
> flg_loop, dev)
> +                else:
> +                    self.attach_detach(process, 0, "plugout", flg_loop,
> + dev)
> +
> +            if opt_plug == "plugin" or opt_plug == "plugout":
> +                break
> +
> +        self.multi_process_quit()
> +
> +    def test_attach_dev_primary(self):
> +        """
> +        Attach physical device from primary.
> +        """
> +        self.attach_detach_dev("pri", "plugin", 0, self.pci0)
> +
> +    def test_attach_dev_secondary(self):
> +        """
> +        Attach physical device from secondary.
> +        """
> +        self.attach_detach_dev("sec", "plugin", 0, self.pci0)
> +
> +    def test_detach_dev_primary(self):
> +        """
> +        Detach physical device from primary.
> +        """
> +        self.attach_detach_dev("pri", "plugout", 0, self.pci0)
> +
> +    def test_detach_dev_secondary(self):
> +        """
> +        Detach physical device from secondary.
> +        """
> +        self.attach_detach_dev("sec", "plugout", 0, self.pci0)
> +
> +    def test_attach_detach_dev_primary_loop(self):
> +        """
> +        Repeat to attach then detach physical device from primary.
> +        """
> +        self.attach_detach_dev("pri", "hotplug", 1, self.pci0)
> +
> +    def test_attach_detach_dev_secondary_loop(self):
> +        """
> +        Repeat to attach then detach physical device from secondary.
> +        """
> +        self.attach_detach_dev("sec", "hotplug", 1, self.pci0)
> +
> +    def test_attach_detach_dev_primary_cross_loop(self):
> +        """
> +        Repeat to attach physical device from primary then detach device
> +        from secondary.
> +        """
> +        self.attach_detach_dev("pri", "crossplug", 1, self.pci0)
> +
> +    def test_attach_detach_dev_secondary_cross_loop(self):
> +        """
> +        Repeat to attach physical device from secondary then detach
> device
> +        from primary.
> +        """
> +        self.attach_detach_dev("sec", "crossplug", 1, self.pci0)
> +
> +    def test_attach_vdev_primary(self):
> +        """
> +        Attach virtual device from primary.
> +        """
> +        self.attach_detach_vdev("pri", "plugin", 0, "net_af_packet")
> +
> +    def test_attach_vdev_secondary(self):
> +        """
> +        Attach virtual device from secondary.
> +        """
> +        self.attach_detach_vdev("sec", "plugin", 0, "net_af_packet")
> +
> +    def test_detach_vdev_primary(self):
> +        """
> +        Detach virtual device from primary.
> +        """
> +        self.attach_detach_vdev("pri", "plugout", 0, "net_af_packet")
> +
> +    def test_detach_vdev_secondary(self):
> +        """
> +        Detach virtual device from secondary.
> +        """
> +        self.attach_detach_vdev("sec", "plugout", 0, "net_af_packet")
> +
> +    def test_attach_detach_vdev_primary_loop(self):
> +        """
> +        Repeat to attach then detach virtual device from primary.
> +        """
> +        self.attach_detach_vdev("pri", "hotplug", 1, "net_af_packet")
> +
> +    def test_attach_detach_vdev_secondary_loop(self):
> +        """
> +        Repeat to attach then detach virtual device from secondary.
> +        """
> +        self.attach_detach_vdev("sec", "hotplug", 1, "net_af_packet")
> +
> +    def test_attach_detach_vdev_primary_cross_loop(self):
> +        """
> +        Repeat to attach virtual device from primary then detach device
> +        from secondary.
> +        """
> +        self.attach_detach_vdev("pri", "crossplug", 1, "net_af_packet")
> +
> +    def test_attach_detach_vdev_secondary_cross_loop(self):
> +        """
> +        Repeat to attach virtual device from secondary then detach
> device
> +        from primary.
> +        """
> +        self.attach_detach_vdev("sec", "crossplug", 1, "net_af_packet")
> +
> +    def tear_down(self):
> +        """
> +        Run after each test case.
> +        """
> +        pass
> +
> +    def tear_down_all(self):
> +        """
> +        Run after each test suite.
> +        """
> +        self.dut.close_session(self.dut)
> +        self.dut.kill_all()
> --
> 2.7.5