The Gaudi Framework  v30r3 (a5ef0a68)
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 (const std::string &type, const 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...
 
StatusCode setProperties ()
 Method for setting declared properties to the values specified in the jobOptions via the job option service. More...
 
template<class T >
StatusCode service (const std::string &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 (const std::string &type, const std::string &name, T *&svc) const
 Access a service by name, type creating it if it doesn't already exist. More...
 
SmartIF< IServiceservice (const std::string &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 (const std::string &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, 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
 
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 Gaudi::Details::PropertyBase &p) override
 set the property form another property More...
 
StatusCode setProperty (const std::string &s) override
 set the property from the formatted string More...
 
StatusCode setProperty (const std::string &n, const std::string &v) override
 set the property from name and the value More...
 
StatusCode setProperty (const std::string &name, const TYPE &value)
 set the property form the value More...
 
StatusCode getProperty (Gaudi::Details::PropertyBase *p) const override
 get the property More...
 
const Gaudi::Details::PropertyBasegetProperty (const std::string &name) const override
 get the property by name More...
 
StatusCode getProperty (const std::string &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 (const std::string &name) const override
 Return true if we have a property with the given name. More...
 
 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...
 
MSG::Level outputLevel () const
 Backward compatibility function for getting the output level. More...
 
- Public Member Functions inherited from CommonMessagingBase
virtual ~CommonMessagingBase ()=default
 Virtual destructor. More...
 
const SmartIF< IMessageSvc > & msgSvc () const
 The standard message service. More...
 
MsgStreammsgStream () const
 Return an uninitialized MsgStream. More...
 
MsgStreammsgStream (const MSG::Level level) const
 Predefined configurable message stream for the efficient printouts. More...
 
MsgStreamalways () const
 shortcut for the method msgStream(MSG::ALWAYS) More...
 
MsgStreamfatal () const
 shortcut for the method msgStream(MSG::FATAL) More...
 
MsgStreamerr () const
 shortcut for the method msgStream(MSG::ERROR) More...
 
MsgStreamerror () const
 shortcut for the method msgStream(MSG::ERROR) More...
 
MsgStreamwarning () const
 shortcut for the method msgStream(MSG::WARNING) More...
 
MsgStreaminfo () const
 shortcut for the method msgStream(MSG::INFO) More...
 
MsgStreamdebug () const
 shortcut for the method msgStream(MSG::DEBUG) More...
 
MsgStreamverbose () const
 shortcut for the method msgStream(MSG::VERBOSE) More...
 
MsgStreammsg () const
 shortcut for the method msgStream(MSG::INFO) 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 PropertyHolder< CommonMessaging< implements< IAlgTool, IDataHandleHolder, IProperty, IStateful > > >
Gaudi::Details::PropertyBaseproperty (const std::string &name) const
 
- 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 28 of file DataStreamTool.h.

Member Typedef Documentation

Constructor & Destructor Documentation

DataStreamTool::DataStreamTool ( const DataStreamTool )
privatedelete

Fake copy constructor (never implemented).

Member Function Documentation

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

Definition at line 41 of file DataStreamTool.cpp.

42 {
43 
44  if ( getStream( input ) ) {
45  warning() << "Input stream " << input << "already in use" << endmsg;
46  }
47 
48  m_streamSpecs.push_back( input );
49 
50  auto strname = name() + '_' + std::to_string( ++m_streamCount );
51  EventSelectorDataStream* s = nullptr;
52 
53  StatusCode status = createStream( strname, input, s );
54 
55  if ( status.isSuccess() && s ) {
56  s->addRef();
57  m_streams.push_back( s );
58  status = StatusCode::SUCCESS;
59  } else {
60  if ( s ) {
61  s->release();
62  error() << "Error connecting/creating Stream: " << s << endmsg;
63  }
64  error() << "Error connecting/creating Stream: " << input << endmsg;
65  status = StatusCode::FAILURE;
66  }
67  return status;
68 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
bool isSuccess() const
Definition: StatusCode.h:287
T to_string(T...args)
StatusCode createStream(const std::string &, const std::string &, EventSelectorDataStream *&) override
T push_back(T...args)
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
MsgStream & warning() const
shortcut for the method msgStream(MSG::WARNING)
unsigned long addRef() override
Reference Interface instance.
Definition: implements.h:39
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
EventSelectorDataStream * getStream(const std::string &) override
Retrieve stream by name.
const std::string & name() const override
Retrieve full identifying name of the concrete tool object.
Definition: AlgTool.cpp:62
Definition of class EventSelectorDataStream.
size_type m_streamCount
string s
Definition: gaudirun.py:253
StreamSpecs m_streamSpecs
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
unsigned long release() override
Release Interface instance.
Definition: implements.h:41
StatusCode DataStreamTool::addStreams ( const StreamSpecs &  inputs)
override

Definition at line 70 of file DataStreamTool.cpp.

71 {
72 
74  for ( auto& i : inputs ) {
75  status = addStream( i );
76  if ( !status.isSuccess() ) break;
77  }
78  return status;
79 }
bool isSuccess() const
Definition: StatusCode.h:287
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
StatusCode addStream(const std::string &) override
virtual Streams::iterator DataStreamTool::beginOfStreams ( )
inlinevirtual

Definition at line 69 of file DataStreamTool.h.

69 { return m_streams.begin(); };
T begin(T...args)
StatusCode DataStreamTool::clear ( )
override

Definition at line 188 of file DataStreamTool.cpp.

189 {
190 
191  StatusCode iret, status = StatusCode::SUCCESS;
192  iret.ignore();
193 
194  // disconnect the streams
195  for ( auto& il : m_streamSpecs ) {
197  if ( s ) {
198  if ( s->isInitialized() ) {
199  iret = finalizeStream( s );
200  if ( !iret.isSuccess() ) {
201  error() << "Error finalizing Stream" << il << endmsg;
202  status = iret;
203  }
204  }
205  iret = eraseStream( il );
206  if ( !iret.isSuccess() ) {
207  error() << "Error diconnecting Stream" << il << endmsg;
208  status = iret;
209  }
210  }
211  }
212 
213  m_streamSpecs.clear();
214 
215  return status;
216 }
bool isInitialized() const
Check initialization status.
bool isSuccess() const
Definition: StatusCode.h:287
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
StatusCode finalizeStream(EventSelectorDataStream *) override
Finalize no longer needed stream.
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
EventSelectorDataStream * getStream(const std::string &) override
Retrieve stream by name.
StatusCode eraseStream(const std::string &) override
Definition of class EventSelectorDataStream.
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:165
string s
Definition: gaudirun.py:253
StreamSpecs m_streamSpecs
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode DataStreamTool::connectStream ( EventSelectorDataStream s)
protected

Connect single stream by reference.

Definition at line 218 of file DataStreamTool.cpp.

219 {
220 
221  if ( !s ) return StatusCode::FAILURE;
222  s->addRef();
223  m_streams.push_back( s );
224  return StatusCode::SUCCESS;
225 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
T push_back(T...args)
unsigned long addRef() override
Reference Interface instance.
Definition: implements.h:39
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
StatusCode DataStreamTool::connectStream ( const std::string info)
protected

Connect single stream by name.

Definition at line 227 of file DataStreamTool.cpp.

228 {
229  if ( getStream( info ) ) {
230  warning() << "Input stream " << info << "already in use" << endmsg;
231  }
232  auto nam = name() + '_' + std::to_string( ++m_streamCount );
233  EventSelectorDataStream* s = nullptr;
234  StatusCode status = createStream( nam, info, s );
235  if ( status.isSuccess() ) return connectStream( s );
236  s->release();
237  return status;
238 }
bool isSuccess() const
Definition: StatusCode.h:287
T to_string(T...args)
StatusCode createStream(const std::string &, const std::string &, EventSelectorDataStream *&) override
MsgStream & warning() const
shortcut for the method msgStream(MSG::WARNING)
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
StatusCode connectStream(EventSelectorDataStream *)
Connect single stream by reference.
EventSelectorDataStream * getStream(const std::string &) override
Retrieve stream by name.
const std::string & name() const override
Retrieve full identifying name of the concrete tool object.
Definition: AlgTool.cpp:62
Definition of class EventSelectorDataStream.
size_type m_streamCount
string s
Definition: gaudirun.py:253
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
unsigned long release() override
Release Interface instance.
Definition: implements.h:41
StatusCode DataStreamTool::createSelector ( const std::string nam,
const std::string typ,
IEvtSelector *&  sel 
)
overrideprotected

Definition at line 111 of file DataStreamTool.cpp.

112 {
113  auto isvc = make_SmartIF( Service::Factory::create( typ, nam, serviceLocator() ).release() );
114  if ( isvc ) {
115  auto isel = isvc.as<IEvtSelector>();
116  if ( isel ) {
117  sel = isel.get();
118  sel->addRef(); // make sure that sel is not left dangling once isel and isvc go out of scope...
119  return StatusCode::SUCCESS;
120  }
121  }
122  sel = nullptr;
123  error() << "Failed to create IEvtSelector " << typ << "/" << nam << endmsg;
124  return StatusCode::FAILURE;
125 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: AlgTool.cpp:83
The Event Selector Interface.
Definition: IEvtSelector.h:18
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
virtual unsigned long addRef()=0
Increment the reference count of Interface instance.
SmartIF< IFace > make_SmartIF(IFace *iface)
Definition: SmartIF.h:152
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode DataStreamTool::createStream ( const std::string nam,
const std::string info,
EventSelectorDataStream *&  stream 
)
overrideprotected

Definition at line 161 of file DataStreamTool.cpp.

163 {
164  stream = new EventSelectorDataStream( nam, info, serviceLocator() );
165  return StatusCode::SUCCESS;
166 }
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: AlgTool.cpp:83
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
Definition of class EventSelectorDataStream.
virtual Streams::iterator DataStreamTool::endOfStreams ( )
inlinevirtual

Definition at line 71 of file DataStreamTool.h.

71 { return m_streams.end(); };
T end(T...args)
StatusCode DataStreamTool::eraseStream ( const std::string info)
override

Definition at line 149 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 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
Streams::iterator getStreamIterator(const std::string &)
T end(T...args)
T erase(T...args)
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
StatusCode DataStreamTool::finalize ( )
override

Definition at line 81 of file DataStreamTool.cpp.

82 {
83  clear().ignore();
85  return AlgTool::finalize();
86 }
StatusCode clear() override
StatusCode finalize() override
Definition: AlgTool.cpp:293
SmartIF< IIncidentSvc > m_incidentSvc
Reference to the incident service.
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:165
void reset(TYPE *ptr=nullptr)
Set the internal pointer to the passed one disposing of the old one.
Definition: SmartIF.h:92
StatusCode DataStreamTool::finalizeStream ( EventSelectorDataStream s)
override

Finalize no longer needed stream.

Definition at line 127 of file DataStreamTool.cpp.

128 {
129  if ( s ) {
130  IEvtSelector* sel = s->selector();
131  if ( sel ) {
132  SmartIF<IService> isvc( sel );
133  if ( isvc ) {
134  isvc->finalize().ignore();
135  s->finalize().ignore();
136  // Fire EndStream "Incident"
137  m_incidentSvc->fireIncident( Incident( name(), IncidentType::EndStream ) );
138  return StatusCode::SUCCESS;
139  }
140  // Failed to get service interface of sub-event selector
141  return StatusCode::FAILURE;
142  }
143  // No selector (yet) attached - no need to finalize it!
144  return StatusCode::SUCCESS;
145  }
146  return StatusCode::FAILURE;
147 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
The Event Selector Interface.
Definition: IEvtSelector.h:18
IEvtSelector * selector() const
Retrieve event selector object.
sel
Definition: IOTest.py:95
virtual void fireIncident(const Incident &incident)=0
Fire an Incident.
virtual StatusCode finalize()
Finalize stream and release resources.
SmartIF< IIncidentSvc > m_incidentSvc
Reference to the incident service.
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
const std::string & name() const override
Retrieve full identifying name of the concrete tool object.
Definition: AlgTool.cpp:62
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:165
Base class for all Incidents (computing events).
Definition: Incident.h:17
StatusCode DataStreamTool::getNextStream ( const EventSelectorDataStream *&  esds,
size_type &  dsid 
)
override

Definition at line 246 of file DataStreamTool.cpp.

247 {
248 
249  EventSelectorDataStream* nextStream = getStream( dsid );
250  if ( !nextStream ) return StatusCode::FAILURE; //<-end of streams reached
251 
252  esds = nextStream;
253  ++m_streamID;
254 
255  return StatusCode::SUCCESS;
256 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
EventSelectorDataStream * getStream(const std::string &) override
Retrieve stream by name.
size_type m_streamID
Definition of class EventSelectorDataStream.
StatusCode DataStreamTool::getPreviousStream ( const EventSelectorDataStream *&  esds,
size_type &  dsid 
)
override

Definition at line 258 of file DataStreamTool.cpp.

259 {
260 
261  EventSelectorDataStream* previousStream = getStream( dsid );
262  if ( !previousStream ) return StatusCode::FAILURE; //<-begin of streams reached
263 
264  esds = previousStream;
265  --m_streamID;
266 
267  return StatusCode::SUCCESS;
268 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
EventSelectorDataStream * getStream(const std::string &) override
Retrieve stream by name.
size_type m_streamID
Definition of class EventSelectorDataStream.
EventSelectorDataStream * DataStreamTool::getStream ( const std::string info)
override

Retrieve stream by name.

Definition at line 168 of file DataStreamTool.cpp.

169 {
170  auto i = getStreamIterator( info );
171  return i != m_streams.end() ? *i : nullptr;
172 }
Streams::iterator getStreamIterator(const std::string &)
T end(T...args)
EventSelectorDataStream * DataStreamTool::getStream ( size_type  pos)
override

Definition at line 180 of file DataStreamTool.cpp.

181 {
182  // pos has to point inside the vector
183  return ( ( pos >= 0 ) && ( (size_t)pos < m_streams.size() ) ) ? m_streams[pos] : nullptr;
184 }
T size(T...args)
DataStreamTool::Streams::iterator DataStreamTool::getStreamIterator ( const std::string info)
protected

Definition at line 174 of file DataStreamTool.cpp.

175 {
177  [&]( const EventSelectorDataStream* i ) { return i->definition() == info; } );
178 }
MsgStream & info() const
shortcut for the method msgStream(MSG::INFO)
T end(T...args)
const std::string & definition() const
Retrieve definition string.
T find_if(T...args)
T begin(T...args)
Definition of class EventSelectorDataStream.
virtual Streams& DataStreamTool::getStreams ( )
inlinevirtual

Definition at line 67 of file DataStreamTool.h.

67 { return m_streams; };
StatusCode DataStreamTool::initialize ( )
override

Definition at line 22 of file DataStreamTool.cpp.

23 {
24 
26  if ( !status.isSuccess() ) {
27  fatal() << "Error. Cannot initialize base class." << endmsg;
28  return status;
29  }
30 
31  // Get the references to the services that are needed by the ApplicationMgr itself
32  m_incidentSvc = serviceLocator()->service( "IncidentSvc" );
33  if ( !m_incidentSvc ) {
34  fatal() << "Error retrieving IncidentSvc." << endmsg;
35  return StatusCode::FAILURE;
36  }
37 
38  return StatusCode::SUCCESS;
39 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: AlgTool.cpp:83
StatusCode initialize() override
Definition: AlgTool.cpp:223
bool isSuccess() const
Definition: StatusCode.h:287
StatusCode service(const Gaudi::Utils::TypeNameString &name, T *&svc, bool createIf=true)
Templated method to access a service by name.
Definition: ISvcLocator.h:79
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
SmartIF< IIncidentSvc > m_incidentSvc
Reference to the incident service.
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
MsgStream & fatal() const
shortcut for the method msgStream(MSG::FATAL)
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode DataStreamTool::initializeStream ( EventSelectorDataStream s)
override

Initialize newly opened stream.

Definition at line 88 of file DataStreamTool.cpp.

89 {
90  IEvtSelector* sel = nullptr;
91  StatusCode status = s->initialize();
92  if ( status.isSuccess() ) {
93  status = createSelector( s->name(), s->selectorType(), sel );
94  if ( status.isSuccess() ) {
95  SmartIF<IProperty> prop( sel ); // Att: IProperty, IService used to point to EventSelector
96  SmartIF<IService> isvc( sel );
97  s->setSelector( sel );
98  sel->release(); // No need for this interface anymore, it is passed to the stream
99  if ( prop && isvc ) {
100  for ( const auto& i : s->properties() ) prop->setProperty( i ).ignore();
101  prop->setProperty( Gaudi::Property<int>( "OutputLevel", msgLevel() ) ).ignore();
102  // FIXME: (MCl) Why do we have to initialize the selector here?
103  return isvc->sysInitialize();
104  }
105  }
106  }
107  return StatusCode::FAILURE;
108 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
const std::string & name() const
Retrieve stream name.
Implementation of property with value of concrete type.
Definition: Property.h:381
The Event Selector Interface.
Definition: IEvtSelector.h:18
bool isSuccess() const
Definition: StatusCode.h:287
sel
Definition: IOTest.py:95
virtual StatusCode initialize()
Parse input criteria.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
StatusCode createSelector(const std::string &, const std::string &, IEvtSelector *&) override
virtual unsigned long release()=0
Release Interface instance.
const std::string & selectorType() const
Retrieve event selector type.
const Properties & properties()
Access properties.
virtual void setSelector(IEvtSelector *pSelector)
Attach event selector object.
MSG::Level msgLevel() const
get the cached level (originally extracted from the embedded MsgStream)
EventSelectorDataStream * DataStreamTool::lastStream ( )
override

Definition at line 186 of file DataStreamTool.cpp.

186 { return m_streams.back(); }
T back(T...args)
DataStreamTool& DataStreamTool::operator= ( const DataStreamTool )
privatedelete

Fake assignment operator (never implemented).

size_type DataStreamTool::size ( )
inlineoverride

Definition at line 63 of file DataStreamTool.h.

63 { return m_streams.size(); };
T size(T...args)

Member Data Documentation

SmartIF<IIncidentSvc> DataStreamTool::m_incidentSvc = nullptr
protected

Reference to the incident service.

Definition at line 92 of file DataStreamTool.h.

size_type DataStreamTool::m_streamCount = 0
protected

Definition at line 85 of file DataStreamTool.h.

size_type DataStreamTool::m_streamID = 0
protected

Definition at line 83 of file DataStreamTool.h.

Streams DataStreamTool::m_streams
protected

Definition at line 87 of file DataStreamTool.h.

StreamSpecs DataStreamTool::m_streamSpecs
protected

Definition at line 89 of file DataStreamTool.h.


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