Converter of Column-wise NTuple into ROOT format. More...

#include <src/RCWNTupleCnv.h>

Inheritance diagram for RootHistCnv::RCWNTupleCnv:

Collaboration diagram for RootHistCnv::RCWNTupleCnv:

Public Member Functions
	RCWNTupleCnv (ISvcLocator *svc)
	Standard constructor. More...

virtual	~RCWNTupleCnv ()
	Standard destructor. More...

Public Member Functions inherited from RootHistCnv::RNTupleCnv
virtual StatusCode	initialize ()
	Initialize the converter. More...

virtual StatusCode	finalize ()
	Finalize the converter. More...

virtual StatusCode	createObj (IOpaqueAddress pAddr, DataObject &refpObj)
	Create the transient representation of an object. More...

virtual StatusCode	updateObj (IOpaqueAddress pAddr, DataObject refpObj)
	Update the transient object from the other representation. More...

virtual StatusCode	createRep (DataObject pObj, IOpaqueAddress &refpAddr)
	Convert the transient object to the requested representation. More...

virtual StatusCode	updateRep (IOpaqueAddress pAddr, DataObject pObj)
	Update the converted representation of a transient object. More...

Public Member Functions inherited from RootHistCnv::RConverter
long	repSvcType () const
	Retrieve the class type of the data store the converter uses. More...

StatusCode	error (const std::string &msg)

StatusCode	regTFile (const std::string, const TFile *)

StatusCode	findTFile (const std::string, TFile *&)

std::string	diskDirectory (const std::string &loc)

std::string	directory (const std::string &loc)

void	setDirectory (const std::string &loc)

void	setDiskDirectory (const std::string &loc)

StatusCode	createDirectory (const std::string &loc)

StatusCode	createDiskDirectory (const std::string &loc)

std::string	getDirectory ()

std::string	convertId (const std::string &) const

Public Member Functions inherited from Converter
virtual StatusCode	setDataProvider (IDataProviderSvc *svc)
	Set Data provider service. More...

virtual SmartIF< IDataProviderSvc > &	dataProvider () const
	Get Data provider service. More...

virtual StatusCode	setConversionSvc (IConversionSvc *svc)
	Set conversion service the converter is connected to. More...

virtual SmartIF< IConversionSvc > &	conversionSvc () const
	Get conversion service the converter is connected to. More...

virtual StatusCode	setAddressCreator (IAddressCreator *creator)
	Set address creator facility. More...

virtual SmartIF< IAddressCreator > &	addressCreator () const
	Retrieve address creator facility. More...

virtual const CLID &	objType () const
	Retrieve the class type of objects the converter produces. More...

virtual long	i_repSvcType () const
	Retrieve the class type of the data store the converter uses. More...

virtual StatusCode	fillObjRefs (IOpaqueAddress pAddress, DataObject pObject)
	Resolve the references of the created transient object. More...

virtual StatusCode	updateObjRefs (IOpaqueAddress pAddress, DataObject pObject)
	Update the references of an updated transient object. More...

virtual StatusCode	fillRepRefs (IOpaqueAddress pAddress, DataObject pObject)
	Resolve the references of the converted object. More...

virtual StatusCode	updateRepRefs (IOpaqueAddress pAddress, DataObject pObject)
	Update the references of an already converted object. More...

	Converter (long storage_type, const CLID &class_type, ISvcLocator *svc=0)
	Standard Constructor. More...

template<class T >
StatusCode	service (const std::string &name, T *&psvc, bool createIf=false) const
	Access a service by name, creating it if it doesn't already exist. More...

template<class T >
StatusCode	service (const std::string &type, const std::string &name, T *&psvc) const
	Access a service by name, type creating it if it doesn't already exist. More...

SmartIF< IService >	service (const std::string &name, const bool createIf=true) const
	Return a pointer to the service identified by name (or "type/name") More...

virtual StatusCode	setDataProvider (IDataProviderSvc *svc)
	Set Data provider service. More...

virtual SmartIF< IDataProviderSvc > &	dataProvider () const
	Get Data provider service. More...

virtual StatusCode	setConversionSvc (IConversionSvc *svc)
	Set conversion service the converter is connected to. More...

virtual SmartIF< IConversionSvc > &	conversionSvc () const
	Get conversion service the converter is connected to. More...

virtual StatusCode	setAddressCreator (IAddressCreator *creator)
	Set address creator facility. More...

virtual SmartIF< IAddressCreator > &	addressCreator () const
	Retrieve address creator facility. More...

virtual const CLID &	objType () const
	Retrieve the class type of objects the converter produces. More...

virtual long	i_repSvcType () const
	Retrieve the class type of the data store the converter uses. More...

