Skip to contentSkip to conversation

KVM-test: TSC drift test

PATCH In review Amos Kong 2 participants 4 messages Apr 21, 2011 – Jul 26, 2011 KVM

lore
Share & tools
lore

Amos Kong

author
#0 lore raw

PATCH 1/1 KVM-test: TSC drift test

This case is used to test the drift between host and guest. Use taskset to make tsc program execute in a single cpu. If the drift ratio bigger than 10%, then fail this case.

---
 client/tests/kvm/deps/get_tsc.c        |   27 ++++++++++
 client/tests/kvm/tests/tsc_drift.py    |   88 ++++++++++++++++++++++++++++++++
 client/tests/kvm/tests_base.cfg.sample |    5 ++
 3 files changed, 120 insertions(+), 0 deletions(-)
 create mode 100644 client/tests/kvm/deps/get_tsc.c
 create mode 100644 client/tests/kvm/tests/tsc_drift.py
client/tests/kvm/deps/get_tsc.c new file +27 -0
new file mode 100644
index 0000000..e91a41f
@@ -0,0 +1,27 @@
+/*
+ * Programme to get cpu's TSC(time stamp counter)
+ * Copyright(C) 2009 Redhat, Inc.
+ * Amos Kong <[email protected]>
+ * Dec 9, 2009
+ *
+ */
+
+#define _GNU_SOURCE
+#include <stdio.h>
+#include <stdint.h>
+
+typedef unsigned long long u64;
+
+u64 rdtsc(void)
+{
+	unsigned tsc_lo, tsc_hi;
+
+	asm volatile("rdtsc" : "=a"(tsc_lo), "=d"(tsc_hi));
+	return tsc_lo | (u64)tsc_hi << 32;
+}
+
+int main(void)
+{
+	printf("%lld\n", rdtsc());
+	return 0;
+}
client/tests/kvm/tests/tsc_drift.py new file +88 -0

88 lines not on this page · raw message

client/tests/kvm/tests_base.cfg.sample +5 -0
index ceafebe..8e70746 100644
@@ -331,6 +331,11 @@ variants:
                         drift_threshold = 10
                         drift_threshold_single = 3
 
+    - tsc_drift:
+        type = tsc_drift
+        drift_threshold = 10
+        interval = 30
+
     - balloon_check:  install setup unattended_install.cdrom
         type = balloon_check
         extra_params += " -balloon virtio"
#1 lore raw
Quoted 3 lines · Amos Kong

This case is used to test the drift between host and guest. Use taskset to make tsc program execute in a single cpu. If the drift ratio bigger than 10%, then fail this case.

The calculations of the tsc frequency looks wrong... See comments below.

Also, when Glauber or Zach could take a look into this test it'd be great!

Quoted 96 lines

---
 client/tests/kvm/deps/get_tsc.c        |   27 ++++++++++ client/tests/kvm/tests/tsc_drift.py    |   88 ++++++++++++++++++++++++++++++++ client/tests/kvm/tests_base.cfg.sample |    5 ++

 3 files changed, 120 insertions(+), 0 deletions(-)

 create mode 100644 client/tests/kvm/deps/get_tsc.c create mode 100644 client/tests/kvm/tests/tsc_drift.py

