#include <GaudiKernel/DataStreamTool.h>

Inheritance diagram for DataStreamTool:

Collaboration diagram for DataStreamTool:

Public Types
typedef std::vector< EventSelectorDataStream * >	Streams

typedef std::vector< StringProperty >	Properties

typedef std::vector< EventSelectorDataStream * >	Streams

typedef std::vector< StringProperty >	Properties

Public Types inherited from extends< BASE, Interfaces >
using	base_class = extends
	Typedef to this class. More...

using	extend_interfaces_base = extend_interfaces< Interfaces...>
	Typedef to the base of this class. More...

using	base_class = extends
	Typedef to this class. More...

using	extend_interfaces_base = extend_interfaces< Interfaces...>
	Typedef to the base of this class. More...

Public Types inherited from extend_interfaces< Interfaces...>
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...

using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...

Public Member Functions
	DataStreamTool (const std::string &type, const std::string &name, const IInterface *parent)
	Standard constructor. More...

	~DataStreamTool () override=default
	Destructor. More...

StatusCode	initialize () override

StatusCode	finalize () override

StatusCode	initializeStream (EventSelectorDataStream *) override
	Initialize newly opened stream. More...

StatusCode	finalizeStream (EventSelectorDataStream *) override
	Finalize no longer needed stream. More...

StatusCode	getNextStream (const EventSelectorDataStream *&, size_type &) override

StatusCode	getPreviousStream (const EventSelectorDataStream *&, size_type &) override

StatusCode	addStream (const std::string &) override

StatusCode	addStreams (const StreamSpecs &) override

StatusCode	eraseStream (const std::string &) override

EventSelectorDataStream *	getStream (const std::string &) override
	Retrieve stream by name. More...

EventSelectorDataStream *	getStream (size_type) override

EventSelectorDataStream *	lastStream () override

size_type	size () override

StatusCode	clear () override

virtual Streams &	getStreams ()

virtual Streams::iterator	beginOfStreams ()

virtual Streams::iterator	endOfStreams ()

	DataStreamTool (const std::string &type, const std::string &name, const IInterface *parent)
	Standard constructor. More...

	~DataStreamTool () override=default
	Destructor. More...

StatusCode	initialize () override

StatusCode	finalize () override

StatusCode	initializeStream (EventSelectorDataStream *) override
	Initialize newly opened stream. More...

StatusCode	finalizeStream (EventSelectorDataStream *) override
	Finalize no longer needed stream. More...

StatusCode	getNextStream (const EventSelectorDataStream *&, size_type &) override

StatusCode	getPreviousStream (const EventSelectorDataStream *&, size_type &) override

StatusCode	addStream (const std::string &) override

StatusCode	addStreams (const StreamSpecs &) override

StatusCode	eraseStream (const std::string &) override

EventSelectorDataStream *	getStream (const std::string &) override
	Retrieve stream by name. More...

EventSelectorDataStream *	getStream (size_type) override

EventSelectorDataStream *	lastStream () override

size_type	size () override

StatusCode	clear () override

virtual Streams &	getStreams ()

virtual Streams::iterator	beginOfStreams ()

virtual Streams::iterator	endOfStreams ()

Public Member Functions inherited from extends< BASE, Interfaces >
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...

StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...

std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...

	~extends () override=default
	Virtual destructor. More...

void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...

StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...

std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...

	~extends () override=default
	Virtual destructor. More...

Public Member Functions inherited from extend_interfaces< Interfaces...>
	~extend_interfaces () override=default
	Virtual destructor. More...

	~extend_interfaces () override=default
	Virtual destructor. More...

Protected Member Functions
StatusCode	createSelector (const std::string &, const std::string &, IEvtSelector *&) override

StatusCode	createStream (const std::string &, const std::string &, EventSelectorDataStream *&) override

StatusCode	connectStream (EventSelectorDataStream *)
	Connect single stream by reference. More...

StatusCode	connectStream (const std::string &)
	Connect single stream by name. More...

Streams::iterator	getStreamIterator (const std::string &)

StatusCode	createSelector (const std::string &, const std::string &, IEvtSelector *&) override

StatusCode	createStream (const std::string &, const std::string &, EventSelectorDataStream *&) override

StatusCode	connectStream (EventSelectorDataStream *)
	Connect single stream by reference. More...

