The Gaudi Framework  v30r3 (a5ef0a68)
EventCollectionSelector Class Reference

Definition of class EventCollectionSelector. More...

#include <src/EventSelector/EventCollectionSelector.h>

Inheritance diagram for EventCollectionSelector:
Collaboration diagram for EventCollectionSelector:

Classes

class  MyContextType
 

Public Member Functions

StatusCode initialize () override
 Service override: Initialize service. More...
 
StatusCode finalize () override
 Service override: Finalize Service. More...
 
StatusCode createContext (Context *&refpCtxt) const override
 Create a new event loop context. More...
 
StatusCode next (Context &refCtxt) const override
 Get next iteration item from the event loop context. More...
 
StatusCode next (Context &refCtxt, int jump) const override
 Get next iteration item from the event loop context, but skip jump elements. More...
 
StatusCode previous (Context &refCtxt) const override
 Get previous iteration item from the event loop context. More...
 
StatusCode previous (Context &refCtxt, int jump) const override
 Get previous iteration item from the event loop context, but skip jump elements. More...
 
StatusCode rewind (Context &refCtxt) const override
 Rewind the dataset. More...
 
StatusCode createAddress (const Context &refCtxt, IOpaqueAddress *&refpAddr) const override
 Create new Opaque address corresponding to the current record. More...
 
StatusCode releaseContext (Context *&refCtxt) const override
 Release existing event iteration context. More...
 
StatusCode resetCriteria (const std::string &cr, Context &c) const override
 Will set a new criteria for the selection of the next list of events and will change the state of the context in a way to point to the new list. More...
 
StatusCode last (Context &refCtxt) const override
 Access last item in the iteration. More...
 
virtual StatusCode connectCollection (MyContextType *ctxt) const
 Connect collection to selector. More...
 
virtual StatusCode connectDataSource (const std::string &db, const std::string &typ) const
 Connect collection's data source to selector. More...
 
virtual StatusCode connectTuple (const std::string &nam, const std::string &itName, NTuple::Tuple *&tup, NTuple::Item< IOpaqueAddress * > *&item) const
 Connect to existing N-tuple. More...
 
virtual StatusCode connectStatement (const std::string &typ, const std::string &crit, INTuple *tuple) const
 Connect selection statement to refine data access. More...
 
virtual StatusCode getNextRecord (NTuple::Tuple *tuple) const
 Read next record of the N-tuple. More...
 
virtual StatusCode getPreviousRecord (NTuple::Tuple *tuple) const
 Read next record of the N-tuple. More...
 
- Public Member Functions inherited from extends< Service, IEvtSelector >
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 Service
const std::stringname () const override
 Retrieve name of the service. More...
 
StatusCode configure () override
 
StatusCode initialize () override
 
StatusCode start () override
 
StatusCode stop () override
 
StatusCode finalize () override
 
StatusCode terminate () override
 
Gaudi::StateMachine::State FSMState () const override
 
Gaudi::StateMachine::State targetFSMState () const override
 
StatusCode reinitialize () override
 
StatusCode restart () override
 
StatusCode sysInitialize () override
 Initialize Service. More...
 
StatusCode sysStart () override
 Initialize Service. More...
 
StatusCode sysStop () override
 Initialize Service. More...
 
StatusCode sysFinalize () override
 Finalize Service. More...
 
StatusCode sysReinitialize () override
 Re-initialize the Service. More...
 
StatusCode sysRestart () override
 Re-initialize the Service. More...
 
 Service (std::string name, ISvcLocator *svcloc)
 Standard Constructor. More...
 
SmartIF< ISvcLocator > & serviceLocator () const override
 Retrieve pointer to service locator. More...
 
StatusCode setProperties ()
 Method for setting declared properties to the values specified for the job. More...
 
template<class T >
StatusCode service (const std::string &name, const T *&psvc, 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 &name, T *&psvc, bool createIf=true) const
 
