/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/base/ |
H A D | coll_base_reduce_scatter.c | 69 err = comm->c_coll->coll_reduce (MPI_IN_PLACE, tmprbuf, total_count, in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 70 … dtype, op, root, comm, comm->c_coll->coll_reduce_module); in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 72 err = comm->c_coll->coll_reduce(tmprbuf, NULL, total_count, in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 73 dtype, op, root, comm, comm->c_coll->coll_reduce_module); in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 85 err = comm->c_coll->coll_reduce (sbuf, tmprbuf, total_count, in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 86 dtype, op, root, comm, comm->c_coll->coll_reduce_module); in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 99 err = comm->c_coll->coll_scatterv (tmprbuf, rcounts, displs, dtype, in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 101 root, comm, comm->c_coll->coll_scatterv_module); in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 103 err = comm->c_coll->coll_scatterv (tmprbuf, rcounts, displs, dtype, in ompi_coll_base_reduce_scatter_intra_nonoverlapping() 105 root, comm, comm->c_coll->coll_scatterv_module); in ompi_coll_base_reduce_scatter_intra_nonoverlapping()
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/coll/adapt/ |
H A D | coll_adapt_module.c | 90 adapt_module->previous_ ## __api = comm->c_coll->coll_ ## __api; \ 91 adapt_module->previous_ ## __api ## _module = comm->c_coll->coll_ ## __api ## _module; \ 92 if (!comm->c_coll->coll_ ## __api || !comm->c_coll->coll_ ## __api ## _module) { \
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/osc/ucx/ |
H A D | osc_ucx_component.c | 227 ret = comm->c_coll->coll_allgather(&my_info_len, 1, MPI_INT, in allgather_len_and_info() 229 comm->c_coll->coll_allgather_module); in allgather_len_and_info() 242 ret = comm->c_coll->coll_allgatherv(my_info, my_info_len, MPI_BYTE, in allgather_len_and_info() 244 comm, comm->c_coll->coll_allgatherv_module); in allgather_len_and_info() 411 ret = module->comm->c_coll->coll_allreduce(MPI_IN_PLACE, values, 2, MPI_LONG, in component_select() 428 ret = module->comm->c_coll->coll_allgather(&disp_unit, 1, MPI_INT, in component_select() 446 ret = module->comm->c_coll->coll_allreduce(MPI_IN_PLACE, &is_eps_ready, 1, MPI_INT, in component_select() 574 ret = comm->c_coll->coll_allgather((void *)&rkey_buffer_size, 1, MPI_INT, in component_select() 576 comm->c_coll->coll_allgather_module); in component_select() 662 ret = module->comm->c_coll->coll_barrier(module->comm, in component_select() [all …]
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/osc/ucx/ |
H A D | osc_ucx_component.c | 188 ret = comm->c_coll->coll_allgather(&my_info_len, 1, MPI_INT, in allgather_len_and_info() 190 comm->c_coll->coll_allgather_module); in allgather_len_and_info() 203 ret = comm->c_coll->coll_allgatherv(my_info, my_info_len, MPI_BYTE, in allgather_len_and_info() 205 comm, comm->c_coll->coll_allgatherv_module); in allgather_len_and_info() 451 ret = module->comm->c_coll->coll_allreduce(MPI_IN_PLACE, values, 2, MPI_LONG, in component_select() 468 ret = module->comm->c_coll->coll_allgather(&disp_unit, 1, MPI_INT, in component_select() 486 ret = module->comm->c_coll->coll_allreduce(MPI_IN_PLACE, &is_eps_ready, 1, MPI_INT, in component_select() 606 ret = comm->c_coll->coll_allgather((void *)&rkey_buffer_size, 1, MPI_INT, in component_select() 608 comm->c_coll->coll_allgather_module); in component_select() 690 ret = module->comm->c_coll->coll_barrier(module->comm, in component_select() [all …]
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/sharedfp/lockedfile/ |
H A D | sharedfp_lockedfile_iread.c | 129 ret = fh->f_comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, buff, recvcnt, in mca_sharedfp_lockedfile_read_ordered_begin() 131 fh->f_comm->c_coll->coll_gather_module ); in mca_sharedfp_lockedfile_read_ordered_begin() 169 ret = fh->f_comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_lockedfile_read_ordered_begin() 171 fh->f_comm, fh->f_comm->c_coll->coll_scatter_module ); in mca_sharedfp_lockedfile_read_ordered_begin()
|
H A D | sharedfp_lockedfile_iwrite.c | 126 ret = fh->f_comm->c_coll->coll_gather ( &sendBuff, in mca_sharedfp_lockedfile_write_ordered_begin() 134 fh->f_comm->c_coll->coll_gather_module ); in mca_sharedfp_lockedfile_write_ordered_begin() 172 ret = fh->f_comm->c_coll->coll_scatter ( buff, in mca_sharedfp_lockedfile_write_ordered_begin() 180 fh->f_comm->c_coll->coll_scatter_module ); in mca_sharedfp_lockedfile_write_ordered_begin()
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/sharedfp/sm/ |
H A D | sharedfp_sm_read.c | 140 ret = sh->comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_sm_read_ordered() 142 sh->comm, sh->comm->c_coll->coll_gather_module ); in mca_sharedfp_sm_read_ordered() 181 ret = sh->comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_sm_read_ordered() 183 sh->comm, sh->comm->c_coll->coll_scatter_module ); in mca_sharedfp_sm_read_ordered()
|
H A D | sharedfp_sm_write.c | 147 ret = sh->comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_sm_write_ordered() 149 sh->comm, sh->comm->c_coll->coll_gather_module ); in mca_sharedfp_sm_write_ordered() 188 ret = sh->comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_sm_write_ordered() 190 sh->comm, sh->comm->c_coll->coll_scatter_module ); in mca_sharedfp_sm_write_ordered()
|
H A D | sharedfp_sm_iread.c | 146 ret = sh->comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_sm_read_ordered_begin() 148 sh->comm, sh->comm->c_coll->coll_gather_module ); in mca_sharedfp_sm_read_ordered_begin() 188 ret = sh->comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_sm_read_ordered_begin() 190 sh->comm, sh->comm->c_coll->coll_scatter_module ); in mca_sharedfp_sm_read_ordered_begin()
|
H A D | sharedfp_sm_iwrite.c | 149 ret = sh->comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_sm_write_ordered_begin() 151 sh->comm, sh->comm->c_coll->coll_gather_module ); in mca_sharedfp_sm_write_ordered_begin() 191 ret = sh->comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_sm_write_ordered_begin() 193 sh->comm, sh->comm->c_coll->coll_scatter_module ); in mca_sharedfp_sm_write_ordered_begin()
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/sharedfp/lockedfile/ |
H A D | sharedfp_lockedfile_write.c | 145 ret = sh->comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, buff, recvcnt, in mca_sharedfp_lockedfile_write_ordered() 147 sh->comm->c_coll->coll_gather_module ); in mca_sharedfp_lockedfile_write_ordered() 185 ret = sh->comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_lockedfile_write_ordered() 187 sh->comm, sh->comm->c_coll->coll_scatter_module ); in mca_sharedfp_lockedfile_write_ordered()
|
H A D | sharedfp_lockedfile_read.c | 140 ret = sh->comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_lockedfile_read_ordered() 142 sh->comm, sh->comm->c_coll->coll_gather_module ); in mca_sharedfp_lockedfile_read_ordered() 181 ret = sh->comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_lockedfile_read_ordered() 183 sh->comm, sh->comm->c_coll->coll_scatter_module ); in mca_sharedfp_lockedfile_read_ordered()
|
H A D | sharedfp_lockedfile_iread.c | 152 ret = sh->comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, buff, recvcnt, in mca_sharedfp_lockedfile_read_ordered_begin() 154 sh->comm->c_coll->coll_gather_module ); in mca_sharedfp_lockedfile_read_ordered_begin() 192 ret = sh->comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_lockedfile_read_ordered_begin() 194 sh->comm, sh->comm->c_coll->coll_scatter_module ); in mca_sharedfp_lockedfile_read_ordered_begin()
|
H A D | sharedfp_lockedfile_iwrite.c | 151 ret = sh->comm->c_coll->coll_gather ( &sendBuff, sendcnt, OMPI_OFFSET_DATATYPE, buff, recvcnt, in mca_sharedfp_lockedfile_write_ordered_begin() 153 sh->comm->c_coll->coll_gather_module ); in mca_sharedfp_lockedfile_write_ordered_begin() 191 ret = sh->comm->c_coll->coll_scatter ( buff, sendcnt, OMPI_OFFSET_DATATYPE, in mca_sharedfp_lockedfile_write_ordered_begin() 193 sh->comm, sh->comm->c_coll->coll_scatter_module ); in mca_sharedfp_lockedfile_write_ordered_begin()
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/monitoring/ |
H A D | coll_monitoring_component.c | 21 if( NULL != __comm->c_coll->coll_ ## __api ## _module ) { \ 22 __module->real.coll_ ## __api = __comm->c_coll->coll_ ## __api; \ 23 __module->real.coll_ ## __api ## _module = __comm->c_coll->coll_ ## __api ## _module; \ 31 if( NULL != __comm->c_coll->coll_i ## __api ## _module ) { \ 32 __module->real.coll_i ## __api = __comm->c_coll->coll_i ## __api; \ 33 … __module->real.coll_i ## __api ## _module = __comm->c_coll->coll_i ## __api ## _module; \
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/coll/monitoring/ |
H A D | coll_monitoring_component.c | 21 if( NULL != __comm->c_coll->coll_ ## __api ## _module ) { \ 22 __module->real.coll_ ## __api = __comm->c_coll->coll_ ## __api; \ 23 __module->real.coll_ ## __api ## _module = __comm->c_coll->coll_ ## __api ## _module; \ 31 if( NULL != __comm->c_coll->coll_i ## __api ## _module ) { \ 32 __module->real.coll_i ## __api = __comm->c_coll->coll_i ## __api; \ 33 … __module->real.coll_i ## __api ## _module = __comm->c_coll->coll_i ## __api ## _module; \
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/fs/lustre/ |
H A D | fs_lustre_file_close.c | 40 fh->f_comm->c_coll->coll_barrier (fh->f_comm, in mca_fs_lustre_file_close() 41 fh->f_comm->c_coll->coll_barrier_module); in mca_fs_lustre_file_close()
|
H A D | fs_lustre_file_set_size.c | 43 fh->f_comm->c_coll->coll_bcast (&err, in mca_fs_lustre_file_set_size() 48 fh->f_comm->c_coll->coll_bcast_module); in mca_fs_lustre_file_set_size()
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/fs/ufs/ |
H A D | fs_ufs_file_close.c | 40 fh->f_comm->c_coll->coll_barrier (fh->f_comm, in mca_fs_ufs_file_close() 41 fh->f_comm->c_coll->coll_barrier_module); in mca_fs_ufs_file_close()
|
H A D | fs_ufs_file_set_size.c | 45 fh->f_comm->c_coll->coll_bcast (&err, in mca_fs_ufs_file_set_size() 50 fh->f_comm->c_coll->coll_bcast_module); in mca_fs_ufs_file_set_size()
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/fs/base/ |
H A D | fs_base_file_close.c | 41 fh->f_comm->c_coll->coll_barrier (fh->f_comm, in mca_fs_base_file_close() 42 fh->f_comm->c_coll->coll_barrier_module); in mca_fs_base_file_close()
|
H A D | fs_base_file_set_size.c | 46 fh->f_comm->c_coll->coll_bcast (&err, in mca_fs_base_file_set_size() 51 fh->f_comm->c_coll->coll_bcast_module); in mca_fs_base_file_set_size()
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/fs/ime/ |
H A D | fs_ime_file_close.c | 31 fh->f_comm->c_coll->coll_barrier (fh->f_comm, in mca_fs_ime_file_close() 32 fh->f_comm->c_coll->coll_barrier_module); in mca_fs_ime_file_close()
|
H A D | fs_ime_file_set_size.c | 39 fh->f_comm->c_coll->coll_bcast(&ret, in mca_fs_ime_file_set_size() 44 fh->f_comm->c_coll->coll_bcast_module); in mca_fs_ime_file_set_size()
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/sharedfp/individual/ |
H A D | sharedfp_individual_collaborate_data.c | 95 comm->c_coll->coll_allgather ( &nodesoneachprocess, 1, MPI_INT, in mca_sharedfp_individual_collaborate_data() 97 comm->c_coll->coll_allgather_module ); in mca_sharedfp_individual_collaborate_data() 140 ret = comm->c_coll->coll_allgatherv ( ind_ts, countbuff[rank], MPI_DOUBLE, in mca_sharedfp_individual_collaborate_data() 142 comm, comm->c_coll->coll_allgatherv_module ); in mca_sharedfp_individual_collaborate_data() 147 ret = comm->c_coll->coll_allgatherv ( ind_recordlength, countbuff[rank], OMPI_OFFSET_DATATYPE, in mca_sharedfp_individual_collaborate_data() 149 comm, comm->c_coll->coll_allgatherv_module ); in mca_sharedfp_individual_collaborate_data()
|