The Gaudi Framework  v31r0 (aeb156f0)
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 40 of file DataStreamTool.cpp.

40  {
41 
42  if ( getStream( input ) ) { warning() << "Input stream " << input << "already in use" << endmsg; }
43 
44  m_streamSpecs.push_back( input );
45 
46  auto strname = name() + '_' + std::to_string( ++m_streamCount );
47  EventSelectorDataStream* s = nullptr;
48 
49  StatusCode status = createStream( strname, input, s );
50 
51  if ( status.isSuccess() && s ) {
52  s->addRef();
53  m_streams.push_back( s );
54  status = StatusCode::SUCCESS;
55  } else {
56  if ( s ) {
57  s->release();
58  error() << "Error connecting/creating Stream: " << s << endmsg;
59  }
60  error() << "Error connecting/creating Stream: " << input << endmsg;
61  status = StatusCode::FAILURE;
62  }
63  return status;
64 }
bool isSuccess() const
Definition: StatusCode.h:267
T to_string(T...args)
StatusCode createStream(const std::string &, const std::string &, EventSelectorDataStream *&) override
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
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:38
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:50
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:58
Definition of class EventSelectorDataStream.
size_type m_streamCount
string s
Definition: gaudirun.py:312
constexpr static const auto FAILURE
Definition: StatusCode.h:86
StreamSpecs m_streamSpecs
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:192
unsigned long release() override
Release Interface instance.
Definition: implements.h:40
StatusCode DataStreamTool::addStreams ( const StreamSpecs &  inputs)
override

Definition at line 66 of file DataStreamTool.cpp.

66  {
67 
69  for ( auto& i : inputs ) {
70  status = addStream( i );
71  if ( !status.isSuccess() ) break;
72  }
73  return status;
74 }
bool isSuccess() const
Definition: StatusCode.h:267
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:50
StatusCode addStream(const std::string &) override
virtual Streams::iterator DataStreamTool::beginOfStreams ( )
inlinevirtual

Definition at line 68 of file DataStreamTool.h.

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

Definition at line 174 of file DataStreamTool.cpp.

174  {
175 
176  StatusCode iret, status = StatusCode::SUCCESS;
177  iret.ignore();
178 
179  // disconnect the streams
180  for ( auto& il : m_streamSpecs ) {
182  if ( s ) {
183  if ( s->isInitialized() ) {
184  iret = finalizeStream( s );
185  if ( !iret.isSuccess() ) {
186  error() << "Error finalizing Stream" << il << endmsg;
187  status = iret;
188  }
189  }
190  iret = eraseStream( il );
191  if ( !iret.isSuccess() ) {
192  error() << "Error diconnecting Stream" << il << endmsg;
193  status = iret;
194  }
195  }
196  }
197 
198  m_streamSpecs.clear();
199 
200  return status;
201 }
bool isInitialized() const
Check initialization status.
bool isSuccess() const
Definition: StatusCode.h:267
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:50
StatusCode finalizeStream(EventSelectorDataStream *) override
Finalize no longer needed stream.
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:153
string s
Definition: gaudirun.py:312
StreamSpecs m_streamSpecs
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:192
StatusCode DataStreamTool::connectStream ( EventSelectorDataStream s)
protected

Connect single stream by reference.

Definition at line 203 of file DataStreamTool.cpp.

203  {
204 
205  if ( !s ) return StatusCode::FAILURE;
206  s->addRef();
207  m_streams.push_back( s );
208  return StatusCode::SUCCESS;
209 }
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
T push_back(T...args)
unsigned long addRef() override
Reference Interface instance.
Definition: implements.h:38
constexpr static const auto FAILURE
Definition: StatusCode.h:86
StatusCode DataStreamTool::connectStream ( const std::string info)
protected

Connect single stream by name.

Definition at line 211 of file DataStreamTool.cpp.

