Refactor runners directory and add ASAN-specific handling

Moved runner files from 'tasks/runners' to 'tasks/common/runners' for better organization. Added conditional handling for AddressSanitizer (ASAN) runs by defining `USE_ASAN` based on environment configuration. Adjusted MPI initialization and threading controls accordingly for improved flexibility.

Author: allnes

cmake/configure.cmake

@@ -6,6 +6,10 @@ if (APPLE)
     set(CMAKE_SHARED_LIBRARY_RUNTIME_C_FLAG TRUE)
 endif(APPLE)
 
+if(DEFINED ENV{PPC_ASAN_RUN} AND "$ENV{PPC_ASAN_RUN}" STREQUAL "1")
+    add_compile_definitions(USE_ASAN)
+endif()
+
 if (NOT CMAKE_BUILD_TYPE)
     set(CMAKE_BUILD_TYPE "Release")
 endif(NOT CMAKE_BUILD_TYPE)

tasks/CMakeLists.txt

@@ -7,19 +7,19 @@ set(exec_perf_tests "ppc_perf_tests")
 # Init func tests executable files
 set(list_of_exec_tests "")
 if (USE_FUNC_TESTS)
-    add_executable(${exec_func_tests} "${CMAKE_CURRENT_SOURCE_DIR}/runners/functional.cpp")
+    add_executable(${exec_func_tests} "${CMAKE_CURRENT_SOURCE_DIR}/common/runners/functional.cpp")
     list(APPEND list_of_exec_tests ${exec_func_tests})
 endif (USE_FUNC_TESTS)
 
 # Init perf tests executable files
 if (USE_PERF_TESTS)
-    add_executable(${exec_perf_tests} "${CMAKE_CURRENT_SOURCE_DIR}/runners/performance.cpp")
+    add_executable(${exec_perf_tests} "${CMAKE_CURRENT_SOURCE_DIR}/common/runners/performance.cpp")
     list(APPEND list_of_exec_tests ${exec_perf_tests})
 endif (USE_PERF_TESTS)
 
 SUBDIRLIST(subdirs ${CMAKE_CURRENT_LIST_DIR})
 foreach(subd ${subdirs})
-    if (subd STREQUAL "runners")
+    if (subd STREQUAL "common")
         continue()
     endif ()
     add_subdirectory(${subd})

tasks/runners/functional.cpp tasks/common/runners/functional.cpptasks/runners/functional.cpp renamed to tasks/common/runners/functional.cpp

@@ -71,6 +71,7 @@ class WorkerTestFailurePrinter : public ::testing::EmptyTestEventListener {
 };
 
 int main(int argc, char** argv) {
+#ifndef USE_ASAN
   MPI_Init(&argc, &argv);
 
   // Limit the number of threads in TBB
@@ -92,4 +93,13 @@ int main(int argc, char** argv) {
 
   MPI_Finalize();
   return status;
+#else
+  // Limit the number of threads in TBB
+  tbb::global_control control(tbb::global_control::max_allowed_parallelism, ppc::util::GetNumThreads());
+  // Limit the number of threads in OMP
+  omp_set_num_threads(ppc::util::GetNumThreads());
+
+  ::testing::InitGoogleTest(&argc, argv);
+  return RUN_ALL_TESTS();
+#endif
 }

tasks/runners/performance.cpp tasks/common/runners/performance.cpptasks/runners/performance.cpp renamed to tasks/common/runners/performance.cpp

@@ -71,6 +71,7 @@ class WorkerTestFailurePrinter : public ::testing::EmptyTestEventListener {
 };
 
 int main(int argc, char** argv) {
+#ifndef USE_ASAN
   MPI_Init(&argc, &argv);
 
   // Limit the number of threads in TBB
@@ -92,4 +93,13 @@ int main(int argc, char** argv) {
 
   MPI_Finalize();
   return status;
+#else
+  // Limit the number of threads in TBB
+  tbb::global_control control(tbb::global_control::max_allowed_parallelism, ppc::util::GetNumThreads());
+  // Limit the number of threads in OMP
+  omp_set_num_threads(ppc::util::GetNumThreads());
+
+  ::testing::InitGoogleTest(&argc, argv);
+  return RUN_ALL_TESTS();
+#endif
 }