StatusCode	connectStream (const std::string &)
	Connect single stream by name. More...

Streams::iterator	getStreamIterator (const std::string &)

Protected Attributes
size_type	m_streamID = 0

size_type	m_streamCount = 0

Streams	m_streams

StreamSpecs	m_streamSpecs

SmartIF< IIncidentSvc >	m_incidentSvc = nullptr
	Reference to the incident service. More...

Private Member Functions
	DataStreamTool (const DataStreamTool &)=delete
	Fake copy constructor (never implemented). More...

DataStreamTool &	operator= (const DataStreamTool &)=delete
	Fake assignment operator (never implemented). More...

	DataStreamTool (const DataStreamTool &)=delete
	Fake copy constructor (never implemented). More...

DataStreamTool &	operator= (const DataStreamTool &)=delete
	Fake assignment operator (never implemented). More...

Detailed Description

Author: Andres Felipe Osorio Oliveros; Marco Clemencic

Date: 2006-09-21

Definition at line 29 of file DataStreamTool.h.

Member Typedef Documentation

typedef std::vector<StringProperty> DataStreamTool::Properties

Definition at line 33 of file DataStreamTool.h.

typedef std::vector<StringProperty> DataStreamTool::Properties

Definition at line 33 of file DataStreamTool.h.

typedef std::vector<EventSelectorDataStream*> DataStreamTool::Streams

Definition at line 32 of file DataStreamTool.h.

typedef std::vector<EventSelectorDataStream*> DataStreamTool::Streams

Definition at line 32 of file DataStreamTool.h.

Constructor & Destructor Documentation

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

Standard constructor.

Definition at line 25 of file DataStreamTool.cpp.

   : base_class ( type, name , parent )
 {
   //declareInterface<IDataStreamTool>(this);
 }

DataStreamTool::~DataStreamTool ( )

overridedefault

Destructor.

DataStreamTool::DataStreamTool ( const DataStreamTool & )

privatedelete

Fake copy constructor (never implemented).

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

Standard constructor.

DataStreamTool::~DataStreamTool ( )

overridedefault

Destructor.

DataStreamTool::DataStreamTool ( const DataStreamTool & )

privatedelete

Fake copy constructor (never implemented).

Member Function Documentation

StatusCode DataStreamTool::addStream ( const std::string & input )

override

Definition at line 54 of file DataStreamTool.cpp.

                                                             {
 
   if ( getStream(input) )   {
     MsgStream log(msgSvc(), name());
     log << MSG::WARNING << "Input stream " << input << "already in use" << endmsg;
   }
 
   m_streamSpecs.push_back(input);
 
   auto strname = name() + '_' + std::to_string( ++m_streamCount );
   EventSelectorDataStream* s = nullptr;
 
   StatusCode status = createStream(strname, input , s );
 
   if( status.isSuccess() && s ) {
     s->addRef();
     m_streams.push_back(s);
     status = StatusCode::SUCCESS;
   } else {
     MsgStream log(msgSvc(), name());
     if (s) {
       s->release();
       log << MSG::ERROR << "Error connecting/creating Stream: " << s << endmsg;
     }
     log << MSG::ERROR << "Error connecting/creating Stream: " << input << endmsg;
     status = StatusCode::FAILURE;
   }
   return status;
 }

StatusCode DataStreamTool::addStream ( const std::string & )

override

StatusCode DataStreamTool::addStreams ( const StreamSpecs & inputs )

override

Definition at line 84 of file DataStreamTool.cpp.

                                                                 {
 
   StatusCode status = StatusCode::SUCCESS;
   for ( auto& i : inputs ) {
       status = addStream(i);
       if  (!status.isSuccess()) break;
   }
   return status;
 
 }

StatusCode DataStreamTool::addStreams ( const StreamSpecs & )

override

virtual Streams::iterator DataStreamTool::beginOfStreams ( )

inlinevirtual

Definition at line 74 of file DataStreamTool.h.

74 {return m_streams.begin(); };

DataStreamTool::m_streams

Streams m_streams

Definition: DataStreamTool.h:95

virtual Streams::iterator DataStreamTool::beginOfStreams ( )

inlinevirtual

Definition at line 74 of file DataStreamTool.h.

74 {return m_streams.begin(); };

DataStreamTool::m_streams