virtual StatusCode	fillObjRefs (IOpaqueAddress pAddress, DataObject pObject)
	Resolve the references of the created transient object. More...

virtual StatusCode	updateObjRefs (IOpaqueAddress pAddress, DataObject pObject)
	Update the references of an updated transient object. More...

virtual StatusCode	fillRepRefs (IOpaqueAddress pAddress, DataObject pObject)
	Resolve the references of the converted object. More...

virtual StatusCode	updateRepRefs (IOpaqueAddress pAddress, DataObject pObject)
	Update the references of an already converted object. More...

	Converter (long storage_type, const CLID &class_type, ISvcLocator *svc=0)
	Standard Constructor. More...

template<class T >
StatusCode	service (const std::string &name, T *&psvc, bool createIf=false) const
	Access a service by name, creating it if it doesn't already exist. More...

template<class T >
StatusCode	service (const std::string &type, const std::string &name, T *&psvc) const
	Access a service by name, type creating it if it doesn't already exist. More...

SmartIF< IService >	service (const std::string &name, const bool createIf=true) const
	Return a pointer to the service identified by name (or "type/name") More...

Public Member Functions inherited from extend_interfaces1< IConverter >
virtual	~extend_interfaces1 ()
	Virtual destructor. More...

virtual	~extend_interfaces1 ()
	Virtual destructor. More...

Public Member Functions inherited from IConverter
	DeclareInterfaceID (IConverter, 3, 0)
	InterfaceID. More...

virtual	~IConverter ()
	Virtual destructor. More...

	DeclareInterfaceID (IConverter, 3, 0)
	InterfaceID. More...

virtual	~IConverter ()
	Virtual destructor. More...

Public Member Functions inherited from IInterface
virtual void *	i_cast (const InterfaceID &) const =0
	main cast function More...

virtual std::vector< std::string >	getInterfaceNames () const =0
	Returns a vector of strings containing the names of all the implemented interfaces. More...

virtual unsigned long	addRef ()=0
	Increment the reference count of Interface instance. More...

virtual unsigned long	release ()=0
	Release Interface instance. More...

virtual unsigned long	refCount () const =0
	Current reference count. More...

virtual StatusCode	queryInterface (const InterfaceID &ti, void **pp)=0
	Set the void** to the pointer to the requested interface of the instance. More...

virtual	~IInterface ()
	Virtual destructor. More...

virtual void *	i_cast (const InterfaceID &) const =0
	main cast function More...

virtual std::vector< std::string >	getInterfaceNames () const =0
	Returns a vector of strings containing the names of all the implemented interfaces. More...

virtual unsigned long	addRef ()=0
	Increment the reference count of Interface instance. More...

virtual unsigned long	release ()=0
	Release Interface instance. More...

virtual unsigned long	refCount () const =0
	Current reference count. More...

virtual StatusCode	queryInterface (const InterfaceID &ti, void **pp)=0
	Set the void** to the pointer to the requested interface of the instance. More...

virtual	~IInterface ()
	Virtual destructor. More...

Static Public Member Functions
static const CLID &	classID ()
	Inquire class type. More...

Static Public Member Functions inherited from RootHistCnv::RConverter
static long	storageType ()
	Inquire storage type. More...

Static Public Member Functions inherited from IInterface
static const InterfaceID &	interfaceID ()
	Return an instance of InterfaceID identifying the interface. More...

static const InterfaceID &	interfaceID ()
	Return an instance of InterfaceID identifying the interface. More...

Protected Member Functions
virtual StatusCode	load (TTree tree, INTuple &refpObject)
	Create the transient representation of an object. More...

virtual StatusCode	book (const std::string &desc, INTuple pObject, TTree &tree)
	Book the N tuple. More...

virtual StatusCode	writeData (TTree rtree, INTuple pObject)
	Write N tuple data. More...

virtual StatusCode	readData (TTree rtree, INTuple pObject, long ievt)
	Read N tuple data. More...

template<class T >
size_t	saveItem (char target, const T src, size_t len)

template<typename T >
size_t	saveItem (char target, T src, size_t len)

template<class T >
size_t	loadItem (char src, T tar, size_t len)

size_t	loadItem (char src, bool tar, size_t len)

size_t	loadItem (char src, float target, size_t len)

size_t	loadItem (char src, double target, size_t len)

size_t	loadItem (char src, long target, size_t len)

size_t	loadItem (char src, unsigned long target, size_t len)

Protected Member Functions inherited from RootHistCnv::RNTupleCnv
	RNTupleCnv (ISvcLocator *svc, const CLID &clid)
	Standard constructor. More...

