Gaudi Framework, version v20r2
	Generated: 18 Jul 2008

InputCopyStream Class Reference

#include <InputCopyStream.h>

Inheritance diagram for InputCopyStream:

[legend]Collaboration diagram for InputCopyStream:

[legend]List of all members.

---

Detailed Description

A small to stream Data I/O.

Author: M.Frank Version: 1.0

Definition at line 13 of file InputCopyStream.h.

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.
Friends
class	AlgFactory< InputCopyStream >
class	Factory< InputCopyStream, IAlgorithm *(std::string, ISvcLocator *)>

---

Constructor & Destructor Documentation

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

Standard algorithm Constructor.

Definition at line 19 of file InputCopyStream.cpp.

 : OutputStream(name, pSvcLocator)
{
  m_doPreLoad      = false;
  m_doPreLoadOpt   = false;
  m_itemNames.push_back("/Event#99999");
}

InputCopyStream::~InputCopyStream

(

)

[virtual]

Standard Destructor.

Definition at line 28 of file InputCopyStream.cpp.

                                    {
}

---

Member Function Documentation

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

Collect leaves from input file.

Definition at line 32 of file InputCopyStream.cpp.

References StatusCode::FAILURE, StatusCode::isSuccess(), OutputStream::m_objects, OutputStream::m_pDataManager, OutputStream::m_pDataProvider, IDataManagerSvc::objectLeaves(), IDataProviderSvc::retrieveObject(), and StatusCode::SUCCESS.

Referenced by collectObjects().

                                                                      {
  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() )  {
                iret = collectLeaves(*i, level+1);
              }
              if ( !iret.isSuccess() )  {
                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 67 of file InputCopyStream.cpp.

References std::vector< _Tp, _Alloc >::begin(), collectLeaves(), MSG::DEBUG, std::vector< _Tp, _Alloc >::end(), endmsg(), MSG::ERROR, StatusCode::isSuccess(), OutputStream::m_currentItem, OutputStream::m_itemList, OutputStream::m_optItemList, OutputStream::m_pDataProvider, Algorithm::msgSvc(), Algorithm::name(), DataStoreItem::path(), IDataProviderSvc::retrieveObject(), and StatusCode::SUCCESS.

                                             {
  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);
    StatusCode iret = m_pDataProvider->retrieveObject(m_currentItem->path(), obj);
    if ( iret.isSuccess() )  {
      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() )  {
      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.

---

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

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

---