add mca parameters to limit partition size and count

Signed-off-by: Axel Schneewind <axel.schneewind@hlrs.de>

Author: AxelSchneewind

ompi/mca/part/persist_aggregated/part_persist_aggregated.h

@@ -80,6 +80,10 @@ struct ompi_part_persist_aggregated_t {
     int32_t                init_world;
     int32_t                my_world_rank; /* Because the back end communicators use a world rank, we need to communicate ours 
                                              to set up the requests. */
+
+    uint32_t min_message_size;          /* parameters to control internal partitioning */
+    uint32_t max_message_count;
+
     opal_atomic_int32_t    block_entry;
     opal_mutex_t lock; 
 };

ompi/mca/part/persist_aggregated/part_persist_aggregated_component.c

@@ -88,6 +88,24 @@ mca_part_persist_aggregated_component_register(void)
                                            MCA_BASE_VAR_SCOPE_READONLY,
                                            &ompi_part_persist_aggregated.free_list_inc);
 
+    // variable for minimal internal partition size
+    ompi_part_persist_aggregated.min_message_size = 4096;
+    (void) mca_base_component_var_register(&mca_part_persist_aggregated_component.partm_version, "min_message_size",
+                                           "Minimal size of transferred messages (internal partitions)",
+                                           MCA_BASE_VAR_TYPE_UNSIGNED_INT, NULL, 0, 0,
+                                           OPAL_INFO_LVL_9,
+                                           MCA_BASE_VAR_SCOPE_READONLY,
+                                           &ompi_part_persist_aggregated.min_message_size);
+
+    // variable for maximal internal partition count
+    ompi_part_persist_aggregated.max_message_count = 4096;
+    (void) mca_base_component_var_register(&mca_part_persist_aggregated_component.partm_version, "max_message_count",
+                                           "Maximal number of transferred messages (internal partitions)",
+                                           MCA_BASE_VAR_TYPE_UNSIGNED_INT, NULL, 0, 0,
+                                           OPAL_INFO_LVL_9,
+                                           MCA_BASE_VAR_SCOPE_READONLY,
+                                           &ompi_part_persist_aggregated.max_message_count);
+
 
     return OPAL_SUCCESS;
 }