tools::wroot::mt_ntuple_column_wise Class Reference

Inheritance diagram for tools::wroot::mt_ntuple_column_wise:

Collaboration diagram for tools::wroot::mt_ntuple_column_wise:

Classes
class	basket_add

Public Member Functions
virtual bool	add_row (imutex &a_mutex, ifile &a_main_file)
virtual bool	end_fill (imutex &a_mutex, ifile &a_main_file)
	mt_ntuple_column_wise (std::ostream &a_out, bool a_byte_swap, uint32 a_compression, seek a_seek_directory, std::vector< branch * > &a_main_branches, const std::string &a_name, const std::string &a_title, bool a_row_mode, uint32 a_nev, bool a_verbose)
	mt_ntuple_column_wise (std::ostream &a_out, bool a_byte_swap, uint32 a_compression, seek a_seek_directory, std::vector< branch * > &a_main_branches, const std::vector< uint32 > &a_basket_sizes, const ntuple_booking &a_bkg, bool a_row_mode, uint32 a_nev, bool a_verbose)
	mt_ntuple_column_wise (std::ostream &a_out, bool a_byte_swap, uint32 a_compression, seek a_seek_directory, std::vector< branch * > &a_main_branches, const std::vector< uint32 > &a_basket_sizes, const ntuple_booking &a_bkg, bool a_verbose)
virtual	~mt_ntuple_column_wise ()
Public Member Functions inherited from tools::wroot::base_pntuple_column_wise
	base_pntuple_column_wise (std::ostream &a_out, bool a_byte_swap, uint32 a_compression, seek a_seek_directory, const std::string &a_name, const std::string &a_title, bool a_verbose)
	base_pntuple_column_wise (std::ostream &a_out, bool a_byte_swap, uint32 a_compression, seek a_seek_directory, const std::vector< uint32 > &a_basket_sizes, const ntuple_booking &a_bkg, bool a_verbose)
virtual	~base_pntuple_column_wise ()
template<class T >
column_ref< T > *	create_column_ref (uint32 a_basket_size, const std::string &a_name, const T &a_ref)
template<class T >
column< T > *	create_column (uint32 a_basket_size, const std::string &a_name, const T &a_def=T())
column_string_ref *	create_column_string_ref (uint32 a_basket_size, const std::string &a_name, const std::string &a_ref)
column_string *	create_column_string (uint32 a_basket_size, const std::string &a_name, const std::string &a_def=std::string())
column_vector_string_ref *	create_column_vector_string_ref (uint32 a_basket_size, const std::string &a_name, const std::vector< std::string > &a_ref, char a_sep)
column_vector_string *	create_column_vector_string (uint32 a_basket_size, const std::string &a_name, const std::vector< std::string > &a_def, char a_sep)
template<class T >
std_vector_column_ref< T > *	create_column_vector_ref (uint32 a_basket_size, const std::string &a_name, const std::vector< T > &a_ref)
template<class T >
std_vector_column< T > *	create_column_vector (uint32 a_basket_size, const std::string &a_name, const std::vector< T > &a_def=std::vector< T >())
Public Member Functions inherited from tools::wroot::base_pntuple
	base_pntuple (std::ostream &a_out, seek a_seek_directory, const std::string &a_name, const std::string &a_title)
virtual	~base_pntuple ()
const std::vector< icol * > &	columns () const
template<class T >
column_ref< T > *	find_column_ref (const std::string &a_name)
template<class T >
column< T > *	find_column (const std::string &a_name)
column_string_ref *	find_column_string_ref (const std::string &a_name)
column_string *	find_column_string (const std::string &a_name)
template<class T >
std_vector_column_ref< T > *	find_column_vector_ref (const std::string &a_name)
template<class T >
std_vector_column< T > *	find_column_vector (const std::string &a_name)
column_vector_string_ref *	find_column_vector_string_ref (const std::string &a_name)
column_vector_string *	find_column_vector_string (const std::string &a_name)
void	print_columns (std::ostream &a_out)
Public Member Functions inherited from tools::wroot::imt_ntuple
virtual	~imt_ntuple ()

Protected Member Functions
	mt_ntuple_column_wise (const mt_ntuple_column_wise &a_from)
