Improve the MPI parcelport and change the default zero-copy serializa…

…tion threshold from 128 to 8192 - Replace the lock-based tag provider with an atomic variable - Make the header message size dynamic
STEllAR-GROUP · Jun 28, 2023 · 3cc519f · 3cc519f
1 parent 9821469
commit 3cc519f
Show file tree

Hide file tree

Showing 14 changed files with 277 additions and 271 deletions.
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -655,8 +655,8 @@ endif()
 hpx_option(
   HPX_WITH_ZERO_COPY_SERIALIZATION_THRESHOLD
   STRING
-  "The threshold in bytes to when perform zero copy optimizations (default: 128)"
-  "128"
+  "The threshold in bytes to when perform zero copy optimizations (default: 8192)"
+  "8192"
   ADVANCED
 )
 hpx_add_config_define(

diff --git a/cmake/toolchains/Cray.cmake b/cmake/toolchains/Cray.cmake
@@ -90,12 +90,6 @@ set(HPX_PARCELPORT_LIBFABRIC_WITH_LOGGING
     OFF
     CACHE BOOL "Libfabric parcelport logging on/off flag"
 )
-set(HPX_WITH_ZERO_COPY_SERIALIZATION_THRESHOLD
-    "4096"
-    CACHE
-      STRING
-      "The threshold in bytes to when perform zero copy optimizations (default: 128)"
-)
 
 # We do a cross compilation here ...
 set(CMAKE_CROSSCOMPILING

diff --git a/cmake/toolchains/CrayKNL.cmake b/cmake/toolchains/CrayKNL.cmake
@@ -88,12 +88,6 @@ set(HPX_PARCELPORT_LIBFABRIC_WITH_LOGGING
     OFF
     CACHE BOOL "Libfabric parcelport logging on/off flag"
 )
-set(HPX_WITH_ZERO_COPY_SERIALIZATION_THRESHOLD
-    "4096"
-    CACHE
-      STRING
-      "The threshold in bytes to when perform zero copy optimizations (default: 128)"
-)
 
 # Set the TBBMALLOC_PLATFORM correctly so that find_package(TBBMalloc) sets the
 # right hints

diff --git a/cmake/toolchains/CrayKNLStatic.cmake b/cmake/toolchains/CrayKNLStatic.cmake
@@ -72,12 +72,6 @@ set(HPX_PARCELPORT_LIBFABRIC_WITH_LOGGING
     OFF
     CACHE BOOL "Libfabric parcelport logging on/off flag"
 )
-set(HPX_WITH_ZERO_COPY_SERIALIZATION_THRESHOLD
-    "4096"
-    CACHE
-      STRING
-      "The threshold in bytes to when perform zero copy optimizations (default: 128)"
-)
 
 # Set the TBBMALLOC_PLATFORM correctly so that find_package(TBBMalloc) sets the
 # right hints

diff --git a/cmake/toolchains/CrayStatic.cmake b/cmake/toolchains/CrayStatic.cmake
@@ -83,9 +83,3 @@ set(HPX_PARCELPORT_LIBFABRIC_WITH_LOGGING
     OFF
     CACHE BOOL "Libfabric parcelport logging on/off flag"
 )
-set(HPX_WITH_ZERO_COPY_SERIALIZATION_THRESHOLD
-    "4096"
-    CACHE
-      STRING
-      "The threshold in bytes to when perform zero copy optimizations (default: 128)"
-)
diff --git a/libs/core/mpi_base/include/hpx/mpi_base/mpi_environment.hpp b/libs/core/mpi_base/include/hpx/mpi_base/mpi_environment.hpp
@@ -86,6 +86,8 @@ namespace hpx::util {
 
         using mutex_type = hpx::spinlock;
 
+        static int MPI_MAX_TAG;
+
     private:
         static mutex_type mtx_;
 

diff --git a/libs/core/mpi_base/src/mpi_environment.cpp b/libs/core/mpi_base/src/mpi_environment.cpp
@@ -23,6 +23,8 @@
 ///////////////////////////////////////////////////////////////////////////////
 namespace hpx::util {
 
+    int mpi_environment::MPI_MAX_TAG = 32767;
+
     namespace detail {
 
         bool detect_mpi_environment(
@@ -267,6 +269,11 @@ namespace hpx::util {
 
         rtcfg.add_entry("hpx.parcel.mpi.rank", std::to_string(this_rank));
         rtcfg.add_entry("hpx.parcel.mpi.processorname", get_processor_name());
+        void* max_tag_p;
+        int flag;
+        MPI_Comm_get_attr(MPI_COMM_WORLD, MPI_TAG_UB, &max_tag_p, &flag);
+        if (flag)
+            MPI_MAX_TAG = *(int*) max_tag_p;
     }
 
     std::string mpi_environment::get_processor_name()

diff --git a/libs/full/parcelport_lci/include/hpx/parcelport_lci/header.hpp b/libs/full/parcelport_lci/include/hpx/parcelport_lci/header.hpp
@@ -108,14 +108,6 @@ namespace hpx::parcelset::policies::lci {
             data_ = header_buffer;
         }
 
-        void reset() noexcept
-        {
-            if (data_ != nullptr)
-            {
-                free(data_);
-            }
-        }
-
         bool valid() const noexcept
         {
             return data_ != nullptr && signature() == MAGIC_SIGNATURE;