Streams m_streams

Definition: DataStreamTool.h:95

StatusCode DataStreamTool::clear ( )

override

StatusCode DataStreamTool::clear ( )

override

Definition at line 206 of file DataStreamTool.cpp.

 {
 
   StatusCode iret, status = StatusCode::SUCCESS;
   iret.ignore();
 
   MsgStream log(msgSvc(), name());
 
   // disconnect the streams
   for ( auto& il : m_streamSpecs ) {
     EventSelectorDataStream* s = getStream(il);
     if ( s )   {
       if ( s->isInitialized() )    {
         iret = finalizeStream(s);
         if ( !iret.isSuccess() )  {
           log << MSG::ERROR << "Error finalizing Stream" << il << endmsg;
           status = iret;
         }
       }
       iret = eraseStream( il );
       if ( !iret.isSuccess() )    {
         log << MSG::ERROR << "Error diconnecting Stream" << il << endmsg;
         status = iret;
       }
     }
   }
 
   m_streamSpecs.clear();
 
   return status;
 }

StatusCode DataStreamTool::connectStream ( EventSelectorDataStream * s )

protected

Connect single stream by reference.

Definition at line 239 of file DataStreamTool.cpp.

 {
 
   if ( !s ) return StatusCode::FAILURE;
   s->addRef();
   m_streams.push_back(s);
   return StatusCode::SUCCESS;
 
 }

StatusCode DataStreamTool::connectStream ( EventSelectorDataStream * )

protected

Connect single stream by reference.

StatusCode DataStreamTool::connectStream ( const std::string & info )

protected

Connect single stream by name.

Definition at line 249 of file DataStreamTool.cpp.

 {
   if ( getStream(info) )   {
     MsgStream log(msgSvc(), name());
     log << MSG::WARNING << "Input stream " << info << "already in use" << endmsg;
   }
   auto nam  = name() +  '_' + std::to_string( ++m_streamCount);
   EventSelectorDataStream* s = nullptr;
   StatusCode status = createStream(nam, info, s);
   if ( status.isSuccess() ) return connectStream(s);
   s->release();
   return status;
 }

StatusCode DataStreamTool::connectStream ( const std::string & )

protected

Connect single stream by name.

StatusCode DataStreamTool::createSelector	(	const std::string &	nam,
		const std::string &	typ,
		IEvtSelector *&	sel
	)

overrideprotected

Definition at line 124 of file DataStreamTool.cpp.

                                                                                                         {
   auto isvc = make_SmartIF( Service::Factory::create(typ, nam, serviceLocator()) );
   if ( isvc ) {
     auto isel = isvc.as<IEvtSelector>();
     if ( isel ) {
       sel = isel.get();
       sel->addRef(); // make sure that sel is not left dangling once isel and isvc go out of scope...
       return StatusCode::SUCCESS;
     }
   }
   sel = nullptr;
   MsgStream log(msgSvc(), name());
   log << MSG::ERROR << "Failed to create IEvtSelector " << typ << "/" << nam << endmsg;
   return StatusCode::FAILURE;
 }

StatusCode DataStreamTool::createSelector	(	const std::string &	,
		const std::string &	,
		IEvtSelector *&
	)

overrideprotected

StatusCode DataStreamTool::createStream	(	const std::string &	,
		const std::string &	,
		EventSelectorDataStream *&
	)

overrideprotected

StatusCode DataStreamTool::createStream	(	const std::string &	nam,
		const std::string &	info,
		EventSelectorDataStream *&	stream
	)

overrideprotected

Definition at line 174 of file DataStreamTool.cpp.

                                                                            {
   stream = new EventSelectorDataStream(nam, info, serviceLocator());
   return StatusCode::SUCCESS;
 }

virtual Streams::iterator DataStreamTool::endOfStreams ( )

inlinevirtual

Definition at line 76 of file DataStreamTool.h.

76 {return m_streams.end(); };

DataStreamTool::m_streams

Streams m_streams

Definition: DataStreamTool.h:95

virtual Streams::iterator DataStreamTool::endOfStreams ( )

inlinevirtual

Definition at line 76 of file DataStreamTool.h.

76 {return m_streams.end(); };

DataStreamTool::m_streams

Streams m_streams

Definition: DataStreamTool.h:95

