@@ -13,7 +13,7 @@ from framework.packet import Packet
from framework.pktgen import PacketGeneratorHelper
from framework.pmd_output import PmdOutput
from framework.qemu_kvm import QEMUKvm
-from framework.settings import CONFIG_ROOT_PATH, HEADER_SIZE
+from framework.settings import CONFIG_ROOT_PATH, HEADER_SIZE, get_host_ip
from framework.test_case import TestCase
from .virtio_common import dsa_common as DC
@@ -63,6 +63,8 @@ class TestBasic4kPagesDsa(TestCase):
self.virtio_mac2 = "52:54:00:00:00:02"
self.base_dir = self.dut.base_dir.replace("~", "/root")
self.random_string = string.ascii_letters + string.digits
+ self.addr = str(self.dut.get_ip_address())
+ self.host_addr = get_host_ip(self.addr).split(":")[0]
self.headers_size = HEADER_SIZE["eth"] + HEADER_SIZE["ip"] + HEADER_SIZE["tcp"]
self.DC = DC(self)
@@ -125,6 +127,7 @@ class TestBasic4kPagesDsa(TestCase):
def start_vm0(self, packed=False, queues=1, server=False):
packed_param = ",packed=on" if packed else ""
+ mq_param = ",mq=on,vectors=%s" % (2 + 2 * queues) if queues > 1 else ""
server = ",server" if server else ""
self.qemu_cmd0 = (
f"taskset -c {self.vm0_lcore} {self.vm0_qemu_path} -name vm0 -enable-kvm "
@@ -133,7 +136,7 @@ class TestBasic4kPagesDsa(TestCase):
f"-chardev socket,id=char0,path=/root/dpdk/vhost-net0{server} "
f"-netdev type=vhost-user,id=netdev0,chardev=char0,vhostforce,queues={queues} "
f"-device virtio-net-pci,netdev=netdev0,mac=%s,"
- f"disable-modern=false,mrg_rxbuf=on,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on{packed_param} "
+ f"disable-modern=false,mrg_rxbuf=on,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on{packed_param}{mq_param} "
f"-cpu host -smp {self.vm0_lcore_smp} -m {self.vm0_mem_size} -object memory-backend-file,id=mem,size={self.vm0_mem_size}M,mem-path=/mnt/tmpfs_nohuge0,share=on "
f"-numa node,memdev=mem -mem-prealloc -drive file={self.vm0_image_path} "
f"-chardev socket,path=/tmp/vm0_qga0.sock,server,nowait,id=vm0_qga0 -device virtio-serial "
@@ -153,6 +156,7 @@ class TestBasic4kPagesDsa(TestCase):
def start_vm1(self, packed=False, queues=1, server=False):
packed_param = ",packed=on" if packed else ""
+ mq_param = ",mq=on,vectors=%s" % (2 + 2 * queues) if queues > 1 else ""
server = ",server" if server else ""
self.qemu_cmd1 = (
f"taskset -c {self.vm1_lcore} {self.vm1_qemu_path} -name vm1 -enable-kvm "
@@ -161,7 +165,7 @@ class TestBasic4kPagesDsa(TestCase):
f"-chardev socket,id=char0,path=/root/dpdk/vhost-net1{server} "
f"-netdev type=vhost-user,id=netdev0,chardev=char0,vhostforce,queues={queues} "
f"-device virtio-net-pci,netdev=netdev0,mac=%s,"
- f"disable-modern=false,mrg_rxbuf=on,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on{packed_param} "
+ f"disable-modern=false,mrg_rxbuf=on,csum=on,guest_csum=on,host_tso4=on,guest_tso4=on,guest_ecn=on{packed_param}{mq_param} "
f"-cpu host -smp {self.vm1_lcore_smp} -m {self.vm1_mem_size} -object memory-backend-file,id=mem,size={self.vm1_mem_size}M,mem-path=/mnt/tmpfs_nohuge1,share=on "
f"-numa node,memdev=mem -mem-prealloc -drive file={self.vm1_image_path} "
f"-chardev socket,path=/tmp/vm1_qga0.sock,server,nowait,id=vm1_qga0 -device virtio-serial "
@@ -169,7 +173,7 @@ class TestBasic4kPagesDsa(TestCase):
)
self.vm1_session = self.dut.new_session(suite="vm1_session")
cmd1 = self.qemu_cmd1 % (
- self.dut.get_ip_address(),
+ self.host_addr,
self.virtio_mac2,
)
self.vm1_session.send_expect(cmd1, "# ")
@@ -181,7 +185,7 @@ class TestBasic4kPagesDsa(TestCase):
def connect_vm0(self):
self.vm0 = QEMUKvm(self.dut, "vm0", self.suite_name)
self.vm0.net_type = "hostfwd"
- self.vm0.hostfwd_addr = "%s:6000" % self.dut.get_ip_address()
+ self.vm0.hostfwd_addr = "%s:6000" % self.host_addr
self.vm0.def_driver = "vfio-pci"
self.vm0.driver_mode = "noiommu"
self.wait_vm_net_ready(vm_index=0)
@@ -194,7 +198,7 @@ class TestBasic4kPagesDsa(TestCase):
def connect_vm1(self):
self.vm1 = QEMUKvm(self.dut, "vm1", "vm_hotplug")
self.vm1.net_type = "hostfwd"
- self.vm1.hostfwd_addr = "%s:6001" % self.dut.get_ip_address()
+ self.vm1.hostfwd_addr = "%s:6001" % self.host_addr
self.vm1.def_driver = "vfio-pci"
self.vm1.driver_mode = "noiommu"
self.wait_vm_net_ready(vm_index=1)