The Gaudi Framework  master (37c0b60a)
DataStreamTool Class Reference

#include <GaudiKernel/DataStreamTool.h>

Inheritance diagram for DataStreamTool:
Collaboration diagram for DataStreamTool:

Public Types

typedef std::vector< EventSelectorDataStream * > Streams
 
typedef std::vector< Gaudi::Property< std::string > > Properties
 
- Public Types inherited from extends< AlgTool, IDataStreamTool >
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 AlgTool
using Factory = Gaudi::PluginService::Factory< IAlgTool *(const std::string &, const std::string &, const IInterface *)>
 
- Public Types inherited from extends< PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > >, IDataHandleHolder >
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 PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > >
using PropertyHolderImpl = PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > >
 Typedef used to refer to this class from derived classes, as in. More...
 
- Public Types inherited from CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > >
using base_class = CommonMessaging
 
- 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...
 

Public Member Functions

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
 
EventSelectorDataStreamgetStream (const std::string &) override
 Retrieve stream by name. More...
 
EventSelectorDataStreamgetStream (size_type) override
 
EventSelectorDataStreamlastStream () override
 
size_type size () override
 
StatusCode clear () override
 
virtual StreamsgetStreams ()
 
virtual Streams::iterator beginOfStreams ()
 
virtual Streams::iterator endOfStreams ()
 
- Public Member Functions inherited from extends< AlgTool, IDataStreamTool >
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::stringgetInterfaceNames () const override
 Implementation of IInterface::getInterfaceNames. More...
 
- Public Member Functions inherited from AlgTool
StatusCode queryInterface (const InterfaceID &riid, void **ppvUnknown) override
 Query for a given interface. More...
 
const std::stringname () const override
 Retrieve full identifying name of the concrete tool object. More...
 
const std::stringtype () const override
 Retrieve type (concrete class) of the sub-algtool. More...
 
const IInterfaceparent () const override
 Retrieve parent of the sub-algtool. More...
 
StatusCode configure () override
 
StatusCode initialize () override
 
StatusCode start () override
 
StatusCode stop () override
 
StatusCode finalize () override
 
StatusCode terminate () override
 
StatusCode reinitialize () override
 
StatusCode restart () override
 
Gaudi::StateMachine::State FSMState () const override
 
Gaudi::StateMachine::State targetFSMState () const override
 
StatusCode sysInitialize () override
 Initialize AlgTool. More...
 
StatusCode sysStart () override
 Start AlgTool. More...
 
StatusCode sysStop () override
 Stop AlgTool. More...
 
StatusCode sysFinalize () override
 Finalize AlgTool. More...
 
StatusCode sysReinitialize () override
 Initialize AlgTool. More...
 
StatusCode sysRestart () override
 Start AlgTool. More...
 
 AlgTool (std::string type, std::string name, const IInterface *parent)
 Standard Constructor. More...
 
SmartIF< ISvcLocator > & serviceLocator () const override
 Retrieve pointer to service locator. More...
 
ISvcLocatorsvcLoc () const
 shortcut for the method service locator More...
 
IDataProviderSvcevtSvc () const
 accessor to event service service More...
 
IToolSvctoolSvc () const
 The standard ToolSvc service, Return a pointer to the service if present. More...
 
template<class T >
StatusCode service (std::string_view name, T *&svc, bool createIf=true) const
 Access a service by name, creating it if it doesn't already exist. More...
 
template<class T >
StatusCode service (std::string_view type, std::string_view name, T *&svc) const
 Access a service by name, type creating it if it doesn't already exist. More...
 
SmartIF< IServiceservice (std::string_view name, const bool createIf=true, const bool quiet=false) const
 Return a pointer to the service identified by name (or "type/name") More...
 
template<typename T >
SmartIF< T > service (std::string_view name, const bool createIf=true, const bool quiet=false) const
 
template<class T >
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, ToolHandle< T > &hndl, const std::string &doc="none")
 
template<class T >
StatusCode declareTool (ToolHandle< T > &handle, bool createIf=true)
 
template<class T >
StatusCode declareTool (ToolHandle< T > &handle, const std::string &toolTypeAndName, bool createIf=true)
 
