tools::mpi::hmpi Class Reference

Inheritance diagram for tools::mpi::hmpi:

Collaboration diagram for tools::mpi::hmpi:

Public Member Functions
virtual bool	pack (const tools::histo::h1d &a_h)
virtual bool	pack (const tools::histo::h2d &a_h)
virtual bool	pack (const tools::histo::h3d &a_h)
virtual bool	pack (const tools::histo::p1d &a_h)
virtual bool	pack (const tools::histo::p2d &a_h)
virtual bool	beg_send (unsigned int a_nhist)
virtual bool	send (int a_dest)
virtual bool	wait_histos (int a_src, std::vector< std::pair< std::string, void * > > &a_hists)
virtual int	rank () const
virtual bool	comm_rank (int &a_rank) const
virtual bool	comm_size (int &a_size) const
	hmpi (std::ostream &a_out, int a_rank, int a_tag, const MPI_Comm &a_comm, bool a_verbose=false)
virtual	~hmpi ()

Protected Types
typedef unsigned int	num_t

Protected Member Functions
	hmpi (const hmpi &a_from)
hmpi &	operator= (const hmpi &a_from)

Static Protected Member Functions
static const std::string &	s_class ()

Protected Attributes
std::ostream &	m_out
int	m_rank
int	m_tag
const MPI_Comm &	m_comm
bool	m_verbose
wrmpi	m_wrmpi

Detailed Description

Definition at line 23 of file hmpi.

Member Typedef Documentation

num_t

typedef unsigned int tools::mpi::hmpi::num_t

protected

Definition at line 26 of file hmpi.

Constructor & Destructor Documentation

hmpi() [1/2]

tools::mpi::hmpi::hmpi ( std::ostream &  a_out, int  a_rank, int  a_tag, const MPI_Comm &  a_comm, bool  a_verbose = false  )

inline

Definition at line 218 of file hmpi.

  :m_out(a_out)
  ,m_rank(a_rank)
  ,m_tag(a_tag)
  ,m_comm(a_comm)
  ,m_verbose(a_verbose)
  ,m_wrmpi(a_out,a_comm)
  {
#ifdef TOOLS_MEM
    tools::mem::increment(s_class().c_str());
#endif
  }

~hmpi()

virtual tools::mpi::hmpi::~hmpi ( )

inlinevirtual

Reimplemented from tools::histo::hmpi.

Definition at line 230 of file hmpi.

                 {
#ifdef TOOLS_MEM
    tools::mem::decrement(s_class().c_str());
#endif
  }

hmpi() [2/2]

tools::mpi::hmpi::hmpi ( const hmpi &  a_from )

inlineprotected

Definition at line 236 of file hmpi.

  :parent(a_from)
  ,m_out(a_from.m_out)
  ,m_rank(a_from.m_rank)
  ,m_tag(a_from.m_tag)
  ,m_comm(a_from.m_comm)
  ,m_verbose(a_from.m_verbose)
  ,m_wrmpi(a_from.m_out,a_from.m_comm)
  {
#ifdef TOOLS_MEM
    tools::mem::increment(s_class().c_str());
#endif
  }

Member Function Documentation

beg_send()

virtual bool tools::mpi::hmpi::beg_send ( unsigned int  a_nhist )

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 58 of file hmpi.

                                              {
    m_wrmpi.pack_reset();
    return m_wrmpi.pack(a_nhist);
  }

comm_rank()

virtual bool tools::mpi::hmpi::comm_rank ( int &  a_rank ) const

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 209 of file hmpi.

                                            {
    if(::MPI_Comm_rank(m_comm,&a_rank)!=MPI_SUCCESS) {a_rank=-1;return false;}
    return true;
  }

comm_size()

virtual bool tools::mpi::hmpi::comm_size ( int &  a_size ) const

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 213 of file hmpi.

                                            {
    if(::MPI_Comm_size(m_comm,&a_size)!=MPI_SUCCESS) {a_size=0;return false;}
    return true;
  }

operator=()

hmpi& tools::mpi::hmpi::operator= ( const hmpi &  a_from )

inlineprotected

Definition at line 249 of file hmpi.

                                     {
    m_rank = a_from.m_rank;
    m_tag = a_from.m_tag;
    m_verbose = a_from.m_verbose;
    return *this;
  }

pack() [1/5]

virtual bool tools::mpi::hmpi::pack ( const tools::histo::h1d &  a_h )

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 32 of file hmpi.

                                              {
    if(!m_wrmpi.spack(a_h.s_cls())) return false;
    if(!histo_data_duiuid_pack(m_wrmpi,a_h.dac())) return false;
    return true;
  }

