From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from dpdk.org (dpdk.org [92.243.14.124]) by dpdk.space (Postfix) with ESMTP id 4C462A0096 for ; Wed, 8 May 2019 10:23:50 +0200 (CEST) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id 32705493D; Wed, 8 May 2019 10:23:50 +0200 (CEST) Received: from mga03.intel.com (mga03.intel.com [134.134.136.65]) by dpdk.org (Postfix) with ESMTP id EB533378B for ; Wed, 8 May 2019 10:23:48 +0200 (CEST) X-Amp-Result: SKIPPED(no attachment in message) X-Amp-File-Uploaded: False Received: from fmsmga004.fm.intel.com ([10.253.24.48]) by orsmga103.jf.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384; 08 May 2019 01:23:47 -0700 X-ExtLoop1: 1 Received: from ubuntu.sh.intel.com ([10.67.118.150]) by fmsmga004.fm.intel.com with ESMTP; 08 May 2019 01:23:46 -0700 From: lihong To: dts@dpdk.org Cc: yinan.wang@intel.com, lihong Date: Wed, 8 May 2019 09:03:13 +0800 Message-Id: <1557277393-11394-1-git-send-email-lihongx.ma@intel.com> X-Mailer: git-send-email 2.7.4 Subject: [dts] [PATCH V2] Add testsuite vhost enqueue interrupt X-BeenThere: dts@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: test suite reviews and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dts-bounces@dpdk.org Sender: "dts" Signed-off-by: lihong --- tests/TestSuite_vhost_enqueue_interrupt.py | 202 +++++++++++++++++++++++++++++ 1 file changed, 202 insertions(+) create mode 100644 tests/TestSuite_vhost_enqueue_interrupt.py diff --git a/tests/TestSuite_vhost_enqueue_interrupt.py b/tests/TestSuite_vhost_enqueue_interrupt.py new file mode 100644 index 0000000..29c3756 --- /dev/null +++ b/tests/TestSuite_vhost_enqueue_interrupt.py @@ -0,0 +1,202 @@ +# BSD LICENSE +# +# Copyright (c) <2019>, Intel Corporation. +# All rights reserved. +# +# Redistribution and use in source and binary forms, with or without +# modification, are permitted provided that the following conditions +# are met: +# +# * Redistributions of source code must retain the above copyright +# notice, this list of conditions and the following disclaimer. +# * Redistributions in binary form must reproduce the above copyright +# notice, this list of conditions and the following disclaimer in +# the documentation and/or other materials provided with the +# distribution. +# * Neither the name of Intel Corporation nor the names of its +# contributors may be used to endorse or promote products derived +# from this software without specific prior written permission. +# +# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + +""" +DPDK Test suite. +Vhost enqueue interrupt need test with l3fwd-power sample +""" + +import utils +import time +from test_case import TestCase + + +class TestVhostEnqueueInterrupt(TestCase): + + def set_up_all(self): + """ + Run at the start of each test suite. + + """ + self.queues = 1 + self.cores_num = len([n for n in self.dut.cores if int(n['socket']) == 0]) + self.vmac = "00:11:22:33:44:10" + self.dut_ports = self.dut.get_ports() + self.mem_channels = self.dut.get_memory_channels() + self.prepare_l3fwd_power() + + def set_up(self): + """ + Run before each test case. + """ + # Clean the execution ENV + self.verify_info = [] + self.dut.send_expect("killall -s INT testpmd", "#") + self.dut.send_expect("killall -s INT l3fwd-power", "#") + self.dut.send_expect("rm -rf ./vhost-net*", "#") + self.vhost = self.dut.new_session(suite="vhost-l3fwd") + self.virtio_user = self.dut.new_session(suite="virtio-user") + + def prepare_l3fwd_power(self): + self.dut.send_expect("cp ./examples/l3fwd-power/main.c .", "#") + self.dut.send_expect( + "sed -i '/DEV_RX_OFFLOAD_CHECKSUM/d' ./examples/l3fwd-power/main.c", "#") + out = self.dut.build_dpdk_apps('examples/l3fwd-power') + self.verify("Error" not in out, "compilation l3fwd-power error") + + def get_core_list(self): + """ + get core list depend on the core number + """ + need_num = 2*self.queues+1 + self.core_config = "1S/%dC/1T" % need_num + self.verify(self.cores_num >= need_num, + "There has not enought cores to test this case") + core_list = self.dut.get_core_list(self.core_config) + self.core_list_virtio = core_list[0: self.queues+1] + self.core_list_l3fwd = core_list[self.queues+1: need_num] + self.core_mask_virtio = utils.create_mask(self.core_list_virtio) + self.core_mask_l3fwd = utils.create_mask(self.core_list_l3fwd) + + def lanuch_virtio_user(self): + """ + launch virtio-user with server mode + """ + command_client = self.dut.target + "/app/testpmd -c %s -n %d " + \ + "--socket-mem 1024,1024 --legacy-mem --no-pci " + \ + "--file-prefix=virtio " + \ + "--vdev=net_virtio_user0,mac=%s,path=./vhost-net,server=1,queues=%d " + \ + "-- -i --rxq=%d --txq=%d --rss-ip" + command_line_client = command_client % ( + self.core_mask_virtio, self.mem_channels, + self.vmac, self.queues, self.queues, self.queues) + self.virtio_user.send_expect(command_line_client, "testpmd> ", 120) + self.virtio_user.send_expect("set fwd txonly", "testpmd> ", 20) + + def lanuch_l3fwd_power(self): + """ + launch l3fwd-power with a virtual vhost device + """ + self.logger.info("Launch l3fwd_sample sample:") + # config the interrupt cores + config_info = "" + for i in range(self.queues): + if config_info != "": + config_info += ',' + config_info += '(0,%d,%s)' % (i, self.core_list_l3fwd[i]) + info = {'core': self.core_list_l3fwd[i], 'port': 0, 'queue': i} + self.verify_info.append(info) + + command_client = "./examples/l3fwd-power/build/app/l3fwd-power " + \ + "-c %s -n %d --socket-mem 1024,1024 --legacy-mem --no-pci " + \ + "--vdev 'net_vhost0,iface=vhost-net,queues=%d,client=1' " + \ + "-- -p 0x1 --parse-ptype 1 --config '%s' " + command_line_client = command_client % ( + self.core_mask_l3fwd, self.mem_channels, + self.queues, config_info) + self.vhost.send_expect(command_line_client, "POWER", 40) + time.sleep(10) + out = self.vhost.get_session_before() + if ("Error" in out and "Error opening" not in out): + self.logger.error("Launch l3fwd-power sample error") + else: + self.logger.info("Launch l3fwd-power sample finished") + + def check_vhost_core_status(self, status): + """ + check the cpu status + """ + out = self.vhost.get_session_before() + for i in range(len(self.verify_info)): + if status == "waked up": + info = "lcore %s is waked up from rx interrupt on port %d queue %d" + info = info % (self.verify_info[i]["core"], self.verify_info[i]['port'], + self.verify_info[i]['queue']) + elif status == "sleeps": + info = "lcore %s sleeps until interrupt triggers" % self.verify_info[i]["core"] + self.logger.info(info) + self.verify(info in out, "The CPU status not right for %s" % info) + + def send_and_verify(self): + """ + start to send packets and check the cpu status + stop and restart to send packets and check the cpu status + """ + self.virtio_user.send_expect("start", "testpmd> ", 20) + self.check_vhost_core_status("waked up") + + self.virtio_user.send_expect("stop", "testpmd> ", 20) + self.check_vhost_core_status("sleeps") + + self.virtio_user.send_expect("start", "testpmd> ", 20) + self.check_vhost_core_status("waked up") + + def close_testpmd_and_session(self): + self.virtio_user.send_expect("quit", "#", 20) + self.dut.close_session(self.vhost) + self.dut.close_session(self.virtio_user) + + def test_virtio_user_interrupt(self): + """ + Check the virtio-user interrupt can work when use vhost-net as backend + """ + self.queues = 1 + self.get_core_list() + self.lanuch_virtio_user() + self.lanuch_l3fwd_power() + self.send_and_verify() + + def test_virtio_user_interrupt_with_multi_queue(self): + """ + Check the virtio-user interrupt can work with multi queue + """ + self.queues = 4 + self.get_core_list() + self.lanuch_virtio_user() + self.lanuch_l3fwd_power() + self.send_and_verify() + + def tear_down(self): + """ + Run after each test case. + """ + self.close_testpmd_and_session() + self.dut.send_expect("killall -s INT l3fwd-power", "#") + self.dut.send_expect("killall -s INT testpmd", "#") + + def tear_down_all(self): + """ + Run after each test suite. + """ + # revert the code + self.dut.send_expect("mv ./main.c ./examples/l3fwd-power/", "#") + self.dut.build_dpdk_apps('examples/l3fwd-power') + pass -- 2.7.4