intercomm 1727 ompi/communicator/comm.c int ompi_comm_determine_first ( ompi_communicator_t *intercomm, int high ) intercomm 1738 ompi/communicator/comm.c rank = ompi_comm_rank (intercomm); intercomm 1739 ompi/communicator/comm.c rsize= ompi_comm_remote_size (intercomm); intercomm 1762 ompi/communicator/comm.c rc = intercomm->c_coll->coll_allgatherv(&high, scount, MPI_INT, intercomm 1764 ompi/communicator/comm.c MPI_INT, intercomm, intercomm 1765 ompi/communicator/comm.c intercomm->c_coll->coll_allgatherv_module); intercomm 1785 ompi/communicator/comm.c ourproc = ompi_group_peer_lookup(intercomm->c_local_group,0); intercomm 1786 ompi/communicator/comm.c theirproc = ompi_group_peer_lookup(intercomm->c_remote_group,0); intercomm 661 ompi/communicator/comm_cid.c ompi_communicator_t *intercomm = cid_context->comm; intercomm 685 ompi/communicator/comm_cid.c local_rank = ompi_comm_rank (intercomm); intercomm 697 ompi/communicator/comm_cid.c rc = intercomm->c_local_comm->c_coll->coll_ireduce (inbuf, context->tmpbuf, count, MPI_INT, op, 0, intercomm 698 ompi/communicator/comm_cid.c intercomm->c_local_comm, &subreq, intercomm 699 ompi/communicator/comm_cid.c intercomm->c_local_comm->c_coll->coll_ireduce_module); intercomm 721 ompi/communicator/comm_cid.c ompi_communicator_t *intercomm = context->cid_context->comm; intercomm 728 ompi/communicator/comm_cid.c intercomm, subreqs)); intercomm 734 ompi/communicator/comm_cid.c MCA_PML_BASE_SEND_STANDARD, intercomm, subreqs + 1)); intercomm 672 ompi/communicator/communicator.h int ompi_comm_determine_first ( ompi_communicator_t *intercomm, intercomm 62 ompi/mpi/c/comm_join.c int MPI_Comm_join(int fd, MPI_Comm *intercomm) intercomm 75 ompi/mpi/c/comm_join.c if ( NULL == intercomm ) { intercomm 103 ompi/mpi/c/comm_join.c *intercomm = MPI_COMM_NULL; intercomm 144 ompi/mpi/c/comm_join.c *intercomm = newcomp; intercomm 51 ompi/mpi/c/comm_spawn.c int root, MPI_Comm comm, MPI_Comm *intercomm, intercomm 79 ompi/mpi/c/comm_spawn.c if ( NULL == intercomm ) { intercomm 164 ompi/mpi/c/comm_spawn.c *intercomm = newcomp; intercomm 52 ompi/mpi/c/comm_spawn_multiple.c int root, MPI_Comm comm, MPI_Comm *intercomm, intercomm 78 ompi/mpi/c/comm_spawn_multiple.c if ( NULL == intercomm ) { intercomm 212 ompi/mpi/c/comm_spawn_multiple.c *intercomm = newcomp; intercomm 47 ompi/mpi/c/intercomm_merge.c int MPI_Intercomm_merge(MPI_Comm intercomm, int high, intercomm 60 ompi/mpi/c/intercomm_merge.c memchecker_comm(intercomm); intercomm 66 ompi/mpi/c/intercomm_merge.c if (ompi_comm_invalid ( intercomm ) || intercomm 67 ompi/mpi/c/intercomm_merge.c !( intercomm->c_flags & OMPI_COMM_INTER ) ) intercomm 72 ompi/mpi/c/intercomm_merge.c return OMPI_ERRHANDLER_INVOKE ( intercomm, MPI_ERR_ARG, intercomm 78 ompi/mpi/c/intercomm_merge.c local_size = ompi_comm_size ( intercomm ); intercomm 79 ompi/mpi/c/intercomm_merge.c remote_size = ompi_comm_remote_size ( intercomm ); intercomm 87 ompi/mpi/c/intercomm_merge.c first = ompi_comm_determine_first ( intercomm, thigh ); intercomm 94 ompi/mpi/c/intercomm_merge.c ompi_group_union ( intercomm->c_local_group, intercomm->c_remote_group, &new_group_pointer ); intercomm 97 ompi/mpi/c/intercomm_merge.c ompi_group_union ( intercomm->c_remote_group, intercomm->c_local_group, &new_group_pointer ); intercomm 101 ompi/mpi/c/intercomm_merge.c intercomm, /* old comm */ intercomm 107 ompi/mpi/c/intercomm_merge.c intercomm->error_handler, /* error handler*/ intercomm 120 ompi/mpi/c/intercomm_merge.c rc = ompi_comm_nextcid (newcomp, intercomm, NULL, NULL, NULL, false, intercomm 127 ompi/mpi/c/intercomm_merge.c rc = ompi_comm_activate (&newcomp, intercomm, NULL, NULL, NULL, false, intercomm 144 ompi/mpi/c/intercomm_merge.c return OMPI_ERRHANDLER_INVOKE(intercomm, rc, FUNC_NAME); intercomm 277 ompi/mpi/cxx/intercepts.cc MPI::Intercomm intercomm; intercomm 306 ompi/mpi/cxx/intercepts.cc intercomm = MPI::Intercomm(comm); intercomm 307 ompi/mpi/cxx/intercepts.cc ret = kid->cxx_copy_fn(intercomm, keyval, kid->extra_state, intercomm 340 ompi/mpi/cxx/intercepts.cc MPI::Intercomm intercomm; intercomm 364 ompi/mpi/cxx/intercepts.cc intercomm = MPI::Intercomm(comm); intercomm 365 ompi/mpi/cxx/intercepts.cc ret = kid->cxx_delete_fn(intercomm, keyval, attribute_val, intercomm 41 ompi/mpi/fortran/mpif-h/comm_join_f.c (MPI_Fint *fd, MPI_Fint *intercomm, MPI_Fint *ierr), intercomm 42 ompi/mpi/fortran/mpif-h/comm_join_f.c (fd, intercomm, ierr) ) intercomm 61 ompi/mpi/fortran/mpif-h/comm_join_f.c (MPI_Fint *fd, MPI_Fint *intercomm, MPI_Fint *ierr), intercomm 62 ompi/mpi/fortran/mpif-h/comm_join_f.c (fd, intercomm, ierr) ) intercomm 69 ompi/mpi/fortran/mpif-h/comm_join_f.c void ompi_comm_join_f(MPI_Fint *fd, MPI_Fint *intercomm, MPI_Fint *ierr) intercomm 78 ompi/mpi/fortran/mpif-h/comm_join_f.c *intercomm = PMPI_Comm_c2f(c_intercomm); intercomm 44 ompi/mpi/fortran/mpif-h/comm_spawn_f.c (char *command, char *argv, MPI_Fint *maxprocs, MPI_Fint *info, MPI_Fint *root, MPI_Fint *comm, MPI_Fint *intercomm, MPI_Fint *array_of_errcodes, MPI_Fint *ierr, int cmd_len, int string_len), intercomm 45 ompi/mpi/fortran/mpif-h/comm_spawn_f.c (command, argv, maxprocs, info, root, comm, intercomm, array_of_errcodes, ierr, cmd_len, string_len) ) intercomm 64 ompi/mpi/fortran/mpif-h/comm_spawn_f.c (char *command, char *argv, MPI_Fint *maxprocs, MPI_Fint *info, MPI_Fint *root, MPI_Fint *comm, MPI_Fint *intercomm, MPI_Fint *array_of_errcodes, MPI_Fint *ierr, int cmd_len, int string_len), intercomm 65 ompi/mpi/fortran/mpif-h/comm_spawn_f.c (command, argv, maxprocs, info, root, comm, intercomm, array_of_errcodes, ierr, cmd_len, string_len) ) intercomm 74 ompi/mpi/fortran/mpif-h/comm_spawn_f.c MPI_Fint *intercomm, MPI_Fint *array_of_errcodes, intercomm 115 ompi/mpi/fortran/mpif-h/comm_spawn_f.c *intercomm = PMPI_Comm_c2f(c_new_comm); intercomm 47 ompi/mpi/fortran/mpif-h/comm_spawn_multiple_f.c (MPI_Fint *count, char *array_of_commands, char *array_of_argv, MPI_Fint *array_of_maxprocs, MPI_Fint *array_of_info, MPI_Fint *root, MPI_Fint *comm, MPI_Fint *intercomm, MPI_Fint *array_of_errcodes, MPI_Fint *ierr, int cmd_string_len, int argv_string_len), intercomm 48 ompi/mpi/fortran/mpif-h/comm_spawn_multiple_f.c (count, array_of_commands, array_of_argv, array_of_maxprocs, array_of_info, root, comm, intercomm, array_of_errcodes, ierr, cmd_string_len, argv_string_len) ) intercomm 67 ompi/mpi/fortran/mpif-h/comm_spawn_multiple_f.c (MPI_Fint *count, char *array_of_commands, char *array_of_argv, MPI_Fint *array_of_maxprocs, MPI_Fint *array_of_info, MPI_Fint *root, MPI_Fint *comm, MPI_Fint *intercomm, MPI_Fint *array_of_errcodes, MPI_Fint *ierr, int cmd_string_len, int argv_string_len), intercomm 68 ompi/mpi/fortran/mpif-h/comm_spawn_multiple_f.c (count, array_of_commands, array_of_argv, array_of_maxprocs, array_of_info, root, comm, intercomm, array_of_errcodes, ierr, cmd_string_len, argv_string_len) ) intercomm 79 ompi/mpi/fortran/mpif-h/comm_spawn_multiple_f.c MPI_Fint *comm, MPI_Fint *intercomm, intercomm 137 ompi/mpi/fortran/mpif-h/comm_spawn_multiple_f.c *intercomm = PMPI_Comm_c2f(c_new_comm); intercomm 41 ompi/mpi/fortran/mpif-h/intercomm_merge_f.c (MPI_Fint *intercomm, ompi_fortran_logical_t *high, MPI_Fint *newintercomm, MPI_Fint *ierr), intercomm 42 ompi/mpi/fortran/mpif-h/intercomm_merge_f.c (intercomm, high, newintercomm, ierr) ) intercomm 61 ompi/mpi/fortran/mpif-h/intercomm_merge_f.c (MPI_Fint *intercomm, ompi_fortran_logical_t *high, MPI_Fint *newintercomm, MPI_Fint *ierr), intercomm 62 ompi/mpi/fortran/mpif-h/intercomm_merge_f.c (intercomm, high, newintercomm, ierr) ) intercomm 68 ompi/mpi/fortran/mpif-h/intercomm_merge_f.c void ompi_intercomm_merge_f(MPI_Fint *intercomm, ompi_fortran_logical_t *high, intercomm 74 ompi/mpi/fortran/mpif-h/intercomm_merge_f.c MPI_Comm c_intercomm = PMPI_Comm_f2c(*intercomm); intercomm 141 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Comm_join, mpi_comm_join, MPI_COMM_JOIN, (MPI_Fint *fd, MPI_Fint *intercomm, MPI_Fint *ierr)); intercomm 150 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Comm_spawn, mpi_comm_spawn, MPI_COMM_SPAWN, (char *command, char *argv, MPI_Fint *maxprocs, MPI_Fint *info, MPI_Fint *root, MPI_Fint *comm, MPI_Fint *intercomm, MPI_Fint *array_of_errcodes, MPI_Fint *ierr, int command_len, int argv_len)); intercomm 151 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Comm_spawn_multiple, mpi_comm_spawn_multiple, MPI_COMM_SPAWN_MULTIPLE, (MPI_Fint *count, char *array_of_commands, char *array_of_argv, MPI_Fint *array_of_maxprocs, MPI_Fint *array_of_info, MPI_Fint *root, MPI_Fint *comm, MPI_Fint *intercomm, MPI_Fint *array_of_errcodes, MPI_Fint *ierr, int cmd_len, int argv_len)); intercomm 301 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Intercomm_merge, mpi_intercomm_merge, MPI_INTERCOMM_MERGE, (MPI_Fint *intercomm, ompi_fortran_logical_t *high, MPI_Fint *newintercomm, MPI_Fint *ierr)); intercomm 2158 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_comm_join_f(fd,intercomm,ierror) & intercomm 2162 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(OUT) :: intercomm intercomm 2167 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h intercomm, array_of_errcodes,ierror,cmd_len,argv_len) & intercomm 2175 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(OUT) :: intercomm intercomm 2185 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h comm,intercomm,array_of_errcodes,ierror, & intercomm 2195 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(OUT) :: intercomm intercomm 1094 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Intercomm_merge(intercomm, high, newintercomm, ierror) intercomm 1095 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: intercomm intercomm 2190 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Comm_join(fd, intercomm, ierror) intercomm 2192 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(out) :: intercomm intercomm 2232 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h comm, intercomm, array_of_errcodes, ierror) intercomm 2239 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(out) :: intercomm intercomm 2250 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h root, comm, intercomm, array_of_errcodes, ierror) intercomm 2258 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(out) :: intercomm intercomm 1094 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Intercomm_merge(intercomm, high, newintercomm, ierror) intercomm 1095 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: intercomm intercomm 2192 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Comm_join(fd, intercomm, ierror) intercomm 2194 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(out) :: intercomm intercomm 2234 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h comm, intercomm, array_of_errcodes, ierror) intercomm 2241 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(out) :: intercomm intercomm 2252 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h root, comm, intercomm, array_of_errcodes, ierror) intercomm 2260 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(out) :: intercomm intercomm 432 ompi/mpi/java/c/mpi_Intracomm.c MPI_Comm intercomm; intercomm 459 ompi/mpi/java/c/mpi_Intracomm.c root, (MPI_Comm)comm, &intercomm, cErrCodes); intercomm 481 ompi/mpi/java/c/mpi_Intracomm.c return (jlong)intercomm; intercomm 490 ompi/mpi/java/c/mpi_Intracomm.c MPI_Comm intercomm; intercomm 542 ompi/mpi/java/c/mpi_Intracomm.c root, (MPI_Comm)comm, &intercomm, cErrCodes); intercomm 583 ompi/mpi/java/c/mpi_Intracomm.c return (jlong)intercomm; intercomm 58 orte/test/mpi/singleton_client_server.c MPI_Comm intercomm, intracomm ; intercomm 118 orte/test/mpi/singleton_client_server.c &intercomm)) ; intercomm 123 orte/test/mpi/singleton_client_server.c CHK(MPI_Intercomm_merge(intercomm, 0, &intracomm)) ; intercomm 151 orte/test/mpi/singleton_client_server.c CHK(MPI_Comm_connect (server_port_name, MPI_INFO_NULL, 0, MPI_COMM_WORLD, &intercomm)) ; intercomm 156 orte/test/mpi/singleton_client_server.c CHK(MPI_Intercomm_merge(intercomm, 1, &intracomm)) ; intercomm 168 orte/test/mpi/singleton_client_server.c CHK(MPI_Comm_accept(server_port_name, MPI_INFO_NULL, 0, intracomm, &intercomm)) ; intercomm 173 orte/test/mpi/singleton_client_server.c CHK(MPI_Intercomm_merge(intercomm, 0, &intracomm)) ;