Modifier and Type | Field and Description |
---|---|
Group |
group |
mpjdev.Comm |
mpjdevComm |
Modifier and Type | Method and Description |
---|---|
void |
Abort(int errorcode)
Abort MPI.
|
void |
Attr_delete(int keyval)
Retrieves attribute value by key.
|
java.lang.Object |
Attr_get(int keyval)
Retrieves attribute value by key.
|
Prequest |
Bsend_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Creates a persistent communication request for a buffered mode send.
|
void |
Bsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Send in buffered mode.
|
protected void |
bsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) |
java.lang.Object |
clone()
Duplicate this communicator.
|
static int |
Compare(Comm comm1, Comm comm2)
Compare two communicators.
|
Intercomm |
Create_intercomm(Comm local_comm, int local_leader, int remote_leader, int tag)
Create an inter-communicator.
|
void |
Free()
Destroy this communicator.
|
Group |
Group()
Return group associated with a communicator.
|
Request |
Ibsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Start a buffered mode, nonblocking send.
|
protected Request |
ibsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) |
Status |
Iprobe(int source, int tag)
Check if there is an incoming message matching the pattern specified.
|
Request |
Irecv(java.lang.Object buf, int offset, int count, Datatype datatype, int src, int tag)
Start a nonblocking receive.
|
protected Request |
irecv(java.lang.Object buf, int offset, int count, Datatype datatype, int src, int tag, boolean pt2pt) |
Request |
Irsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Start a ready mode, nonblocking send.
|
protected Request |
irsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) |
Request |
Isend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Start a standard mode, nonblocking send.
|
protected Request |
isend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) |
Request |
Issend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Start a synchronous mode, nonblocking send.
|
protected Request |
issend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) |
int |
Pack_size(int incount, Datatype datatype)
Returns an upper bound on the increment of position effected by pack.
|
int |
Pack(java.lang.Object inbuf, int offset, int incount, Datatype datatype, mpjbuf.Buffer outbuf, int position)
Packs message in send buffer inbuf into space specified in outbuf.
|
Status |
Probe(int source, int tag)
Wait until there is an incoming message matching the pattern specified.
|
int |
Rank()
Rank of this process in group of this communicator.
|
Prequest |
Recv_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Creates a persistent communication request for a receive operation.
|
Status |
Recv(java.lang.Object buf, int offset, int count, Datatype datatype, int source, int tag)
Blocking receive operation.
|
protected Status |
recv(java.lang.Object buf, int offset, int count, Datatype datatype, int source, int tag, boolean pt2pt) |
Prequest |
Rsend_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Creates a persistent communication request for a ready mode send.
|
void |
Rsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Send in ready mode.
|
protected void |
rsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) |
Prequest |
Send_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Creates a persistent communication request for a standard mode send.
|
void |
Send(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Blocking send operation.
|
protected void |
send(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) |
Status |
Sendrecv_replace(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int sendtag, int source, int recvtag)
Execute a blocking send and receive operation, receiving message into send buffer.
|
protected Status |
sendrecv(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, int dest, int sendtag, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype, int source, int recvtag) |
Status |
Sendrecv(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, int dest, int sendtag, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype, int source, int recvtag)
Execute a blocking send and receive operation.
|
int |
Size()
Size of group of this communicator.
|
Prequest |
Ssend_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Creates a persistent communication request for a synchronous mode send.
|
void |
Ssend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag)
Send in synchronous mode.
|
protected void |
ssend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) |
boolean |
Test_inter()
Test if this communicator is an inter-communicator.
|
int |
Topo_test()
Returns the type of topology associated with the communicator.
|
int |
Unpack(mpjbuf.Buffer inbuf, int position, java.lang.Object outbuf, int offset, int outcount, Datatype datatype)
Unpacks message in receive buffer outbuf into space specified in inbuf.
|
public Group group
public mpjdev.Comm mpjdevComm
public int Size() throws MPIException
returns: | number of processors in the group of this communicator |
Java binding of the MPI operation MPI_COMM_SIZE.
MPIException
public int Rank() throws MPIException
returns: | rank of the calling process in the group of this communicator |
Java binding of the MPI operation MPI_COMM_RANK.
MPIException
public Group Group() throws MPIException
returns: | group corresponding to this communicator group |
Java binding of the MPI operation MPI_COMM_GROUP.
MPIException
public static int Compare(Comm comm1, Comm comm2) throws MPIException
comm1 | first communicator |
comm2 | second communicator |
returns: | result |
Java binding of the MPI operation MPI_COMM_COMPARE.
MPI.IDENT(0) results if the comm1 and comm2 are references to the same object (ie, if comm1 == comm2). MPI.CONGRUENT(3) results if the underlying groups are identical but the communicators differ by context. MPI.SIMILAR(1) results if the underlying groups are similar but the communicators differ by context. MPI.UNEQUAL(2) results otherwise.
MPIException
public void Free() throws MPIException
Java binding of the MPI operation MPI_COMM_FREE.
MPIException
public boolean Test_inter() throws MPIException
returns: | true if this is an inter-communicator, false otherwise |
Java binding of the MPI operation MPI_COMM_TEST_INTER.
MPIException
public Intercomm Create_intercomm(Comm local_comm, int local_leader, int remote_leader, int tag) throws MPIException
local_comm | local intra-communicator |
local_leader | rank of local group leader in localComm |
remote_leader | rank of remote group leader in this communictor |
tag | ``safe'' tag |
returns: | new inter-communicator |
Java binding of the MPI operation MPI_INTERCOMM_CREATE.
(This operation is defined as a method on the ``peer communicator'', making it analogous to a send or recv communication with the remote group leader.)
MPIException
public java.lang.Object Attr_get(int keyval) throws MPIException
keyval | one of the key values predefined by the implementation |
returns: | attribute value |
Java binding of the MPI operation MPI_ATTR_GET.
MPIException
public void Attr_delete(int keyval) throws MPIException
keyval | one of the key values predefined by the implementation |
returns: | attribute value |
Java binding of the MPI operation MPI_ATTR_GET.
MPIException
public void Send(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
Java binding of the MPI operation MPI_SEND.
The actual argument associated with buf must be one-dimensional array. The value offset is a subscript in this array, defining the position of the first item of the message.
If the datatype argument represents an MPI basic type, its value must agree with the element type of buf---either a primitive type or a reference (object) type. If the datatype argument represents an MPI derived type, its base type must agree with the element type of buf
MPIException
protected void send(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) throws MPIException
MPIException
public void Ssend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
Java binding of the MPI operation MPI_SSEND.
Further comments as for Send.
MPIException
protected void ssend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) throws MPIException
MPIException
public void Bsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
Java binding of the MPI operation MPI_BSEND.
This operation copies message into a buffer (mpi.Buffer) specified by MPI.Buffer_attach operation, and then sends using the standard mode of communication. Further comments as for Send.
MPIException
protected void bsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) throws MPIException
MPIException
public void Rsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
Java binding of the MPI operation MPI_RSEND.
Further comments as for Send.
MPIException
protected void rsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) throws MPIException
MPIException
public Request Isend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
returns: | communication request |
Java binding of the MPI operation MPI_ISEND.
Further comments as for Send.
MPIException
protected Request isend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) throws MPIException
MPIException
public Request Ibsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
returns: | communication request |
Java binding of the MPI operation MPI_IBSEND.
Further comments as for Send.
MPIException
protected Request ibsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) throws MPIException
MPIException
public Request Issend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
returns: | communication request |
Java binding of the MPI operation MPI_ISSEND.
Further comments as for Send.
MPIException
protected Request issend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) throws MPIException
MPIException
public Request Irsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
returns: | communication request |
Java binding of the MPI operation MPI_IRSEND.
Further comments as for Send.
MPIException
protected Request irsend(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag, boolean pt2pt) throws MPIException
MPIException
public Status Recv(java.lang.Object buf, int offset, int count, Datatype datatype, int source, int tag) throws MPIException
buf | receive buffer array |
offset | initial offset in receive buffer |
count | number of items in receive buffer |
datatype | datatype of each item in receive buffer |
source | rank of source |
tag | message tag |
returns: | status object |
Java binding of the MPI operation MPI_RECV.
The actual argument associated with buf must be one-dimensional array. The value offset is a subscript in this array, defining the position into which the first item of the incoming message will be copied.
If the datatype argument represents an MPI basic type, its value must agree with the element type of buf---either a primitive type or a reference (object) type. If the datatype argument represents an MPI derived type, its base type must agree with the element type of buf
MPIException
protected Status recv(java.lang.Object buf, int offset, int count, Datatype datatype, int source, int tag, boolean pt2pt) throws MPIException
MPIException
public Request Irecv(java.lang.Object buf, int offset, int count, Datatype datatype, int src, int tag) throws MPIException
buf | receive buffer array |
offset | initial offset in receive buffer |
count | number of items in receive buffer |
datatype | datatype of each item in receive buffer |
source | rank of source |
tag | message tag |
returns: | communication request |
Java binding of the MPI operation MPI_IRECV.
Further comments as for Recv.
MPIException
protected Request irecv(java.lang.Object buf, int offset, int count, Datatype datatype, int src, int tag, boolean pt2pt) throws MPIException
MPIException
public Status Iprobe(int source, int tag) throws MPIException
source | rank of source |
tag | message tag |
returns: | status object or null handle |
Java binding of the MPI operation MPI_IPROBE.
If such a message is currently available, a status object similar to the return value of a matching Recv operation is returned. Otherwise a null handle is returned.
MPIException
public Status Probe(int source, int tag) throws MPIException
source | rank of source |
tag | message tag |
returns: | status object |
Java binding of the MPI operation MPI_PROBE.
Returns a status object similar to the return value of a matching Recv operation.
MPIException
public int Pack_size(int incount, Datatype datatype) throws MPIException
incount | number of items in input buffer |
datatype | datatype of each item in input buffer |
returns: | upper bound on size of packed message |
Java binding of the MPI operation MPI_PACK_SIZE.
It is an error to call this function if the base type of datatype is MPI.OBJECT.
MPIException
public int Pack(java.lang.Object inbuf, int offset, int incount, Datatype datatype, mpjbuf.Buffer outbuf, int position) throws MPIException
inbuf | input buffer array |
offset | initial offset in input buffer |
incount | number of items in input buffer |
datatype | datatype of each item in input buffer |
outbuf | output buffer |
position | initial position in output buffer |
returns: | final position in output buffer |
Java binding of the MPI operation MPI_PACK.
The return value is the output value of position - the inital value incremented by the number of bytes written.
MPIException
public int Unpack(mpjbuf.Buffer inbuf, int position, java.lang.Object outbuf, int offset, int outcount, Datatype datatype) throws MPIException
inbuf | input buffer |
position | initial position in input buffer |
outbuf | output buffer array |
offset | initial offset in output buffer |
outcount | number of items in output buffer |
datatype | datatype of each item in output buffer |
returns: | final position in input buffer |
Java binding of the MPI operation MPI_UNPACK.
The return value is the output value of position - the inital value incremented by the number of bytes read.
MPIException
public Prequest Bsend_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
returns: | persistent communication request |
Java binding of the MPI operation MPI_BSEND_INIT.
Further comments as for Send.
MPIException
public Prequest Send_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
returns: | persistent communication request |
Java binding of the MPI operation MPI_SEND_INIT.
Further comments as for Send.
MPIException
public Prequest Ssend_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
returns: | persistent communication request |
Java binding of the MPI operation MPI_SSEND_INIT.
Further comments as for Send.
MPIException
public Prequest Rsend_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | send buffer array |
offset | initial offset in send buffer |
count | number of items to send |
datatype | datatype of each item in send buffer |
dest | rank of destination |
tag | message tag |
returns: | persistent communication request |
Java binding of the MPI operation MPI_RSEND_INIT.
Further comments as for Send.
MPIException
public Prequest Recv_init(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int tag) throws MPIException
buf | receive buffer array |
offset | initial offset in receive buffer |
count | number of items in receive buffer |
datatype | datatype of each item in receive buffer |
source | rank of source |
tag | message tag |
returns: | communication request |
Java binding of the MPI operation MPI_RECV_INIT.
Further comments as for Recv.
MPIException
public Status Sendrecv(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, int dest, int sendtag, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype, int source, int recvtag) throws MPIException
sendbuf | send buffer array |
sendoffset | initial offset in send buffer |
sendcount | number of items to send |
sendtype | datatype of each item in send buffer |
dest | rank of destination |
sendtag | send tag |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
recvcount | number of items in receive buffer |
recvtype | datatype of each item in receive buffer |
source | rank of source |
recvtag | receive tag |
returns: | status object |
Java binding of the MPI operation MPI_SENDRECV.
Further comments as for Send and Recv.
MPIException
public Status Sendrecv_replace(java.lang.Object buf, int offset, int count, Datatype datatype, int dest, int sendtag, int source, int recvtag) throws MPIException
buf | buffer array |
offset | initial offset in buffer |
count | number of items to send |
type | datatype of each item in buffer |
dest | rank of destination |
sendtag | send tag |
source | rank of source |
recvtag | receive tag |
returns: | status object |
Further comments as for Send and Recv.
MPIException
protected Status sendrecv(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, int dest, int sendtag, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype, int source, int recvtag) throws MPIException
MPIException
public int Topo_test() throws MPIException
returns: | topology type of communicator |
Java binding of the MPI operation MPI_TOPO_TEST.
The return value will be one of MPI.GRAPH, MPI.CART or MPI.UNDEFINED.
MPIException
public void Abort(int errorcode) throws MPIException
errorcode | error code for Unix or POSIX environments |
Java binding of the MPI operation MPI_ABORT.
MPIException
public java.lang.Object clone() throws MPIException
returns: | copy of this communicator |
Java binding of the MPI operation MPI_COMM_DUP.
The new communicator is ``congruent'' to the old one, but has a different context.
clone
in class java.lang.Object
MPIException