template<class T >
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, ToolHandleArray< T > &hndlArr, const std::string &doc="none")
 
template<class T >
void addToolsArray (ToolHandleArray< T > &hndlArr)
 
void acceptDHVisitor (IDataHandleVisitor *) const override
 
void registerTool (IAlgTool *tool) const
 
void deregisterTool (IAlgTool *tool) const
 
const std::vector< IAlgTool * > & tools () const
 
IAuditorSvcauditorSvc () const
 Access the auditor service. More...
 
IMonitorSvcmonitorSvc () const
 Access the monitor service. More...
 
template<class T >
void declareInfo (const std::string &name, const T &var, const std::string &desc) const
 Declare monitoring information. More...
 
void declareInfo (const std::string &name, const std::string &format, const void *var, int size, const std::string &desc) const
 Declare monitoring information (special case) More...
 
 ~AlgTool () override
 
- Public Member Functions inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > > >
std::vector< Gaudi::DataHandle * > inputHandles () const override
 
std::vector< Gaudi::DataHandle * > outputHandles () const override
 
virtual const DataObjIDCollextraInputDeps () const override
 
virtual const DataObjIDCollextraOutputDeps () const override
 
void declare (Gaudi::DataHandle &handle) override
 
void renounce (Gaudi::DataHandle &handle) override
 
bool renounceInput (const DataObjID &id) override
 
const DataObjIDCollinputDataObjs () const override
 
const DataObjIDColloutputDataObjs () const override
 
void addDependency (const DataObjID &id, const Gaudi::DataHandle::Mode &mode) override
 
- Public Member Functions inherited from extends< PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > >, IDataHandleHolder >
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::stringgetInterfaceNames () const override
 Implementation of IInterface::getInterfaceNames. More...
 
- Public Member Functions inherited from PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > >
 PropertyHolder ()=default
 
Gaudi::Details::PropertyBasedeclareProperty (Gaudi::Details::PropertyBase &prop)
 Declare a property. More...
 
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, TYPE &value, const std::string &doc="none")
 Helper to wrap a regular data member and use it as a regular property. More...
 
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, Gaudi::Property< TYPE, VERIFIER, HANDLERS > &prop, const std::string &doc="none")
 Declare a PropertyBase instance setting name and documentation. More...
 
Gaudi::Details::PropertyBasedeclareRemoteProperty (const std::string &name, IProperty *rsvc, const std::string &rname="")
 Declare a remote property. More...
 
StatusCode setProperty (const std::string &name, const Gaudi::Details::PropertyBase &p) override
 set the property from another property with a different name More...
 
StatusCode setProperty (const std::string &s) override
 set the property from the formatted string More...
 
StatusCode setProperty (const Gaudi::Details::PropertyBase &p)
 Set the property from a property. More...
 
virtual StatusCode setProperty (const std::string &name, const Gaudi::Details::PropertyBase &p)=0
 Set the property from a property with a different name. More...
 
virtual StatusCode setProperty (const std::string &s)=0
 Set the property by string. More...
 
StatusCode setProperty (const std::string &name, const char *v)
 Special case for string literals. More...
 
StatusCode setProperty (const std::string &name, const std::string &v)
 Special case for std::string. More...
 
StatusCode setProperty (const std::string &name, const TYPE &value)
 set the property form the value More...
 
StatusCode setPropertyRepr (const std::string &n, const std::string &r) override
 set the property from name and value string representation More...
 
StatusCode getProperty (Gaudi::Details::PropertyBase *p) const override
 get the property More...
 
const Gaudi::Details::PropertyBasegetProperty (std::string_view name) const override
 get the property by name More...
 
StatusCode getProperty (std::string_view n, std::string &v) const override
 convert the property to the string More...
 
const std::vector< Gaudi::Details::PropertyBase * > & getProperties () const override
 get all properties More...
 
bool hasProperty (std::string_view name) const override
 Return true if we have a property with the given name. More...
 
Gaudi::Details::PropertyBaseproperty (std::string_view name) const
 \fixme property and bindPropertiesTo should be protected More...
 
