|
||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object mpi.Comm
public abstract class Comm
Method Summary | |
---|---|
void |
Abort(int errorcode)
Abort MPI. |
abstract void |
Allgather(java.lang.Object sendbuf,
int sendoffset,
int sendcount,
Datatype sendtype,
java.lang.Object recvbuf,
int recvoffset,
int recvcount,
Datatype recvtype)
Similar to Gather, but all processes receive the result. |
abstract void |
Allgatherv(java.lang.Object sendbuf,
int sendoffset,
int sendcount,
Datatype sendtype,
java.lang.Object recvbuf,
int recvoffset,
int[] recvcount,
int[] displs,
Datatype recvtype)
Similar to Gatherv, but all processes receive the result. |
abstract void |
Allreduce(java.lang.Object sendbuf,
int sendoffset,
java.lang.Object recvbuf,
int recvoffset,
int count,
Datatype datatype,
Op op)
Same as Reduce except that the result appears in the receive buffer of all processes in the group. |
abstract void |
Alltoall(java.lang.Object sendbuf,
int sendoffset,
int sendcount,
Datatype sendtype,
java.lang.Object recvbuf,
int recvoffset,
int recvcount,
Datatype recvtype)
Extension of Allgather to the case where each process sends distinct data to each of the receivers. |
abstract void |
Alltoallv(java.lang.Object sendbuf,
int sendoffset,
int[] sendcount,
int[] sdispls,
Datatype sendtype,
java.lang.Object recvbuf,
int recvoffset,
int[] recvcount,
int[] rdispls,
Datatype recvtype)
Adds flexibility to Alltoall: location of data for send is specified by sdispls and location to place data on receive side is specified by rdispls. |
abstract void |
Barrier()
A call to Barrier blocks the caller until all processes in the group have called it. |
abstract void |
Bcast(java.lang.Object buf,
int offset,
int count,
Datatype datatype,
int root)
Broadcast a message from the process with rank root to all processes of the group, itself included. |
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. |
java.lang.Object |
clone()
Duplicate this communicator. |
static int |
Compare(Comm comm1,
Comm comm2)
Compare two communicators. |
Intercomm |
Create_intercomm(Comm local_intracomm,
int local_leader,
int remote_leader,
int tag)
Creates an inter-communicator from two intra-communicators. |
void |
Delete_attr(Keyval key)
Deletes an attribute value associated with a key on a communicator. |
static Errhandler |
Errorhandler_get()
Returns the error handler currently associated with the communicator. |
static void |
Errorhandler_set(Errhandler errhandler)
Associates a new error handler with communicator at the calling process. |
void |
Free()
Destroy this communicator. |
abstract void |
Gather(java.lang.Object sendbuf,
int sendoffset,
int sendcount,
Datatype sendtype,
java.lang.Object recvbuf,
int recvoffset,
int recvcount,
Datatype recvtype,
int root)
Each process (root process included) sends the contents of its send buffer to the root process, which receives these contents in its recvbuf. |
abstract void |
Gatherv(java.lang.Object sendbuf,
int sendoffset,
int sendcount,
Datatype sendtype,
java.lang.Object recvbuf,
int recvoffset,
int[] recvcount,
int[] displs,
Datatype recvtype,
int root)
Extend the functionality of Gather by allowing varying counts of data from each process. |
java.lang.Object |
Get_attr(Keyval key)
Retrieves attribute value by key. |
java.lang.String |
Get_name()
Return the print name from the communicator. |
abstract 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. |
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 source,
int tag)
Start a nonblocking receive. |
Request |
Irsend(java.lang.Object buf,
int offset,
int count,
Datatype datatype,
int dest,
int tag)
Start a ready mode, nonblocking send. |
boolean |
Is_null()
Replaces comparision with MPI.COMM_NULL. |
Request |
Isend(java.lang.Object buf,
int offset,
int count,
Datatype datatype,
int dest,
int tag)
Start a standard mode, nonblocking send. |
Request |
Issend(java.lang.Object buf,
int offset,
int count,
Datatype datatype,
int dest,
int tag)
Start a synchronous mode, nonblocking send. |
int |
Pack_size(int incount,
Datatype datatype)
Returns an upper bound on the increment of position effected by pack. |
int |
Pack_size(int incount,
java.lang.Object[] obj)
Special version of Pack_size for MPI.OBJECT datatype |
int |
Pack(java.lang.Object inbuf,
int offset,
int incount,
Datatype datatype,
byte[] 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. |
abstract 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 source,
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. |
abstract void |
Reduce_scatter(java.lang.Object sendbuf,
int sendoffset,
java.lang.Object recvbuf,
int recvoffset,
int[] recvcounts,
Datatype datatype,
Op op)
Combine elements in input buffer of each process using the reduce operation, and scatter the combined values over the output buffers of the processes. |
abstract void |
Reduce(java.lang.Object sendbuf,
int sendoffset,
java.lang.Object recvbuf,
int recvoffset,
int count,
Datatype datatype,
Op op,
int root)
Combine elements in input buffer of each process using the reduce operation, and return the combined value in the output buffer of the root process. |
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. |
abstract void |
Scan(java.lang.Object sendbuf,
int sendoffset,
java.lang.Object recvbuf,
int recvoffset,
int count,
Datatype datatype,
Op op)
Perform a prefix reduction on data distributed across the group. |
abstract void |
Scatter(java.lang.Object sendbuf,
int sendoffset,
int sendcount,
Datatype sendtype,
java.lang.Object recvbuf,
int recvoffset,
int recvcount,
Datatype recvtype,
int root)
Inverse of the operation Gather. |
abstract void |
Scatterv(java.lang.Object sendbuf,
int sendoffset,
int[] sendcount,
int[] displs,
Datatype sendtype,
java.lang.Object recvbuf,
int recvoffset,
int recvcount,
Datatype recvtype,
int root)
Inverse of the operation Gatherv. |
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. |
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. |
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. |
void |
Set_attr(Keyval key,
java.lang.Object attribute_val)
Stores attribute value associated with a key. |
void |
Set_name(java.lang.String name)
Sets the print name for a communicator. |
abstract 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. |
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(byte[] inbuf,
int position,
java.lang.Object outbuf,
int offset,
int outcount,
Datatype datatype)
Unpacks message in receive buffer outbuf into space specified in inbuf |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
---|
public abstract 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 abstract 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 abstract Group Group() throws MPIException
returns: | group corresponding to this communicator |
Java binding of the MPI operation MPI_COMM_GROUP.
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
public void Free() throws MPIException
Java binding of the MPI operation MPI_COMM_FREE.
An explicitly called Free method is required rather than an implicitly called finalize method, because MPI COMM FREE is a collective operation. We cannot assume that the Java garbage collector will call a finalize method synchronously on all processors.
MPIException
public boolean Is_null()
returns: | true if the communicator object has been freed, false otherwise |
public void Abort(int errorcode) throws MPIException
errorcode | error code for Unix or POSIX environments |
Java binding of the MPI operation MPI_ABORT.
The MPI standard says: the process calling MPI_Abort must be a member of the communicator passed in. If the communicator is invalid or the process is not a member of the communicator, MPI_Abort is called on MPI_COMM_WORLD.
MPIException
public void Set_name(java.lang.String name) throws MPIException
name | Name of the communicator |
Java binding of the MPI operation MPI_COMM_SET_NAME.
MPIException
public java.lang.String Get_name() throws MPIException
returns: | Name of the communicator |
Java binding of the MPI operation MPI_COMM_GET_NAME.
The three predefined communicators will have predefined names associated with them. Thus, the names of MPI.COMM_WORLD, MPI.COMM_SELF and MPI.COMM_NULL will have the default of MPI.COMM_WORLD, MPI.COMM_SELF and MPI.COMM_NULL
MPIException
public java.lang.Object Get_attr(Keyval key) throws MPIException
key | key value |
returns: | attribute value or null if no attribute is associated with the key |
Java binding of the MPI operation MPI_COMM_GET_ATTR.
Retrieves attribute value by key. The call is erroneous if there is no key with value keyval. On the other hand, the call is correct if the key value exists, but no attribute is attached on comm for that key; in such case, the call returns null
MPIException
public void Delete_attr(Keyval key) throws MPIException
key | the key value of the deleted attribute |
Java binding of the MPI operation MPI_COMM_DELETE_ATTR.
MPIException
public void Set_attr(Keyval key, java.lang.Object attribute_val) throws MPIException
key | key value, as returned by MPI.Comm_create_keyval |
Java binding of the MPI operation MPI_COMM_SET_ATTR.
If the value is already present, then the outcome is as if Comm.Delete_attr() was first called to delete the previous value, and a new value was next stored
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 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 results if the comm1 and comm2 are references to the same object (ie, if comm1 == comm2). MPI.CONGRUENT results if the underlying groups are identical but the communicators differ by context. MPI.SIMILAR results if the underlying groups are similar but the communicators differ by context. MPI.UNEQUAL results otherwise.
MPIException
public Intercomm Create_intercomm(Comm local_intracomm, int local_leader, int remote_leader, int tag) throws MPIException
local_intracomm | local intra-communicator |
local_leader | rank of local group leader in local_intracomm |
remote_leader | rank of remote group leader in this intra-communicator |
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 intra-communicator", making it analogous to a Send or Recv communication with the remote group leader.
The MPI 1.2 standard contains two mutually exclusive comments on the input intra-communicators. One says that their respective groups must be disjoint; the other that the leaders can be the same process.
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
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
public Request Irecv(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: | communication request |
Java binding of the MPI operation MPI_IRECV.
Further comments as for Recv.
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 class type (object). If the datatype argument represents an MPI derived type, its base type must agree with the element type of buf.
If a data type has MPI.OBJECT as its base type, the objects in the buffer will be transparently serialized and unserialized inside the communication operations.
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
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 class type (object). If the datatype argument represents an MPI derived type, its base type must agree with the element type of buf
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
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
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 Isend.
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 specified by MPI.Buffer_attach operation, and then sends using the standard mode of communication. Further comments as for Send.
MPIException
public Status Iprobe(int source, int tag) throws MPIException
source | source rank |
tag | tag value |
returns: | status object or null reference |
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 reference is returned.
MPIException
public Status Probe(int source, int tag) throws MPIException
source | source rank |
tag | tag value |
returns: | status object or null reference |
Java binding of the MPI operation MPI_PROBE.
Returns a status object similar to the return value of a matching Recv operation.
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
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 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 Recv_init(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: | persistent communication request |
Java binding of the MPI operation MPI_RECV_INIT.
Further comments as for Recv.
MPIException
public int Pack(java.lang.Object inbuf, int offset, int incount, Datatype datatype, byte[] 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, in bytes |
returns: | final position in output buffer, in bytes |
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(byte[] 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, in bytes |
outcount | number of items in output buffer |
datatype | datatype of each item in output buffer |
returns: | final position in input buffer, in bytes |
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 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, in bytes |
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 (FastMPJ provides Pack_size(int,Object[]) method instead) or MPI.PACKED (not sense) .
MPIException
public int Pack_size(int incount, java.lang.Object[] obj) throws MPIException
incount | number of items in input buffer |
obj | array of objects to be packed |
returns: | upper bound on size of packed message, in bytes |
MPIException
public abstract void Barrier() throws MPIException
Java binding of the MPI operation MPI_BARRIER.
MPIException
public abstract void Bcast(java.lang.Object buf, int offset, int count, Datatype datatype, int root) throws MPIException
buf | inout buffer array |
offset | initial offset in buffer |
count | number of items in buffer |
datatype | datatype of each item in buffer |
root | rank of broadcast root |
Java binding of the MPI operation MPI_BCAST.
MPIException
public abstract void Gather(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype, int root) 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 |
recvbuf | receive buffer array (significant only at root) |
recvoffset | initial offset in receive buffer (significant only at root) |
recvcount | number of items to receive from each process |
recvtype | datatype of each item in receive buffer |
root | rank of receiving process |
Java binding of the MPI operation MPI_GATHER.
MPIException
public abstract void Gatherv(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, java.lang.Object recvbuf, int recvoffset, int[] recvcount, int[] displs, Datatype recvtype, int root) 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 |
recvbuf | receive buffer array (significant only at root) |
recvoffset | initial offset in receive buffer (significant only at root) |
recvcounts | number of elements received from each process (significant only at root) |
displs | displacements at which to place incoming data from each process (significant only at root) |
recvtype | datatype of each item in receive buffer (significant only at root) |
root | rank of receiving process |
Java binding of the MPI operation MPI_GATHERV.
The size of arrays recvcounts and displs should be the size of the group. Entry i of displs specifies the displacement relative to element recvoffset of recvbuf at which to place incoming data. sendtype and recvtype must be the same.
Note that if recvtype is a derived data type, elements of displs are in units of the derived type extent, (unlike recvoffset, which is a direct index into the buffer array).
MPIException
public abstract void Scatter(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype, int root) throws MPIException
sendbuf | send buffer array (significant only at root) |
sendoffset | initial offset in send buffer |
sendcount | number of items to send to each process (significant only at root |
sendtype | datatype of each item in send buffer (significant only at root) |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
recvcount | number of items to receive |
recvtype | datatype of each item in receive buffer |
root | rank of sending process |
Java binding of the MPI operation MPI_SCATTER.
MPIException
public abstract void Scatterv(java.lang.Object sendbuf, int sendoffset, int[] sendcount, int[] displs, Datatype sendtype, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype, int root) throws MPIException
sendbuf | send buffer array (significant only at root) |
sendoffset | initial offset in send buffer |
sendcount | number of items to send to each process |
displs | displacements from which to take outgoing data to each process |
sendtype | datatype of each item in send buffer |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
recvcount | number of items to receive |
recvtype | datatype of each item in receive buffer |
root | rank of sending process |
Java binding of the MPI operation MPI_SCATTERV.
MPIException
public abstract void Allgather(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype) 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 |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
recvcount | number of items to receive from each process |
recvtype | datatype of each item in receive buffer |
Java binding of the MPI operation MPI_ALLGATHER.
MPIException
public abstract void Allgatherv(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, java.lang.Object recvbuf, int recvoffset, int[] recvcount, int[] displs, Datatype recvtype) 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 |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
recvcounts | number of received elements from each process |
displs | displacements at which to place incoming data |
recvtype | datatype of each item in receive buffer |
Java binding of the MPI operation MPI_ALLGATHERV.
MPIException
public abstract void Alltoall(java.lang.Object sendbuf, int sendoffset, int sendcount, Datatype sendtype, java.lang.Object recvbuf, int recvoffset, int recvcount, Datatype recvtype) throws MPIException
sendbuf | send buffer array |
sendoffset | initial offset in send buffer |
sendcount | number of items sent to each process |
sendtype | datatype send buffer items |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
recvcount | number of items received from any process |
recvtype | datatype of receive buffer items |
Java binding of the MPI operation MPI_ALLTOALL.
MPIException
public abstract void Alltoallv(java.lang.Object sendbuf, int sendoffset, int[] sendcount, int[] sdispls, Datatype sendtype, java.lang.Object recvbuf, int recvoffset, int[] recvcount, int[] rdispls, Datatype recvtype) throws MPIException
sendbuf | send buffer array |
sendoffset | initial offset in send buffer |
sendcount | number of items sent to each process |
sdispls | displacements from which to take outgoing data. Entry j specifies the displacement from which to take the outgoing data destined for process j |
sendtype | datatype send buffer items |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
recvcounts | number of elements received from each process |
rdispls | displacements at which to place incoming data. Entry i specifies the displacement at which to place the incoming data from process i |
recvtype | datatype of each item in receive buffer |
Java binding of the MPI operation MPI_ALLTOALLV.
MPIException
public abstract void Reduce(java.lang.Object sendbuf, int sendoffset, java.lang.Object recvbuf, int recvoffset, int count, Datatype datatype, Op op, int root) throws MPIException
sendbuf | send buffer array |
sendoffset | initial offset in send buffer |
recvbuf | receive buffer array (significant only at root) |
recvoffset | initial offset in receive buffer |
count | number of items in send buffer |
datatype | data type of each item in send buffer |
op | reduce operation |
root | rank of root process |
Java binding of the MPI operation MPI_REDUCE.
op can be a predefined operation or an user-defined operation. The predefined operations are available in Java as MPI.MAX, MPI.MIN, MPI.SUM, MPI.PROD, MPI.LAND, MPI.BAND, MPI.LOR, MPI.BOR, MPI.LXOR, MPI.BXOR, MPI.MINLOC and MPI.MAXLOC. The operation is always assumed to be associative. The datatype must be compatible with op.
MPIException
public abstract void Allreduce(java.lang.Object sendbuf, int sendoffset, java.lang.Object recvbuf, int recvoffset, int count, Datatype datatype, Op op) throws MPIException
sendbuf | send buffer array |
sendoffset | initial offset in send buffer |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
count | number of items in send buffer |
datatype | data type of each item in send buffer |
op | reduce operation |
Java binding of the MPI operation MPI_ALLREDUCE.
MPIException
public abstract void Reduce_scatter(java.lang.Object sendbuf, int sendoffset, java.lang.Object recvbuf, int recvoffset, int[] recvcounts, Datatype datatype, Op op) throws MPIException
sendbuf | send buffer array |
sendoffset | initial offset in send buffer |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
recvcounts | numbers of result elements distributed to each process. Array must be identical on all calling processes. |
datatype | data type of each item in send buffer |
op | reduce operation |
Java binding of the MPI operation MPI_REDUCE_SCATTER.
MPIException
public abstract void Scan(java.lang.Object sendbuf, int sendoffset, java.lang.Object recvbuf, int recvoffset, int count, Datatype datatype, Op op) throws MPIException
sendbuf | send buffer array |
sendoffset | initial offset in send buffer |
recvbuf | receive buffer array |
recvoffset | initial offset in receive buffer |
count | number of items in input buffer |
datatype | data type of each item in input buffer |
op | reduce operation |
Java binding of the MPI operation MPI_SCAN.
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 static void Errorhandler_set(Errhandler errhandler) throws MPIException
errhandler | new MPI error handler for communicator |
Java binding of the MPI operation MPI_ERRORHANDLER_SET..
Not implemented in the current release
MPIException
public static Errhandler Errorhandler_get() throws MPIException
returns: | MPI error handler currently associated with communicator |
Java binding of the MPI operation MPI_ERRORHANDLER_GET..
Not implemented in the current release
MPIException
|
||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |