Home Research Papers Posters Manuals Talks Download People Help Internal

ck-com/EachToManyMulticastStrategy.h

Go to the documentation of this file.

#ifndef EACH_TO_MANY_MULTICAST_STRATEGY
#define EACH_TO_MANY_MULTICAST_STRATEGY

#include "ComlibManager.h"
#include "routerstrategy.h"

class EachToManyMulticastStrategy : public RouterStrategy, public CharmStrategy {
 protected:
 
    virtual void commonInit(int*);

 public:
    EachToManyMulticastStrategy(int strategyId, CkGroupID src, CkGroupID dest, 
                int nsrcpes=0, int *srcpelist=0, 
                int ndestpes =0, int *destpelist =0);

    EachToManyMulticastStrategy(int substrategy, CkArrayID src, 
                                CkArrayID dest, int nsrc=0, 
                                CkArrayIndex *srcelements=0, int ndest=0, 
                                CkArrayIndex *destelements=0);
    
    EachToManyMulticastStrategy(CkMigrateMessage *m) : RouterStrategy(m), CharmStrategy(m) {
      ComlibPrintf("[%d] EachToManyMulticast migration constructor\n",CkMyPe());
    };
    
    ~EachToManyMulticastStrategy();

    void insertMessage(MessageHolder *msg) {
      //      ((CharmMessageHolder*)msg) -> checkme();
      insertMessage((CharmMessageHolder*)msg);
    }

    //Basic function, subclasses should not have to change it
    virtual void insertMessage(CharmMessageHolder *msg);

    virtual void pup(PUP::er &p);    
    virtual void localMulticast(void *msg);

    virtual void notifyDone();

    virtual void deliver(char *, int);

    virtual void handleMessage(void *msg) {
      envelope *env = (envelope*)msg;
      
      deliver((char*)msg, env->getTotalsize());
    }
    
    PUPable_decl(EachToManyMulticastStrategy);

};
#endif

---