client/tests/kvm/deps/get_tsc.c new file +27 -0
new file mode 100644
index 0000000..e91a41f
@@ -0,0 +1,27 @@
+/*
+ * Programme to get cpu's TSC(time stamp counter)
+ * Copyright(C) 2009 Redhat, Inc.
+ * Amos Kong <[email protected]>
+ * Dec 9, 2009
+ *
+ */
+
+#define _GNU_SOURCE
+#include <stdio.h>
+#include <stdint.h>
+
+typedef unsigned long long u64;
+
+u64 rdtsc(void)
+{
+       unsigned tsc_lo, tsc_hi;
+
+       asm volatile("rdtsc" : "=a"(tsc_lo), "=d"(tsc_hi));
+       return tsc_lo | (u64)tsc_hi << 32;
+}
+
+int main(void)
+{
+       printf("%lld\n", rdtsc());
+       return 0;
+}
client/tests/kvm/tests/tsc_drift.py new file +48 -0
new file mode 100644
index 0000000..de2fb76
@@ -0,0 +1,88 @@
+import time, os, logging, commands, re
+from autotest_lib.client.common_lib import error
+from autotest_lib.client.bin import local_host
+import kvm_test_utils
+
+
+def run_tsc_drift(test, params, env):
+    """
+    Check the TSC(time stamp counter) frequency of guest and host whether match
+    or not
+
+    1) Computer average tsc frequency of host's cpus by C the program
+    2) Copy the C code to the guest, complie and run it to get tsc
+       frequency of guest's vcpus
+    3) Sleep sometimes and get the TSC of host and guest again
+    4) Compute the TSC frequency of host and guest
+    5) Compare the frequency deviation between host and guest with standard
+
+    @param test: Kvm test object
+    @param params: Dictionary with the test parameters.
+    @param env: Dictionary with test environment.
+    """
+    drift_threshold = float(params.get("drift_threshold"))
+    interval = float(params.get("interval"))
+    cpu_chk_cmd = params.get("cpu_chk_cmd")
+    tsc_freq_path = os.path.join(test.bindir, 'deps/get_tsc.c')
+    host_freq = 0
+
+    def get_tsc(machine="host", i=0):
+        cmd = "taskset -c %s /tmp/get_tsc" % i
+        if machine == "host":
+            s, o = commands.getstatusoutput(cmd)
+        else:
+            s, o = session.cmd_status_output(cmd)
+        if s != 0:
+            logging.debug(o)
+            raise error.TestError("Fail to get tsc of host, ncpu: %d" % i)
+        return float(re.findall("(\d+)",o)[0])
+
+    vm = env.get_vm(params["main_vm"])
+    vm.verify_alive()
+    timeout = float(params.get("login_timeout", 240))
+    session = vm.wait_for_login(timeout=timeout)
+
+    commands.getoutput("gcc %s -o /tmp/get_tsc" % tsc_freq_path)
+    ncpu = local_host.LocalHost().get_num_cpu()
+
+    logging.info("Interval is %s" % interval)

client/tests/kvm/tests/tsc_drift.py line 58

Quoted 10 lines
client/tests/kvm/tests/tsc_drift.py new file +10 -0
+    logging.info("Determine the TSC frequency in the host")
+    for i in range(ncpu):
+        tsc1 = get_tsc("host", i)
+        time.sleep(interval)
+        tsc2 = get_tsc("host", i)
+
+        delta = tsc2 - tsc1
+        logging.info("Host TSC delta for cpu %s is %s" % (i, delta))
+        if delta < 0:
+            raise error.TestError("Host TSC for cpu %s warps %s" % (i, delta))

^ Yeah, I don't think this is expected to warp, but yet, good to check.

client/tests/kvm/tests/tsc_drift.py line 60

Quoted 1 line
client/tests/kvm/tests/tsc_drift.py new file +1 -0
+        host_freq += delta / ncpu

Now, i really didn't understand the concept behind the tsc frequency. So we have a difference between 2 timestamps taken over an arbitrary period of time (in this case, looks 30s by default) and divide by the number of cpus, however we will repeat this procedure by the same amount so:

N * ( d_tsc1/N + d_tsc2/N + d_tsc3/N + ... + d_tscn/N)

This could be simplified to

(d_tsc1 + d_tsc2 + d_tsc3 +.... + d_tscn)

Unless I'm missing something... so

host_freq = sum(d_tsci)

The calculation could be simplified then... And by definition, isn't frequency how many times a phenomena occurs (in this case, change of timestamp counter) per time? So, don't we have to divide this sum by the time the program slept? Also, it looks like the whole logic to get the frequencies can be factored to a single function and just call that function for guest and host.

Signature · 1 line
Lucas
author
#2 lore raw
Quoted 17 lines · * On Fri, Apr 29, 2011 at 02:42:20AM -0300, Lucas Meneghel Rodrigues wrote:
Quoted 3 lines · Amos Kong

This case is used to test the drift between host and guest. Use taskset to make tsc program execute in a single cpu. If the drift ratio bigger than 10%, then fail this case.

The calculations of the tsc frequency looks wrong... See comments below.

Also, when Glauber or Zach could take a look into this test it'd be great!

Quoted 8 lines

---

?client/tests/kvm/deps/get_tsc.c ? ? ? ?| ? 27 ++++++++++
?client/tests/kvm/tests/tsc_drift.py ? ?| ? 88 ++++++++++++++++++++++++++++++++
?client/tests/kvm/tests_base.cfg.sample | ? ?5 ++