virtual	~RNTupleCnv ()
	Standard destructor. More...

virtual std::string	rootVarType (int)
	Return ROOT type info: More...

Protected Member Functions inherited from RootHistCnv::RConverter
	RConverter (const CLID &clid, ISvcLocator *svc)
	Standard constructor. More...

virtual	~RConverter ()
	Standard destructor. More...

virtual StatusCode	readObject (IOpaqueAddress pAddr, DataObject &refpObj)
	Create the transient representation of an object. More...

virtual TObject *	createPersistent (DataObject *pObj)
	Create the persistent representation of an object. More...

StatusCode	createAddress (DataObject pObject, TDirectory pDir, TObject pTObject, IOpaqueAddress &refpAddr)
	Create address of the transient object according to the requested representation. More...

StatusCode	createAddress (const std::string &rzdir, const CLID &clid, long id, TObject pTobj, IOpaqueAddress &refpAddress)

StatusCode	createAddress (const std::string &rzdir, const CLID &clid, const std::string &title, TObject pTobj, IOpaqueAddress &refpAddress)

TDirectory *	changeDirectory (DataObject *pObject)
	Switch to object directory (=Parent directory) More...

Protected Member Functions inherited from Converter
virtual	~Converter ()
	Standard Destructor. More...

SmartIF< ISvcLocator > &	serviceLocator () const
	Retrieve pointer to service locator. More...

SmartIF< IMessageSvc > &	msgSvc () const
	Retrieve pointer to message service. More...

SmartIF< IMessageSvc > &	messageService () const

SmartIF< IDataManagerSvc > &	dataManager () const
	Get Data Manager service. More...

virtual	~Converter ()
	Standard Destructor. More...

SmartIF< ISvcLocator > &	serviceLocator () const
	Retrieve pointer to service locator. More...

SmartIF< IMessageSvc > &	msgSvc () const
	Retrieve pointer to message service. More...

SmartIF< IMessageSvc > &	messageService () const

SmartIF< IDataManagerSvc > &	dataManager () const
	Get Data Manager service. More...

Additional Inherited Members
Public Types inherited from Converter
typedef Gaudi::PluginService::Factory< IConverter , ISvcLocator >	Factory

typedef Gaudi::PluginService::Factory< IConverter , ISvcLocator >	Factory

Public Types inherited from implements1< IConverter >
typedef implements1	base_class
	Typedef to this class. More...

typedef implements1	base_class
	Typedef to this class. More...

typedef extend_interfaces1< IConverter >	extend_interfaces_base
	Typedef to the base of this class. More...

typedef extend_interfaces1< IConverter >	extend_interfaces_base
	Typedef to the base of this class. More...

typedef extend_interfaces_base::ext_iids	interfaces
	MPL set of all the implemented interfaces. More...

typedef extend_interfaces_base::ext_iids	interfaces
	MPL set of all the implemented interfaces. More...

Public Types inherited from extend_interfaces1< IConverter >
typedef IConverter::iid::iids::type	ext_iids
	MPL set of interfaces extended by this one. More...

typedef IConverter::iid::iids::type	ext_iids
	MPL set of interfaces extended by this one. More...

Public Types inherited from IConverter
enum	Status { INVALID_ADDRESS = IInterface::LAST_ERROR+1, INVALID_OBJECT, NO_MEMORY, BAD_STORAGE_TYPE, NO_SOURCE_OBJECT, ICONVERSIONSVC_LAST_ERROR, INVALID_ADDRESS = IInterface::LAST_ERROR+1, INVALID_OBJECT, NO_MEMORY, BAD_STORAGE_TYPE, NO_SOURCE_OBJECT, ICONVERSIONSVC_LAST_ERROR }
	Status code. More...

enum	Status { INVALID_ADDRESS = IInterface::LAST_ERROR+1, INVALID_OBJECT, NO_MEMORY, BAD_STORAGE_TYPE, NO_SOURCE_OBJECT, ICONVERSIONSVC_LAST_ERROR, INVALID_ADDRESS = IInterface::LAST_ERROR+1, INVALID_OBJECT, NO_MEMORY, BAD_STORAGE_TYPE, NO_SOURCE_OBJECT, ICONVERSIONSVC_LAST_ERROR }
	Status code. More...

Public Types inherited from IInterface
enum	Status { SUCCESS = 1, NO_INTERFACE, VERSMISMATCH, LAST_ERROR, SUCCESS = 1, NO_INTERFACE, VERSMISMATCH, LAST_ERROR }
	Return status. More...

enum	Status { SUCCESS = 1, NO_INTERFACE, VERSMISMATCH, LAST_ERROR, SUCCESS = 1, NO_INTERFACE, VERSMISMATCH, LAST_ERROR }
	Return status. More...