template<typename IFace = IService>
SmartIF< IFace > service (const std::string &name, bool createIf=true) const
 
template<class T >
StatusCode service (const std::string &svcType, const std::string &svcName, T *&psvc) const
 Access a service by name and type, creating it if it doesn't already exist. More...
 
template<class T >
StatusCode declareTool (ToolHandle< T > &handle, std::string toolTypeAndName, bool createIf=true)
 Declare used tool. More...
 
SmartIF< IAuditorSvc > & auditorSvc () const
 The standard auditor service.May not be invoked before sysInitialize() has been invoked. More...
 
- Public Member Functions inherited from PropertyHolder< CommonMessaging< implements< IService, 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< IService, 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 Attributes

SmartIF< INTupleSvcm_tupleSvc
 Reference to Tuple service. More...
 
SmartIF< IAddressCreatorm_pAddrCreator
 
Gaudi::Property< std::stringm_tupleSvcName
 
Gaudi::Property< std::stringm_authentication {this, "Authentication", "", "authentication string (if needed)"}
 
Gaudi::Property< std::stringm_cntName {this, "Container", "B2PiPi", "container name"}
 
Gaudi::Property< std::stringm_itemName {this, "Item", "Address", "item name"}
 
Gaudi::Property< std::stringm_criteria {this, "Criteria", "", "criteria"}
 
Gaudi::Property< std::stringm_database {this, "DB", "", "datafile name"}
 
Gaudi::Property< std::stringm_dbType {this, "DbType", "", "database type identifier"}
 
Gaudi::Property< std::stringm_dbSvc {this, "DbService", "", "database service (exclusive property with db type)"}
 
Gaudi::Property< std::stringm_statement {this, "Function", "NTuple::Selector", "selector name"}
 
- Protected Attributes inherited from Service
Gaudi::StateMachine::State m_state = Gaudi::StateMachine::OFFLINE
 Service state. More...
 
Gaudi::StateMachine::State m_targetState = Gaudi::StateMachine::OFFLINE
 Service state. More...
 
Gaudi::Property< int > m_outputLevel {this, "OutputLevel", MSG::NIL, "output level"}
 
Gaudi::Property< bool > m_auditInit {this, "AuditServices", false, "[[deprecated]] unused"}
 
Gaudi::Property< bool > m_auditorInitialize {this, "AuditInitialize", false, "trigger auditor on initialize()"}
 
Gaudi::Property< bool > m_auditorStart {this, "AuditStart", false, "trigger auditor on start()"}
 
Gaudi::Property< bool > m_auditorStop {this, "AuditStop", false, "trigger auditor on stop()"}
 
Gaudi::Property< bool > m_auditorFinalize {this, "AuditFinalize", false, "trigger auditor on finalize()"}
 
Gaudi::Property< bool > m_auditorReinitialize {this, "AuditReinitialize", false, "trigger auditor on reinitialize()"}
 
Gaudi::Property< bool > m_auditorRestart {this, "AuditRestart", false, "trigger auditor on restart()"}
 
SmartIF< IAuditorSvcm_pAuditorSvc
 Auditor Service. More...
 

Additional Inherited Members

- Public Types inherited from extends< Service, IEvtSelector >
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 Service
using Factory = Gaudi::PluginService::Factory< IService *(const std::string &, ISvcLocator *)>
 
- Public Types inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
using PropertyHolderImpl = PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
 Typedef used to refer to this class from derived classes, as in. More...
 
- Public Types inherited from CommonMessaging< implements< IService, 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...
 
- Protected Member Functions inherited from Service
 ~Service () override
 Standard Destructor. More...
 
int outputLevel () const
 get the Service's output level More...
 
- Protected Member Functions inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
Gaudi::Details::PropertyBaseproperty (const std::string &name) const
 
- Protected Member Functions inherited from CommonMessaging< implements< IService, 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...
 

Detailed Description

Definition of class EventCollectionSelector.

Basic event selector service. The event selector service itself is able to connect other services to attached streams.