211  {
212  if ( getStream( info ) ) { warning() << "Input stream " << info << "already in use" << endmsg; }
213  auto nam = name() + '_' + std::to_string( ++m_streamCount );
214  EventSelectorDataStream* s = nullptr;
215  StatusCode status = createStream( nam, info, s );
216  if ( status.isSuccess() ) return connectStream( s );
217  s->release();
218  return status;
219 }
bool isSuccess() const
Definition: StatusCode.h:267
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:50
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:58
Definition of class EventSelectorDataStream.
size_type m_streamCount
string s
Definition: gaudirun.py:312
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:192
unsigned long release() override
Release Interface instance.
Definition: implements.h:40
StatusCode DataStreamTool::createSelector ( const std::string nam,
const std::string typ,
IEvtSelector *&  sel 
)
overrideprotected

Definition at line 104 of file DataStreamTool.cpp.

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

Definition at line 151 of file DataStreamTool.cpp.

152  {
153  stream = new EventSelectorDataStream( nam, info, serviceLocator() );
154  return StatusCode::SUCCESS;
155 }
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: AlgTool.cpp:79
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
Definition of class EventSelectorDataStream.
virtual Streams::iterator DataStreamTool::endOfStreams ( )
inlinevirtual

Definition at line 70 of file DataStreamTool.h.

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

Definition at line 140 of file DataStreamTool.cpp.

140  {
141 
142  auto i = getStreamIterator( info );
143  if ( i != m_streams.end() ) {
144  ( *i )->release();
145  m_streams.erase( i );
146  return StatusCode::SUCCESS;
147  }
148  return StatusCode::FAILURE;
149 }
Streams::iterator getStreamIterator(const std::string &)
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
T end(T...args)
T erase(T...args)
constexpr static const auto FAILURE
Definition: StatusCode.h:86
StatusCode DataStreamTool::finalize ( )
override

Definition at line 76 of file DataStreamTool.cpp.

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

Finalize no longer needed stream.

Definition at line 119 of file DataStreamTool.cpp.

119  {
120  if ( s ) {
121  IEvtSelector* sel = s->selector();
122  if ( sel ) {
123  SmartIF<IService> isvc( sel );
124  if ( isvc ) {
125  isvc->finalize().ignore();
126  s->finalize().ignore();
127  // Fire EndStream "Incident"
128  m_incidentSvc->fireIncident( Incident( name(), IncidentType::EndStream ) );
129  return StatusCode::SUCCESS;
130  }
131  // Failed to get service interface of sub-event selector
132  return StatusCode::FAILURE;
133  }
134  // No selector (yet) attached - no need to finalize it!
135  return StatusCode::SUCCESS;
136  }
137  return StatusCode::FAILURE;
138 }
The Event Selector Interface.
Definition: IEvtSelector.h:18
IEvtSelector * selector() const
Retrieve event selector object.
sel
Definition: IOTest.py:93
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
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.
const std::string & name() const override
Retrieve full identifying name of the concrete tool object.
Definition: AlgTool.cpp:58
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:153
Base class for all Incidents (computing events).
Definition: Incident.h:17
constexpr static const auto FAILURE
Definition: StatusCode.h:86
StatusCode DataStreamTool::getNextStream ( const EventSelectorDataStream *&  esds,
size_type &  dsid 
)
override

Definition at line 227 of file DataStreamTool.cpp.

227  {
228 
229  EventSelectorDataStream* nextStream = getStream( dsid );
230  if ( !nextStream ) return StatusCode::FAILURE; //<-end of streams reached
231 
232  esds = nextStream;
233  ++m_streamID;
234 
235  return StatusCode::SUCCESS;
236 }
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
EventSelectorDataStream * getStream(const std::string &) override
Retrieve stream by name.
size_type m_streamID
Definition of class EventSelectorDataStream.
constexpr static const auto FAILURE
Definition: StatusCode.h:86
StatusCode DataStreamTool::getPreviousStream ( const EventSelectorDataStream *&  esds,
size_type &  dsid 
)
override

Definition at line 238 of file DataStreamTool.cpp.

