Merge ~kevinbecker/+git/autotest-client-tests:kevinbecker/pmqtest into ~canonical-kernel-team/+git/autotest-client-tests:master

[Kevin Becker]

UBUNTU: SAUCE: Added pmqtest from upstream

Signed-off-by: Kevin Becker <email address hidden>

[Po-Hsu Lin (cypressyew)]

Looking good.

One small nit is that we can check Max > 100 when parsing test output:

  for line in lines:
      if 'Max' in line:
          # Check if any max value is over 100
          if int(line.split()[-1]) > 100
              raise error.TestError('FAIL: Max latency over 100us.')

But this is rather trivial.

review: Approve

[Po-Hsu Lin (cypressyew)]

Applied and pushed.

diff --git a/rt_tests_pmqtest/control b/rt_tests_pmqtest/control
new file mode 100644
index 0000000..9248a47
--- /dev/null
+++ b/rt_tests_pmqtest/control
@@ -0,0 +1,20 @@
+AUTHOR = '''
+Authors: 
+Carsten Emde <[e-mail]>
+ '''
+NAME = "pmqtest"
+DOC = '''
+description rt test utils
+URL https://git.kernel.org/pub/scm/utils/rt-tests/rt-tests.git
+'''
+SUITE = "None"
+TIME = "MEDIUM"
+TEST_CLASS = 'kernel'
+TEST_CATEGORY = 'Functional'
+TEST_TYPE = 'client'
+
+result = job.run_test_detail('rt_tests_pmqtest', test_name='setup', tag='setup', timeout=60*5)
+if result == 'GOOD':
+    job.run_test('rt_tests_pmqtest', test_name='rt_tests_pmqtest', tag='rt_tests_pmqtest')
+else:
+    print("ERROR: test failed to build")
diff --git a/rt_tests_pmqtest/rt_tests_pmqtest.py b/rt_tests_pmqtest/rt_tests_pmqtest.py
new file mode 100644
index 0000000..d9e3fda
--- /dev/null
+++ b/rt_tests_pmqtest/rt_tests_pmqtest.py
@@ -0,0 +1,85 @@
+import multiprocessing
+import os
+import platform
+import re
+import shutil
+from autotest.client import canonical, test, utils
+from autotest.client.shared import error
+
+class rt_tests_pmqtest(test.test):
+    version = 1
+
+    def initialize(self):
+        self.flavour = re.split('-\d*-', platform.uname()[2])[-1]
+        self.arch = platform.processor()
+
+    def install_required_pkgs(self):
+        try:
+            series = platform.dist()[2]
+        except AttributeError:
+            import distro
+            series = distro.codename()
+
+        pkgs = [
+            'build-essential',
+            'git',
+            'libnuma-dev',
+        ]
+        gcc = 'gcc' if self.arch in ['ppc64le', 'aarch64', 's390x', 'riscv64'] else 'gcc-multilib'
+        pkgs.append(gcc)
+
+        cmd = 'yes "" | DEBIAN_FRONTEND=noninteractive apt-get install --yes --force-yes ' + ' '.join(pkgs)
+        self.results = utils.system_output(cmd, retain_output=True)
+
+    # setup
+    #
+    #    Automatically run when there is no autotest/client/tmp/<test-suite> directory
+    #
+    def setup(self):
+        self.install_required_pkgs()
+        self.job.require_gcc()
+        os.chdir(self.srcdir)
+        shutil.rmtree('rt-tests', ignore_errors=True)
+        canonical.setup_proxy()
+        branch = 'main'
+        cmd = 'git clone -b {} https://git.kernel.org/pub/scm/utils/rt-tests/rt-tests.git'.format(branch)
+        utils.system_output(cmd, retain_output=True)
+
+        # Print test suite HEAD SHA1 commit id for future reference
+        os.chdir(os.path.join(self.srcdir, 'rt-tests'))
+        title_local = utils.system_output("git log --oneline -1 | sed 's/(.*)//'", retain_output=False, verbose=False)
+        title_upstream = utils.system_output("git log --oneline | grep -v SAUCE | head -1", retain_output=False, verbose=False)
+        print("Latest commit in '{}' branch: {}".format(branch, title_local))
+        print("Latest upstream commit: {}".format(title_upstream))
+
+        try:
+            nprocs = '-j' + str(multiprocessing.cpu_count())
+        except:
+            nprocs = ''
+        utils.make(nprocs)
+
+
+    # run_once
+    #
+    #    Driven by the control file for each individual test.
+    #
+    #    Runs pmqtest for 60 seconds. This will fail if the max latency is over 100us.
+    #
+    def run_once(self, test_name, args='-Sp80 -i100 -d0 -b100 -q -D60', exit_on_error=True):
+        if test_name == 'setup':
+            return
+
+        self.results = utils.system_output(self.srcdir + '/rt-tests/pmqtest ' + args, retain_output=True)
+
+        lines = self.results.split('\n')
+
+        max_latencies = []
+        for line in lines:
+            if 'Max' in line:
+                max_latencies.append(int(line.split()[-1]))
+
+        # Check if any max value is over 100
+        if any(value > 100 for value in max_latencies):
+            raise error.TestError('FAIL: Max latency over 100us.')
+
+        return