pack() [2/5]

virtual bool tools::mpi::hmpi::pack ( const tools::histo::h2d &  a_h )

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 37 of file hmpi.

                                              {
    if(!m_wrmpi.spack(a_h.s_cls())) return false;
    if(!histo_data_duiuid_pack(m_wrmpi,a_h.dac())) return false;
    return true;
  }

pack() [3/5]

virtual bool tools::mpi::hmpi::pack ( const tools::histo::h3d &  a_h )

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 42 of file hmpi.

                                              {
    if(!m_wrmpi.spack(a_h.s_cls())) return false;
    if(!histo_data_duiuid_pack(m_wrmpi,a_h.dac())) return false;
    return true;
  }

pack() [4/5]

virtual bool tools::mpi::hmpi::pack ( const tools::histo::p1d &  a_h )

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 47 of file hmpi.

                                              {
    if(!m_wrmpi.spack(a_h.s_cls())) return false;
    if(!profile_data_duiuidd_pack(m_wrmpi,a_h.get_histo_data())) return false;
    return true;
  }

pack() [5/5]

virtual bool tools::mpi::hmpi::pack ( const tools::histo::p2d &  a_h )

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 52 of file hmpi.

                                              {
    if(!m_wrmpi.spack(a_h.s_cls())) return false;
    if(!profile_data_duiuidd_pack(m_wrmpi,a_h.get_histo_data())) return false;
    return true;
  }

rank()

virtual int tools::mpi::hmpi::rank ( ) const

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 208 of file hmpi.

{ return m_rank;}

s_class()

static const std::string& tools::mpi::hmpi::s_class ( )

inlinestaticprotected

Definition at line 27 of file hmpi.

                                    {
    static const std::string s_v("tools::mpi::hmpi");
    return s_v;
  }

send()

