InputCopyStream Class Reference

A small to stream Data I/O. More...

#include <InputCopyStream.h>

Inheritance diagram for InputCopyStream:

[legend]

Collaboration diagram for InputCopyStream:

[legend]

List of all members.

Public Member Functions
	InputCopyStream (const std::string &name, ISvcLocator *pSvcLocator)
	Standard algorithm Constructor.
virtual	~InputCopyStream ()
	Standard Destructor.
virtual StatusCode	collectLeaves (IRegistry *dir, int level)
	Collect leaves from input file.
virtual StatusCode	collectObjects ()
	Collect all objects to be written tio the output stream.
Private Attributes
bool	m_takeOptionalFromTES
	Allow optional items to be on TES instead of input file.
Friends
class	AlgFactory< InputCopyStream >
class	Factory< InputCopyStream, IAlgorithm *(std::string, ISvcLocator *)>

---

Detailed Description

A small to stream Data I/O.

Author: M.Frank Version: 1.0

Definition at line 13 of file InputCopyStream.h.

---

Constructor & Destructor Documentation

InputCopyStream::InputCopyStream	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Standard algorithm Constructor.

Definition at line 20 of file InputCopyStream.cpp.

 : OutputStream(name, pSvcLocator)
{
  m_doPreLoad      = false;
  m_doPreLoadOpt   = false;
  m_itemNames.push_back("/Event#99999");
  declareProperty("TakeOptionalFromTES", m_takeOptionalFromTES = false, 
                  "Allow optional items to be on TES instead of input file") ;
}

InputCopyStream::~InputCopyStream

(

)

[virtual]

Standard Destructor.

Definition at line 31 of file InputCopyStream.cpp.

                                    {
}

---

Member Function Documentation

StatusCode InputCopyStream::collectLeaves	(	IRegistry *	dir,
		int	level
	)			[virtual]

Collect leaves from input file.

Definition at line 35 of file InputCopyStream.cpp.

                                                                      {
  MsgStream log(msgSvc(), name());
  if ( level < m_currentItem->depth() )   {
    if ( dir )  {
      // dir->object != 0, because was retrived in previous recursion
      m_objects.push_back(dir->object());
      if ( dir->address() )  {
        std::vector<IRegistry*> lfs;
        const std::string& dbase = dir->address()->par()[0];
        // Cololect all pending leaves
        StatusCode iret, sc = m_pDataManager->objectLeaves(dir,lfs);
        if ( sc.isSuccess() )  {
          std::vector<IRegistry*>::iterator i=lfs.begin();
          for(; i!=lfs.end(); ++i)  {
            // Continue if the leaf has the same database as the parent
            if ( (*i)->address() && (*i)->address()->par()[0] == dbase )  {
              DataObject* obj = 0;
              iret = m_pDataProvider->retrieveObject(dir, (*i)->name(), obj);
              if (  iret.isSuccess() )  {
                log << MSG::VERBOSE << "::collectLeaves Success retrieving " << (*i)->name() << endmsg ;
                iret = collectLeaves(*i, level+1);
              }
              if ( !iret.isSuccess() )  {
                log << MSG::VERBOSE << "::collectLeaves Failure retrieving " << (*i)->name() << endmsg ;
                sc = iret;
              }
            }
          }
        }
        return sc;
      }
    }
    return StatusCode::FAILURE;
  }
  return StatusCode::SUCCESS;
}

StatusCode InputCopyStream::collectObjects

(

)

[virtual]

Collect all objects to be written tio the output stream.

Reimplemented from OutputStream.

Definition at line 73 of file InputCopyStream.cpp.

                                             {
  MsgStream log(msgSvc(), name());
  StatusCode status = StatusCode::SUCCESS;
  Items::iterator i;
  // Traverse the tree and collect the requested objects
  for ( i = m_itemList.begin(); i != m_itemList.end(); i++ )    {
    DataObject* obj = 0;
    m_currentItem = (*i);
    log << MSG::VERBOSE << "::collectObjects Looping over mandatory " << m_currentItem->path() << endmsg ;
    StatusCode iret = m_pDataProvider->retrieveObject(m_currentItem->path(), obj);
    if ( iret.isSuccess() )  {
      log << MSG::VERBOSE << "::collectObjects Success retrieving mandatory " << (*i)->path() << endmsg ;
      iret = collectLeaves(obj->registry(), 0);
    }
    if ( !iret.isSuccess() )  {
      log << MSG::ERROR << "Cannot write mandatory object(s) (Not found) "
          << m_currentItem->path() << endmsg;
      status = iret;
    }
  }
  // Traverse the tree and collect the requested objects (tolerate missing itmes here)
  for ( i = m_optItemList.begin(); i != m_optItemList.end(); i++ )    {
    DataObject* obj = 0;
    m_currentItem = (*i);
    StatusCode iret = m_pDataProvider->retrieveObject(m_currentItem->path(), obj);
    if ( iret.isSuccess() )  {
      log << MSG::VERBOSE << "::collectObjects Success retrieving optional " << (*i)->path() << endmsg ;
      if ( m_takeOptionalFromTES ){ // look into TES
        iret = m_pDataManager->traverseSubTree(obj, m_agent);      
      } else { // look only at DST
        iret = collectLeaves(obj->registry(), 0);
      }
    }
    if ( !iret.isSuccess() )    {
      log << MSG::DEBUG << "Ignore request to write non-mandatory object(s) "
          << m_currentItem->path() << endmsg;
    }
  }
  return status;
}

---

Friends And Related Function Documentation

friend class AlgFactory< InputCopyStream > [friend]

Definition at line 14 of file InputCopyStream.h.

friend class Factory< InputCopyStream, IAlgorithm *(std::string, ISvcLocator *)> [friend]

Definition at line 15 of file InputCopyStream.h.

---

Member Data Documentation

bool InputCopyStream::m_takeOptionalFromTES [private]

Allow optional items to be on TES instead of input file.

Definition at line 29 of file InputCopyStream.h.

---

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

• /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v21r9/GaudiSvc/src/PersistencySvc/InputCopyStream.h
• /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v21r9/GaudiSvc/src/PersistencySvc/InputCopyStream.cpp