StatusCode DataStreamTool::eraseStream ( const std::string & )

override

StatusCode DataStreamTool::eraseStream ( const std::string & info )

override

Definition at line 163 of file DataStreamTool.cpp.

                                                                  {
 
   auto i = getStreamIterator(info);
   if ( i !=  m_streams.end() )   {
     (*i)->release();
     m_streams.erase(i);
     return StatusCode::SUCCESS;
   }
   return StatusCode::FAILURE;
 }

StatusCode DataStreamTool::finalize ( )

override

StatusCode DataStreamTool::finalize ( )

override

Definition at line 95 of file DataStreamTool.cpp.

                                     {
   clear().ignore();
   m_incidentSvc.reset();
   return AlgTool::finalize();
 }

StatusCode DataStreamTool::finalizeStream ( EventSelectorDataStream * s )

override

Finalize no longer needed stream.

Definition at line 141 of file DataStreamTool.cpp.

                                                                       {
   if ( s )    {
     IEvtSelector* sel = s->selector();
     if ( sel )    {
       SmartIF<IService> isvc(sel);
       if ( isvc )   {
         isvc->finalize().ignore();
         s->finalize().ignore();
         // Fire EndStream "Incident"
         m_incidentSvc->fireIncident(Incident(name(),IncidentType::EndStream));
         return StatusCode::SUCCESS;
       }
       // Failed to get service interface of sub-event selector
       return StatusCode::FAILURE;
     }
     // No selector (yet) attached - no need to finalize it!
     return StatusCode::SUCCESS;
   }
   return StatusCode::FAILURE;
 }

StatusCode DataStreamTool::finalizeStream ( EventSelectorDataStream * )

override

Finalize no longer needed stream.

StatusCode DataStreamTool::getNextStream	(	const EventSelectorDataStream *&	esds,
		size_type &	dsid
	)

override

Definition at line 270 of file DataStreamTool.cpp.

 {
 
   EventSelectorDataStream * nextStream = getStream(dsid);
   if ( !nextStream ) return StatusCode::FAILURE; //<-end of streams reached
 
   esds = nextStream;
   ++m_streamID;
 
   return StatusCode::SUCCESS;
 
 }

StatusCode DataStreamTool::getNextStream	(	const EventSelectorDataStream *&	,
		size_type &
	)

override

StatusCode DataStreamTool::getPreviousStream	(	const EventSelectorDataStream *&	esds,
		size_type &	dsid
	)

override

Definition at line 283 of file DataStreamTool.cpp.

 {
 
   EventSelectorDataStream * previousStream = getStream(dsid);
   if (  !previousStream ) return StatusCode::FAILURE; //<-begin of streams reached
 
   esds = previousStream;
   --m_streamID;
 
   return StatusCode::SUCCESS;
 
 }

StatusCode DataStreamTool::getPreviousStream	(	const EventSelectorDataStream *&	,
		size_type &
	)

override

EventSelectorDataStream* DataStreamTool::getStream ( const std::string & )

override

Retrieve stream by name.

EventSelectorDataStream * DataStreamTool::getStream ( const std::string & info )

override

Retrieve stream by name.

Definition at line 181 of file DataStreamTool.cpp.

                                                                            {
   auto i = getStreamIterator(info);
   return   i != m_streams.end() ? *i : nullptr;
 }

EventSelectorDataStream* DataStreamTool::getStream ( size_type )

override

EventSelectorDataStream * DataStreamTool::getStream ( size_type pos )

override

Definition at line 193 of file DataStreamTool.cpp.

                                                                    {
   // pos has to point inside the vector
   return  ( (pos >= 0) && ((size_t)pos < m_streams.size()) ) ? m_streams[pos]
                                                              : nullptr;
 }

Streams::iterator DataStreamTool::getStreamIterator ( const std::string & )

protected

DataStreamTool::Streams::iterator DataStreamTool::getStreamIterator ( const std::string & info )

protected

Definition at line 186 of file DataStreamTool.cpp.

                                                                                         {
   return std::find_if( std::begin(m_streams), std::end(m_streams),
                        [&](const EventSelectorDataStream* i) {
                            return i->definition()==info;
   });
 }

virtual Streams& DataStreamTool::getStreams ( )

inlinevirtual

Definition at line 72 of file DataStreamTool.h.

