mpjdev
Class Comm
java.lang.Object
mpjdev.Comm
public class Comm
- extends java.lang.Object
Method Summary |
void |
barrier()
|
Comm |
clone()
|
Comm |
create(Comm localcomm,
Group peergroup,
int localleader,
int remoteleader,
int tag)
|
Comm |
create(Group ngroup)
this method is used to create intra-communicators,
not inter-communicators. |
Comm |
create(int[] ids)
this method will create intracommunicators. |
void |
free()
|
int |
id()
|
Status |
iprobe(int src,
int tag)
|
Request |
irecv(Buffer buf,
int src,
int tag,
Status status,
boolean pt2pt)
|
Request |
isend(Buffer buf,
int dest,
int tag,
boolean pt2pt)
|
Request |
issend(Buffer buf,
int dest,
int tag,
boolean pt2pt)
|
Status |
probe(int src,
int tag)
|
Status |
recv(Buffer buf,
int src,
int tag,
boolean pt2pt)
|
void |
send(Buffer buf,
int dest,
int tag,
boolean pt2pt)
|
int |
size()
|
Comm |
split(int color,
int key)
|
void |
ssend(Buffer buf,
int dest,
int tag,
boolean pt2pt)
|
Methods inherited from class java.lang.Object |
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
sendctxt
public int sendctxt
recvctxt
public int recvctxt
group
public Group group
localgroup
public Group localgroup
create
public Comm create(int[] ids)
throws MPJDevException
- this method will create intracommunicators. One way is to
use create(grp), or get ids from grp at MPJ level and
give the argument. contexts will be managed in this device and
intercomms will be created by create(grp1,grp2) or whatever
it may require.
- Throws:
MPJDevException
create
public Comm create(Group ngroup)
throws MPJDevException
- this method is used to create intra-communicators,
not inter-communicators.
- Throws:
MPJDevException
create
public Comm create(Comm localcomm,
Group peergroup,
int localleader,
int remoteleader,
int tag)
throws MPJDevException
- Throws:
MPJDevException
clone
public Comm clone()
- Overrides:
clone
in class java.lang.Object
probe
public Status probe(int src,
int tag)
throws MPJDevException
- Throws:
MPJDevException
iprobe
public Status iprobe(int src,
int tag)
throws MPJDevException
- Throws:
MPJDevException
irecv
public Request irecv(Buffer buf,
int src,
int tag,
Status status,
boolean pt2pt)
throws MPJDevException
- Throws:
MPJDevException
recv
public Status recv(Buffer buf,
int src,
int tag,
boolean pt2pt)
throws MPJDevException
- Throws:
MPJDevException
barrier
public void barrier()
throws MPJDevException
- Throws:
MPJDevException
isend
public Request isend(Buffer buf,
int dest,
int tag,
boolean pt2pt)
throws MPJDevException
- Throws:
MPJDevException
send
public void send(Buffer buf,
int dest,
int tag,
boolean pt2pt)
throws MPJDevException
- Throws:
MPJDevException
issend
public Request issend(Buffer buf,
int dest,
int tag,
boolean pt2pt)
throws MPJDevException
- Throws:
MPJDevException
ssend
public void ssend(Buffer buf,
int dest,
int tag,
boolean pt2pt)
throws MPJDevException
- Throws:
MPJDevException
size
public int size()
id
public int id()
free
public void free()
throws MPJDevException
- Throws:
MPJDevException
split
public Comm split(int color,
int key)
throws MPJDevException
- Throws:
MPJDevException