typedef Gaudi::InterfaceId< IInterface, 0, 0 >	iid
	Interface ID. More...

typedef mpl::set1< iid >	ext_iids
	Extra interfaces. More...

typedef Gaudi::InterfaceId< IInterface, 0, 0 >	iid
	Interface ID. More...

typedef mpl::set1< iid >	ext_iids
	Extra interfaces. More...

Protected Attributes inherited from RootHistCnv::RNTupleCnv
SmartIF< INTupleSvc >	m_ntupleSvc
	Reference to N tuple service. More...

Detailed Description

Converter of Column-wise NTuple into ROOT format.

Author: Charles Leggett

Definition at line 23 of file RCWNTupleCnv.h.

Constructor & Destructor Documentation

RootHistCnv::RCWNTupleCnv::RCWNTupleCnv ( ISvcLocator * svc )

inline

Standard constructor.

Definition at line 30 of file RCWNTupleCnv.h.

30 : RNTupleCnv(svc, classID()) {

31 }

RootHistCnv::RNTupleCnv::RNTupleCnv

RNTupleCnv(ISvcLocator *svc, const CLID &clid)

Standard constructor.

Definition: RNTupleCnv.cpp:35

RootHistCnv::RCWNTupleCnv::classID

static const CLID & classID()

Inquire class type.

Definition: RCWNTupleCnv.h:26

virtual RootHistCnv::RCWNTupleCnv::~RCWNTupleCnv ( )

inlinevirtual

Standard destructor.

Definition at line 33 of file RCWNTupleCnv.h.

33 {

34 }

Member Function Documentation

StatusCode RootHistCnv::RCWNTupleCnv::book	(	const std::string &	desc,
		INTuple *	pObject,
		TTree *&	tree
	)

protectedvirtual

Book the N tuple.

Implements RootHistCnv::RNTupleCnv.

