p2pmpi.mpi
Class Comm

java.lang.Object
  p2pmpi.mpi.Comm

Direct Known Subclasses:

IntraComm

public class Comm
extends java.lang.Object

Point-to-Point communication class

Constructor Summary

Comm(p2pmpi.mpi.dev.Device myDevice, p2pmpi.common.RankTable rankTable, int rank, int rankInList, int numRank, p2pmpi.common.MapRankTable mapRankTable)
Internal use

Comm(Group group)
Create a new communicator by group

Method Summary

Group	Group() Returns group of this communicator
Request	Irecv(java.lang.Object recvBuffer, int offset, int count, Datatype datatype, int src, int tag) Begins a non-blocking receive.
Request	Isend(java.lang.Object sendBuffer, int offset, int count, Datatype datatype, int dest, int tag)
int	Rank() Returns my rank number in communicator.
Status	Recv(java.lang.Object recvBuffer, int offset, int count, Datatype datatype, int src, int tag) Basic (blocking) receive.
int	Send(java.lang.Object sendBuffer, int offset, int count, Datatype datatype, int dest, int tag)
Status	Sendrecv(java.lang.Object sendBuffer, int sendOffset, int sendCount, Datatype sendType, int dest, int sendTag, java.lang.Object recvBuffer, int recvOffset, int recvCount, Datatype recvType, int source, int recvTag)
int	Size() Returns the number of processes in communicator.
int	SizeTotal() Internal use.
int	Ssend(java.lang.Object sendBuffer, int offset, int count, Datatype datatype, int dest, int tag) Basic send operation.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Comm

public Comm(p2pmpi.mpi.dev.Device myDevice,
            p2pmpi.common.RankTable rankTable,
            int rank,
            int rankInList,
            int numRank,
            p2pmpi.common.MapRankTable mapRankTable)

Internal use

Comm

public Comm(Group group)

Create a new communicator by group

Parameters:

group - Group

Method Detail

Group

public Group Group()

Returns group of this communicator

Returns:

group

Size

public int Size()

Returns the number of processes in communicator.

Returns:

number of processes in co

SizeTotal

public int SizeTotal()

Internal use.

Rank

public int Rank()

Returns my rank number in communicator.

Returns:

MPI rank

Ssend

public int Ssend(java.lang.Object sendBuffer,
                 int offset,
                 int count,
                 Datatype datatype,
                 int dest,
                 int tag)

Basic send operation.

Parameters:

sendBuffer - send buffer array

offset - initial offset in send buffer

count - number of items to send

datatype - datatype of send buffer items

dest - rank of destination

tag - message tag

Send

public int Send(java.lang.Object sendBuffer,
                int offset,
                int count,
                Datatype datatype,
                int dest,
                int tag)

Isend

public Request Isend(java.lang.Object sendBuffer,
                     int offset,
                     int count,
                     Datatype datatype,
                     int dest,
                     int tag)

Sendrecv

public Status Sendrecv(java.lang.Object sendBuffer,
                       int sendOffset,
                       int sendCount,
                       Datatype sendType,
                       int dest,
                       int sendTag,
                       java.lang.Object recvBuffer,
                       int recvOffset,
                       int recvCount,
                       Datatype recvType,
                       int source,
                       int recvTag)

Recv

public Status Recv(java.lang.Object recvBuffer,
                   int offset,
                   int count,
                   Datatype datatype,
                   int src,
                   int tag)

Basic (blocking) receive.

Parameters:

recvBuffer - receive buffer array

offset - initial offset in receive buffer

count - number of items to receive

datatype - datatype of received items

src - rank of source

tag - message tag

Irecv

public Request Irecv(java.lang.Object recvBuffer,
                     int offset,
                     int count,
                     Datatype datatype,
                     int src,
                     int tag)

Begins a non-blocking receive.

Parameters:

recvBuffer - receive buffer array

offset - initial offset in receive buffer

count - number of items to receive

datatype - datatype of received items

src - rank of source

tag - message tag