Home Research Papers Posters Manuals Talks Download People Help Wiki Internal

conv-com/routerstrategy.h

Go to the documentation of this file.

/* Class that calls Krishnan's routers from the new Comlib.
   Developed to be called from Converse
   Sameer Kumar 05/14/04
*/
   

#ifndef ROUTER_STRATEGY
#define ROUTER_STRATEGY

#include "convcomlibmanager.h"

#include "gridrouter.h"
#include "graphrouter.h"
#include "de.h"
#include "treerouter.h"
#include "3dgridrouter.h"
#include "prefixrouter.h"

class RouterStrategy : public Strategy {

    Router * router;
    CkQ<MessageHolder *> msgQ;
    CkQ<char *> recvQ, procQ;
    CkQ<DummyMsg *> dummyQ;

    comID id;
    int *pelist;
    int npes;
    int *procMap;
    int *bcast_pemap;
    int myPe;
    int routerID;

    int doneHandle;    //Array strategy done handle
    int myDoneHandle;   //my own done handle, which will inturn call
                       //array strategy done handle
 
   int doneFlag, bufferedDoneInserting;

    void setReverseMap();

 public:
    //constructor
    //stratid = which topology to use ? (Mesh?, Grid?, Hypercube ?)
    //npes = number of processors in the all to all operation
    //pelist = list of processors
    RouterStrategy(int stratid, int handle, int npes, int *pelist);
    RouterStrategy(CkMigrateMessage *m): Strategy(m){}
    
    ~RouterStrategy();

    //Insert messages
    void insertMessage(MessageHolder *msg);
    //Finished inserting
    void doneInserting();

    //Call Krishnan's router functions
    void RecvManyMsg(char *msg);
    void ProcManyMsg(char *msg);
    void DummyEP(DummyMsg *m);
    
    void Done(DummyMsg *m);

    int * getProcMap() {return procMap;}

    virtual void pup(PUP::er &p);
    PUPable_decl(RouterStrategy);
};


//Call the router functions
inline void RouterStrategy::RecvManyMsg(char *msg) {

    //comID new_id;
    int new_refno =0;

    //FOO BAR when structure of comid changes this will break !!!!!
    ComlibPrintf("In RecvManyMsg at %d\n", CkMyPe());
    //memcpy(&new_id,(msg+CmiReservedHeaderSize+sizeof(int)), sizeof(comID));
    //ComlibPrintf("REFNO = %d, %d\n", new_id.refno, id.refno);
    
    //First int in comid is refno
    memcpy(&new_refno, (char*) msg + CmiReservedHeaderSize + sizeof(int), 
           sizeof(int)); 

    if(new_refno != id.refno)
        recvQ.push(msg);
    else
        router->RecvManyMsg(id, msg);
}

inline void RouterStrategy::ProcManyMsg(char *msg) {    

    //comID new_id;
    int new_refno =0;
    ComlibPrintf("In ProcManyMsg at %d\n", CkMyPe());
    //memcpy(&new_id,(msg+CmiReservedHeaderSize+sizeof(int)), sizeof(comID));
    //First int in comid is refno
    memcpy(&new_refno, (char*) msg + CmiReservedHeaderSize + sizeof(int), 
           sizeof(int)); 
    
    if(new_refno != id.refno)
        procQ.push(msg);
    else
        router->ProcManyMsg(id, msg);
}

inline void RouterStrategy::DummyEP(DummyMsg *m) {

    if(id.refno != m->id.refno)
        dummyQ.push(m);
    else {
        router->DummyEP(m->id, m->magic);
        CmiFree(m);
    }
}

#endif

---