File tree Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Expand file tree Collapse file tree 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"
@@ -612,6 +613,15 @@ static int ompi_mpi_instance_init_common (void)
612
613
return ompi_instance_print_error ("ompi_win_init() failed" , ret );
613
614
}
614
615
616
+ /* initialize partcomm */
617
+ if (OMPI_SUCCESS != (ret = mca_base_framework_open (& ompi_part_base_framework , 0 ))) {
618
+ return ompi_instance_print_error ("mca_part_base_select() failed" , ret );
619
+ }
620
+
621
+ if (OMPI_SUCCESS != (ret = mca_part_base_select (true, true))) {
622
+ return ompi_instance_print_error ("mca_part_base_select() failed" , ret );
623
+ }
624
+
615
625
/* Setup the dynamic process management (DPM) subsystem */
616
626
if (OMPI_SUCCESS != (ret = ompi_dpm_init ())) {
617
627
return ompi_instance_print_error ("ompi_dpm_init() failed" , ret );
You can’t perform that action at this time.
0 commit comments