mt_ntuple_column_wise &	operator= (const mt_ntuple_column_wise &a_from)
bool	end_leaves (imutex &a_mutex) const
Protected Member Functions inherited from tools::wroot::base_pntuple_column_wise
	base_pntuple_column_wise (const base_pntuple_column_wise &a_from)
base_pntuple_column_wise &	operator= (const base_pntuple_column_wise &)
Protected Member Functions inherited from tools::wroot::base_pntuple
	base_pntuple (const base_pntuple &a_from)
base_pntuple &	operator= (const base_pntuple &)

Static Protected Member Functions
static bool	ready_to_flush_baskets (std::vector< icol * > &a_cols)
static bool	flush_baskets (imutex &a_mutex, ifile &a_main_file, std::vector< icol * > &a_cols, std::vector< branch * > &a_main_branches)
static bool	flush_remaining_baskets (size_t &a_number, imutex &a_mutex, ifile &a_main_file, std::vector< icol * > &a_cols, std::vector< branch * > &a_main_branches)

Protected Attributes
std::vector< branch * > &	m_main_branches
bool	m_row_mode
uint32	m_nev
Protected Attributes inherited from tools::wroot::base_pntuple_column_wise
file	m_file
std::vector< branch * >	m_branches
Protected Attributes inherited from tools::wroot::base_pntuple
std::ostream &	m_out
seek	m_seek_directory
std::string	m_name
std::string	m_title
std::vector< icol * >	m_cols

Detailed Description

Definition at line 16 of file mt_ntuple_column_wise.

Constructor & Destructor Documentation

mt_ntuple_column_wise() [1/4]

tools::wroot::mt_ntuple_column_wise::mt_ntuple_column_wise ( std::ostream &  a_out, bool  a_byte_swap, uint32  a_compression, seek  a_seek_directory, std::vector< branch * > &  a_main_branches, const std::string &  a_name, const std::string &  a_title, bool  a_row_mode, uint32  a_nev, bool  a_verbose  )

inline

Definition at line 117 of file mt_ntuple_column_wise.

  :parent(a_out,a_byte_swap,a_compression,a_seek_directory,a_name,a_title,a_verbose)
  ,m_main_branches(a_main_branches)
  ,m_row_mode(a_row_mode)
  ,m_nev(a_nev)
  {
    if(m_row_mode) {
      if(!m_nev) m_nev = 4000;  //4000*sizeof(double) = 32000 = default basket size.
    } else {
      m_nev = 0;
    }
  }

mt_ntuple_column_wise() [2/4]

tools::wroot::mt_ntuple_column_wise::mt_ntuple_column_wise ( std::ostream &  a_out, bool  a_byte_swap, uint32  a_compression, seek  a_seek_directory, std::vector< branch * > &  a_main_branches, const std::vector< uint32 > &  a_basket_sizes, const ntuple_booking &  a_bkg, bool  a_row_mode, uint32  a_nev, bool  a_verbose  )

inline

Definition at line 134 of file mt_ntuple_column_wise.

  :parent(a_out,a_byte_swap,a_compression,a_seek_directory,a_basket_sizes,a_bkg,a_verbose)
  ,m_main_branches(a_main_branches)
  ,m_row_mode(a_row_mode)
  ,m_nev(a_nev)
  {
    if(m_row_mode) {
      if(!m_nev) m_nev = 4000;
    } else {
      m_nev = 0;
    }
  }

mt_ntuple_column_wise() [3/4]

tools::wroot::mt_ntuple_column_wise::mt_ntuple_column_wise ( std::ostream &  a_out, bool  a_byte_swap, uint32  a_compression, seek  a_seek_directory, std::vector< branch * > &  a_main_branches, const std::vector< uint32 > &  a_basket_sizes, const ntuple_booking &  a_bkg, bool  a_verbose  )

inline

Definition at line 153 of file mt_ntuple_column_wise.

  :parent(a_out,a_byte_swap,a_compression,a_seek_directory,a_basket_sizes,a_bkg,a_verbose)
  ,m_main_branches(a_main_branches)
  ,m_row_mode(false)
  ,m_nev(0)
  {
    if(m_row_mode) {
      if(!m_nev) m_nev = 4000;
    } else {
      m_nev = 0;
    }
  }