?3 files changed, 120 insertions(+), 0 deletions(-) ?create mode 100644 client/tests/kvm/deps/get_tsc.c ?create mode 100644 client/tests/kvm/tests/tsc_drift.py

...

Quoted 9 lines
Quoted 4 lines

+ ? ? ? ?delta = tsc2 - tsc1
+ ? ? ? ?logging.info("Host TSC delta for cpu %s is %s" % (i, delta))
+ ? ? ? ?if delta < 0:
+ ? ? ? ? ? ?raise error.TestError("Host TSC for cpu %s warps %s" % (i, delta))

^ Yeah, I don't think this is expected to warp, but yet, good to check.

Quoted 1 line

+ ? ? ? ?host_freq += delta / ncpu

Quoted 7 lines

Now, i really didn't understand the concept behind the tsc frequency. So we have a difference between 2 timestamps taken over an arbitrary period of time (in this case, looks 30s by default) and divide by the number of cpus, however we will repeat this procedure by the same amount so:

N * ( d_tsc1/N + d_tsc2/N + d_tsc3/N + ... + d_tscn/N)

^ ?

I call it 'frequency' because the interval is fixed (30 seconds)

1) get a average tsc increment of host cpus in 30s host_freq = ( d_tsc1/N + d_tsc2/N + d_tsc3/N + ... + d_tscn/N)

          = ( d_tsc1 + d_tsc2 + d_tsc3 + ... + d_tscn)/N

2) get tsc increment of each vcpus in 30s d_tsc_vcpu1
d_tsc_vcpu2
...
d_tsc_vcpuN

3) compare 'd_tsc_vcpu1' with 'host_freq' ratio = (d_tsc_vcpu1 - host_freq) / host_freq if ratio larger than 10%, then fail this test.

ratio = (d_tsc_vcpu2 - host_freq) / host_freq if ratio larger than 10%, then fail this test.
...

Have talked with jason, I'll try to write a kvm-unit test for this testcase.

Quoted 14 lines

This could be simplified to

(d_tsc1 + d_tsc2 + d_tsc3 +.... + d_tscn)

Unless I'm missing something... so

host_freq = sum(d_tsci)

The calculation could be simplified then... And by definition, isn't frequency how many times a phenomena occurs (in this case, change of timestamp counter) per time? So, don't we have to divide this sum by the time the program slept? Also, it looks like the whole logic to get the frequencies can be factored to a single function and just call that function for guest and host.

#3 lore raw
In reply to Amos Kong
Quoted 3 lines · Amos Kong

This case is used to test the drift between host and guest. Use taskset to make tsc program execute in a single cpu. If the drift ratio bigger than 10%, then fail this case.

Hi Amos, per the last conversation we've had about this test case, you were going to look into add it as a kvm unit test. I'm going to put this on your todo list, please report the status when you can. Meanwhile, I'm going to mark the corresponding patch on patchwork as 'superseded'. Thanks!

Quoted 158 lines

---
 client/tests/kvm/deps/get_tsc.c        |   27 ++++++++++ client/tests/kvm/tests/tsc_drift.py    |   88 ++++++++++++++++++++++++++++++++ client/tests/kvm/tests_base.cfg.sample |    5 ++

 3 files changed, 120 insertions(+), 0 deletions(-)

 create mode 100644 client/tests/kvm/deps/get_tsc.c create mode 100644 client/tests/kvm/tests/tsc_drift.py

