Home Research Papers Posters Manuals Talks Download People Help Internal

ck-com/OneTimeMulticastStrategy.h

Go to the documentation of this file.

#ifndef ONE_TIME_MULTICAST_STRATEGY
#define ONE_TIME_MULTICAST_STRATEGY

#include "ComlibManager.h"
#include "ComlibSectionInfo.h"

class OneTimeMulticastStrategy: public Strategy, public CharmStrategy {
 private:
  
  ComlibSectionInfo sinfo; // This is used to create the multicast messages themselves

  void remoteMulticast(ComlibMulticastMsg * multMsg, bool rootPE);
  void localMulticast(CharmMessageHolder *cmsg);
  
 public:

  virtual void determineNextHopPEs(const int totalDestPEs, const ComlibMulticastIndexCount* destPEs, const int myIndex, const int rootPE , int * &pelist, int &npes);

    OneTimeMulticastStrategy(CkMigrateMessage *m): Strategy(m), CharmStrategy(m){}
  
  OneTimeMulticastStrategy();
  ~OneTimeMulticastStrategy();
  
  void insertMessage(MessageHolder *msg) {insertMessage((CharmMessageHolder*)msg);}
  void insertMessage(CharmMessageHolder *msg);
  
  void handleMessage(void *msg);    

  void pup(PUP::er &p);

  PUPable_decl(OneTimeMulticastStrategy);

};





class OneTimeRingMulticastStrategy: public OneTimeMulticastStrategy {
  
 public:
  void determineNextHopPEs(const int totalDestPEs, const ComlibMulticastIndexCount* destPEs, const int myIndex, const int rootPE , int * &pelist, int &npes);

 OneTimeRingMulticastStrategy(CkMigrateMessage *m): OneTimeMulticastStrategy(m) {}
 OneTimeRingMulticastStrategy(): OneTimeMulticastStrategy() {}
  ~OneTimeRingMulticastStrategy() {}
  
  void pup(PUP::er &p){ OneTimeMulticastStrategy::pup(p); }
  
  PUPable_decl(OneTimeRingMulticastStrategy);

};



class OneTimeTreeMulticastStrategy: public OneTimeMulticastStrategy {
 private:
  int degree;
  
 public:
  
  void determineNextHopPEs(const int totalDestPEs, const ComlibMulticastIndexCount* destPEs, const int myIndex, const int rootPE, int * &pelist, int &npes);
  
 OneTimeTreeMulticastStrategy(CkMigrateMessage *m): OneTimeMulticastStrategy(m) {}

 OneTimeTreeMulticastStrategy(int treeDegree=4): OneTimeMulticastStrategy(), degree(treeDegree) {}

  ~OneTimeTreeMulticastStrategy() {}
  
  void pup(PUP::er &p){ 
    OneTimeMulticastStrategy::pup(p); 
    p | degree;
  }
  
  PUPable_decl(OneTimeTreeMulticastStrategy);
};



class OneTimeTopoTreeMulticastStrategy: public OneTimeMulticastStrategy 
{
    private:
        int degree;
        
    public:
        OneTimeTopoTreeMulticastStrategy(CkMigrateMessage *m): OneTimeMulticastStrategy(m) {}
        OneTimeTopoTreeMulticastStrategy(int treeDegree=4): OneTimeMulticastStrategy(), degree(treeDegree) { }
        ~OneTimeTopoTreeMulticastStrategy() {}
        void determineNextHopPEs(const int totalDestPEs, const ComlibMulticastIndexCount* destPEs, const int myIndex, const int rootPE, int * &pelist, int &npes);
        void pup(PUP::er &p)
        { 
            OneTimeMulticastStrategy::pup(p);
            p | degree;
        }
        PUPable_decl(OneTimeTopoTreeMulticastStrategy);
};



class OneTimeDimensionOrderedMulticastStrategy: public OneTimeMulticastStrategy {
 public:
  
  void determineNextHopPEs(const int totalDestPEs, const ComlibMulticastIndexCount* destPEs, const int myIndex, const int rootPE, int * &pelist, int &npes);
  
 OneTimeDimensionOrderedMulticastStrategy(CkMigrateMessage *m): OneTimeMulticastStrategy(m) {}

 OneTimeDimensionOrderedMulticastStrategy(): OneTimeMulticastStrategy() {}

  ~OneTimeDimensionOrderedMulticastStrategy() {}
  
  void pup(PUP::er &p){ 
    OneTimeMulticastStrategy::pup(p); 
  }
  
  PUPable_decl(OneTimeDimensionOrderedMulticastStrategy);
 private:
  int findMinMaxArray(int min, int len, int *array, bool* notincluded, int notIndex);
};




class OneTimeNodeTreeMulticastStrategy: public OneTimeMulticastStrategy {
 private:
  int degree;
  
 public:
  
  void determineNextHopPEs(const int totalDestPEs, const ComlibMulticastIndexCount* destPEs, const int myIndex, const int rootPE, int * &pelist, int &npes);
  
 OneTimeNodeTreeMulticastStrategy(CkMigrateMessage *m): OneTimeMulticastStrategy(m) {}
  
 OneTimeNodeTreeMulticastStrategy(int treeDegree=4): OneTimeMulticastStrategy(), degree(treeDegree) {}
  
  ~OneTimeNodeTreeMulticastStrategy() {}
  
  void pup(PUP::er &p){ 
    OneTimeMulticastStrategy::pup(p); 
    p | degree;
  }
  
  PUPable_decl(OneTimeNodeTreeMulticastStrategy);
};



class OneTimeNodeTreeRingMulticastStrategy: public OneTimeMulticastStrategy {
 private:
  int degree;
  
 public:
  
  void determineNextHopPEs(const int totalDestPEs, const ComlibMulticastIndexCount* destPEs, const int myIndex, const int rootPE, int * &pelist, int &npes);
  
 OneTimeNodeTreeRingMulticastStrategy(CkMigrateMessage *m): OneTimeMulticastStrategy(m) {}
  
 OneTimeNodeTreeRingMulticastStrategy(int treeDegree=4): OneTimeMulticastStrategy(), degree(treeDegree) {}
  
  ~OneTimeNodeTreeRingMulticastStrategy() {}
  
  void pup(PUP::er &p){ 
    OneTimeMulticastStrategy::pup(p); 
    p | degree;
  }
  
  PUPable_decl(OneTimeNodeTreeRingMulticastStrategy);
};

#endif

---