ByteStreamOutputStreamCopyTool Class Reference

This is a tool that implements the IAthenaOutputStreamTool for copying ByteStream from input. More...

#include <ByteStreamOutputStreamCopyTool.h>

Inheritance diagram for ByteStreamOutputStreamCopyTool:

Collaboration diagram for ByteStreamOutputStreamCopyTool:

Public Member Functions
	ByteStreamOutputStreamCopyTool (const std::string &type, const std::string &name, const IInterface *parent)
	Constructor. More...
virtual StatusCode	initialize () override
	Initialize. More...
virtual StatusCode	connectOutput (const std::string &outputName="") override
	Connect to the output stream Must connectOutput BEFORE streaming Only specify "outputName" if one wants to override jobOptions. More...
virtual StatusCode	commitOutput (bool doCommit=false) override
	Commit the output stream after having streamed out objects Must commitOutput AFTER streaming. More...
virtual StatusCode	finalizeOutput () override
	Finalize the output stream after the last commit, e.g. More...
virtual StatusCode	connectServices (const std::string &dataStore, const std::string &cnvSvc, bool extendProvenenceRecord=false) override
	No need to connect Services. More...
virtual StatusCode	streamObjects (const TypeKeyPairs &typeKeys, const std::string &outputName="") override
	No object written for this tool. More...
virtual StatusCode	streamObjects (const DataObjectVec &dataObjects, const std::string &outputName="") override
	no stream of vector of objects either. More...
virtual StatusCode	getInputItemList (SG::IFolder *m_p2BWrittenFromTool) override
	Get ItemList from the OutputStreamTool (e.g. all input objects) More...

Private Attributes
ServiceHandle< IByteStreamOutputSvc >	m_outputSvc
	Handle for BS output Svc. More...
ServiceHandle< IByteStreamInputSvc >	m_inputSvc
	Handle for BS input Svc. More...

Detailed Description

This is a tool that implements the IAthenaOutputStreamTool for copying ByteStream from input.

Definition at line 38 of file ByteStreamOutputStreamCopyTool.h.

Constructor & Destructor Documentation

ByteStreamOutputStreamCopyTool()

ByteStreamOutputStreamCopyTool::ByteStreamOutputStreamCopyTool	(	const std::string &	type,
		const std::string &	name,
		const IInterface *	parent
	)

Constructor.

Definition at line 17 of file ByteStreamOutputStreamCopyTool.cxx.

  : base_class(type, name, parent),
    m_outputSvc("ByteStreamEventStorageOutputSvc", name),
    m_inputSvc("ByteStreamEventStorageInputSvc", name)
{
   // Declare IAthenaOutputStreamTool interface
   declareInterface<IAthenaOutputStreamTool>(this);
   declareProperty("ByteStreamOutputSvc", m_outputSvc);
   declareProperty("ByteStreamInputSvc",  m_inputSvc);
}

Member Function Documentation

commitOutput()

StatusCode ByteStreamOutputStreamCopyTool::commitOutput ( bool  doCommit = false )

overridevirtual

Commit the output stream after having streamed out objects Must commitOutput AFTER streaming.

Definition at line 56 of file ByteStreamOutputStreamCopyTool.cxx.

                                                             {
 
   ATH_MSG_DEBUG("In commitOutput");
   const RawEvent* re = m_inputSvc->currentEvent() ; 
   if(!re){
     ATH_MSG_ERROR(" failed to get the current event from ByteStreamInputSvc");
     return StatusCode::FAILURE ; 
   }
   if( ! m_outputSvc->putEvent(re) ) {
     ATH_MSG_ERROR(" failed to write event to ByteStreamOutputSvc");
     return StatusCode::FAILURE ; 
   }
   ATH_MSG_DEBUG(" done in commitOutput");
   return StatusCode::SUCCESS;
}

connectOutput()

StatusCode ByteStreamOutputStreamCopyTool::connectOutput ( const std::string &  outputName = "" )

overridevirtual

Connect to the output stream Must connectOutput BEFORE streaming Only specify "outputName" if one wants to override jobOptions.

Do nothing for connectOutput

Definition at line 51 of file ByteStreamOutputStreamCopyTool.cxx.

                                                                           {
   return StatusCode::SUCCESS;
}

connectServices()

StatusCode ByteStreamOutputStreamCopyTool::connectServices ( const std::string &  dataStore, const std::string &  cnvSvc, bool  extendProvenenceRecord = false  )

overridevirtual

No need to connect Services.

Do nothing for connectServices

Definition at line 44 of file ByteStreamOutputStreamCopyTool.cxx.

            {
   return StatusCode::SUCCESS;
}

finalizeOutput()

StatusCode ByteStreamOutputStreamCopyTool::finalizeOutput ( )

overridevirtual

Finalize the output stream after the last commit, e.g.

in finalize

Definition at line 72 of file ByteStreamOutputStreamCopyTool.cxx.

                                                          {
   return StatusCode::SUCCESS;
}

getInputItemList()

StatusCode ByteStreamOutputStreamCopyTool::getInputItemList ( SG::IFolder *  m_p2BWrittenFromTool )

overridevirtual

Get ItemList from the OutputStreamTool (e.g. all input objects)

Definition at line 92 of file ByteStreamOutputStreamCopyTool.cxx.

                                                                        {
   return StatusCode::SUCCESS;
}

initialize()

StatusCode ByteStreamOutputStreamCopyTool::initialize ( )

overridevirtual

Initialize.

Definition at line 32 of file ByteStreamOutputStreamCopyTool.cxx.

                                                      {
 
   ATH_MSG_INFO("Initializing");
 
   // retrieve services
   ATH_CHECK( m_inputSvc.retrieve() );
   ATH_CHECK( m_outputSvc.retrieve() );
 
   return StatusCode::SUCCESS;
}

streamObjects() [1/2]

StatusCode ByteStreamOutputStreamCopyTool::streamObjects ( const DataObjectVec &  dataObjects, const std::string &  outputName = ""  )

overridevirtual

no stream of vector of objects either.

Definition at line 84 of file ByteStreamOutputStreamCopyTool.cxx.

    {
   if (dataObjects.size() != 0){
      ATH_MSG_WARNING("Streaming objects is not supported. The whole input event is written out");
   }
   return StatusCode::SUCCESS;
}

streamObjects() [2/2]

StatusCode ByteStreamOutputStreamCopyTool::streamObjects ( const TypeKeyPairs &  typeKeys, const std::string &  outputName = ""  )

overridevirtual

No object written for this tool.

Definition at line 76 of file ByteStreamOutputStreamCopyTool.cxx.

    {
   if (typeKeys.size() != 0){
     ATH_MSG_WARNING("Streaming objects is not supported. The whole input event is written out");
   }
   return StatusCode::SUCCESS;
}

Member Data Documentation

m_inputSvc

ServiceHandle<IByteStreamInputSvc> ByteStreamOutputStreamCopyTool::m_inputSvc

private

Handle for BS input Svc.

Definition at line 79 of file ByteStreamOutputStreamCopyTool.h.

m_outputSvc

ServiceHandle<IByteStreamOutputSvc> ByteStreamOutputStreamCopyTool::m_outputSvc

private

Handle for BS output Svc.

Definition at line 76 of file ByteStreamOutputStreamCopyTool.h.

---

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

• ByteStreamOutputStreamCopyTool.h
• ByteStreamOutputStreamCopyTool.cxx