mpiserialdc.hh

Go to the documentation of this file.

#ifndef __RVL_MPI_SERDC
#define __RVL_MPI_SERDC

#define FRUITCAKE

#include "mpiserialfo.hh"
#include "data.hh"

namespace RVL {

  class MPISerialDCF;

  class MPISerialDC: public DataContainer {
    
    friend class MPISerialDCF;

  private:
    
    MPISerialDC();
    MPISerialDC(MPISerialDC const &);

  protected:

    int rk;

    DataContainer * mydc;

  public:

    MPISerialDC(DataContainerFactory const & F):  rk(0), mydc(NULL) {
      /* set rank - all processes*/
#ifdef IWAVE_USE_MPI
      MPI_Comm_rank(MPI_COMM_WORLD,&rk);
#endif
      /* construct internal PC */
      if (rk==0) mydc=F.build();
    }

    ~MPISerialDC() { if (mydc) delete mydc; }

    void eval(FunctionObject & f, 
          std::vector<DataContainer const * > &x);
    
    void eval(FunctionObjectConstEval & f, 
          vector<DataContainer const *> & x) const;

    ostream & write(ostream & str) const;
  };

  class MPISerialDCF: public DataContainerFactory {

  private:

    int rk;

    DataContainerFactory const & f;

    MPISerialDC * buildMPISerialDC() const;

  public:

    MPISerialDCF(DataContainerFactory const & _f)
    : rk(0), f(_f) {
#ifdef IWAVE_USE_MPI
      MPI_Comm_rank(MPI_COMM_WORLD,&rk);
#endif
    }
      
    MPISerialDCF(MPISerialDCF const & fact)
    : rk(0), f(fact.f) {
#ifdef IWAVE_USE_MPI
      MPI_Comm_rank(MPI_COMM_WORLD,&rk);
#endif
    }
    ~MPISerialDCF() {}
    DataContainer * build() const { return buildMPISerialDC(); }
    bool compare(DataContainerFactory const & dcf) const;
    bool isCompatible(DataContainer const & dc) const;
    ostream & write(ostream & str) const;
  };

}

#endif

---