aboutsummaryrefslogtreecommitdiff
path: root/tests/atomic_add-bench.c
diff options
context:
space:
mode:
authorThomas Huth <thuth@redhat.com>2021-03-12 10:22:38 +0100
committerThomas Huth <thuth@redhat.com>2021-03-12 15:46:30 +0100
commit3b472e71d50fe33f2e0dfdd447dde5910ddf0761 (patch)
tree1cbbd713dcd7538794dbc569bd3f8c8309ad8ec0 /tests/atomic_add-bench.c
parentda668aa15b99150a8595c491aee00d5d2426aaf9 (diff)
tests: Move benchmarks into a separate folder
Make it clear that these files are related to benchmarks by moving them into a new folder called "bench". Message-Id: <20210312092238.79509-1-thuth@redhat.com> Acked-by: Paolo Bonzini <pbonzini@redhat.com> Signed-off-by: Thomas Huth <thuth@redhat.com>
Diffstat (limited to 'tests/atomic_add-bench.c')
-rw-r--r--tests/atomic_add-bench.c180
1 files changed, 0 insertions, 180 deletions
diff --git a/tests/atomic_add-bench.c b/tests/atomic_add-bench.c
deleted file mode 100644
index f05471ab45..0000000000
--- a/tests/atomic_add-bench.c
+++ /dev/null
@@ -1,180 +0,0 @@
-#include "qemu/osdep.h"
-#include "qemu/thread.h"
-#include "qemu/host-utils.h"
-#include "qemu/processor.h"
-
-struct thread_info {
- uint64_t r;
-} QEMU_ALIGNED(64);
-
-struct count {
- QemuMutex lock;
- unsigned long val;
-} QEMU_ALIGNED(64);
-
-static QemuThread *threads;
-static struct thread_info *th_info;
-static unsigned int n_threads = 1;
-static unsigned int n_ready_threads;
-static struct count *counts;
-static unsigned int duration = 1;
-static unsigned int range = 1024;
-static bool use_mutex;
-static bool test_start;
-static bool test_stop;
-
-static const char commands_string[] =
- " -n = number of threads\n"
- " -m = use mutexes instead of atomic increments\n"
- " -p = enable sync profiler\n"
- " -d = duration in seconds\n"
- " -r = range (will be rounded up to pow2)";
-
-static void usage_complete(char *argv[])
-{
- fprintf(stderr, "Usage: %s [options]\n", argv[0]);
- fprintf(stderr, "options:\n%s\n", commands_string);
-}
-
-/*
- * From: https://en.wikipedia.org/wiki/Xorshift
- * This is faster than rand_r(), and gives us a wider range (RAND_MAX is only
- * guaranteed to be >= INT_MAX).
- */
-static uint64_t xorshift64star(uint64_t x)
-{
- x ^= x >> 12; /* a */
- x ^= x << 25; /* b */
- x ^= x >> 27; /* c */
- return x * UINT64_C(2685821657736338717);
-}
-
-static void *thread_func(void *arg)
-{
- struct thread_info *info = arg;
-
- qatomic_inc(&n_ready_threads);
- while (!qatomic_read(&test_start)) {
- cpu_relax();
- }
-
- while (!qatomic_read(&test_stop)) {
- unsigned int index;
-
- info->r = xorshift64star(info->r);
- index = info->r & (range - 1);
- if (use_mutex) {
- qemu_mutex_lock(&counts[index].lock);
- counts[index].val += 1;
- qemu_mutex_unlock(&counts[index].lock);
- } else {
- qatomic_inc(&counts[index].val);
- }
- }
- return NULL;
-}
-
-static void run_test(void)
-{
- unsigned int i;
-
- while (qatomic_read(&n_ready_threads) != n_threads) {
- cpu_relax();
- }
-
- qatomic_set(&test_start, true);
- g_usleep(duration * G_USEC_PER_SEC);
- qatomic_set(&test_stop, true);
-
- for (i = 0; i < n_threads; i++) {
- qemu_thread_join(&threads[i]);
- }
-}
-
-static void create_threads(void)
-{
- unsigned int i;
-
- threads = g_new(QemuThread, n_threads);
- th_info = g_new(struct thread_info, n_threads);
- counts = qemu_memalign(64, sizeof(*counts) * range);
- memset(counts, 0, sizeof(*counts) * range);
- for (i = 0; i < range; i++) {
- qemu_mutex_init(&counts[i].lock);
- }
-
- for (i = 0; i < n_threads; i++) {
- struct thread_info *info = &th_info[i];
-
- info->r = (i + 1) ^ time(NULL);
- qemu_thread_create(&threads[i], NULL, thread_func, info,
- QEMU_THREAD_JOINABLE);
- }
-}
-
-static void pr_params(void)
-{
- printf("Parameters:\n");
- printf(" # of threads: %u\n", n_threads);
- printf(" duration: %u\n", duration);
- printf(" ops' range: %u\n", range);
-}
-
-static void pr_stats(void)
-{
- unsigned long long val = 0;
- unsigned int i;
- double tx;
-
- for (i = 0; i < range; i++) {
- val += counts[i].val;
- }
- tx = val / duration / 1e6;
-
- printf("Results:\n");
- printf("Duration: %u s\n", duration);
- printf(" Throughput: %.2f Mops/s\n", tx);
- printf(" Throughput/thread: %.2f Mops/s/thread\n", tx / n_threads);
-}
-
-static void parse_args(int argc, char *argv[])
-{
- int c;
-
- for (;;) {
- c = getopt(argc, argv, "hd:n:mpr:");
- if (c < 0) {
- break;
- }
- switch (c) {
- case 'h':
- usage_complete(argv);
- exit(0);
- case 'd':
- duration = atoi(optarg);
- break;
- case 'n':
- n_threads = atoi(optarg);
- break;
- case 'm':
- use_mutex = true;
- break;
- case 'p':
- qsp_enable();
- break;
- case 'r':
- range = pow2ceil(atoi(optarg));
- break;
- }
- }
-}
-
-int main(int argc, char *argv[])
-{
- parse_args(argc, argv);
- pr_params();
- create_threads();
- run_test();
- pr_stats();
- return 0;
-}