tools::mpi::wrmpi Class Reference

Inheritance diagram for tools::mpi::wrmpi:

Collaboration diagram for tools::mpi::wrmpi:

Public Types
typedef unsigned int	num_t

Public Member Functions
virtual bool	pack (char a_val)
virtual bool	pack (short a_val)
virtual bool	pack (int a_val)
virtual bool	pack (unsigned int a_val)
virtual bool	pack (tools::uint64 a_val)
virtual bool	pack (tools::int64 a_val)
virtual bool	pack (float a_val)
virtual bool	pack (double a_val)
virtual bool	bpack (bool a_val)
virtual bool	spack (const std::string &a_s)
virtual bool	vpack (const std::vector< unsigned int > &a_v)
virtual bool	vpack (const std::vector< int > &a_v)
virtual bool	vpack (const std::vector< double > &a_v)
virtual bool	pack (tools::uint32 a_size, const char *a_buffer)
virtual bool	pack (tools::uint32 a_size, const int *a_buffer)
virtual bool	unpack (char &a_val)
virtual bool	unpack (short &a_val)
virtual bool	unpack (int &a_val)
virtual bool	unpack (unsigned int &a_val)
virtual bool	unpack (tools::uint64 &a_val)
virtual bool	unpack (tools::int64 &a_val)
virtual bool	unpack (float &a_val)
virtual bool	unpack (double &a_val)
virtual bool	bunpack (bool &a_val)
virtual bool	vunpack (std::vector< unsigned int > &a_v)
virtual bool	vunpack (std::vector< int > &a_v)
virtual bool	vunpack (std::vector< double > &a_v)
virtual bool	sunpack (std::string &a_s)
virtual bool	unpack (tools::uint32 &a_size, char *&a_buffer)
virtual bool	unpack (tools::uint32 &a_size, int *&a_buffer)
virtual void	pack_reset ()
virtual bool	send_buffer (int a_dest, int a_tag)
virtual bool	wait_buffer (int a_rank, int a_src, int a_tag, int &a_probe_src, bool a_verbose=false)
virtual bool	wait_buffer (int a_rank, int a_tag, int &a_probe_src, bool a_verbose=false)
	wrmpi (std::ostream &a_out, const MPI_Comm &a_comm, tools::uint32 a_size=128)
	wrmpi (std::ostream &a_out, const MPI_Comm &a_comm, tools::uint32 a_size, char *a_buffer)
virtual	~wrmpi ()
int	ipos () const
const char *	buffer () const
Public Member Functions inherited from tools::impi
virtual	~impi ()

Protected Member Functions
	wrmpi (const wrmpi &a_from)
wrmpi &	operator= (const wrmpi &)
bool	expand2 (tools::uint32 a_new_size)
bool	expand (tools::uint32 a_new_size)

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

Protected Attributes
std::ostream &	m_out
const MPI_Comm &	m_comm
tools::uint32	m_size
char *	m_buffer
char *	m_max
char *	m_pos
int	m_ipos

Detailed Description

Definition at line 41 of file wrmpi.

Member Typedef Documentation

num_t

typedef unsigned int tools::mpi::wrmpi::num_t

Definition at line 44 of file wrmpi.

Constructor & Destructor Documentation

wrmpi() [1/3]

tools::mpi::wrmpi::wrmpi ( std::ostream &  a_out, const MPI_Comm &  a_comm, tools::uint32  a_size = 128  )

inline

Definition at line 423 of file wrmpi.

  :m_out(a_out)
  ,m_comm(a_comm)
  ,m_size(0)
  ,m_buffer(0)
  ,m_max(0)
  ,m_pos(0)
  ,m_ipos(0)
  {
#ifdef TOOLS_MEM
    tools::mem::increment(s_class().c_str());
#endif
    m_size = a_size;
    m_buffer = new char[m_size];
    //if(!m_buffer) {}
    m_max = m_buffer+m_size;
    m_pos = m_buffer;
  }

wrmpi() [2/3]