virtual bool tools::mpi::hmpi::send ( int  a_dest )

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 62 of file hmpi.

                                {
    if(::MPI_Send(m_wrmpi.buffer(),m_wrmpi.ipos(),MPI_CHAR,a_dest,m_tag,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::hmpi::send : rank " << m_rank << " : MPI_Send failed." << std::endl;
      return false;
    }
    m_wrmpi.pack_reset();
    return true;
  }

wait_histos()

virtual bool tools::mpi::hmpi::wait_histos ( int  a_src, std::vector< std::pair< std::string, void * > > &  a_hists  )

inlinevirtual

Implements tools::histo::hmpi.

Definition at line 71 of file hmpi.

                                                                                     {
    a_hists.clear();
 
    typedef std::pair<std::string,void*> class_pointer;
 
    MPI_Status status;
    if(::MPI_Probe(a_src,m_tag,m_comm,&status)!=MPI_SUCCESS) {
      m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank << " : MPI_Probe : failed." << std::endl;
      return false;
    }
 
    int buffer_size = 0;
    if(::MPI_Get_count(&status,MPI_CHAR,&buffer_size)!=MPI_SUCCESS) {
      m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank << " : MPI_Get_count : failed." << std::endl;
      return false;
    }
 
    if(!buffer_size) {
      m_out << "exlb::mpi::wait_histos : MPI_Get_count returns zero data." << std::endl;
      return false;
    }
 
    if(m_verbose) m_out << "rank " << m_rank << " : get_count " << buffer_size << std::endl;
 
    char* buffer = new char[buffer_size];
    if(!buffer) {
      m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank << " : can't alloc buffer of size " << buffer_size << std::endl;
      return false;
    }
 
    if(::MPI_Recv(buffer,buffer_size,MPI_CHAR,a_src,m_tag,m_comm,&status)!=MPI_SUCCESS) {
      m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank << " : MPI_Recv : failed." << std::endl;
      delete [] buffer;
      return false;
    }
 
    if(m_verbose) m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank << " : unpack data ..." << std::endl;
 
    wrmpi _mpi(m_out,m_comm,buffer_size,buffer); //give ownership of buffer to _mpi.
 
    num_t nhist;
    if(!_mpi.unpack(nhist)) return false;
 
    if(m_verbose)
      m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank << " : number of histos to unpack " << nhist << std::endl;
 
   {for(num_t ihist=0;ihist<nhist;ihist++) {
 
      std::string scls;
      if(!_mpi.sunpack(scls)) return false;
 
      if(scls==tools::histo::h1d::s_class()) {
        tools::histo::histo_data<double,unsigned int,unsigned int,double> hdata;
        if(!histo_data_duiuid_unpack(_mpi,hdata)) return false;
        tools::histo::h1d* h = new tools::histo::h1d("",10,0,1);
        h->copy_from_data(hdata);
        if(m_verbose) {
          m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank
                << " : got a " << scls
                << ", title " << h->title()
                << ", mean_x " << h->mean() << ", rms " << h->rms()
                << std::endl;
        }
        a_hists.push_back(class_pointer(h->s_cls(),h)); //give ownership of h.
 
      } else if(scls==tools::histo::h2d::s_class()) {
        tools::histo::histo_data<double,unsigned int,unsigned int,double> hdata;
        if(!histo_data_duiuid_unpack(_mpi,hdata)) return false;
        tools::histo::h2d* h = new tools::histo::h2d("",10,0,1,10,0,1);
        h->copy_from_data(hdata);
        if(m_verbose) {
          m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank
                << " : got a " << scls
                << ", title " << h->title()
                << ", mean_x " << h->mean_x() << ", rms_x " << h->rms_x()
                << ", mean_y " << h->mean_y() << ", rms_y " << h->rms_y()
                << std::endl;
        }
        a_hists.push_back(class_pointer(h->s_cls(),h)); //give ownership of h.
 
      } else if(scls==tools::histo::h3d::s_class()) {
        tools::histo::histo_data<double,unsigned int,unsigned int,double> hdata;
        if(!histo_data_duiuid_unpack(_mpi,hdata)) return false;
        tools::histo::h3d* h = new tools::histo::h3d("",10,0,1,10,0,1,10,0,1);
        h->copy_from_data(hdata);
        if(m_verbose) {
          m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank
                << " : got a " << scls
                << ", title " << h->title()
                << ", mean_x " << h->mean_x() << ", rms_x " << h->rms_x()
                << ", mean_y " << h->mean_y() << ", rms_y " << h->rms_y()
                << ", mean_z " << h->mean_z() << ", rms_z " << h->rms_z()
                << std::endl;
        }
        a_hists.push_back(class_pointer(h->s_cls(),h)); //give ownership of h.
 
      } else if(scls==tools::histo::p1d::s_class()) {
        tools::histo::profile_data<double,unsigned int,unsigned int,double,double> pdata;
        if(!profile_data_duiuidd_unpack(_mpi,pdata)) return false;
        tools::histo::p1d* h = new tools::histo::p1d("",10,0,1);
        h->copy_from_data(pdata);
        if(m_verbose) {
          m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank
                << " : got a " << scls
                << ", title " << h->title()
                << ", mean_x " << h->mean() << ", rms " << h->rms()
                << std::endl;
        }
        a_hists.push_back(class_pointer(h->s_cls(),h)); //give ownership of h.
 
      } else if(scls==tools::histo::p2d::s_class()) {
        tools::histo::profile_data<double,unsigned int,unsigned int,double,double> pdata;
        if(!profile_data_duiuidd_unpack(_mpi,pdata)) return false;
        tools::histo::p2d* h = new tools::histo::p2d("",10,0,1,10,0,1);
        h->copy_from_data(pdata);
        if(m_verbose) {
          m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank
                << " : got a " << scls
                << ", title " << h->title()
                << ", mean_x " << h->mean_x() << ", rms_x " << h->rms_x()
                << ", mean_y " << h->mean_y() << ", rms_y " << h->rms_y()
                << std::endl;
        }
        a_hists.push_back(class_pointer(h->s_cls(),h)); //give ownership of h.
 
      } else {
        m_out << "tools::mpi::hmpi::wait_histos : rank " << m_rank
              << " : got not treated class " << scls
              << std::endl;
      }
 
    }} //ihist
 
    return true;
  }

Member Data Documentation

m_comm

const MPI_Comm& tools::mpi::hmpi::m_comm

protected

Definition at line 259 of file hmpi.

m_out

std::ostream& tools::mpi::hmpi::m_out

protected

Definition at line 256 of file hmpi.

m_rank

int tools::mpi::hmpi::m_rank

protected

Definition at line 257 of file hmpi.

m_tag

int tools::mpi::hmpi::m_tag

protected

Definition at line 258 of file hmpi.

m_verbose

bool tools::mpi::hmpi::m_verbose

protected

Definition at line 260 of file hmpi.

m_wrmpi

wrmpi tools::mpi::hmpi::m_wrmpi

protected

Definition at line 261 of file hmpi.

---

The documentation for this class was generated from the following file:

• /Users/barrand/private/dev/softinex/g4tools/g4tools/tools/mpi/hmpi