void bindPropertiesTo (Gaudi::Interfaces::IOptionsSvc &optsSvc)
 
 PropertyHolder (const PropertyHolder &)=delete
 
PropertyHolderoperator= (const PropertyHolder &)=delete
 
- Public Member Functions inherited from CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > >
MSG::Level msgLevel () const
 get the cached level (originally extracted from the embedded MsgStream) More...
 
bool msgLevel (MSG::Level lvl) const
 get the output level from the embedded MsgStream 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 &)
 
- Protected Member Functions inherited from AlgTool
template<typename I >
void declareInterface (I *i)
 
std::vector< IAlgTool * > & tools ()
 
- Protected Member Functions inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > > >
void initDataHandleHolder ()
 initializes all handles - called by the sysInitialize method of any descendant of this More...
 
- Protected Member Functions inherited from CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > >
MSG::Level setUpMessaging () const
 Set up local caches. More...
 
MSG::Level resetMessaging ()
 Reinitialize internal states. More...
 
void updateMsgStreamOutputLevel (int level)
 Update the output level of the cached MsgStream. More...
 

Protected Attributes

size_type m_streamID = 0
 
size_type m_streamCount = 0
 
Streams m_streams
 
StreamSpecs m_streamSpecs
 
SmartIF< IIncidentSvcm_incidentSvc = nullptr
 Reference to the incident service. More...
 
- Protected Attributes inherited from AlgTool
std::unique_ptr< IDataHandleVisitorm_updateDataHandles
 Hook for for derived classes to provide a custom visitor for data handles. More...
 
- Protected Attributes inherited from DataHandleHolderBase< PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > > >
DataObjIDColl m_inputDataObjs
 
DataObjIDColl m_outputDataObjs
 

Private Member Functions

 DataStreamTool (const DataStreamTool &)=delete
 Fake copy constructor (never implemented). More...
 