client/tests/kvm/deps/get_tsc.c new file +27 -0
new file mode 100644
index 0000000..e91a41f
@@ -0,0 +1,27 @@
+/*
+ * Programme to get cpu's TSC(time stamp counter)
+ * Copyright(C) 2009 Redhat, Inc.
+ * Amos Kong <[email protected]>
+ * Dec 9, 2009
+ *
+ */
+
+#define _GNU_SOURCE
+#include <stdio.h>
+#include <stdint.h>
+
+typedef unsigned long long u64;
+
+u64 rdtsc(void)
+{
+       unsigned tsc_lo, tsc_hi;
+
+       asm volatile("rdtsc" : "=a"(tsc_lo), "=d"(tsc_hi));
+       return tsc_lo | (u64)tsc_hi << 32;
+}
+
+int main(void)
+{
+       printf("%lld\n", rdtsc());
+       return 0;
+}
client/tests/kvm/tests/tsc_drift.py new file +88 -0
new file mode 100644
index 0000000..de2fb76
@@ -0,0 +1,88 @@
+import time, os, logging, commands, re
+from autotest_lib.client.common_lib import error
+from autotest_lib.client.bin import local_host
+import kvm_test_utils
+
+
+def run_tsc_drift(test, params, env):
+    """
+    Check the TSC(time stamp counter) frequency of guest and host whether match
+    or not
+
+    1) Computer average tsc frequency of host's cpus by C the program
+    2) Copy the C code to the guest, complie and run it to get tsc
+       frequency of guest's vcpus
+    3) Sleep sometimes and get the TSC of host and guest again
+    4) Compute the TSC frequency of host and guest
+    5) Compare the frequency deviation between host and guest with standard
+
+    @param test: Kvm test object
+    @param params: Dictionary with the test parameters.
+    @param env: Dictionary with test environment.
+    """
+    drift_threshold = float(params.get("drift_threshold"))
+    interval = float(params.get("interval"))
+    cpu_chk_cmd = params.get("cpu_chk_cmd")
+    tsc_freq_path = os.path.join(test.bindir, 'deps/get_tsc.c')
+    host_freq = 0
+
+    def get_tsc(machine="host", i=0):
+        cmd = "taskset -c %s /tmp/get_tsc" % i
+        if machine == "host":
+            s, o = commands.getstatusoutput(cmd)
+        else:
+            s, o = session.cmd_status_output(cmd)
+        if s != 0:
+            logging.debug(o)
+            raise error.TestError("Fail to get tsc of host, ncpu: %d" % i)
+        return float(re.findall("(\d+)",o)[0])
+
+    vm = env.get_vm(params["main_vm"])
+    vm.verify_alive()
+    timeout = float(params.get("login_timeout", 240))
+    session = vm.wait_for_login(timeout=timeout)
+
+    commands.getoutput("gcc %s -o /tmp/get_tsc" % tsc_freq_path)
+    ncpu = local_host.LocalHost().get_num_cpu()
+
+    logging.info("Interval is %s" % interval)
+    logging.info("Determine the TSC frequency in the host")
+    for i in range(ncpu):
+        tsc1 = get_tsc("host", i)
+        time.sleep(interval)
+        tsc2 = get_tsc("host", i)
+
+        delta = tsc2 - tsc1
+        logging.info("Host TSC delta for cpu %s is %s" % (i, delta))
+        if delta < 0:
+            raise error.TestError("Host TSC for cpu %s warps %s" % (i, delta))
+
+        host_freq += delta / ncpu
+    logging.info("Average frequency of host's cpus: %s" % host_freq)
+
+    vm.copy_files_to(tsc_freq_path,'/tmp/get_tsc.c')
+    session.cmd("gcc /tmp/get_tsc.c -o /tmp/get_tsc")
+
+    s, guest_ncpu = session.cmd_status_output(cpu_chk_cmd)
+
+    success = True
+    for i in range(int(guest_ncpu)):
+        tsc1 = get_tsc("guest", i)
+        time.sleep(interval)
+        tsc2 = get_tsc("guest", i)
+
+        delta = tsc2 - tsc1
+        logging.info("Guest TSC delta for vcpu %s is %s" % (i, delta))
+        if delta < 0:
+            logging.error("Guest TSC for vcpu %s warps %s" % (i, delta))
+
+        ratio = 100 * (delta - host_freq) / host_freq
+        logging.info("TSC drift ratio for vcpu %s is %s" % (i, ratio))
+        if abs(ratio) > drift_threshold:
+            logging.error("TSC drift found for vcpu %s ratio %s" % (i, ratio))
+            success = False
+
+    if not success:
+        raise error.TestFail("TSC drift found for the guest, please check the "
+                             "log for details")
+    session.close()
client/tests/kvm/tests_base.cfg.sample +0 -0
index ceafebe..8e70746 100644
@@ -331,6 +331,11 @@ variants:

                        drift_threshold = 10 drift_threshold_single = 3

+    - tsc_drift:
+        type = tsc_drift
+        drift_threshold = 10
+        interval = 30
+
    - balloon_check:  install setup unattended_install.cdrom type = balloon_check
        extra_params += " -balloon virtio"

_______________________________________________
Autotest mailing list
[email protected]
http://test.kernel.org/cgi-bin/mailman/listinfo/autotest

Signature · 1 line
Lucas