Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

hmat_info: add case #5215

Draft
wants to merge 1 commit into
base: master
Choose a base branch
from
Draft

hmat_info: add case #5215

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 34 additions & 0 deletions libvirt/tests/cfg/numa/guest_numa_hmat/hmat_info.cfg
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,34 @@
- guest_numa_hmat.hmat_info:
type = hmat_info
take_regular_screendumps = no
start_vm = "no"
single_host_node = yes
cpu_mode = 'host-model'
no s390-virtio
aarch64:
cpu_mode = 'host-passthrough'
numa_cell0_cache0 = "{'size_unit': 'KiB', 'line_unit': 'B', 'policy': 'writeback', 'associativity': 'direct', 'line_value': '8', 'level': '1', 'size_value': '10'}"
numa_cell0_cache1 = "{'size_unit': 'KiB', 'line_unit': 'B', 'policy': 'writethrough', 'associativity': 'full', 'line_value': '16', 'level': '2', 'size_value': '128'}"
numa_cell0 = "{'caches': [${numa_cell0_cache0}, ${numa_cell0_cache1}], 'memory': '1048576', 'cpus': '0-1', 'unit': 'KiB', 'id': '0'}"
numa_cell1_cache0 = "{'size_unit': 'KiB', 'line_unit': 'B', 'line_value': '8', 'level': '1', 'size_value': '10', 'associativity': 'none', 'policy': 'none'}"
numa_cell1 = "{'caches': [${numa_cell1_cache0}], 'memory': '1048576', 'cpus': '2-3', 'unit': 'KiB', 'id': '1'}"
bandwidth0 = "{'cache': '1', 'initiator': '0', 'target': '0', 'type': 'access', 'unit': 'KiB', 'value': '204800'}"
bandwidth1 = "{'initiator': '0', 'target': '0', 'type': 'read', 'unit': 'KiB', 'value': '205824'}"
bandwidth2 = "{'initiator': '0', 'target': '0', 'type': 'write', 'unit': 'KiB', 'value': '206848'}"
bandwidth3 = "{'initiator': '0', 'target': '1', 'type': 'access', 'unit': 'KiB', 'value': '102400'}"
bandwidth4 = "{'initiator': '1', 'target': '1', 'type': 'read', 'unit': 'KiB', 'value': '103424'}"
bandwidth5 = "{'initiator': '1', 'target': '1', 'type': 'write', 'unit': 'KiB', 'value': '104448'}"
latency0 = "{'cache': '1', 'initiator': '0', 'target': '0', 'type': 'read', 'value': '5'}"
latency1 = "{'initiator': '0', 'target': '0', 'type': 'read', 'value': '6'}"
latency2 = "{'initiator': '0', 'target': '0', 'type': 'write', 'value': '7'}"
latency3 = "{'initiator': '0', 'target': '1', 'type': 'access', 'value': '10'}"
latency4 = "{'initiator': '1', 'target': '1', 'type': 'read', 'value': '11'}"
latency5 = "{'initiator': '1', 'target': '1', 'type': 'write', 'value': '12'}"
bandwidth = "'bandwidth': [${bandwidth0}, ${bandwidth1}, ${bandwidth2}, ${bandwidth3}, ${bandwidth4}, ${bandwidth5}]"
latency = "'latency':[${latency0}, ${latency1}, ${latency2}, ${latency3}, ${latency4}, ${latency5}]"
interconnects = "'interconnects': {${bandwidth}, ${latency}}"
numa_cell = "'numa_cell': [${numa_cell0}, ${numa_cell1}]"
vm_attrs = "{'vcpu': 4, 'cpu': {'mode': '${cpu_mode}', ${numa_cell}, ${interconnects}}}"
variants:
- default:
func_supported_since_libvirt_ver = (7, 5, 0)
163 changes: 163 additions & 0 deletions libvirt/tests/src/numa/guest_numa_hmat/hmat_info.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,163 @@
#
# ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
#
# Copyright Red Hat
#
# SPDX-License-Identifier: GPL-2.0
# Author: Dan Zheng <[email protected]>
#

import re

from virttest import utils_libvirtd
from virttest import utils_split_daemons
from virttest import virsh
from virttest import test_setup
from virttest.libvirt_xml import capability_xml
from virttest.libvirt_xml import vm_xml
from virttest.utils_test import libvirt
from virttest.utils_libvirt import libvirt_nested

from provider.numa import numa_base


def setup_default(numatest_obj):
"""
Default setup function for the test

:param numatest_obj: NumaTest object
"""
numatest_obj.setup()
numatest_obj.test.log.debug("Step: setup is done")


def prepare_vm_xml(numatest_obj):
"""
Customize the vm xml

:param numatest_obj: NumaTest object
:return: VMXML object updated
"""
vmxml = numatest_obj.prepare_vm_xml()

numatest_obj.test.log.debug("Step: vm xml before defining:\n%s", vmxml)
return vmxml


def verify_guest_dmesg(numatest_obj, vm_session):

