handle, SELF, TYPE_SHARED, WORLD
Modifier | Constructor and Description |
---|---|
protected |
Intracomm() |
protected |
Intracomm(long handle) |
protected |
Intracomm(long[] commRequest) |
Modifier and Type | Method and Description |
---|---|
Intercomm |
accept(java.lang.String port,
Info info,
int root)
Java binding of
MPI_COMM_ACCEPT . |
Intercomm |
accept(java.lang.String port,
int root)
Java binding of
MPI_COMM_ACCEPT using MPI_INFO_NULL . |
Intracomm |
clone()
Duplicates this communicator.
|
static void |
closePort(java.lang.String name)
Java binding of
MPI_CLOSE_PORT . |
Intercomm |
connect(java.lang.String port,
Info info,
int root)
Java binding of
MPI_COMM_CONNECT . |
Intercomm |
connect(java.lang.String port,
int root)
Java binding of
MPI_COMM_CONNECT using MPI_INFO_NULL . |
Intracomm |
create(Group group)
Create a new communicator.
|
CartComm |
createCart(int[] dims,
boolean[] periods,
boolean reorder)
Creates a communicator to which the Cartesian topology
information is attached.
|
GraphComm |
createDistGraph(int[] sources,
int[] degrees,
int[] destinations,
Info info,
boolean reorder)
Creates a communicator to which the distributed graph topology
information is attached.
|
GraphComm |
createDistGraph(int[] sources,
int[] degrees,
int[] destinations,
int[] weights,
Info info,
boolean reorder)
Creates a communicator to which the distributed graph topology
information is attached.
|
GraphComm |
createDistGraphAdjacent(int[] sources,
int[] destinations,
Info info,
boolean reorder)
Creates a communicator to which the distributed graph topology
information is attached.
|
GraphComm |
createDistGraphAdjacent(int[] sources,
int[] sourceWeights,
int[] destinations,
int[] destWeights,
Info info,
boolean reorder)
Creates a communicator to which the distributed graph topology
information is attached.
|
GraphComm |
createGraph(int[] index,
int[] edges,
boolean reorder)
Creates a communicator to which the graph topology information is attached.
|
Intracomm |
createGroup(Group group,
int tag)
Create a new intracommunicator for the given group.
|
Intracomm |
dup()
Duplicates this communicator.
|
Intracomm |
dupWithInfo(Info info)
Duplicates this communicator with the info object used in the call.
|
void |
exScan(java.lang.Object buf,
int count,
Datatype type,
Op op)
Perform a prefix reduction on data distributed across the group.
|
void |
exScan(java.lang.Object sendbuf,
java.lang.Object recvbuf,
int count,
Datatype type,
Op op)
Perform a prefix reduction on data distributed across the group.
|
Intracomm |
iDup()
Duplicates this communicator.
|
Request |
iExScan(java.nio.Buffer sendbuf,
java.nio.Buffer recvbuf,
int count,
Datatype type,
Op op)
Perform a prefix reduction on data distributed across the group.
|
Request |
iExScan(java.nio.Buffer buf,
int count,
Datatype type,
Op op)
Perform a prefix reduction on data distributed across the group.
|
Request |
iScan(java.nio.Buffer sendbuf,
java.nio.Buffer recvbuf,
int count,
Datatype type,
Op op)
Perform a prefix reduction on data distributed across the group.
|
Request |
iScan(java.nio.Buffer buf,
int count,
Datatype type,
Op op)
Perform a prefix reduction on data distributed across the group.
|
static java.lang.String |
lookupName(java.lang.String service)
Java binding of
MPI_LOOKUP_NAME using MPI_INFO_NULL . |
static java.lang.String |
lookupName(java.lang.String service,
Info info)
Java binding of
MPI_LOOKUP_NAME . |
static java.lang.String |
openPort()
Java binding of
MPI_OPEN_PORT using MPI_INFO_NULL . |
static java.lang.String |
openPort(Info info)
Java binding of
MPI_OPEN_PORT . |
static void |
publishName(java.lang.String service,
Info info,
java.lang.String port)
Java binding of
MPI_PUBLISH_NAME . |
static void |
publishName(java.lang.String service,
java.lang.String port)
Java binding of
MPI_PUBLISH_NAME using MPI_INFO_NULL . |
void |
scan(java.lang.Object recvbuf,
int count,
Datatype type,
Op op)
Perform a prefix reduction on data distributed across the group.
|
void |
scan(java.lang.Object sendbuf,
java.lang.Object recvbuf,
int count,
Datatype type,
Op op)
Perform a prefix reduction on data distributed across the group.
|
Intercomm |
spawn(java.lang.String command,
java.lang.String[] argv,
int maxprocs,
Info info,
int root,
int[] errcodes)
Java binding of
MPI_COMM_SPAWN . |
Intercomm |
spawnMultiple(java.lang.String[] commands,
java.lang.String[][] argv,
int[] maxprocs,
Info[] info,
int root,
int[] errcodes)
Java binding of
MPI_COMM_SPAWN_MULTIPLE . |
Intracomm |
split(int colour,
int key)
Partition the group associated with this communicator and create
a new communicator within each subgroup.
|
Intracomm |
splitType(int splitType,
int key,
Info info)
Partition the group associated with this communicator and create
a new communicator within each subgroup.
|
static void |
unpublishName(java.lang.String service,
Info info,
java.lang.String port)
Java binding of
MPI_UNPUBLISH_NAME . |
static void |
unpublishName(java.lang.String service,
java.lang.String port)
Java binding of
MPI_UNPUBLISH_NAME using MPI_INFO_NULL . |
abort, allGather, allGather, allGatherv, allGatherv, allReduce, allReduce, allToAll, allToAllv, allToAllw, barrier, bcast, bSend, bSendInit, callErrhandler, compare, createIntercomm, createKeyval, deleteAttr, disconnect, dup, dupWithInfo, free, freeKeyval, gather, gather, gatherv, gatherv, gatherv, getAttr, getErrhandler, getGroup, getInfo, getName, getRank, getRequest, getSize, getTopology, iAllGather, iAllGather, iAllGatherv, iAllGatherv, iAllReduce, iAllReduce, iAllToAll, iAllToAllv, iAllToAllw, iBarrier, iBcast, ibSend, iDup, iGather, iGather, iGatherv, iGatherv, iGatherv, iNeighborAllGather, iNeighborAllGatherv, iNeighborAllToAll, iNeighborAllToAllv, iProbe, iRecv, iReduce, iReduce, iReduceScatter, iReduceScatter, iReduceScatterBlock, iReduceScatterBlock, irSend, iScatter, iScatter, iScatterv, iScatterv, iScatterv, iSend, isInter, isNull, isSend, neighborAllGather, neighborAllGatherv, neighborAllToAll, neighborAllToAllv, pack, packSize, probe, recv, recvInit, reduce, reduce, reduceLocal, reduceScatter, reduceScatter, reduceScatterBlock, reduceScatterBlock, rSend, rSendInit, scatter, scatter, scatterv, scatterv, scatterv, send, sendInit, sendRecv, sendRecvReplace, setAttr, setErrhandler, setInfo, setName, setType, sSend, sSendInit, unpack
protected Intracomm()
protected Intracomm(long handle)
protected Intracomm(long[] commRequest)
public Intracomm clone()
Java binding of MPI_COMM_DUP
.
It is recommended to use dup()
instead of clone()
because the last can't throw an MPIException
.
public Intracomm dup() throws MPIException
Java binding of MPI_COMM_DUP
.
dup
in class Comm
MPIException
- Signals that an MPI error of some sort has occurred.public Intracomm iDup() throws MPIException
Java binding of MPI_COMM_IDUP
.
The new communicator can't be used before the operation completes.
The request object must be obtained calling Comm.getRequest()
.
iDup
in class Comm
MPIException
- Signals that an MPI error of some sort has occurred.public Intracomm dupWithInfo(Info info) throws MPIException
Java binding of MPI_COMM_DUP_WITH_INFO
.
dupWithInfo
in class Comm
info
- info object to associate with the new communicatorMPIException
- Signals that an MPI error of some sort has occurred.public final Intracomm split(int colour, int key) throws MPIException
Java binding of the MPI operation MPI_COMM_SPLIT
.
colour
- control of subset assignmentkey
- control of rank assignmentMPIException
- Signals that an MPI error of some sort has occurred.public final Intracomm splitType(int splitType, int key, Info info) throws MPIException
Java binding of the MPI operation MPI_COMM_SPLIT_TYPE
.
splitType
- type of processes to be grouped togetherkey
- control of rank assignmentinfo
- info argumentMPIException
- Signals that an MPI error of some sort has occurred.public final Intracomm create(Group group) throws MPIException
Java binding of the MPI operation MPI_COMM_CREATE
.
group
- group which is a subset of the group of this communicatorMPIException
- Signals that an MPI error of some sort has occurred.public final Intracomm createGroup(Group group, int tag) throws MPIException
Java binding of the MPI operation MPI_COMM_CREATE_GROUP
.
group
- group which is a subset of the group of this communicatortag
- an integer tagMPIException
- Signals that an MPI error of some sort has occurred.public final CartComm createCart(int[] dims, boolean[] periods, boolean reorder) throws MPIException
Java binding of the MPI operation MPI_CART_CREATE
.
The number of dimensions of the Cartesian grid is taken to be the
size of the dims
argument. The array periods
must
be the same size.
dims
- the number of processes in each dimensionperiods
- true
if grid is periodic,
false
if not, in each dimensionreorder
- true
if ranking may be reordered,
false
if notMPIException
- Signals that an MPI error of some sort has occurred.public final GraphComm createGraph(int[] index, int[] edges, boolean reorder) throws MPIException
Java binding of the MPI operation MPI_GRAPH_CREATE
.
The number of nodes in the graph, nnodes, is taken
to be size of the index
argument.
index
- node degreesedges
- graph edgesreorder
- true
if ranking may be reordered,
false
if notMPIException
- Signals that an MPI error of some sort has occurred.public final GraphComm createDistGraph(int[] sources, int[] degrees, int[] destinations, int[] weights, Info info, boolean reorder) throws MPIException
Java binding of the MPI operation MPI_DIST_GRAPH_CREATE
.
The number of source nodes is the size of the sources
argument.
sources
- source nodes for which this process specifies edgesdegrees
- number of destinations for each source nodedestinations
- destination nodes for the source nodesweights
- weights for source to destination edgesinfo
- hints on optimization and interpretation of weightsreorder
- the process may be reordered (true) or not (false)MPIException
- Signals that an MPI error of some sort has occurred.public final GraphComm createDistGraph(int[] sources, int[] degrees, int[] destinations, Info info, boolean reorder) throws MPIException
Java binding of the MPI operation MPI_DIST_GRAPH_CREATE
using MPI_UNWEIGHTED
.
The number of source nodes is the size of the sources
argument.
sources
- source nodes for which this process specifies edgesdegrees
- number of destinations for each source nodedestinations
- destination nodes for the source nodesinfo
- hints on optimization and interpretation of weightsreorder
- the process may be reordered (true) or not (false)MPIException
- Signals that an MPI error of some sort has occurred.public final GraphComm createDistGraphAdjacent(int[] sources, int[] sourceWeights, int[] destinations, int[] destWeights, Info info, boolean reorder) throws MPIException
Java binding of the MPI operation MPI_DIST_GRAPH_CREATE_ADJACENT
.
The number of source/destination nodes is the size of the
sources
/destinations
argument.
sources
- ranks of processes for which the calling process
is a destinationsourceWeights
- weights of the edges into the calling processdestinations
- ranks of processes for which the calling process
is a sourcedestWeights
- weights of the edges out of the calling processinfo
- hints on optimization and interpretation of weightsreorder
- the process may be reordered (true) or not (false)MPIException
- Signals that an MPI error of some sort has occurred.public final GraphComm createDistGraphAdjacent(int[] sources, int[] destinations, Info info, boolean reorder) throws MPIException
Java binding of the MPI operation MPI_DIST_GRAPH_CREATE_ADJACENT
using MPI_UNWEIGHTED
.
The number of source/destination nodes is the size of the
sources
/destinations
argument.
sources
- ranks of processes for which the calling process
is a destinationdestinations
- ranks of processes for which the calling process
is a sourceinfo
- hints on optimization and interpretation of weightsreorder
- the process may be reordered (true) or not (false)MPIException
- Signals that an MPI error of some sort has occurred.public final void scan(java.lang.Object sendbuf, java.lang.Object recvbuf, int count, Datatype type, Op op) throws MPIException
Java binding of the MPI operation MPI_SCAN
.
sendbuf
- send buffer arrayrecvbuf
- receive buffer arraycount
- number of items in input buffertype
- data type of each item in input bufferop
- reduce operationMPIException
- Signals that an MPI error of some sort has occurred.public final void scan(java.lang.Object recvbuf, int count, Datatype type, Op op) throws MPIException
Java binding of the MPI operation MPI_SCAN
using MPI_IN_PLACE
instead of the send buffer.
recvbuf
- receive buffer arraycount
- number of items in input buffertype
- data type of each item in input bufferop
- reduce operationMPIException
- Signals that an MPI error of some sort has occurred.public final Request iScan(java.nio.Buffer sendbuf, java.nio.Buffer recvbuf, int count, Datatype type, Op op) throws MPIException
Java binding of the MPI operation MPI_ISCAN
.
sendbuf
- send buffer arrayrecvbuf
- receive buffer arraycount
- number of items in input buffertype
- data type of each item in input bufferop
- reduce operationMPIException
- Signals that an MPI error of some sort has occurred.public final Request iScan(java.nio.Buffer buf, int count, Datatype type, Op op) throws MPIException
Java binding of the MPI operation MPI_ISCAN
using MPI_IN_PLACE
instead of the send buffer.
buf
- send/receive buffer arraycount
- number of items in buffertype
- data type of each item in bufferop
- reduce operationMPIException
- Signals that an MPI error of some sort has occurred.public final void exScan(java.lang.Object sendbuf, java.lang.Object recvbuf, int count, Datatype type, Op op) throws MPIException
Java binding of the MPI operation MPI_EXSCAN
.
sendbuf
- send buffer arrayrecvbuf
- receive buffer arraycount
- number of items in input buffertype
- data type of each item in input bufferop
- reduce operationMPIException
- Signals that an MPI error of some sort has occurred.public final void exScan(java.lang.Object buf, int count, Datatype type, Op op) throws MPIException
Java binding of the MPI operation MPI_EXSCAN
using MPI_IN_PLACE
instead of the send buffer.
buf
- receive buffer arraycount
- number of items in input buffertype
- data type of each item in input bufferop
- reduce operationMPIException
- Signals that an MPI error of some sort has occurred.public final Request iExScan(java.nio.Buffer sendbuf, java.nio.Buffer recvbuf, int count, Datatype type, Op op) throws MPIException
Java binding of the MPI operation MPI_IEXSCAN
.
sendbuf
- send buffer arrayrecvbuf
- receive buffer arraycount
- number of items in input buffertype
- data type of each item in input bufferop
- reduce operationMPIException
- Signals that an MPI error of some sort has occurred.public final Request iExScan(java.nio.Buffer buf, int count, Datatype type, Op op) throws MPIException
Java binding of the MPI operation MPI_IEXSCAN
using MPI_IN_PLACE
instead of the send buffer.
buf
- receive buffer arraycount
- number of items in input buffertype
- data type of each item in input bufferop
- reduce operationMPIException
- Signals that an MPI error of some sort has occurred.public static java.lang.String openPort() throws MPIException
MPI_OPEN_PORT
using MPI_INFO_NULL
.MPIException
- Signals that an MPI error of some sort has occurred.public static java.lang.String openPort(Info info) throws MPIException
MPI_OPEN_PORT
.info
- implementation-specific informationMPIException
- Signals that an MPI error of some sort has occurred.public static void closePort(java.lang.String name) throws MPIException
MPI_CLOSE_PORT
.name
- port nameMPIException
- Signals that an MPI error of some sort has occurred.public final Intercomm accept(java.lang.String port, int root) throws MPIException
MPI_COMM_ACCEPT
using MPI_INFO_NULL
.port
- port nameroot
- rank in comm of root nodeMPIException
- Signals that an MPI error of some sort has occurred.public final Intercomm accept(java.lang.String port, Info info, int root) throws MPIException
MPI_COMM_ACCEPT
.port
- port nameinfo
- implementation-specific informationroot
- rank in comm of root nodeMPIException
- Signals that an MPI error of some sort has occurred.public final Intercomm connect(java.lang.String port, int root) throws MPIException
MPI_COMM_CONNECT
using MPI_INFO_NULL
.port
- port nameroot
- rank in comm of root nodeMPIException
- Signals that an MPI error of some sort has occurred.public final Intercomm connect(java.lang.String port, Info info, int root) throws MPIException
MPI_COMM_CONNECT
.port
- port nameinfo
- implementation-specific informationroot
- rank in comm of root nodeMPIException
- Signals that an MPI error of some sort has occurred.public static void publishName(java.lang.String service, java.lang.String port) throws MPIException
MPI_PUBLISH_NAME
using MPI_INFO_NULL
.service
- service nameport
- port nameMPIException
- Signals that an MPI error of some sort has occurred.public static void publishName(java.lang.String service, Info info, java.lang.String port) throws MPIException
MPI_PUBLISH_NAME
.service
- service nameinfo
- implementation-specific informationport
- port nameMPIException
- Signals that an MPI error of some sort has occurred.public static void unpublishName(java.lang.String service, java.lang.String port) throws MPIException
MPI_UNPUBLISH_NAME
using MPI_INFO_NULL
.service
- service nameport
- port nameMPIException
- Signals that an MPI error of some sort has occurred.public static void unpublishName(java.lang.String service, Info info, java.lang.String port) throws MPIException
MPI_UNPUBLISH_NAME
.service
- service nameinfo
- implementation-specific informationport
- port nameMPIException
- Signals that an MPI error of some sort has occurred.public static java.lang.String lookupName(java.lang.String service) throws MPIException
MPI_LOOKUP_NAME
using MPI_INFO_NULL
.service
- service nameMPIException
- Signals that an MPI error of some sort has occurred.public static java.lang.String lookupName(java.lang.String service, Info info) throws MPIException
MPI_LOOKUP_NAME
.service
- service nameinfo
- implementation-specific informationMPIException
- Signals that an MPI error of some sort has occurred.public final Intercomm spawn(java.lang.String command, java.lang.String[] argv, int maxprocs, Info info, int root, int[] errcodes) throws MPIException
MPI_COMM_SPAWN
.
This intracommunicator will contain the group of spawned processes.command
- name of program to be spawnedargv
- arguments to command; if this parameter is null,
MPI_ARGV_NULL
will be used.maxprocs
- maximum number of processes to startinfo
- info object telling the runtime where
and how to start the processesroot
- rank of process in which previous arguments are examinederrcodes
- one code per process; if this parameter is null,
MPI_ERRCODES_IGNORE
will be used.MPIException
- Signals that an MPI error of some sort has occurred.public final Intercomm spawnMultiple(java.lang.String[] commands, java.lang.String[][] argv, int[] maxprocs, Info[] info, int root, int[] errcodes) throws MPIException
MPI_COMM_SPAWN_MULTIPLE
.
This intracommunicator will contain the group of spawned processes.commands
- programs to be executedargv
- arguments for commands; if this parameter is null,
MPI_ARGVS_NULL
will be used.maxprocs
- maximum number of processes to start for each commandinfo
- info objects telling the runtime where
and how to start the processesroot
- rank of process in which previous arguments are examinederrcodes
- one code per process; if this parameter is null,
MPI_ERRCODES_IGNORE
will be used.MPIException
- Signals that an MPI error of some sort has occurred.