72 { return m_streams; };

DataStreamTool::m_streams

Streams m_streams

Definition: DataStreamTool.h:95

virtual Streams& DataStreamTool::getStreams ( )

inlinevirtual

Definition at line 72 of file DataStreamTool.h.

72 { return m_streams; };

DataStreamTool::m_streams

Streams m_streams

Definition: DataStreamTool.h:95

StatusCode DataStreamTool::initialize ( )

override

Definition at line 33 of file DataStreamTool.cpp.

                                       {
 
   MsgStream logger(msgSvc(), name());
 
   StatusCode status = AlgTool::initialize();
   if( !status.isSuccess() )  {
     logger << MSG::FATAL << "Error. Cannot initialize base class." << endmsg;
     return status;
   }
 
   // Get the references to the services that are needed by the ApplicationMgr itself
   m_incidentSvc = serviceLocator()->service("IncidentSvc");
   if( !m_incidentSvc )  {
     logger << MSG::FATAL << "Error retrieving IncidentSvc." << endmsg;
     return StatusCode::FAILURE;
   }
 
   return StatusCode::SUCCESS;
 
 }

StatusCode DataStreamTool::initialize ( )

override

StatusCode DataStreamTool::initializeStream ( EventSelectorDataStream * s )

override

Initialize newly opened stream.

Definition at line 101 of file DataStreamTool.cpp.

                                                                         {
   IEvtSelector* sel = nullptr;
   StatusCode status = s->initialize();
   if ( status.isSuccess() )   {
     status = createSelector(s->name(), s->selectorType(), sel);
     if ( status.isSuccess() )   {
       SmartIF<IProperty> prop(sel); //Att: IProperty, IService used to point to EventSelector
       SmartIF<IService>  isvc(sel);
       s->setSelector(sel);
       sel->release();  // No need for this interface anymore, it is passed to the stream
       if ( prop && isvc )   {
         for( const auto& i : s->properties() ) prop->setProperty(i).ignore();
         int output_level = this->outputLevel();
         prop->setProperty(IntegerProperty("OutputLevel",output_level)).ignore();
         // FIXME: (MCl) Why do we have to initialize the selector here?
         return isvc->sysInitialize();
       }
     }
   }
   return StatusCode::FAILURE;
 }

StatusCode DataStreamTool::initializeStream ( EventSelectorDataStream * )

override

Initialize newly opened stream.

EventSelectorDataStream * DataStreamTool::lastStream ( )

override

Definition at line 199 of file DataStreamTool.cpp.

 {
   return m_streams.back();
 }

EventSelectorDataStream* DataStreamTool::lastStream ( )

override

DataStreamTool& DataStreamTool::operator= ( const DataStreamTool & )

privatedelete

Fake assignment operator (never implemented).

DataStreamTool& DataStreamTool::operator= ( const DataStreamTool & )

privatedelete

Fake assignment operator (never implemented).

size_type DataStreamTool::size ( )

inlineoverride

Definition at line 68 of file DataStreamTool.h.

68 { return m_streams.size(); };

DataStreamTool::m_streams

Streams m_streams

Definition: DataStreamTool.h:95

size_type DataStreamTool::size ( )

inlineoverride

Definition at line 68 of file DataStreamTool.h.

68 { return m_streams.size(); };

DataStreamTool::m_streams

Streams m_streams

Definition: DataStreamTool.h:95

Member Data Documentation

SmartIF< IIncidentSvc > DataStreamTool::m_incidentSvc = nullptr

protected

Reference to the incident service.

Definition at line 100 of file DataStreamTool.h.

size_type DataStreamTool::m_streamCount = 0

protected

Definition at line 93 of file DataStreamTool.h.

size_type DataStreamTool::m_streamID = 0

protected

Definition at line 91 of file DataStreamTool.h.

Streams DataStreamTool::m_streams

protected

Definition at line 95 of file DataStreamTool.h.

StreamSpecs DataStreamTool::m_streamSpecs

protected

Definition at line 97 of file DataStreamTool.h.

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

InstallArea/x86_64-slc6-gcc49-opt/include/GaudiKernel/DataStreamTool.h
GaudiKernel/src/Lib/DataStreamTool.cpp

Public Types

Public Member Functions

Protected Member Functions

Protected Attributes

Private Member Functions

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation