File tree 1 file changed +10
-0
lines changed
1 file changed +10
-0
lines changed Original file line number Diff line number Diff line change 43
43
#include "ompi/mca/pml/base/base.h"
44
44
#include "ompi/mca/coll/base/base.h"
45
45
#include "ompi/mca/osc/base/base.h"
46
+ #include "ompi/mca/part/base/base.h"
46
47
#include "ompi/mca/io/base/base.h"
47
48
#include "ompi/mca/topo/base/base.h"
48
49
#include "opal/mca/pmix/base/base.h"
@@ -626,6 +627,15 @@ static int ompi_mpi_instance_init_common (void)
626
627
return ompi_instance_print_error ("ompi_win_init() failed" , ret );
627
628
}
628
629
630
+ /* initialize partcomm */
631
+ if (OMPI_SUCCESS != (ret = mca_base_framework_open (& ompi_part_base_framework , 0 ))) {
632
+ return ompi_instance_print_error ("mca_part_base_select() failed" , ret );
633
+ }
634
+
635
+ if (OMPI_SUCCESS != (ret = mca_part_base_select (true, true))) {
636
+ return ompi_instance_print_error ("mca_part_base_select() failed" , ret );
637
+ }
638
+
629
639
/* Setup the dynamic process management (DPM) subsystem */
630
640
if (OMPI_SUCCESS != (ret = ompi_dpm_init ())) {
631
641
return ompi_instance_print_error ("ompi_dpm_init() failed" , ret );
You can’t perform that action at this time.
0 commit comments