History: +------—+-------------------------------------------—+------—+ | Date | Comment | Who | +------—+-------------------------------------------—+------—+ | 3/10/00 | Initial version | M.Frank | +------—+-------------------------------------------—+------—+

Author
Markus Frank
Version
1.0

Definition at line 42 of file EventCollectionSelector.h.

Member Function Documentation

StatusCode EventCollectionSelector::connectCollection ( MyContextType ctxt) const
virtual

Connect collection to selector.

Definition at line 193 of file EventCollectionSelector.cpp.

194 {
195  if ( ctxt ) {
197  if ( status.isSuccess() ) {
198  status = connectTuple( m_cntName, m_itemName, ctxt->tuple, ctxt->item );
199  if ( status.isSuccess() ) {
200  status = connectStatement( m_statement, m_criteria, ctxt->tuple );
201  if ( status.isSuccess() ) {
202  *( ctxt->item ) = 0;
203  return status;
204  }
205  }
206  }
207  return status;
208  }
209  return StatusCode::FAILURE;
210 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
bool isSuccess() const
Definition: StatusCode.h:287
virtual StatusCode connectDataSource(const std::string &db, const std::string &typ) const
Connect collection&#39;s data source to selector.
Gaudi::Property< std::string > m_cntName
Gaudi::Property< std::string > m_database
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
Gaudi::Property< std::string > m_statement
Gaudi::Property< std::string > m_dbType
Gaudi::Property< std::string > m_criteria
virtual StatusCode connectTuple(const std::string &nam, const std::string &itName, NTuple::Tuple *&tup, NTuple::Item< IOpaqueAddress * > *&item) const
Connect to existing N-tuple.
Gaudi::Property< std::string > m_itemName
virtual StatusCode connectStatement(const std::string &typ, const std::string &crit, INTuple *tuple) const
Connect selection statement to refine data access.
StatusCode EventCollectionSelector::connectDataSource ( const std::string db,
const std::string typ 
) const
virtual

Connect collection's data source to selector.

Definition at line 84 of file EventCollectionSelector.cpp.

85 {
88  if ( svc && !db.empty() ) {
89  std::string ident = name() + ' ';
90  ident += "DATAFILE='" + m_database.value().substr( 5 ) + "' ";
91  if ( !m_dbSvc.empty() )
92  ident += "SVC='" + m_dbSvc + "' ";
93  else
94  ident += "TYP='" + m_dbType + "' ";
95  ident += "OPT='READ' ";
96  if ( m_authentication.length() > 0 ) {
97  ident += "AUTH='" + m_authentication + "' ";
98  }
99  status = svc->connect( ident );
100  }
101  return status;
102 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
constexpr static const auto FAILURE
Definition: StatusCode.h:88
Small smart pointer class with automatic reference counting for IInterface.
Definition: IConverter.h:15
T empty(T...args)
const std::string & name() const override
Retrieve name of the service.
Definition: Service.cpp:288
Gaudi::Property< std::string > m_authentication
Gaudi::Property< std::string > m_database
STL class.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
Gaudi::Property< std::string > m_dbType
Gaudi::Property< std::string > m_dbSvc
StatusCode EventCollectionSelector::connectStatement ( const std::string typ,
const std::string crit,
INTuple tuple 
) const
virtual

Connect selection statement to refine data access.

Definition at line 125 of file EventCollectionSelector.cpp.

127 {
128  std::string seltyp = typ;
129  if ( !seltyp.empty() || !crit.empty() ) {
130  if ( !crit.empty() && seltyp.length() == 0 ) seltyp = "NTuple::Selector";
131  SmartIF<ISelectStatement> stmt( ObjFactory::create( seltyp, serviceLocator() ).release() );
132  if ( stmt ) {
133  if ( !crit.empty() ) stmt->setCriteria( crit );
134  tuple->attachSelector( stmt ).ignore();
135  return StatusCode::SUCCESS;
136  }
137  return StatusCode::FAILURE;
138  }
139  return StatusCode::SUCCESS;
140 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
T empty(T...args)
STL class.
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
T length(T...args)
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:165
virtual StatusCode attachSelector(ISelectStatement *sel)=0
Attach selector.
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: Service.cpp:291
StatusCode EventCollectionSelector::connectTuple ( const std::string nam,
const std::string itName,
NTuple::Tuple *&  tup,
NTuple::Item< IOpaqueAddress * > *&  item 
) const
virtual

Connect to existing N-tuple.

Definition at line 105 of file EventCollectionSelector.cpp.

107 {
108  std::string top = "/NTUPLES/" + name() + '/' + nam;
109  StatusCode status = m_tupleSvc->retrieveObject( top, (DataObject*&)tup );
110  if ( status.isSuccess() ) {
111  item = new NTuple::Item<IOpaqueAddress*>();
112  status = tup->item( itName, *item );
113  if ( status.isSuccess() ) return status;
114  error() << "Item " << itName << " is not part of the collection:" << top << endmsg;
115  delete item;
116  item = nullptr;
117  } else {
118  error() << "Cannot connect to collection:" << top << endmsg;
119  }
120  tup = nullptr;
121  return status;
122 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
const std::string & name() const override
Retrieve name of the service.
Definition: Service.cpp:288
bool isSuccess() const
Definition: StatusCode.h:287
STL class.
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
virtual StatusCode retrieveObject(IRegistry *pDirectory, boost::string_ref path, DataObject *&pObject)=0
Retrieve object identified by its directory entry.
A DataObject is the base class of any identifiable object on any data store.
Definition: DataObject.h:30
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode EventCollectionSelector::createAddress ( const Context &  refCtxt,
IOpaqueAddress *&  refpAddr 
) const
override

Create new Opaque address corresponding to the current record.

Parameters
refCtxt[IN/OUT] Reference to the context
refpAddr[OUT] Reference to address pointer
Returns
StatusCode indicating success or failure

Definition at line 275 of file EventCollectionSelector.cpp.

276 {
277  const MyContextType* ctxt = dynamic_cast<const MyContextType*>( &refCtxt );
278  if ( ctxt ) {
279  IOpaqueAddress* pA = *( ctxt->item );
280  if ( pA ) {
281  IOpaqueAddress* pAddress = nullptr;
282  StatusCode status = m_pAddrCreator->createAddress( pA->svcType(), pA->clID(), pA->par(), pA->ipar(), pAddress );
283  if ( status.isSuccess() ) {
284  refpAddr = pAddress;
285  return StatusCode::SUCCESS;
286  } else {
287  error() << "Failed to access " << pA->par()[0] << ":" << pA->par()[1] << " SvcTyp:" << long( pA->svcType() )
288  << " CLID:" << pA->clID() << endmsg;
289  }
290  }
291  }
292  return StatusCode::FAILURE;
293 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
virtual const CLID & clID() const =0
Retrieve class information from link.
virtual StatusCode createAddress(long svc_type, const CLID &clid, const std::string *par, const unsigned long *ipar, IOpaqueAddress *&refpAddress)=0
Create a Generic address using explicit arguments to identify a single object.
bool isSuccess() const
Definition: StatusCode.h:287
virtual const std::string * par() const =0
Retrieve String parameters.
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
virtual const unsigned long * ipar() const =0
Access to generic link parameters.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
virtual long svcType() const =0
Retrieve service type.
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
Opaque address interface definition.
SmartIF< IAddressCreator > m_pAddrCreator
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode EventCollectionSelector::createContext ( Context *&  refpCtxt) const
override

Create a new event loop context.

Parameters
refpCtxt[IN/OUT] Reference to pointer to store the context
Returns
StatusCode indicating success or failure

Definition at line 222 of file EventCollectionSelector.cpp.

223 {
224  refpCtxt = nullptr;
225  auto ctxt = std::make_unique<MyContextType>();
226  StatusCode status = connectCollection( ctxt.get() );
227  if ( !status.isSuccess() ) {
228  error() << "Unable to connect Collection file \"" << m_database << "\"" << endmsg;
229  return status;
230  }
231  refpCtxt = ctxt.release();
232  return StatusCode::SUCCESS;
233 }
Gaudi::Property< std::string > m_database
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
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
virtual StatusCode connectCollection(MyContextType *ctxt) const
Connect collection to selector.
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode EventCollectionSelector::finalize ( )
override

Service override: Finalize Service.

Definition at line 213 of file EventCollectionSelector.cpp.

214 {
215  // release services
216  m_pAddrCreator = nullptr;
217  m_tupleSvc = nullptr;
218  return Service::finalize();
219 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
StatusCode finalize() override
Definition: Service.cpp:173
SmartIF< IAddressCreator > m_pAddrCreator
StatusCode EventCollectionSelector::getNextRecord ( NTuple::Tuple tuple) const
virtual

Read next record of the N-tuple.

Definition at line 143 of file EventCollectionSelector.cpp.

144 {
146  if ( tuple ) {
147  do {
148  status = m_tupleSvc->readRecord( tuple );
149  if ( status.isSuccess() ) {
150  ISelectStatement* statement = tuple->selector();
151  bool use_it = ( statement ) ? ( *statement )( tuple ) : true;
152  if ( use_it ) {
153  return status;
154  }
155  }
156  } while ( status.isSuccess() );
157  }
158  return status;
159 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
constexpr static const auto FAILURE
Definition: StatusCode.h:88
A select statement can either contain.
bool isSuccess() const
Definition: StatusCode.h:287
virtual ISelectStatement * selector()=0
Access selector.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
virtual StatusCode readRecord(NTuple::Tuple *tuple)=0
Read single record from N tuple.
StatusCode EventCollectionSelector::getPreviousRecord ( NTuple::Tuple tuple) const
virtual

Read next record of the N-tuple.

Read previous record of the N-tuple.

Definition at line 162 of file EventCollectionSelector.cpp.

163 {
165  if ( tuple ) {
166  IRegistry* pReg = tuple->registry();
167  if ( pReg ) {
168  IOpaqueAddress* pAddr = pReg->address();
169  if ( pAddr ) {
170  long* ip = (long*)pAddr->ipar();
171  do {
172  if ( ip[1] > 1 ) {
173  ip[1] -= 2;
174  status = m_tupleSvc->readRecord( tuple );
175  if ( status.isSuccess() ) {
176  ISelectStatement* statement = tuple->selector();
177  bool use_it = ( statement ) ? ( *statement )( tuple ) : true;
178  if ( use_it ) {
179  return status;
180  }
181  }
182  } else {
183  return StatusCode::FAILURE;
184  }
185  } while ( status.isSuccess() );
186  }
187  }
188  }
189  return StatusCode::FAILURE;
190 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
constexpr static const auto FAILURE
Definition: StatusCode.h:88
A select statement can either contain.
bool isSuccess() const
Definition: StatusCode.h:287
virtual ISelectStatement * selector()=0
Access selector.
IRegistry * registry() const
Get pointer to Registry.
Definition: DataObject.h:73
virtual const unsigned long * ipar() const =0
Access to generic link parameters.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
The IRegistry represents the entry door to the environment any data object residing in a transient da...
Definition: IRegistry.h:22
virtual StatusCode readRecord(NTuple::Tuple *tuple)=0
Read single record from N tuple.
Opaque address interface definition.
virtual IOpaqueAddress * address() const =0
Retrieve opaque storage address.
StatusCode EventCollectionSelector::initialize ( )
override

Service override: Initialize service.

Definition at line 61 of file EventCollectionSelector.cpp.

62 {
63  // Initialize base class
65  if ( !status.isSuccess() ) {
66  error() << "Error initializing base class Service!" << endmsg;
67  return status;
68  }
69  m_pAddrCreator = serviceLocator()->service( "EventPersistencySvc" );
70  if ( !m_pAddrCreator ) {
71  error() << "Unable to locate IAddressCreator interface of "
72  << "EventPersistencySvc" << endmsg;
73  return status;
74  }
76  if ( !m_tupleSvc ) {
77  error() << "Unable to locate INTupleSvc interface of " << m_tupleSvcName << endmsg;
78  return status;
79  }
80  return status;
81 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
StatusCode initialize() override
Definition: Service.cpp:63
bool isSuccess() const
Definition: StatusCode.h:287
Gaudi::Property< std::string > m_tupleSvcName
StatusCode service(const Gaudi::Utils::TypeNameString &name, T *&svc, bool createIf=true)
Templated method to access a service by name.
Definition: ISvcLocator.h:79
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
SmartIF< IAddressCreator > m_pAddrCreator
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: Service.cpp:291
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode EventCollectionSelector::last ( Context &  refCtxt) const
override

Access last item in the iteration.

Parameters
refCtxt[IN/OUT] Reference to the Context object.
Returns
StatusCode indicating success or failure

Definition at line 320 of file EventCollectionSelector.cpp.

320 { return StatusCode::FAILURE; }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
StatusCode EventCollectionSelector::next ( Context &  refCtxt) const
override

Get next iteration item from the event loop context.

Parameters
refCtxt[IN/OUT] Reference to the context
Returns
StatusCode indicating success or failure

Definition at line 236 of file EventCollectionSelector.cpp.

236 { return next( refCtxt, 1 ); }
StatusCode next(Context &refCtxt) const override
Get next iteration item from the event loop context.
StatusCode EventCollectionSelector::next ( Context &  refCtxt,
int  jump 
) const
override

Get next iteration item from the event loop context, but skip jump elements.

Parameters
refCtxt[IN/OUT] Reference to the context
Returns
StatusCode indicating success or failure

Definition at line 239 of file EventCollectionSelector.cpp.

240 {
241  MyContextType* ctxt = dynamic_cast<MyContextType*>( &refCtxt );
242  if ( ctxt ) {
243  *( ctxt->item ) = ctxt->addressBuffer;
245  for ( int i = 0; i < jump && sc.isSuccess(); ++i ) {
246  sc = getNextRecord( ctxt->tuple );
247  }
248  return sc;
249  }
250  return StatusCode::FAILURE;
251 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
virtual StatusCode getNextRecord(NTuple::Tuple *tuple) const
Read next record of the N-tuple.
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 EventCollectionSelector::previous ( Context &  refCtxt) const
override

Get previous iteration item from the event loop context.

Parameters
refCtxt[IN/OUT] Reference to the context
jump[IN] Number of events to be skipped
Returns
StatusCode indicating success or failure

Definition at line 254 of file EventCollectionSelector.cpp.

254 { return previous( refCtxt, 1 ); }
StatusCode previous(Context &refCtxt) const override
Get previous iteration item from the event loop context.
StatusCode EventCollectionSelector::previous ( Context &  refCtxt,
int  jump 
) const
override

Get previous iteration item from the event loop context, but skip jump elements.

Parameters
refCtxt[IN/OUT] Reference to the context
jump[IN] Number of events to be skipped
Returns
StatusCode indicating success or failure

Definition at line 257 of file EventCollectionSelector.cpp.

258 {
259  MyContextType* ctxt = dynamic_cast<MyContextType*>( &refCtxt );
260  if ( ctxt ) {
261  *( ctxt->item ) = ctxt->addressBuffer;
263  for ( int i = 0; i < jump && sc.isSuccess(); ++i ) {
264  sc = getPreviousRecord( ctxt->tuple );
265  }
266  return sc;
267  }
268  return StatusCode::FAILURE;
269 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:51
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
virtual StatusCode getPreviousRecord(NTuple::Tuple *tuple) const
Read next record of the N-tuple.
StatusCode EventCollectionSelector::releaseContext ( Context *&  refCtxt) const
override

Release existing event iteration context.

Parameters
refCtxt[IN/OUT] Reference to the context
Returns
StatusCode indicating success or failure

Definition at line 296 of file EventCollectionSelector.cpp.

297 {
298  MyContextType* ctxt = dynamic_cast<MyContextType*>( refCtxt );
299  if ( ctxt ) {
300  delete ctxt;
301  ctxt = nullptr;
302  return StatusCode::SUCCESS;
303  }
304  return StatusCode::FAILURE;
305 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
StatusCode EventCollectionSelector::resetCriteria ( const std::string cr,
Context &  refCtxt 
) const
override

Will set a new criteria for the selection of the next list of events and will change the state of the context in a way to point to the new list.

Parameters
crThe new criteria string.
cReference pointer to the Context object.
Returns
StatusCode indicating success or failure

Definition at line 309 of file EventCollectionSelector.cpp.

310 {
311  MyContextType* ctxt = dynamic_cast<MyContextType*>( &refCtxt );
312  if ( ctxt ) {
313  ctxt->criteria = cr;
314  return StatusCode::SUCCESS;
315  }
316  return StatusCode::FAILURE;
317 }
constexpr static const auto FAILURE
Definition: StatusCode.h:88
constexpr static const auto SUCCESS
Definition: StatusCode.h:87
StatusCode EventCollectionSelector::rewind ( Context &  refCtxt) const
override

Rewind the dataset.

Parameters
refCtxt[IN/OUT] Reference to the context
Returns
StatusCode indicating success or failure

Definition at line 272 of file EventCollectionSelector.cpp.

272 { return StatusCode::FAILURE; }
constexpr static const auto FAILURE
Definition: StatusCode.h:88

Member Data Documentation

Gaudi::Property<std::string> EventCollectionSelector::m_authentication {this, "Authentication", "", "authentication string (if needed)"}
protected

Definition at line 86 of file EventCollectionSelector.h.

Gaudi::Property<std::string> EventCollectionSelector::m_cntName {this, "Container", "B2PiPi", "container name"}
protected

Definition at line 87 of file EventCollectionSelector.h.

Gaudi::Property<std::string> EventCollectionSelector::m_criteria {this, "Criteria", "", "criteria"}
protected

Definition at line 89 of file EventCollectionSelector.h.

Gaudi::Property<std::string> EventCollectionSelector::m_database {this, "DB", "", "datafile name"}
protected

Definition at line 90 of file EventCollectionSelector.h.

Gaudi::Property<std::string> EventCollectionSelector::m_dbSvc {this, "DbService", "", "database service (exclusive property with db type)"}
protected

Definition at line 92 of file EventCollectionSelector.h.

Gaudi::Property<std::string> EventCollectionSelector::m_dbType {this, "DbType", "", "database type identifier"}
protected

Definition at line 91 of file EventCollectionSelector.h.

Gaudi::Property<std::string> EventCollectionSelector::m_itemName {this, "Item", "Address", "item name"}
protected

Definition at line 88 of file EventCollectionSelector.h.

SmartIF<IAddressCreator> EventCollectionSelector::m_pAddrCreator
mutableprotected

Definition at line 81 of file EventCollectionSelector.h.

Gaudi::Property<std::string> EventCollectionSelector::m_statement {this, "Function", "NTuple::Selector", "selector name"}
protected

Definition at line 93 of file EventCollectionSelector.h.

SmartIF<INTupleSvc> EventCollectionSelector::m_tupleSvc
mutableprotected

Reference to Tuple service.

Definition at line 80 of file EventCollectionSelector.h.

Gaudi::Property<std::string> EventCollectionSelector::m_tupleSvcName
protected
Initial value:
{this, "CnvService", "EvtTupleSvc",
"name of the event collection service"}

Definition at line 84 of file EventCollectionSelector.h.


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