~mt_ntuple_column_wise()

virtual tools::wroot::mt_ntuple_column_wise::~mt_ntuple_column_wise ( )

inlinevirtual

Definition at line 171 of file mt_ntuple_column_wise.

{}

mt_ntuple_column_wise() [4/4]

tools::wroot::mt_ntuple_column_wise::mt_ntuple_column_wise ( const mt_ntuple_column_wise &  a_from )

inlineprotected

Definition at line 173 of file mt_ntuple_column_wise.

  :imt_ntuple(a_from)
  ,parent(a_from)
  ,m_main_branches(a_from.m_main_branches)
  ,m_row_mode(a_from.m_row_mode)
  ,m_nev(a_from.m_nev)
  {}

Member Function Documentation

add_row()

virtual bool tools::wroot::mt_ntuple_column_wise::add_row ( imutex &  a_mutex, ifile &  a_main_file  )

inlinevirtual

Implements tools::wroot::imt_ntuple.

Definition at line 72 of file mt_ntuple_column_wise.

                                                           {
    if(m_cols.empty()) return false;
   {tools_vforit(icol*,m_cols,it) (*it)->add();}
    if(m_main_branches.size()!=m_cols.size()) {
      m_out << "tools::wroot::mt_ntuple_column_wise::add_row :"
            << " m_main_branches.size() (" << m_main_branches.size() << ") != "
            << "m_cols.size() (" << m_cols.size() << ")."
            << std::endl;
      return false;
    }
   {std::vector<branch*>::const_iterator itb = m_main_branches.begin();
    tools_vforit(icol*,m_cols,it) {
      branch* main_branch = (*itb);itb++;
      basket_add _badd(a_mutex,a_main_file,*main_branch,(*it)->get_branch(),m_cols,m_main_branches,m_row_mode);
      if(!(*it)->get_branch().pfill(_badd,m_nev)) return false;
    }}
   {tools_vforit(icol*,m_cols,it) (*it)->set_def();}
    return true;
  }

end_fill()

virtual bool tools::wroot::mt_ntuple_column_wise::end_fill ( imutex &  a_mutex, ifile &  a_main_file  )

inlinevirtual

Implements tools::wroot::imt_ntuple.

Definition at line 91 of file mt_ntuple_column_wise.

                                                            {
    if(m_main_branches.size()!=m_cols.size()) {
      m_out << "tools::wroot::mt_ntuple_column_wise::end_fill :"
            << " m_main_branches.size() (" << m_main_branches.size() << ") != "
            << "m_cols.size() (" << m_cols.size() << ")."
            << std::endl;
      return false;
    }
    std::vector<branch*>::const_iterator itb = m_main_branches.begin();
    tools_vforit(icol*,m_cols,it) {
      branch* main_branch = (*itb);itb++;
      basket_add _badd(a_mutex,a_main_file,*main_branch,(*it)->get_branch(),m_cols,m_main_branches,m_row_mode);
      if(!(*it)->get_branch().end_pfill(_badd)) return false;
    }
    if(m_row_mode) {
      size_t number;
      bool status = flush_remaining_baskets(number,a_mutex,a_main_file,m_cols,m_main_branches);
      if(number) {
        m_out << "tools::wroot::mt_ntuple_column_wise::end_fill : it remained " << number << " baskets not written on file." << std::endl;
    status = false;
      }
      if(!status) return false;
    }
    return end_leaves(a_mutex);
  }

end_leaves()

bool tools::wroot::mt_ntuple_column_wise::end_leaves ( imutex &  a_mutex ) const

inlineprotected