DataStreamTooloperator= (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 38 of file DataStreamTool.h.

Member Typedef Documentation

◆ Properties

◆ Streams

Constructor & Destructor Documentation

◆ DataStreamTool()

DataStreamTool::DataStreamTool ( const DataStreamTool )
privatedelete

Fake copy constructor (never implemented).

Member Function Documentation

◆ addStream()

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

Definition at line 50 of file DataStreamTool.cpp.

50  {
51 
52  if ( getStream( input ) ) { warning() << "Input stream " << input << "already in use" << endmsg; }
53 
54  m_streamSpecs.push_back( input );
55 
56  auto strname = name() + '_' + std::to_string( ++m_streamCount );
57  EventSelectorDataStream* s = nullptr;
58 
59  StatusCode status = createStream( strname, input, s );
60 
61  if ( status.isSuccess() && s ) {
62  s->addRef();
64  status = StatusCode::SUCCESS;
65  } else {
66  if ( s ) {
67  s->release();
68  error() << "Error connecting/creating Stream: " << s << endmsg;
69  }
70  error() << "Error connecting/creating Stream: " << input << endmsg;
71  status = StatusCode::FAILURE;
72  }
73  return status;
74 }

◆ addStreams()

StatusCode DataStreamTool::addStreams ( const StreamSpecs &  inputs)
override

Definition at line 76 of file DataStreamTool.cpp.

76  {
77 
79  for ( auto& i : inputs ) {
80  status = addStream( i );
81  if ( !status.isSuccess() ) break;
82  }
83  return status;
84 }

◆ beginOfStreams()

virtual Streams::iterator DataStreamTool::beginOfStreams ( )
inlinevirtual

Definition at line 78 of file DataStreamTool.h.

78 { return m_streams.begin(); }

◆ clear()

StatusCode DataStreamTool::clear ( )
override

Definition at line 184 of file DataStreamTool.cpp.

184  {
185 
186  StatusCode iret, status = StatusCode::SUCCESS;
187  iret.ignore();
188 
189  // disconnect the streams
190  for ( auto& il : m_streamSpecs ) {
192  if ( s ) {
193  if ( s->isInitialized() ) {
194  iret = finalizeStream( s );
195  if ( !iret.isSuccess() ) {
196  error() << "Error finalizing Stream" << il << endmsg;
197  status = iret;
198  }
199  }
200  iret = eraseStream( il );
201  if ( !iret.isSuccess() ) {
202  error() << "Error diconnecting Stream" << il << endmsg;
203  status = iret;
204  }
205  }
206  }
207 
208  m_streamSpecs.clear();
209 
210  return status;
211 }

◆ connectStream() [1/2]

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

Connect single stream by name.

Definition at line 221 of file DataStreamTool.cpp.

221  {
222  if ( getStream( info ) ) { warning() << "Input stream " << info << "already in use" << endmsg; }
223  auto nam = name() + '_' + std::to_string( ++m_streamCount );
224  EventSelectorDataStream* s = nullptr;
225  StatusCode status = createStream( nam, info, s );
226  if ( status.isSuccess() ) return connectStream( s );
227  s->release();
228  return status;
229 }

◆ connectStream() [2/2]

StatusCode DataStreamTool::connectStream ( EventSelectorDataStream s)
protected

Connect single stream by reference.

Definition at line 213 of file DataStreamTool.cpp.

213  {
214 
215  if ( !s ) return StatusCode::FAILURE;
216  s->addRef();
217  m_streams.push_back( s );
218  return StatusCode::SUCCESS;
219 }

◆ createSelector()

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

Definition at line 114 of file DataStreamTool.cpp.

114  {
115  auto isvc = make_SmartIF( Service::Factory::create( typ, nam, serviceLocator() ).release() );
116  if ( isvc ) {
117  auto isel = isvc.as<IEvtSelector>();
118  if ( isel ) {
119  sel = isel.get();
120  sel->addRef(); // make sure that sel is not left dangling once isel and isvc go out of scope...
121  return StatusCode::SUCCESS;
122  }
123  }
124  sel = nullptr;
125  error() << "Failed to create IEvtSelector " << typ << "/" << nam << endmsg;
126  return StatusCode::FAILURE;
127 }

◆ createStream()

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

Definition at line 161 of file DataStreamTool.cpp.

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

◆ endOfStreams()

virtual Streams::iterator DataStreamTool::endOfStreams ( )
inlinevirtual

Definition at line 80 of file DataStreamTool.h.

80 { return m_streams.end(); }

◆ eraseStream()

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

Definition at line 150 of file DataStreamTool.cpp.

150  {
151 
152  auto i = getStreamIterator( info );
153  if ( i != m_streams.end() ) {
154  ( *i )->release();
155  m_streams.erase( i );
156  return StatusCode::SUCCESS;
157  }
158  return StatusCode::FAILURE;
159 }

◆ finalize()

StatusCode DataStreamTool::finalize ( )
override

Definition at line 86 of file DataStreamTool.cpp.

86  {
87  clear().ignore();
89  return AlgTool::finalize();
90 }

◆ finalizeStream()

StatusCode DataStreamTool::finalizeStream ( EventSelectorDataStream s)
override

Finalize no longer needed stream.

Definition at line 129 of file DataStreamTool.cpp.

129  {
130  if ( s ) {
131  IEvtSelector* sel = s->selector();
132  if ( sel ) {
133  SmartIF<IService> isvc( sel );
134  if ( isvc ) {
135  isvc->finalize().ignore();
136  s->finalize().ignore();
137  // Fire EndStream "Incident"
138  m_incidentSvc->fireIncident( Incident( name(), IncidentType::EndStream ) );
139  return StatusCode::SUCCESS;
140  }
141  // Failed to get service interface of sub-event selector
142  return StatusCode::FAILURE;
143  }
144  // No selector (yet) attached - no need to finalize it!
145  return StatusCode::SUCCESS;
146  }
147  return StatusCode::FAILURE;
148 }

◆ getNextStream()

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

Definition at line 237 of file DataStreamTool.cpp.

237  {
238 
239  EventSelectorDataStream* nextStream = getStream( dsid );
240  if ( !nextStream ) return StatusCode::FAILURE; //<-end of streams reached
241 
242  esds = nextStream;
243  ++m_streamID;
244 
245  return StatusCode::SUCCESS;
246 }

◆ getPreviousStream()

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

Definition at line 248 of file DataStreamTool.cpp.

248  {
249 
250  EventSelectorDataStream* previousStream = getStream( dsid );
251  if ( !previousStream ) return StatusCode::FAILURE; //<-begin of streams reached
252 
253  esds = previousStream;
254  --m_streamID;
255 
256  return StatusCode::SUCCESS;
257 }

◆ getStream() [1/2]

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

Retrieve stream by name.

Definition at line 167 of file DataStreamTool.cpp.

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

◆ getStream() [2/2]

EventSelectorDataStream * DataStreamTool::getStream ( size_type  pos)
override

Definition at line 177 of file DataStreamTool.cpp.

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

◆ getStreamIterator()

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

Definition at line 172 of file DataStreamTool.cpp.

172  {
174  [&]( const EventSelectorDataStream* i ) { return i->definition() == info; } );
175 }

