Data size based aggregation

source/adios2/CMakeLists.txt

@@ -31,6 +31,7 @@ add_library(adios2_core
   helper/adiosMath.cpp
   helper/adiosMemory.cpp
   helper/adiosNetwork.cpp
+  helper/adiosPartitioner.cpp
   helper/adiosPluginManager.cpp
   helper/adiosString.cpp helper/adiosString.tcc
   helper/adiosSystem.cpp

source/adios2/engine/bp5/BP5Engine.cpp

@@ -277,6 +277,10 @@ void BP5Engine::ParseParams(IO &io, struct BP5Params &Params)
             {
                 parameter = (int)AggregationType::TwoLevelShm;
             }
+            else if (value == "datasizebased")
+            {
+                parameter = (int)AggregationType::DataSizeBased;
+            }
             else
             {
                 helper::Throw<std::invalid_argument>(

source/adios2/engine/bp5/BP5Engine.h

@@ -123,6 +123,7 @@ class BP5Engine
         EveryoneWrites,
         EveryoneWritesSerial,
         TwoLevelShm,
+        DataSizeBased,
         Auto
     };
 
@@ -148,7 +149,7 @@ class BP5Engine
     MACRO(DirectIO, Bool, bool, false)                                                             \
     MACRO(DirectIOAlignOffset, UInt, unsigned int, 512)                                            \
     MACRO(DirectIOAlignBuffer, UInt, unsigned int, 0)                                              \
-    MACRO(AggregationType, AggregationType, int, (int)AggregationType::TwoLevelShm)                \
+    MACRO(AggregationType, AggregationType, int, (int)AggregationType::DataSizeBased)              \
     MACRO(AsyncOpen, Bool, bool, true)                                                             \
     MACRO(AsyncWrite, AsyncWrite, int, (int)AsyncWrite::Sync)                                      \
     MACRO(GrowthFactor, Float, float, DefaultBufferGrowthFactor)                                   \