238  {
239 
240  EventSelectorDataStream* previousStream = getStream( dsid );
241  if ( !previousStream ) return StatusCode::FAILURE; //<-begin of streams reached
242 
243  esds = previousStream;
244  --m_streamID;
245 
246  return StatusCode::SUCCESS;
247 }
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
EventSelectorDataStream * getStream(const std::string &) override
Retrieve stream by name.
size_type m_streamID
Definition of class EventSelectorDataStream.
constexpr static const auto FAILURE
Definition: StatusCode.h:86
EventSelectorDataStream * DataStreamTool::getStream ( const std::string info)
override

Retrieve stream by name.

Definition at line 157 of file DataStreamTool.cpp.

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

Definition at line 167 of file DataStreamTool.cpp.

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

Definition at line 162 of file DataStreamTool.cpp.

162  {
164  [&]( const EventSelectorDataStream* i ) { return i->definition() == info; } );
165 }
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 66 of file DataStreamTool.h.

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

Definition at line 22 of file DataStreamTool.cpp.

22  {
23 
25  if ( !status.isSuccess() ) {
26  fatal() << "Error. Cannot initialize base class." << endmsg;
27  return status;
28  }
29 
30  // Get the references to the services that are needed by the ApplicationMgr itself
31  m_incidentSvc = serviceLocator()->service( "IncidentSvc" );
32  if ( !m_incidentSvc ) {
33  fatal() << "Error retrieving IncidentSvc." << endmsg;
34  return StatusCode::FAILURE;
35  }
36 
37  return StatusCode::SUCCESS;
38 }
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: AlgTool.cpp:79
StatusCode initialize() override
Definition: AlgTool.cpp:201
bool isSuccess() const
Definition: StatusCode.h:267
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
StatusCode service(const Gaudi::Utils::TypeNameString &name, T *&svc, bool createIf=true)
Templated method to access a service by name.
Definition: ISvcLocator.h:76
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:50
SmartIF< IIncidentSvc > m_incidentSvc
Reference to the incident service.
constexpr static const auto FAILURE
Definition: StatusCode.h:86
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:192
StatusCode DataStreamTool::initializeStream ( EventSelectorDataStream s)
override

Initialize newly opened stream.

Definition at line 82 of file DataStreamTool.cpp.

82  {
83  IEvtSelector* sel = nullptr;
84  StatusCode status = s->initialize();
85  if ( status.isSuccess() ) {
86  status = createSelector( s->name(), s->selectorType(), sel );
87  if ( status.isSuccess() ) {
88  SmartIF<IProperty> prop( sel ); // Att: IProperty, IService used to point to EventSelector
89  SmartIF<IService> isvc( sel );
90  s->setSelector( sel );
91  sel->release(); // No need for this interface anymore, it is passed to the stream
92  if ( prop && isvc ) {
93  for ( const auto& i : s->properties() ) prop->setProperty( i ).ignore();
94  prop->setProperty( Gaudi::Property<int>( "OutputLevel", msgLevel() ) ).ignore();
95  // FIXME: (MCl) Why do we have to initialize the selector here?
96  return isvc->sysInitialize();
97  }
98  }
99  }
100  return StatusCode::FAILURE;
101 }
const std::string & name() const
Retrieve stream name.
Implementation of property with value of concrete type.
Definition: Property.h:352
The Event Selector Interface.
Definition: IEvtSelector.h:18
bool isSuccess() const
Definition: StatusCode.h:267
sel
Definition: IOTest.py:93
virtual StatusCode initialize()
Parse input criteria.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:50
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.
constexpr static const auto FAILURE
Definition: StatusCode.h:86
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 172 of file DataStreamTool.cpp.

172 { 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 62 of file DataStreamTool.h.

62 { 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 91 of file DataStreamTool.h.

size_type DataStreamTool::m_streamCount = 0
protected

Definition at line 84 of file DataStreamTool.h.

size_type DataStreamTool::m_streamID = 0
protected

Definition at line 82 of file DataStreamTool.h.

Streams DataStreamTool::m_streams
protected

Definition at line 86 of file DataStreamTool.h.

StreamSpecs DataStreamTool::m_streamSpecs
protected

Definition at line 88 of file DataStreamTool.h.


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