[rocprofiler-systems] Consolidate CTests to tests/ folder (#1461)

* Consolidate CTests to tests/ folder * Remove comment * Consolidate CTests to tests/ folder * Remove comment * Separate source code and test code for thread-limit into appropriate folders * Remove sleeper.cpp and instead use linux sleep cmd * Merge python-console tests into python-tests
2025-11-03 11:03:35 -05:00
parent 9f940c7265
commit 2a080641a1
11 changed files with 295 additions and 278 deletions
@@ -0,0 +1,107 @@
+// MIT License
+//
+// Copyright (c) 2025 Advanced Micro Devices, Inc. All Rights Reserved.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a copy
+// of this software and associated documentation files (the "Software"), to deal
+// in the Software without restriction, including without limitation the rights
+// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+// copies of the Software, and to permit persons to whom the Software is
+// furnished to do so, subject to the following conditions:
+//
+// The above copyright notice and this permission notice shall be included in all
+// copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+// SOFTWARE.
+
+#include <atomic>
+#include <chrono>
+#include <cstdio>
+#include <cstdlib>
+#include <iostream>
+#include <mutex>
+#include <pthread.h>
+#include <random>
+#include <ratio>
+#include <string>
+#include <thread>
+#include <vector>
+
+long
+fib(long n)
+{
+    return (n < 2) ? n : fib(n - 1) + fib(n - 2);
+}
+
+#if !defined(MAX_THREADS)
+#    define MAX_THREADS 4000
+#endif
+
+auto total_duration = std::chrono::duration<long, std::nano>{};
+
+int
+main(int argc, char** argv)
+{
+    std::string _name = argv[0];
+    auto        _pos  = _name.find_last_of('/');
+    if(_pos != std::string::npos) _name = _name.substr(_pos + 1);
+
+    size_t nthread     = 2 * MAX_THREADS;
+    size_t concurrency = std::thread::hardware_concurrency();
+    long   nfib        = 35;
+
+    if(argc > 1) nfib = atol(argv[1]);
+    if(argc > 2) concurrency = atol(argv[2]);
+    if(argc > 3) nthread = atol(argv[3]);
+
+    printf("\n[%s] Threads: %zu\n[%s] concurrency: %zu\n[%s] fibonacci(%li)\n",
+           _name.c_str(), nthread, _name.c_str(), concurrency, _name.c_str(), nfib);
+
+    auto threads = std::vector<std::thread>{};
+    auto _sync   = [_name, &threads]() {
+        std::this_thread::yield();
+        for(auto& itr : threads)
+            itr.join();
+        threads.clear();
+    };
+
+    threads.reserve(concurrency);
+    for(size_t i = 0; i < nthread; ++i)
+    {
+        if(i > MAX_THREADS - 8)
+        {
+            printf("[%s] launching thread %zu (max: %d)...\n", _name.c_str(), i,
+                   MAX_THREADS);
+            fflush(stdout);
+        }
+
+        threads.emplace_back(
+            [](auto n) {
+                auto t0 = std::chrono::steady_clock::now();
+                n       = fib(n);
+                (void) n;
+                auto        diff   = (std::chrono::steady_clock::now() - t0);
+                static auto _mutex = std::mutex{};
+                _mutex.lock();
+                total_duration += diff;
+                _mutex.unlock();
+            },
+            nfib);
+
+        if(i % concurrency == (concurrency - 1)) _sync();
+    }
+
+    _sync();
+
+    printf("[%s] ... completed with an average of %.3f msec per thread\n", _name.c_str(),
+           std::chrono::duration_cast<std::chrono::milliseconds>(total_duration).count() *
+               (1.0 / nthread));
+
+    return 0;
+}