tools::mpi::wrmpi::wrmpi ( std::ostream &  a_out, const MPI_Comm &  a_comm, tools::uint32  a_size, char *  a_buffer  )

inline

Definition at line 441 of file wrmpi.

  :m_out(a_out)
  ,m_comm(a_comm)
  ,m_size(a_size)
  ,m_buffer(a_buffer)
  ,m_max(0)
  ,m_pos(0)
  ,m_ipos(0)
  {
#ifdef TOOLS_MEM
    tools::mem::increment(s_class().c_str());
#endif
    m_max = m_buffer+m_size;
    m_pos = m_buffer;
  }

~wrmpi()

virtual tools::mpi::wrmpi::~wrmpi ( )

inlinevirtual

Definition at line 456 of file wrmpi.

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

wrmpi() [3/3]

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

inlineprotected

Definition at line 463 of file wrmpi.

  :parent(a_from)
  ,m_out(a_from.m_out)
  ,m_comm(a_from.m_comm)
  ,m_size(0)
  ,m_buffer(0)
  ,m_max(0)
  ,m_pos(0)
  ,m_ipos(0)
  {
#ifdef TOOLS_MEM
    tools::mem::increment(s_class().c_str());
#endif
  }

Member Function Documentation

bpack()

virtual bool tools::mpi::wrmpi::bpack ( bool  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 131 of file wrmpi.

                                 {
    tools::uint32 sz = tools::uint32(sizeof(unsigned char));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    unsigned char val = a_val?1:0;
    if(::MPI_Pack(&val,1,MPI_UNSIGNED_CHAR,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(bool) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

buffer()

const char* tools::mpi::wrmpi::buffer ( ) const

inline

Definition at line 483 of file wrmpi.

{return m_buffer;}

bunpack()

virtual bool tools::mpi::wrmpi::bunpack ( bool &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 299 of file wrmpi.

                                    {
    typedef unsigned char bool_t;
    bool_t val;
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&val,1,MPI_UNSIGNED_CHAR,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(bool) failed." << std::endl;
      a_val = false;
      return false;
    }
    a_val = val==1?true:false;
    return true;
  }

expand()

bool tools::mpi::wrmpi::expand ( tools::uint32  a_new_size )

inlineprotected

Definition at line 489 of file wrmpi.

                                      {
    tools::diff_pointer_t len = m_pos-m_buffer;
    if(!tools::realloc<char>(m_buffer,a_new_size,m_size)) {
      m_out << "tools::mpi::wrmpi::expand :"
            << " can't realloc " << a_new_size << " bytes."
            << std::endl;
      m_size = 0;
      m_max = 0;
      m_pos = 0;
      //m_wb.set_eob(m_max);
      return false;
    }
    m_size = a_new_size;
    m_max = m_buffer + m_size;
    m_pos = m_buffer + len;
    return true;
  }

expand2()

bool tools::mpi::wrmpi::expand2 ( tools::uint32  a_new_size )

inlineprotected

Definition at line 487 of file wrmpi.

{return expand(tools::mx<tools::uint32>(2*m_size,a_new_size));} //CERN-ROOT logic.

ipos()

int tools::mpi::wrmpi::ipos ( ) const

inline

Definition at line 479 of file wrmpi.

{return m_ipos;}

operator=()

wrmpi& tools::mpi::wrmpi::operator= ( const wrmpi &  )

inlineprotected

Definition at line 477 of file wrmpi.

{return *this;}

pack() [1/10]

virtual bool tools::mpi::wrmpi::pack ( char  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 51 of file wrmpi.

                                {
    tools::uint32 sz = tools::uint32(sizeof(char));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    if(::MPI_Pack(&a_val,1,MPI_CHAR,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(char) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [2/10]

virtual bool tools::mpi::wrmpi::pack ( double  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 121 of file wrmpi.

                                  {
    tools::uint32 sz = tools::uint32(sizeof(double));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    if(::MPI_Pack(&a_val,1,MPI_DOUBLE,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(double) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [3/10]

virtual bool tools::mpi::wrmpi::pack ( float  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 111 of file wrmpi.

                                 {
    tools::uint32 sz = tools::uint32(sizeof(float));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    if(::MPI_Pack(&a_val,1,MPI_FLOAT,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(float) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [4/10]

virtual bool tools::mpi::wrmpi::pack ( int  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 71 of file wrmpi.

                               {
    tools::uint32 sz = tools::uint32(sizeof(int));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    if(::MPI_Pack(&a_val,1,MPI_INT,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(int) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [5/10]

virtual bool tools::mpi::wrmpi::pack ( short  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 61 of file wrmpi.

                                 {
    tools::uint32 sz = tools::uint32(sizeof(short));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    if(::MPI_Pack(&a_val,1,MPI_SHORT,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(short) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [6/10]

virtual bool tools::mpi::wrmpi::pack ( tools::int64  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 101 of file wrmpi.

                                      {
    tools::uint32 sz = tools::uint32(sizeof(tools::int64));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    if(::MPI_Pack(&a_val,1,TOOLS_MPI_INT64,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(int64) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [7/10]

virtual bool tools::mpi::wrmpi::pack ( tools::uint32  a_size, const char *  a_buffer  )

inlinevirtual

Implements tools::impi.

Definition at line 203 of file wrmpi.

                                                             {
    if(!pack((num_t)a_size)) return false;
    tools::uint32 sz = (tools::uint32)(a_size*sizeof(char));
    if((m_pos+sz)>m_max) {if(!expand2(m_size+sz)) return false;}
#ifdef TOOLS_USE_MPI_PACK_NOT_CONST
    if(::MPI_Pack(const_cast<char*>(a_buffer),a_size,MPI_CHAR,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#else
    if(::MPI_Pack(a_buffer,a_size,MPI_CHAR,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#endif
      m_out << "tools::mpi::wrmpi : MPI_Pack(char*) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [8/10]

virtual bool tools::mpi::wrmpi::pack ( tools::uint32  a_size, const int *  a_buffer  )

inlinevirtual

Implements tools::impi.

Definition at line 219 of file wrmpi.

                                                            {
    if(!pack((num_t)a_size)) return false;
    tools::uint32 sz = (tools::uint32)(a_size*sizeof(int));
    if((m_pos+sz)>m_max) {if(!expand2(m_size+sz)) return false;}
#ifdef TOOLS_USE_MPI_PACK_NOT_CONST
    if(::MPI_Pack(const_cast<int*>(a_buffer),a_size,MPI_INT,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#else
    if(::MPI_Pack(a_buffer,a_size,MPI_INT,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#endif
      m_out << "tools::mpi::wrmpi : MPI_Pack(int*) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [9/10]

virtual bool tools::mpi::wrmpi::pack ( tools::uint64  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 91 of file wrmpi.

                                       {
    tools::uint32 sz = tools::uint32(sizeof(tools::uint64));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    if(::MPI_Pack(&a_val,1,TOOLS_MPI_UINT64,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(uint64) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack() [10/10]

virtual bool tools::mpi::wrmpi::pack ( unsigned int  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 81 of file wrmpi.

                                        {
    tools::uint32 sz = tools::uint32(sizeof(unsigned int));
    if(m_pos+sz>m_max) {if(!expand2(m_size+sz)) return false;}
    if(::MPI_Pack(&a_val,1,MPI_UNSIGNED,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Pack(unsigned int) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

pack_reset()

virtual void tools::mpi::wrmpi::pack_reset ( )

inlinevirtual

Implements tools::impi.

Definition at line 383 of file wrmpi.

                            {
    delete [] m_buffer;
    m_size = 128;
    m_buffer = new char[m_size];
    //if(!m_buffer) {}
    m_max = m_buffer+m_size;
    m_pos = m_buffer;
    m_ipos = 0; //IMPORTANT
  }

s_class()

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

inlinestaticprotected

Definition at line 46 of file wrmpi.

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

send_buffer()

virtual bool tools::mpi::wrmpi::send_buffer ( int  a_dest, int  a_tag  )

inlinevirtual

Implements tools::impi.

Definition at line 393 of file wrmpi.

                                                 { // used in tools/mpi/pntuple.
    if(::MPI_Send(m_buffer,m_ipos,MPI_CHAR,a_dest,a_tag,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi::send_buffer : MPI_Send() failed for rank destination " << a_dest << "." << std::endl;
      return false;
    }
    return true;
  }

spack()

virtual bool tools::mpi::wrmpi::spack ( const std::string &  a_s )

inlinevirtual

Implements tools::impi.

Definition at line 142 of file wrmpi.

                                           {
    if(!pack((num_t)a_s.size())) return false;
    tools::uint32 sz = (tools::uint32)a_s.size();
    if((m_pos+sz)>m_max) {if(!expand2(m_size+sz)) return false;}
#ifdef TOOLS_USE_MPI_PACK_NOT_CONST
    if(::MPI_Pack(const_cast<char*>(a_s.c_str()),a_s.size(),MPI_CHAR,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#else
    if(::MPI_Pack(a_s.c_str(),a_s.size(),MPI_CHAR,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#endif
      m_out << "tools::mpi::wrmpi : MPI_Pack(std::string) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

sunpack()

virtual bool tools::mpi::wrmpi::sunpack ( std::string &  a_s )

inlinevirtual

Implements tools::impi.

Definition at line 343 of file wrmpi.

                                       {
    num_t num;
    if(!unpack(num)) {a_s.clear();return false;}
    a_s.resize(num);
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,const_cast<char*>(a_s.c_str()),a_s.size(),MPI_CHAR,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(std::string) failed." << std::endl;
      a_s.clear();
      return false;
    }
    return true;
  }

unpack() [1/10]

virtual bool tools::mpi::wrmpi::unpack ( char &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 235 of file wrmpi.

                                   {
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&a_val,1,MPI_CHAR,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(char) failed." << std::endl;
      a_val = 0;
      return false;
    }
    return true;
  }

unpack() [2/10]

virtual bool tools::mpi::wrmpi::unpack ( double &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 291 of file wrmpi.

                                     {
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&a_val,1,MPI_DOUBLE,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(double) failed." << std::endl;
      a_val = 0;
      return false;
    }
    return true;
  }

unpack() [3/10]

virtual bool tools::mpi::wrmpi::unpack ( float &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 283 of file wrmpi.

                                    {
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&a_val,1,MPI_FLOAT,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(float) failed." << std::endl;
      a_val = 0;
      return false;
    }
    return true;
  }

unpack() [4/10]

virtual bool tools::mpi::wrmpi::unpack ( int &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 251 of file wrmpi.

                                  {
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&a_val,1,MPI_INT,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(int) failed." << std::endl;
      a_val = 0;
      return false;
    }
    return true;
  }

unpack() [5/10]

virtual bool tools::mpi::wrmpi::unpack ( short &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 243 of file wrmpi.

                                    {
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&a_val,1,MPI_SHORT,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(short) failed." << std::endl;
      a_val = 0;
      return false;
    }
    return true;
  }

unpack() [6/10]

virtual bool tools::mpi::wrmpi::unpack ( tools::int64 &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 275 of file wrmpi.

                                         {
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&a_val,1,TOOLS_MPI_INT64,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(int64) failed." << std::endl;
      a_val = 0;
      return false;
    }
    return true;
  }

unpack() [7/10]

virtual bool tools::mpi::wrmpi::unpack ( tools::uint32 &  a_size, char *&  a_buffer  )

inlinevirtual

Implements tools::impi.

Definition at line 354 of file wrmpi.

                                                           {
    num_t num;
    if(!unpack(num)) {a_size = 0;a_buffer = 0;return false;}
    a_buffer = new char[num];
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,a_buffer,num,MPI_CHAR,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(char*) failed." << std::endl;
      delete [] a_buffer;
      a_size = 0;
      a_buffer = 0;
      return false;
    }
    a_size = num;
    return true;
  }

unpack() [8/10]

virtual bool tools::mpi::wrmpi::unpack ( tools::uint32 &  a_size, int *&  a_buffer  )

inlinevirtual

Implements tools::impi.

Definition at line 368 of file wrmpi.

                                                          {
    num_t num;
    if(!unpack(num)) {a_size = 0;a_buffer = 0;return false;}
    a_buffer = new int[num];
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,a_buffer,num,MPI_INT,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(int*) failed." << std::endl;
      delete [] a_buffer;
      a_size = 0;
      a_buffer = 0;
      return false;
    }
    a_size = num;
    return true;
  }

unpack() [9/10]

virtual bool tools::mpi::wrmpi::unpack ( tools::uint64 &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 267 of file wrmpi.

                                          {
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&a_val,1,TOOLS_MPI_UINT64,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(uint64) failed." << std::endl;
      a_val = 0;
      return false;
    }
    return true;
  }

unpack() [10/10]

virtual bool tools::mpi::wrmpi::unpack ( unsigned int &  a_val )

inlinevirtual

Implements tools::impi.

Definition at line 259 of file wrmpi.

                                           {
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,&a_val,1,MPI_UNSIGNED,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(unsigned int) failed." << std::endl;
      a_val = 0;
      return false;
    }
    return true;
  }

vpack() [1/3]

virtual bool tools::mpi::wrmpi::vpack ( const std::vector< double > &  a_v )

inlinevirtual

Implements tools::impi.

Definition at line 188 of file wrmpi.

                                                   {
    if(!pack((num_t)a_v.size())) return false;
    tools::uint32 sz = (tools::uint32)(a_v.size()*sizeof(double));
    if((m_pos+sz)>m_max) {if(!expand2(m_size+sz)) return false;}
#ifdef TOOLS_USE_MPI_PACK_NOT_CONST
    if(::MPI_Pack(const_cast<double*>(tools::vec_data(a_v)),a_v.size(),MPI_DOUBLE,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#else
    if(::MPI_Pack(tools::vec_data(a_v),a_v.size(),MPI_DOUBLE,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#endif
      m_out << "tools::mpi::wrmpi : MPI_Pack(std::vector<double>) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

vpack() [2/3]

virtual bool tools::mpi::wrmpi::vpack ( const std::vector< int > &  a_v )

inlinevirtual

Implements tools::impi.

Definition at line 173 of file wrmpi.

                                                {
    if(!pack((num_t)a_v.size())) return false;
    tools::uint32 sz = (tools::uint32)(a_v.size()*sizeof(int));
    if((m_pos+sz)>m_max) {if(!expand2(m_size+sz)) return false;}
#ifdef TOOLS_USE_MPI_PACK_NOT_CONST
    if(::MPI_Pack(const_cast<int*>(tools::vec_data(a_v)),a_v.size(),MPI_INT,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#else
    if(::MPI_Pack(tools::vec_data(a_v),a_v.size(),MPI_INT,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#endif
      m_out << "tools::mpi::wrmpi : MPI_Pack(std::vector<int>) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

vpack() [3/3]

virtual bool tools::mpi::wrmpi::vpack ( const std::vector< unsigned int > &  a_v )

inlinevirtual

Implements tools::impi.

Definition at line 157 of file wrmpi.

                                                         {
    if(!pack((num_t)a_v.size())) return false;
    tools::uint32 sz = (tools::uint32)(a_v.size()*sizeof(unsigned int));
    if((m_pos+sz)>m_max) {if(!expand2(m_size+sz)) return false;}
#ifdef TOOLS_USE_MPI_PACK_NOT_CONST
    if(::MPI_Pack(const_cast<unsigned int*>(tools::vec_data(a_v)),a_v.size(),
                  MPI_UNSIGNED,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#else
    if(::MPI_Pack(tools::vec_data(a_v),a_v.size(),MPI_UNSIGNED,m_buffer,m_size,&m_ipos,m_comm)!=MPI_SUCCESS) {
#endif
      m_out << "tools::mpi::wrmpi : MPI_Pack(std::vector<unsigned int>) failed." << std::endl;
      return false;
    }
    m_pos += sz;
    return true;
  }

vunpack() [1/3]

virtual bool tools::mpi::wrmpi::vunpack ( std::vector< double > &  a_v )

inlinevirtual

Implements tools::impi.

Definition at line 332 of file wrmpi.

                                               {
    num_t num;
    if(!unpack(num)) {a_v.clear();return false;}
    a_v.resize(num);
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,tools::vec_data(a_v),a_v.size(),MPI_DOUBLE,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(std::vector<double>) failed." << std::endl;
      a_v.clear();
      return false;
    }
    return true;
  }

vunpack() [2/3]

virtual bool tools::mpi::wrmpi::vunpack ( std::vector< int > &  a_v )

inlinevirtual

Implements tools::impi.

Definition at line 321 of file wrmpi.

                                            {
    num_t num;
    if(!unpack(num)) {a_v.clear();return false;}
    a_v.resize(num);
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,tools::vec_data(a_v),a_v.size(),MPI_INT,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(std::vector<int>) failed." << std::endl;
      a_v.clear();
      return false;
    }
    return true;
  }

vunpack() [3/3]

virtual bool tools::mpi::wrmpi::vunpack ( std::vector< unsigned int > &  a_v )

inlinevirtual

Implements tools::impi.

Definition at line 310 of file wrmpi.

                                                     {
    num_t num;
    if(!unpack(num)) {a_v.clear();return false;}
    a_v.resize(num);
    if(::MPI_Unpack(m_buffer,m_size,&m_ipos,tools::vec_data(a_v),a_v.size(),MPI_UNSIGNED,m_comm)!=MPI_SUCCESS) {
      m_out << "tools::mpi::wrmpi : MPI_Unpack(std::vector<unsigned int>) failed." << std::endl;
      a_v.clear();
      return false;
    }
    return true;
  }

wait_buffer() [1/2]

virtual bool tools::mpi::wrmpi::wait_buffer ( int  a_rank, int  a_src, int  a_tag, int &  a_probe_src, bool  a_verbose = false  )

inlinevirtual

Implements tools::impi.

Definition at line 401 of file wrmpi.

                                                                                                   {
    int buffer_size = 0;
    char* _buffer = 0;
    if (!mpi::wait_buffer(m_out,a_rank,a_src,a_tag,m_comm,buffer_size,_buffer,a_probe_src,a_verbose)) {
      m_out << "tools::mpi::wrmpi::wait_buffer : failed for rank " << a_rank << " and source " << a_src <<"." << std::endl;
      return false;
    }
    // we take ownership of buffer :
    delete [] m_buffer;
    m_size = buffer_size;
    m_buffer = _buffer;
    m_max = m_buffer+m_size;
    m_pos = m_buffer;
    m_ipos = 0; //IMPORTANT
    return true;
  }

wait_buffer() [2/2]

virtual bool tools::mpi::wrmpi::wait_buffer ( int  a_rank, int  a_tag, int &  a_probe_src, bool  a_verbose = false  )

inlinevirtual

Implements tools::impi.

Definition at line 418 of file wrmpi.

                                                                                         {
    return wait_buffer(a_rank,MPI_ANY_SOURCE,a_tag,a_probe_src,a_verbose);
  }

Member Data Documentation

m_buffer

char* tools::mpi::wrmpi::m_buffer

protected

Definition at line 511 of file wrmpi.

m_comm

const MPI_Comm& tools::mpi::wrmpi::m_comm

protected

Definition at line 509 of file wrmpi.

m_ipos

int tools::mpi::wrmpi::m_ipos

protected

Definition at line 515 of file wrmpi.

m_max

char* tools::mpi::wrmpi::m_max

protected

Definition at line 512 of file wrmpi.

m_out

std::ostream& tools::mpi::wrmpi::m_out

protected

Definition at line 508 of file wrmpi.

m_pos

char* tools::mpi::wrmpi::m_pos

protected

Definition at line 513 of file wrmpi.

m_size

tools::uint32 tools::mpi::wrmpi::m_size

protected

Definition at line 510 of file wrmpi.

---

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

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