-
- /* if(comm->ch.shmem_coll_ok == 1){
- MPIR_T_PVAR_COUNTER_INC(MV2, mv2_num_shmem_coll_calls, 1);
- if (1 == comm->ch.is_blocked) {
- mpi_errno = MPIR_2lvl_Allgather_MV2(sendbuf, sendcount, sendtype,
- recvbuf, recvcount, recvtype,
- comm, errflag);
- }
- else {
- mpi_errno = MPIR_Allgather_intra(sendbuf, sendcount, sendtype,
- recvbuf, recvcount, recvtype,
- comm, errflag);
- }
- } else {*/
+ if(partial_sub_ok ==1){
+ if (smpi_comm_is_blocked(comm)){
+ mpi_errno = MPIR_2lvl_Allgather_MV2(sendbuf, sendcount, sendtype,
+ recvbuf, recvcount, recvtype,
+ comm);
+ }else{
+ mpi_errno = smpi_coll_tuned_allgather_mpich(sendbuf, sendcount, sendtype,
+ recvbuf, recvcount, recvtype,
+ comm);
+ }
+ } else {