Definition at line 91 of file RCWNTupleCnv.cpp.

 {
   MsgStream log(msgSvc(), "RCWNTupleCnv");
   rtree = new TTree(desc.c_str(), nt->title().c_str());
   log << MSG::VERBOSE << "created tree id: " << rtree->GetName()
       << "  title: "<< nt->title() << " desc: " << desc << endmsg;
 
   // Loop over the items
 
   std::string block_name,var_name;
   long lowerRange, upperRange;
   long size = 0;
   long cursize, oldsize = 0;
   std::vector<std::string> item_fullname;
   //    std::vector<long> item_size,item_size2;
   std::vector<long> item_buf_pos, item_buf_len, item_buf_end;
   std::vector<long> item_range_lower, item_range_upper;
   std::vector<std::pair<std::string,std::string> > item_name;
 
   const INTuple::ItemContainer& cols = nt->items();
   for (INTuple::ItemContainer::const_iterator i = cols.begin();
        i != cols.end(); ++i ) {
     std::string item = "";
 
     switch( (*i)->type() )   {
     case DataTypeInfo::INT:               // int
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<int>*>(*i),item,
           block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::CHAR:              // char
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<char>*>(*i),
           item, block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::SHORT:             // short
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<short>*>(*i),item,
           block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::LONG:              // long
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<long>*>(*i),item,
           block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::LONGLONG:          // long long
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<long long>*>(*i),item,
           block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::UCHAR:             // unsigned char
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<unsigned char>*>(*i),
           item, block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::USHORT:            // unsigned short
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<unsigned short>*>(*i),
           item, block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::UINT:              // unsigned int
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<unsigned int>*>(*i),
           item, block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::ULONG:             // unsigned long
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<unsigned long>*>(*i),
           item, block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::ULONGLONG:         // unsigned long long
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<unsigned long long>*>(*i),
           item, block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::DOUBLE:            // double
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<double>*>(*i),item,
           block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::FLOAT:             // float
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<float>*>(*i),item,
           block_name,var_name,lowerRange,upperRange,size);
       break;
     case DataTypeInfo::BOOL:               // bool
       analyzeItem(rootVarType( (*i)->type() ),
           dynamic_cast<const NTuple::_Data<bool>*>(*i),item,
           block_name,var_name,lowerRange,upperRange,size);
       break;
     default:
       break;
     }
 
     item_name.push_back(std::pair<std::string,std::string>(block_name,item));
     cursize = size - oldsize;
 
     log << MSG::VERBOSE << "item: " << item << " type " << (*i)->type()
         << " blk: " << block_name
         << " var: " << var_name << " rng: " << lowerRange << " "
         << upperRange << " sz: " << size << " " << cursize
         << " buf_pos: " << size-cursize << endmsg;
 
     item_fullname.push_back(var_name);
     item_buf_pos.push_back(size-cursize);
     item_buf_len.push_back(cursize);
     item_buf_end.push_back(size);
     item_range_lower.push_back(lowerRange);
     item_range_upper.push_back(upperRange);
 
     oldsize = size;
   }
 
   char* buff = new char[size];
   log << MSG::VERBOSE << "Created buffer size: " << size << " at "
       << (void*)buff << endmsg;
 
   // Zero out the buffer to make ROOT happy
   memset (buff,0,size);
 
   // Tell the ntuple where it is
   nt->setBuffer(buff);
 
   char *buf_pos = buff;
 
   std::vector<std::pair<std::string,std::string> >::const_iterator itr,end;
   end = item_name.end();
 
   // Loop over items, creating a new branch for each one;
   unsigned int i_item = 0;
   for (itr=item_name.begin(); itr!=end; ++itr, ++i_item) {
 
     buf_pos = buff + item_buf_pos[i_item];
 
 //      log << MSG::WARNING << "adding TBranch " << i_item << "  "
 //      << item_fullname[i_item]
 //      << "  format: " << itr->second.c_str() << "  at "
 //      << (void*) buf_pos << " (" << (void*) buff << "+"
 //      << (void*)item_buf_pos[i_item] << ")"
 //      << endmsg;
 
 #if ROOT_VERSION_CODE >= ROOT_VERSION(5,15,0)
     TBranch *br = new TBranch(rtree,
 #else
     TBranch *br = new TBranch(
 #endif
                               item_fullname[i_item].c_str(),
                               buf_pos,
                               itr->second.c_str()
                               );
 
     if (itr->first != "AUTO_BLK") {
       std::string tit = itr->first;
       tit = itr->first + "::" + br->GetTitle();
       br->SetTitle(tit.c_str());
     }
 
     log << MSG::DEBUG << "adding TBranch  " << br->GetTitle() << "  at "
         << (void*) buf_pos << endmsg;
 
 
     // for index items with a limited range. Must be a TLeafI!
     if ( item_range_lower[i_item] < item_range_upper[i_item] ) {
 //        log << MSG::VERBOSE << "\"" << item_fullname[i_item]
 //        << "\" is range limited " << item_range_lower[i_item] << "  "
 //        << item_range_upper[i_item] << endmsg;
       TLeafI *index = 0;
       TObject *tobj = br->GetListOfLeaves()->FindObject( item_fullname[i_item].c_str() );
       if (tobj->IsA()->InheritsFrom("TLeafI")) {
         index = dynamic_cast<TLeafI*>(tobj);
 
         if (index != 0) {
           index->SetMaximum( item_range_upper[i_item] );
           // FIXME -- add for next version of ROOT
           // index->SetMinimum( item_range_lower[i_item] );
         } else {
           log << MSG::ERROR << "Could dynamic cast to TLeafI: "
               << item_fullname[i_item] << endmsg;
         }
       }
     }
 
     rtree->GetListOfBranches()->Add(br);
 
   }
 
 
   log << MSG::INFO << "Booked TTree with ID: " << desc
       << " \"" << nt->title() << "\" in directory "
       << getDirectory() << endmsg;
 
   return StatusCode::SUCCESS;
 
 }

static const CLID& RootHistCnv::RCWNTupleCnv::classID ( )

inlinestatic

Inquire class type.

Definition at line 26 of file RCWNTupleCnv.h.

                                     {
       return CLID_ColumnWiseTuple;
     }

StatusCode RootHistCnv::RCWNTupleCnv::load	(	TTree *	tree,
		INTuple *&	refpObject
	)

protectedvirtual

Create the transient representation of an object.

Implements RootHistCnv::RNTupleCnv.