search_list = ['Flags:00 Type:Access Latency Initiator', 'Initiator-Target[0-1]:10 nsec',
'Flags:00 Type:Read Latency Initiator', 'Initiator-Target[0-0]:6 nsec',
'Initiator-Target[1-1]:11 nsec', 'Flags:00 Type:Write Latency Initiator',
'Initiator-Target[0-0]:7 nsec', 'Initiator-Target[1-1]:12 nsec',
'Flags:00 Type:Access Bandwidth Initiator', 'Initiator-Target[0-1]:100 MB/s',
'Flags:00 Type:Read Bandwidth Initiator', 'Initiator-Target[0-0]:201 MB/s',
'Initiator-Target[1-1]:101 MB/s', 'Flags:00 Type:Write Bandwidth Initiator',
'Initiator-Target[0-0]:202 MB/s', 'Initiator-Target[1-1]:102 MB/s',
'Flags:01 Type:Read Latency Initiator', 'Initiator-Target[0-0]:5 nsec',
'Flags:01 Type:Access Bandwidth Initiator', 'Initiator-Target[0-0]:200 MB/s']
cmd_dmesg = 'dmesg | grep hmat'
status, output = vm_session.cmd_status_output(cmd_dmesg)
if status:
numatest_obj.test.error("Can not find any message with command '%s'" % cmd_dmesg)

for search_item in search_list:
if not output.count(search_item):
numatest_obj.test.fail("Expect '%s' in guest dmesg, but not found" % search_item)
numatest_obj.test.log.debug("Verify guest dmesg - PASS")


def verify_hmat_cache_by_virsh_capabilities(numatest_obj, vm_session, capa_xml):
def _compare_cache(expected_cache, actual_cache):
if actual_cache != expected_cache:
numatest_obj.test.fail("Expect cache should "
"be '%s', but found '%s'" % (expected_cache,
actual_cache))

topo_xml = capa_xml.cells_topology
cells = topo_xml.get_cell(withmem=True)
numa_cell0_cache0 = eval(numatest_obj.params.get('numa_cell0_cache0'))
numa_cell0_cache1 = eval(numatest_obj.params.get('numa_cell0_cache1'))
numa_cell1_cache0 = eval(numatest_obj.params.get('numa_cell1_cache0'))
for one_cell in cells:
cache_list = one_cell.cache
numatest_obj.test.log.debug("cache_list:%s", cache_list)
if one_cell.cell_id == '0':
_compare_cache(numa_cell0_cache0, cache_list[0])
_compare_cache(numa_cell0_cache1, cache_list[1])
else:
_compare_cache(numa_cell1_cache0, cache_list[0])

numatest_obj.test.log.debug("Verify cache in virsh capabilities - PASS")


def verify_hmat_interconnects_by_virsh_capabilities(numatest_obj, vm_session, capa_xml):
topo_xml = capa_xml.cells_topology
interconnects = topo_xml.interconnects
latency_list = interconnects.latency
bandwidth_list = interconnects.bandwidth
numatest_obj.test.log.debug(latency_list)
numatest_obj.test.log.debug(bandwidth_list)
""" for counter in range(0, 6):
latency = numatest_obj.params.get('latency%s' % counter)
bandwidth = numatest_obj.params.get('bandwidth%s' % counter)
if latency_list[] """



def run_default(numatest_obj):
"""
Default run function for the test

:param numatest_obj: NumaTest object
"""
numatest_obj.test.log.debug("Step: prepare vm xml")
vmxml = prepare_vm_xml(numatest_obj)
numatest_obj.test.log.debug("Step: define vm")
virsh.define(vmxml.xml, **numatest_obj.virsh_dargs)
numatest_obj.test.log.debug("Step: start vm")
virsh.start(numatest_obj.vm.name, **numatest_obj.virsh_dargs)
numatest_obj.test.log.debug("After vm is started, vm xml:\n"
"%s", vm_xml.VMXML.new_from_dumpxml(numatest_obj.vm.name))
vm_session = numatest_obj.vm.wait_for_login()
verify_guest_dmesg(numatest_obj, vm_session)

libvirt_nested.install_virt_pkgs(vm_session)
if utils_split_daemons.is_modular_daemon(vm_session):
utils_libvirtd.Libvirtd(session=vm_session).start()
utils_libvirtd.Libvirtd(session=vm_session, service_name='virtproxyd.socket').start()

vm_ip = numatest_obj.vm.get_address()
virsh_dargs = {'remote_ip': vm_ip,
'remote_user': numatest_obj.params.get('username'),
'remote_pwd': numatest_obj.params.get('password'),
'ssh_remote_auth': True}
virsh_instance = virsh.VirshPersistent(**virsh_dargs)
capa_xml = capability_xml.CapabilityXML(virsh_instance=virsh_instance)
numatest_obj.test.log.debug("capa_xml:%s", capa_xml)
verify_hmat_cache_by_virsh_capabilities(numatest_obj, vm_session, capa_xml)
verify_hmat_interconnects_by_virsh_capabilities(numatest_obj, vm_session, capa_xml)


def teardown_default(numatest_obj):
"""
Default teardown function for the test

:param numatest_obj: NumaTest object
"""
numatest_obj.teardown()
numatest_obj.test.log.debug("Step: teardown is done")


def run(test, params, env):
"""
Test for numa memory binding with emulator thread pin
"""
vm_name = params.get("main_vm")
vm = env.get_vm(vm_name)
numatest_obj = numa_base.NumaTest(vm, params, test)
try:
setup_default(numatest_obj)
run_default(numatest_obj)
finally:
teardown_default(numatest_obj)
Loading