mpjdev
Class Comm

java.lang.Object
  extended by mpjdev.Comm

public class Comm
extends java.lang.Object


Field Summary
 Group group
           
 Group localgroup
           
 int recvctxt
           
 int sendctxt
           
 
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
 

Field Detail

sendctxt

public int sendctxt

recvctxt

public int recvctxt

group

public Group group

localgroup

public Group localgroup
Method Detail

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