Definition at line 232 of file mt_ntuple_column_wise.

                                         {
 
#include "MT_SET_MAX.icc"
 
    std::vector<icol*>::const_iterator pit = m_cols.begin();
    tools_vforcit(branch*,m_main_branches,mit) {
      if((*mit)->leaves().empty()) {
        m_out << "tools::wroot::mt_ntuple_column_wise::end_leaves :"
              << " branch " << (*mit)->name() << " without leaf." << std::endl;
        return false;
      }
 
      base_leaf* _mleaf = *((*mit)->leaves().begin());
      base_leaf* _pleaf = (*pit)->get_leaf(); pit++; //WARNING.
 
      TOOLS_WROOT_MT_NTUPLE_STRING_SET_MAX
 
    }
#undef TOOLS_WROOT_MT_NTUPLE_STRING_SET_MAX
 
    return true;
  }

flush_baskets()

static bool tools::wroot::mt_ntuple_column_wise::flush_baskets ( imutex &  a_mutex, ifile &  a_main_file, std::vector< icol * > &  a_cols, std::vector< branch * > &  a_main_branches  )

inlinestaticprotected

Definition at line 191 of file mt_ntuple_column_wise.

                                                                                                                             {
    a_mutex.lock();
    bool status = true;
    std::vector<branch*>::const_iterator itb = a_main_branches.begin();
    tools_vforit(icol*,a_cols,it) {
      branch& _branch = (*it)->get_branch();
      basket* _front_basket = _branch.m_parallel_baskets.front();
      branch* main_branch = (*itb);itb++;
      if(status) {
        uint32 add_bytes,nout;
        if(main_branch->add_basket(a_main_file,*_front_basket,add_bytes,nout)) {
           main_branch->set_tot_bytes(main_branch->tot_bytes()+add_bytes);
           main_branch->set_zip_bytes(main_branch->zip_bytes()+nout);
        } else {
          status = false;
        }
      }
      _branch.m_parallel_baskets.erase(_branch.m_parallel_baskets.begin());
      delete _front_basket;
    }
    a_mutex.unlock();
    return status;
  }

flush_remaining_baskets()

static bool tools::wroot::mt_ntuple_column_wise::flush_remaining_baskets ( size_t &  a_number, imutex &  a_mutex, ifile &  a_main_file, std::vector< icol * > &  a_cols, std::vector< branch * > &  a_main_branches  )

inlinestaticprotected

Definition at line 215 of file mt_ntuple_column_wise.

                                                                                                                                                        {
    a_number = 0;
    while(ready_to_flush_baskets(a_cols)) {
      if(!flush_baskets(a_mutex,a_main_file,a_cols,a_main_branches)) return false;
    }
    // look for pending baskets.
   {tools_vforit(icol*,a_cols,it) {
      branch& _branch = (*it)->get_branch();
      a_number += _branch.m_parallel_baskets.size();
    }}
   {tools_vforit(icol*,a_cols,it) {
      branch& _branch = (*it)->get_branch();
      safe_clear(_branch.m_parallel_baskets);
    }}
    return true;
  }

operator=()

mt_ntuple_column_wise& tools::wroot::mt_ntuple_column_wise::operator= ( const mt_ntuple_column_wise &  a_from )

inlineprotected

Definition at line 180 of file mt_ntuple_column_wise.

{parent::operator=(a_from);return *this;}

ready_to_flush_baskets()

static bool tools::wroot::mt_ntuple_column_wise::ready_to_flush_baskets ( std::vector< icol * > &  a_cols )

inlinestaticprotected

Definition at line 182 of file mt_ntuple_column_wise.

                                                               {
    //return true if all parallel branches have at least one basket in their m_parallel_baskets.
    if(a_cols.empty()) return false;
    tools_vforit(icol*,a_cols,it) {
      branch& _branch = (*it)->get_branch();
      if(_branch.m_parallel_baskets.empty()) return false;
    }
    return true;
  }

Member Data Documentation

m_main_branches

std::vector<branch*>& tools::wroot::mt_ntuple_column_wise::m_main_branches

protected

Definition at line 255 of file mt_ntuple_column_wise.

m_nev

uint32 tools::wroot::mt_ntuple_column_wise::m_nev

protected

Definition at line 257 of file mt_ntuple_column_wise.

m_row_mode

bool tools::wroot::mt_ntuple_column_wise::m_row_mode

protected

Definition at line 256 of file mt_ntuple_column_wise.

---

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

• /Users/barrand/private/dev/softinex/g4tools/g4tools/tools/wroot/mt_ntuple_column_wise