Definition at line 428 of file RCWNTupleCnv.cpp.

 {
   MsgStream log(msgSvc(), "RCWNTupleCnv::load");
 
   StatusCode status;
 
   NTuple::Tuple *pObj = 0;
 
   std::string title = tree->GetTitle();
   log << MSG::VERBOSE << "loading CWNT " << title << " at: "
     << tree << endmsg;
 
   status = m_ntupleSvc->create(CLID_ColumnWiseTuple, title, pObj);
   INTuple* ntup = dynamic_cast<INTuple*>(pObj);
 
   INTupleItem* item=0;
 
   std::string itemName, indexName, item_type, itemTitle, blockName;
   // long numEnt, numVar;
   long size, totsize=0;
   std::list< std::pair<TLeaf*,int> > itemList;
 
   // numEnt = (int)tree->GetEntries();
   // numVar = tree->GetNbranches();
 
   // loop over all branches (==leaves)
   TObjArray* lbr = tree->GetListOfBranches();
   TIter bitr ( lbr );
   while ( TObject *tobjb = bitr() ) {
 
     TBranch* br = (TBranch*)tobjb;
     itemTitle = br->GetTitle();
 
     int ipos = itemTitle.find("::");
     if (ipos >= 0) {
       blockName = itemTitle.substr(0,ipos);
     } else {
       blockName = "";
     }
 
     TObjArray* lf = br->GetListOfLeaves();
 
     TIter litr ( lf );
     while ( TObject *tobj = litr() ) {
 
       bool hasRange=false;
       int indexRange = 0;
       int itemSize;
       item = 0;
 
       //      TLeaf* tl = (TLeaf*)tobj;
       TLeaf* tl = dynamic_cast<TLeaf*> (tobj);
       itemName = tl->GetName();
 
       //    char* buf_pos = (char*)tl->GetValuePointer();
       //    cout << " " << itemName << "  " << blockName << "  "
       //         << (void*)buf_pos;
 
 
       if (blockName != "") {
         log << MSG::DEBUG << "loading NTuple item " << blockName << "/"
         << itemName;
       } else {
         log << MSG::DEBUG << "loading NTuple item " << itemName;
       }
 
       int arraySize;
       TLeaf* indexLeaf = tl->GetLeafCounter(arraySize);
 
       if (arraySize == 0) {
     log << MSG::ERROR << "TLeaf counter size = 0. This should not happen!"
         << endmsg;
       }
 
       if (indexLeaf != 0) {
         //index Arrays and Matrices
 
         indexName = indexLeaf->GetName();
         //    indexRange = tl->GetNdata();
         indexRange = indexLeaf->GetMaximum();
         itemSize = indexRange * tl->GetLenType() * arraySize;
 
         log << "[" << indexName;
 
     // Just for Matrices
     if (arraySize != 1) {
       log << "][" << arraySize;
     }
     log << "]";
 
       } else {
     itemSize = tl->GetLenType() * arraySize;
 
     indexName = "";
 
     if (arraySize == 1) {
       // Simple items
     } else {
       // Arrays of constant size
       log << "[" << arraySize << "]";
     }
       }
 
       log << endmsg;
 
       //    cout << "  index: " << indexName <<  endl;
 
       //    size = tl->GetNdata() * tl->GetLenType();
       size = itemSize;
       totsize += size;
 
       hasRange = tl->IsRange();
 
       itemList.push_back(std::pair<TLeaf*,int>(tl,itemSize));
 
 
       // Integer
       if (tobj->IsA()->InheritsFrom("TLeafI")) {
 
         TLeafI *tli = dynamic_cast<TLeafI*>(tobj);
         if (tli->IsUnsigned()) {
           unsigned long min=0, max=0;
           if (hasRange) {
             min = tli->GetMinimum();
             max = tli->GetMaximum();
           }
 
           item = createNTupleItem(itemName, blockName, indexName, indexRange,
                   arraySize,
                                   min, max, ntup);
         } else {
           long min=0, max=0;
           if (hasRange) {
             min = tli->GetMinimum();
             max = tli->GetMaximum();
           }
 
           item = createNTupleItem(itemName, blockName, indexName, indexRange,
                   arraySize,
                                   min, max, ntup);
         }
 
         // Float
       } else if (tobj->IsA()->InheritsFrom("TLeafF")) {
         float min=0., max=0.;
 
         TLeafF *tlf = dynamic_cast<TLeafF*>(tobj);
         if (hasRange) {
           min = float(tlf->GetMinimum());
           max = float(tlf->GetMaximum());
         }
 
         item = createNTupleItem(itemName, blockName, indexName, indexRange,
                 arraySize,
                                 min, max, ntup);
 
         // Double
       } else if (tobj->IsA()->InheritsFrom("TLeafD")) {
         double min=0., max=0.;
 
         TLeafD *tld = dynamic_cast<TLeafD*>(tobj);
         if (hasRange) {
           min = tld->GetMinimum();
           max = tld->GetMaximum();
         }
 
         item = createNTupleItem(itemName, blockName, indexName, indexRange,
                 arraySize,
                                 min, max, ntup);
 
 
       } else {
         log << MSG::ERROR << "Uknown data type" << endmsg;
       }
 
 
       if (item) {
         ntup->add(item);
       } else {
         log << MSG::ERROR
         << "Unable to create ntuple item \""
         <<  itemName << "\"" << endmsg;
       }
 
     } // end litr
   }   // end bitr
 
   log << MSG::DEBUG << "Total buffer size of NTuple: " << totsize
       << " Bytes." << endmsg;
 
   char* buf = new char[totsize];
   char* bufpos = buf;
 
   ntup->setBuffer(buf);
 
   std::list< std::pair<TLeaf*,int> >::const_iterator iitr = itemList.begin();
   int ts = 0;
   for (; iitr!= itemList.end(); ++iitr) {
     TLeaf* leaf = (*iitr).first;
     int isize   = (*iitr).second;
 
     log << MSG::VERBOSE << "setting TBranch " << leaf->GetBranch()->GetName()
         << " buffer at " << (void*) bufpos << endmsg;
 
     leaf->GetBranch()->SetAddress((void*)bufpos);
 
 //        //testing
 //        if (leaf->IsA()->InheritsFrom("TLeafI")) {
 //      for (int ievt=0; ievt<5; ievt++) {
 //        leaf->GetBranch()->GetEvent(ievt);
 //        int *idat = (int*)bufpos;
 //        log << MSG::WARNING << leaf->GetName() << ": " << ievt << "   "
 //            << *idat << endmsg;
 
 //      }
 //        }
 
     ts += isize;
 
     bufpos += isize;
   }
 
   if (totsize != ts ) {
     log << MSG::ERROR << "buffer size mismatch: " << ts << "  " << totsize
         << endmsg;
   }
 
   refpObject = ntup;
 
   return StatusCode::SUCCESS;
 }

template<class T >

size_t RootHistCnv::RCWNTupleCnv::loadItem	(	char *	src,
		T *	tar,
		size_t	len
	)

inlineprotected

Definition at line 60 of file RCWNTupleCnv.h.

                                                      {
       long* s = (long*)src;
       for ( size_t i = 0; i < len; i++ )   {
         *(tar++) = T( *(s++));
       }
       return sizeof(long)*len;
     }

size_t RootHistCnv::RCWNTupleCnv::loadItem	(	char *	src,
		bool *	tar,
		size_t	len
	)

inlineprotected

Definition at line 67 of file RCWNTupleCnv.h.

                                                         {
       long* s = (long*)src;
       for ( size_t i = 0; i < len; i++ )   {
         *(tar++) = (*(s++)) ? true : false;
       }
       return sizeof(long)*len;
     }

size_t RootHistCnv::RCWNTupleCnv::loadItem	(	char *	src,
		float *	target,
		size_t	len
	)

inlineprotected

Definition at line 74 of file RCWNTupleCnv.h.

                                                             {
       memcpy(target, src, sizeof(float)*len);
       return sizeof(float)*len;
     }

size_t RootHistCnv::RCWNTupleCnv::loadItem	(	char *	src,
		double *	target,
		size_t	len
	)

inlineprotected

Definition at line 78 of file RCWNTupleCnv.h.

                                                              {
       memcpy(target, src, sizeof(double)*len);
       return sizeof(double)*len;
     }

size_t RootHistCnv::RCWNTupleCnv::loadItem	(	char *	src,
		long *	target,
		size_t	len
	)

inlineprotected

Definition at line 82 of file RCWNTupleCnv.h.

                                                            {
       memcpy(target, src, sizeof(long)*len);
       return sizeof(long)*len;
     }

size_t RootHistCnv::RCWNTupleCnv::loadItem	(	char *	src,
		unsigned long *	target,
		size_t	len
	)

inlineprotected

Definition at line 86 of file RCWNTupleCnv.h.

                                                                     {
       memcpy(target, src, sizeof(unsigned long)*len);
       return sizeof(unsigned long)*len;
     }

StatusCode RootHistCnv::RCWNTupleCnv::readData	(	TTree *	rtree,
		INTuple *	pObject,
		long	ievt
	)

protectedvirtual

Read N tuple data.

Implements RootHistCnv::RNTupleCnv.

