@@ -100,18 +100,6 @@ int ompi_dpm_init(void)
100
100
return OMPI_SUCCESS ;
101
101
}
102
102
103
- static int compare_pmix_proc (const void * a , const void * b )
104
- {
105
- const pmix_proc_t * proc_a = (pmix_proc_t * )a ;
106
- const pmix_proc_t * proc_b = (pmix_proc_t * )b ;
107
-
108
- int nspace_dif = strncmp (proc_a -> nspace , proc_b -> nspace , PMIX_MAX_NSLEN );
109
- if (nspace_dif != 0 )
110
- return nspace_dif ;
111
-
112
- return proc_a -> rank - proc_b -> rank ;
113
- }
114
-
115
103
int ompi_dpm_connect_accept (ompi_communicator_t * comm , int root ,
116
104
const char * port_string , bool send_first ,
117
105
ompi_communicator_t * * newcomm )
@@ -395,10 +383,6 @@ int ompi_dpm_connect_accept(ompi_communicator_t *comm, int root,
395
383
PMIX_INFO_CONSTRUCT (& tinfo );
396
384
PMIX_INFO_LOAD (& tinfo , PMIX_TIMEOUT , & ompi_pmix_connect_timeout , PMIX_UINT32 );
397
385
398
- /*
399
- * sort procs so that all ranks call PMIx_Connect() with the processes in same order
400
- */
401
- qsort (procs , nprocs , sizeof (pmix_proc_t ), compare_pmix_proc );
402
386
pret = PMIx_Connect (procs , nprocs , & tinfo , 1 );
403
387
PMIX_INFO_DESTRUCT (& tinfo );
404
388
PMIX_PROC_FREE (procs , nprocs );
0 commit comments