◆ getStreams()

virtual Streams& DataStreamTool::getStreams ( )
inlinevirtual

Definition at line 76 of file DataStreamTool.h.

76 { return m_streams; }

◆ initialize()

StatusCode DataStreamTool::initialize ( )
override

Definition at line 32 of file DataStreamTool.cpp.

32  {
33 
35  if ( !status.isSuccess() ) {
36  fatal() << "Error. Cannot initialize base class." << endmsg;
37  return status;
38  }
39 
40  // Get the references to the services that are needed by the ApplicationMgr itself
41  m_incidentSvc = serviceLocator()->service( "IncidentSvc" );
42  if ( !m_incidentSvc ) {
43  fatal() << "Error retrieving IncidentSvc." << endmsg;
44  return StatusCode::FAILURE;
45  }
46 
47  return StatusCode::SUCCESS;
48 }

◆ initializeStream()

StatusCode DataStreamTool::initializeStream ( EventSelectorDataStream s)
override

Initialize newly opened stream.

Definition at line 92 of file DataStreamTool.cpp.

92  {
93  IEvtSelector* sel = nullptr;
94  StatusCode status = s->initialize();
95  if ( status.isSuccess() ) {
96  status = createSelector( s->name(), s->selectorType(), sel );
97  if ( status.isSuccess() ) {
98  SmartIF<IProperty> prop( sel ); // Att: IProperty, IService used to point to EventSelector
99  SmartIF<IService> isvc( sel );
100  s->setSelector( sel );
101  sel->release(); // No need for this interface anymore, it is passed to the stream
102  if ( prop && isvc ) {
103  for ( const auto& i : s->properties() ) prop->setProperty( i ).ignore();
104  prop->setProperty( Gaudi::Property<int>( "OutputLevel", msgLevel() ) ).ignore();
105  // FIXME: (MCl) Why do we have to initialize the selector here?
106  return isvc->sysInitialize();
107  }
108  }
109  }
110  return StatusCode::FAILURE;
111 }

◆ lastStream()

EventSelectorDataStream * DataStreamTool::lastStream ( )
override

Definition at line 182 of file DataStreamTool.cpp.

182 { return m_streams.back(); }

◆ operator=()

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

Fake assignment operator (never implemented).

◆ size()

size_type DataStreamTool::size ( )
inlineoverride

Definition at line 72 of file DataStreamTool.h.

72 { return m_streams.size(); }

Member Data Documentation

◆ m_incidentSvc

SmartIF<IIncidentSvc> DataStreamTool::m_incidentSvc = nullptr
protected

Reference to the incident service.

Definition at line 101 of file DataStreamTool.h.

◆ m_streamCount

size_type DataStreamTool::m_streamCount = 0
protected

Definition at line 94 of file DataStreamTool.h.

◆ m_streamID

size_type DataStreamTool::m_streamID = 0
protected

Definition at line 92 of file DataStreamTool.h.

◆ m_streams

Streams DataStreamTool::m_streams
protected

Definition at line 96 of file DataStreamTool.h.

◆ m_streamSpecs

StreamSpecs DataStreamTool::m_streamSpecs
protected

Definition at line 98 of file DataStreamTool.h.