Definition at line 351 of file RCWNTupleCnv.cpp.

 {
   MsgStream log(msgSvc(), "RCWNTupleCnv::readData");
 
   if (ievt >= rtree->GetEntries()) {
     log << MSG::ERROR << "no more entries in tree to read. max: "
     << rtree->GetEntries() << "  current: " << ievt
     << endmsg;
     return StatusCode::FAILURE;
   }
 
   rtree->GetEvent(ievt);
 
   ievt++;
 
   INTuple::ItemContainer& cols = ntup->items();
   char * src = ntup->buffer();
 
   // copy data from ntup->buffer() to ntup->items()->buffer()
 
   for (INTuple::ItemContainer::iterator i = cols.begin(); i != cols.end(); i++ )   {
 
 
     switch( (*i)->type() )   {
     case DataTypeInfo::BOOL:              // bool
       src += loadItem(src, (bool*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::CHAR:              // char
       src += loadItem(src, (char*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::SHORT:             // short
       src += loadItem(src, (short*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::INT:             // short
       src += loadItem(src, (int*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::LONG:             // long
       src += loadItem(src, (long*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::LONGLONG:         // long long
       src += loadItem(src, (long long*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::UCHAR:             // unsigned char
       src += loadItem(src, (unsigned char*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::USHORT:            // unsigned short
       src += loadItem(src, (unsigned short*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::UINT:            // unsigned short
       src += loadItem(src, (unsigned int*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::ULONG:            // unsigned long
       src += loadItem(src, (unsigned long*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::ULONGLONG:        // unsigned long long
       src += loadItem(src, (unsigned long long*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::FLOAT:            // float
       src += loadItem(src, (float*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::DOUBLE:            // unsigned short
       src += loadItem(src, (double*)(*i)->buffer(), (*i)->length());
       break;
     default:
       break;
     }
 
   }
 
   return StatusCode::SUCCESS;
 }

template<class T >

size_t RootHistCnv::RCWNTupleCnv::saveItem	(	char *	target,
		const T *	src,
		size_t	len
	)

inlineprotected

Definition at line 46 of file RCWNTupleCnv.h.

                                                               {
       long* tar = (long*)target;
       for ( size_t i = 0; i < len; i++ )   {
         *(tar++) = long( *(src++));
       }
       return sizeof(long)*len;
     }

template<typename T >

size_t RootHistCnv::RCWNTupleCnv::saveItem	(	char *	target,
		T *	src,
		size_t	len
	)

inlineprotected

Definition at line 54 of file RCWNTupleCnv.h.

                                                       {
       memcpy(target, src, sizeof(T)*len);
       return sizeof(T)*len;
     }

StatusCode RootHistCnv::RCWNTupleCnv::writeData	(	TTree *	rtree,
		INTuple *	pObject
	)

protectedvirtual

Write N tuple data.

Implements RootHistCnv::RNTupleCnv.

Definition at line 292 of file RCWNTupleCnv.cpp.

 {
   // Fill the tree;
   const INTuple::ItemContainer& cols = nt->items();
   char * tar = nt->buffer();
   for (INTuple::ItemContainer::const_iterator i = cols.begin(); i != cols.end(); i++ )   {
     switch( (*i)->type() )   {
     case DataTypeInfo::BOOL:              // bool
       tar += saveItem(tar, (bool*)(*i)->buffer(),   (*i)->length());
       break;
     case DataTypeInfo::CHAR:              // char
       tar += saveItem(tar, (char*)(*i)->buffer(),   (*i)->length());
       break;
     case DataTypeInfo::SHORT:             // short
       tar += saveItem(tar, (short*)(*i)->buffer(),  (*i)->length());
       break;
     case DataTypeInfo::INT:             // int
       tar += saveItem(tar, (int*)(*i)->buffer(),    (*i)->length());
       break;
     case DataTypeInfo::LONG:             // long
       tar += saveItem(tar, (long*)(*i)->buffer(),   (*i)->length());
       break;
     case DataTypeInfo::LONGLONG:         // long long
       tar += saveItem(tar, (long long*)(*i)->buffer(),   (*i)->length());
       break;
     case DataTypeInfo::UCHAR:             // unsigned char
       tar += saveItem(tar, (unsigned char*)(*i)->buffer(),  (*i)->length());
       break;
     case DataTypeInfo::USHORT:            // unsigned short
       tar += saveItem(tar, (unsigned short*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::UINT:            // unsigned int
       tar += saveItem(tar, (unsigned int*)(*i)->buffer(),   (*i)->length());
       break;
     case DataTypeInfo::ULONG:            // unsigned long
       tar += saveItem(tar, (unsigned long*)(*i)->buffer(),  (*i)->length());
       break;
     case DataTypeInfo::ULONGLONG:        // unsigned long
       tar += saveItem(tar, (unsigned long long*)(*i)->buffer(),  (*i)->length());
       break;
     case DataTypeInfo::FLOAT:            // float
       tar += saveItem(tar, (float*)(*i)->buffer(), (*i)->length());
       break;
     case DataTypeInfo::DOUBLE:            // double
       tar += saveItem(tar, (double*)(*i)->buffer(), (*i)->length());
       break;
     default:
       break;
     }
   }
 
   rtree->Fill();
   nt->reset();
   return StatusCode::SUCCESS;
 }

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

RootHistCnv/src/RCWNTupleCnv.h
RootHistCnv/src/RCWNTupleCnv.cpp

Public Member Functions

Static Public Member Functions

Protected Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation