[ dtest ] hipModuleLaunchKernel multiThreaded n multiGPU scenarios

1.Added hipModuleLaunchKernel multithreaded multi GPU scenario.
2.removed hipCtxCreate API from earlier test as it is deprecated.

SWDEV-238517 for enhancing hip unit tests

Change-Id: Id102d80887b6ff61a59938dbeb9fa2a26a3275b2

tests/src/runtimeApi/module/hipModuleLoadDataMultThreaded.cpp

@@ -35,118 +35,102 @@ THE SOFTWARE.
 
 #define LEN 64
 #define SIZE LEN << 2
-#define THREADS 2
-#define MAX_THREADS 16
+#define THREADS 8
+#define MAX_THREADS 512
 
 #define FILENAME "vcpy_kernel.code"
 #define kernel_name "hello_world"
 
-std::vector<char> load_file()
-{
-    std::ifstream file(FILENAME, std::ios::binary | std::ios::ate);
-    std::streamsize fsize = file.tellg();
-    file.seekg(0, std::ios::beg);
+std::vector<char> load_file() {
+  std::ifstream file(FILENAME, std::ios::binary | std::ios::ate);
+  std::streamsize fsize = file.tellg();
+  file.seekg(0, std::ios::beg);
 
-    std::vector<char> buffer(fsize);
-    if (!file.read(buffer.data(), fsize)) {
-        failed("could not open code object '%s'\n", FILENAME);
-    }
-    return buffer;
+  std::vector<char> buffer(fsize);
+  if (!file.read(buffer.data(), fsize)) {
+    failed("could not open code object '%s'\n", FILENAME);
+  }
+  return buffer;
 }
 
 void run(const std::vector<char>& buffer) {
-    hipDevice_t device;
-    HIPCHECK(hipDeviceGet(&device, 0));
-    hipCtx_t context;
-    HIPCHECK(hipCtxCreate(&context, 0, device));
+  hipModule_t Module;
+  hipFunction_t Function;
+  HIPCHECK(hipModuleLoadData(&Module, &buffer[0]));
+  HIPCHECK(hipModuleGetFunction(&Function, Module, kernel_name));
 
-    hipModule_t Module;
-    hipFunction_t Function;
-    HIPCHECK(hipModuleLoadData(&Module, &buffer[0]));
-    HIPCHECK(hipModuleGetFunction(&Function, Module, kernel_name));
-    
-    float *A, *B, *Ad, *Bd;
-    A = new float[LEN];
-    B = new float[LEN];
+  float *A, *B, *Ad, *Bd;
+  A = new float[LEN];
+  B = new float[LEN];
 
-    for (uint32_t i = 0; i < LEN; i++) {
-        A[i] = i * 1.0f;
-        B[i] = 0.0f;
-    }
+  for (uint32_t i = 0; i < LEN; i++) {
+    A[i] = i * 1.0f;
+    B[i] = 0.0f;
+  }
 
-    HIPCHECK(hipMalloc((void**)&Ad, SIZE));
-    HIPCHECK(hipMalloc((void**)&Bd, SIZE));
+  HIPCHECK(hipMalloc((void**)&Ad, SIZE));
+  HIPCHECK(hipMalloc((void**)&Bd, SIZE));
 
-    HIPCHECK(hipMemcpy(Ad, A, SIZE, hipMemcpyHostToDevice));
-    HIPCHECK(hipMemcpy(Bd, B, SIZE, hipMemcpyHostToDevice));
+  HIPCHECK(hipMemcpy(Ad, A, SIZE, hipMemcpyHostToDevice));
+  HIPCHECK(hipMemcpy(Bd, B, SIZE, hipMemcpyHostToDevice));
 
-    hipStream_t stream;
-    HIPCHECK(hipStreamCreate(&stream));
+  hipStream_t stream;
+  HIPCHECK(hipStreamCreate(&stream));
 
-    struct {
-        void* _Ad;
-        void* _Bd;
-    } args;
-    args._Ad = (void*) Ad;
-    args._Bd = (void*) Bd;
-    size_t size = sizeof(args);
+  struct {
+    void* _Ad;
+    void* _Bd;
+  } args;
+  args._Ad = (void*) Ad;
+  args._Bd = (void*) Bd;
+  size_t size = sizeof(args);
 
-    void* config[] = {HIP_LAUNCH_PARAM_BUFFER_POINTER, &args, HIP_LAUNCH_PARAM_BUFFER_SIZE, &size,
-                      HIP_LAUNCH_PARAM_END};
-    HIPCHECK(hipModuleLaunchKernel(Function, 1, 1, 1, LEN, 1, 1, 0, stream, NULL, (void**)&config));
+  void* config[] = {HIP_LAUNCH_PARAM_BUFFER_POINTER, &args, HIP_LAUNCH_PARAM_BUFFER_SIZE, &size,
+                    HIP_LAUNCH_PARAM_END};
+  HIPCHECK(hipModuleLaunchKernel(Function, 1, 1, 1, LEN, 1, 1, 0, stream, NULL, (void**)&config));
 
-    HIPCHECK(hipStreamDestroy(stream));
+  HIPCHECK(hipStreamDestroy(stream));
 
-    HIPCHECK(hipModuleUnload(Module));
+  HIPCHECK(hipModuleUnload(Module));
 
-    HIPCHECK(hipMemcpy(B, Bd, SIZE, hipMemcpyDeviceToHost));
+  HIPCHECK(hipMemcpy(B, Bd, SIZE, hipMemcpyDeviceToHost));
 
-    for (uint32_t i = 0; i < LEN; i++) {
-        assert(A[i] == B[i]);
-    }
-   
-    hipFree(Ad); 
-    hipFree(Bd); 
-    delete[] A;
-    delete[] B;
-    hipCtxDestroy(context);
-    
+  for (uint32_t i = 0; i < LEN; i++) {
+    assert(A[i] == B[i]);
+  }
+
+  hipFree(Ad);
+  hipFree(Bd);
+  delete[] A;
+  delete[] B;
 }
 
-struct joinable_thread : std::thread
-{
-    template <class... Xs>
-    joinable_thread(Xs&&... xs) : std::thread(std::forward<Xs>(xs)...) // NOLINT
-    {
-    }
+struct joinable_thread : std::thread {
+  template <class... Xs>
+  joinable_thread(Xs&&... xs) : std::thread(std::forward<Xs>(xs)...) {} // NOLINT
 
-    joinable_thread& operator=(joinable_thread&& other) = default;
-    joinable_thread(joinable_thread&& other)            = default;
+  joinable_thread& operator=(joinable_thread&& other) = default;
+  joinable_thread(joinable_thread&& other)      = default;
 
-    ~joinable_thread()
-    {
-        if(this->joinable())
-            this->join();
-    }
+  ~joinable_thread() {
+    if (this->joinable())
+      this->join();
+  }
 };
 
 void run_multi_threads(uint32_t n, const std::vector<char>& buffer) {
-    
-    std::vector<joinable_thread> threads;
-    
-    for (uint32_t i = 0; i < n; i++) {
-        threads.emplace_back(std::thread{[&, buffer] {
-        run(buffer);
-        }});
-    }
-    
+  std::vector<joinable_thread> threads;
+  for (uint32_t i = 0; i < n; i++) {
+    threads.emplace_back(std::thread{[&, buffer] {
+    run(buffer);
+    }});
+  }
 }
 
 int main() {
+  HIPCHECK(hipInit(0));
+  auto buffer = load_file();
+  run_multi_threads(min(THREADS * std::thread::hardware_concurrency(), MAX_THREADS), buffer);
 
-    HIPCHECK(hipInit(0));
-    auto buffer = load_file();
-    run_multi_threads(min(THREADS * std::thread::hardware_concurrency(), MAX_THREADS), buffer);
-
-    passed();
+  passed();
 }