The documentation for this class was generated from the following files:
Write.stream
stream
Definition: Write.py:32
DataStreamTool::clear
StatusCode clear() override
Definition: DataStreamTool.cpp:184
DataStreamTool::getStreamIterator
Streams::iterator getStreamIterator(const std::string &)
Definition: DataStreamTool.cpp:172
StatusCode::isSuccess
bool isSuccess() const
Definition: StatusCode.h:314
gaudirun.s
string s
Definition: gaudirun.py:346
SmartIF::reset
void reset(TYPE *ptr=nullptr)
Set the internal pointer to the passed one disposing of the old one.
Definition: SmartIF.h:96
std::find_if
T find_if(T... args)
std::vector::size
T size(T... args)
EventSelectorDataStream::definition
const std::string & definition() const
Retrieve definition string.
Definition: EventSelectorDataStream.h:110
IEvtSelector
Definition: IEvtSelector.h:28
conf.release
string release
Definition: conf.py:27
std::vector::back
T back(T... args)
DataStreamTool::createStream
StatusCode createStream(const std::string &, const std::string &, EventSelectorDataStream *&) override
Definition: DataStreamTool.cpp:161
AlgTool::initialize
StatusCode initialize() override
Definition: AlgTool.cpp:199
CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > >::msgLevel
MSG::Level msgLevel() const
get the cached level (originally extracted from the embedded MsgStream)
Definition: CommonMessaging.h:148
AlgTool::name
const std::string & name() const override
Retrieve full identifying name of the concrete tool object.
Definition: AlgTool.cpp:67
std::vector::push_back
T push_back(T... args)
AlgTool::serviceLocator
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: AlgTool.cpp:88
StatusCode
Definition: StatusCode.h:65
DataStreamTool::finalizeStream
StatusCode finalizeStream(EventSelectorDataStream *) override
Finalize no longer needed stream.
Definition: DataStreamTool.cpp:129
DataStreamTool::createSelector
StatusCode createSelector(const std::string &, const std::string &, IEvtSelector *&) override
Definition: DataStreamTool.cpp:114
DataStreamTool::m_incidentSvc
SmartIF< IIncidentSvc > m_incidentSvc
Reference to the incident service.
Definition: DataStreamTool.h:101
DataStreamTool::connectStream
StatusCode connectStream(EventSelectorDataStream *)
Connect single stream by reference.
Definition: DataStreamTool.cpp:213
std::to_string
T to_string(T... args)
std::vector::erase
T erase(T... args)
SmartIF< IService >
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202
DataStreamTool::addStream
StatusCode addStream(const std::string &) override
Definition: DataStreamTool.cpp:50
IOTest.sel
sel
Definition: IOTest.py:106
StatusCode::ignore
const StatusCode & ignore() const
Allow discarding a StatusCode without warning.
Definition: StatusCode.h:139
DataStreamTool::getStream
EventSelectorDataStream * getStream(const std::string &) override
Retrieve stream by name.
Definition: DataStreamTool.cpp:167
make_SmartIF
SmartIF< IFace > make_SmartIF(IFace *iface)
Definition: SmartIF.h:150
DataStreamTool::eraseStream
StatusCode eraseStream(const std::string &) override
Definition: DataStreamTool.cpp:150
StatusCode::SUCCESS
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
std::vector::begin
T begin(T... args)
DataStreamTool::m_streamID
size_type m_streamID
Definition: DataStreamTool.h:92
EventSelectorDataStream
Definition of class EventSelectorDataStream.
Definition: EventSelectorDataStream.h:55
DataStreamTool::m_streamCount
size_type m_streamCount
Definition: DataStreamTool.h:94
std::vector::end
T end(T... args)
StatusCode::FAILURE
constexpr static const auto FAILURE
Definition: StatusCode.h:101
DataStreamTool::m_streamSpecs
StreamSpecs m_streamSpecs
Definition: DataStreamTool.h:98
Incident
Definition: Incident.h:27
DataStreamTool::m_streams
Streams m_streams
Definition: DataStreamTool.h:96
Gaudi::Property< int >
AlgTool::finalize
StatusCode finalize() override
Definition: AlgTool.cpp:266