The Gaudi Framework  v33r1 (b1225454)
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...
 
- 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, " 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 52 of file EventCollectionSelector.h.

Member Function Documentation

◆ connectCollection()

StatusCode EventCollectionSelector::connectCollection ( MyContextType ctxt) const
virtual

Connect collection to selector.

Definition at line 189 of file EventCollectionSelector.cpp.

189  {
190  if ( ctxt ) {
192  if ( status.isSuccess() ) {
193  status = connectTuple( m_cntName, m_itemName, ctxt->tuple, ctxt->item );
194  if ( status.isSuccess() ) {
195  status = connectStatement( m_statement, m_criteria, ctxt->tuple );
196  if ( status.isSuccess() ) {
197  *( ctxt->item ) = 0;
198  return status;
199  }
200  }
201  }
202  return status;
203  }
204  return StatusCode::FAILURE;
205 }
virtual StatusCode connectStatement(const std::string &typ, const std::string &crit, INTuple *tuple) const
Connect selection statement to refine data access.
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:61
virtual StatusCode connectDataSource(const std::string &db, const std::string &typ) const
Connect collection's data source to selector.
Gaudi::Property< std::string > m_statement
bool isSuccess() const
Definition: StatusCode.h:365
Gaudi::Property< std::string > m_dbType
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_criteria
constexpr static const auto FAILURE
Definition: StatusCode.h:101
Gaudi::Property< std::string > m_itemName

◆ connectDataSource()

StatusCode EventCollectionSelector::connectDataSource ( const std::string db,
const std::string typ 
) const
virtual

Connect collection's data source to selector.

Definition at line 91 of file EventCollectionSelector.cpp.

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

◆ connectStatement()

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 128 of file EventCollectionSelector.cpp.

129  {
130  std::string seltyp = typ;
131  if ( !seltyp.empty() || !crit.empty() ) {
132  if ( !crit.empty() && seltyp.length() == 0 ) seltyp = "NTuple::Selector";
133  SmartIF<ISelectStatement> stmt( ObjFactory::create( seltyp, serviceLocator() ).release() );
134  if ( stmt ) {
135  if ( !crit.empty() ) stmt->setCriteria( crit );
136  tuple->attachSelector( stmt ).ignore();
137  return StatusCode::SUCCESS;
138  }
139  return StatusCode::FAILURE;
140  }
141  return StatusCode::SUCCESS;
142 }
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: Service.cpp:287
T empty(T... args)
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
STL class.
T length(T... args)
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:168
constexpr static const auto FAILURE
Definition: StatusCode.h:101
virtual StatusCode attachSelector(ISelectStatement *sel)=0
Attach selector.

◆ connectTuple()

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 109 of file EventCollectionSelector.cpp.

110  {
111  std::string top = "/NTUPLES/" + name() + '/' + nam;
112  StatusCode status = m_tupleSvc->retrieveObject( top, (DataObject*&)tup );
113  if ( status.isSuccess() ) {
114  item = new NTuple::Item<IOpaqueAddress*>();
115  status = tup->item( itName, *item );
116  if ( status.isSuccess() ) return status;
117  error() << "Item " << itName << " is not part of the collection:" << top << endmsg;
118  delete item;
119  item = nullptr;
120  } else {
121  error() << "Cannot connect to collection:" << top << endmsg;
122  }
123  tup = nullptr;
124  return status;
125 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
STL class.
const std::string & name() const override
Retrieve name of the service.
Definition: Service.cpp:284
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:61
bool isSuccess() const
Definition: StatusCode.h:365
virtual StatusCode retrieveObject(IRegistry *pDirectory, std::string_view 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:40
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202

◆ createAddress()

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 274 of file EventCollectionSelector.cpp.

274  {
275  const MyContextType* ctxt = dynamic_cast<const MyContextType*>( &refCtxt );
276  if ( ctxt ) {
277  IOpaqueAddress* pA = *( ctxt->item );
278  if ( pA ) {
279  IOpaqueAddress* pAddress = nullptr;
280  StatusCode status = m_pAddrCreator->createAddress( pA->svcType(), pA->clID(), pA->par(), pA->ipar(), pAddress );
281  if ( status.isSuccess() ) {
282  refpAddr = pAddress;
283  return StatusCode::SUCCESS;
284  } else {
285  error() << "Failed to access " << pA->par()[0] << ":" << pA->par()[1] << " SvcTyp:" << long( pA->svcType() )
286  << " CLID:" << pA->clID() << endmsg;
287  }
288  }
289  }
290  return StatusCode::FAILURE;
291 }
virtual const std::string * par() const =0
Retrieve String parameters.
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.
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
virtual long svcType() const =0
Retrieve service type.
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
virtual const CLID & clID() const =0
Retrieve class information from link.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:61
bool isSuccess() const
Definition: StatusCode.h:365
constexpr static const auto FAILURE
Definition: StatusCode.h:101
Opaque address interface definition.
SmartIF< IAddressCreator > m_pAddrCreator
virtual const unsigned long * ipar() const =0
Access to generic link parameters.
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202

◆ createContext()

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 228 of file EventCollectionSelector.cpp.

228  {
229  refpCtxt = nullptr;
230  auto ctxt = std::make_unique<MyContextType>();
231  StatusCode status = connectCollection( ctxt.get() );
232  if ( !status.isSuccess() ) {
233  error() << "Unable to connect Collection file \"" << m_database << "\"" << endmsg;
234  return status;
235  }
236  refpCtxt = ctxt.release();
237  return StatusCode::SUCCESS;
238 }
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
virtual StatusCode connectCollection(MyContextType *ctxt) const
Connect collection to selector.
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:61
bool isSuccess() const
Definition: StatusCode.h:365
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202

◆ finalize()

StatusCode EventCollectionSelector::finalize ( )
override

Service override: Finalize Service.

Definition at line 208 of file EventCollectionSelector.cpp.

208  {
209  // release services
210  m_pAddrCreator = nullptr;
211  m_tupleSvc = nullptr;
212  return Service::finalize();
213 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
StatusCode finalize() override
Definition: Service.cpp:174
SmartIF< IAddressCreator > m_pAddrCreator

◆ getNextRecord()

StatusCode EventCollectionSelector::getNextRecord ( NTuple::Tuple tuple) const
virtual

Read next record of the N-tuple.

Definition at line 145 of file EventCollectionSelector.cpp.

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

◆ getPreviousRecord()

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 161 of file EventCollectionSelector.cpp.

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

◆ initialize()

StatusCode EventCollectionSelector::initialize ( )
override

Service override: Initialize service.

Definition at line 69 of file EventCollectionSelector.cpp.

69  {
70  // Initialize base class
72  if ( !status.isSuccess() ) {
73  error() << "Error initializing base class Service!" << endmsg;
74  return status;
75  }
76  m_pAddrCreator = serviceLocator()->service( "EventPersistencySvc" );
77  if ( !m_pAddrCreator ) {
78  error() << "Unable to locate IAddressCreator interface of "
79  << "EventPersistencySvc" << endmsg;
80  return status;
81  }
83  if ( !m_tupleSvc ) {
84  error() << "Unable to locate INTupleSvc interface of " << m_tupleSvcName << endmsg;
85  return status;
86  }
87  return status;
88 }
SmartIF< INTupleSvc > m_tupleSvc
Reference to Tuple service.
StatusCode initialize() override
Definition: Service.cpp:70
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: Service.cpp: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:86
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:61
bool isSuccess() const
Definition: StatusCode.h:365
SmartIF< IAddressCreator > m_pAddrCreator
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202

◆ last()

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 316 of file EventCollectionSelector.cpp.

316 { return StatusCode::FAILURE; }
constexpr static const auto FAILURE
Definition: StatusCode.h:101

◆ next() [1/2]

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 241 of file EventCollectionSelector.cpp.

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

◆ next() [2/2]

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 244 of file EventCollectionSelector.cpp.

244  {
245  MyContextType* ctxt = dynamic_cast<MyContextType*>( &refCtxt );
246  if ( ctxt ) {
247  *( ctxt->item ) = ctxt->addressBuffer;
249  for ( int i = 0; i < jump && sc.isSuccess(); ++i ) { sc = getNextRecord( ctxt->tuple ); }
250  return sc;
251  }
252  return StatusCode::FAILURE;
253 }
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
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:61
constexpr static const auto FAILURE
Definition: StatusCode.h:101

◆ previous() [1/2]

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 256 of file EventCollectionSelector.cpp.

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

◆ previous() [2/2]

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 259 of file EventCollectionSelector.cpp.

259  {
260  MyContextType* ctxt = dynamic_cast<MyContextType*>( &refCtxt );
261  if ( ctxt ) {
262  *( ctxt->item ) = ctxt->addressBuffer;
264  for ( int i = 0; i < jump && sc.isSuccess(); ++i ) { sc = getPreviousRecord( ctxt->tuple ); }
265  return sc;
266  }
267  return StatusCode::FAILURE;
268 }
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
virtual StatusCode getPreviousRecord(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:61
constexpr static const auto FAILURE
Definition: StatusCode.h:101

◆ releaseContext()

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 294 of file EventCollectionSelector.cpp.

294  {
295  MyContextType* ctxt = dynamic_cast<MyContextType*>( refCtxt );
296  if ( ctxt ) {
297  delete ctxt;
298  ctxt = nullptr;
299  return StatusCode::SUCCESS;
300  }
301  return StatusCode::FAILURE;
302 }
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
constexpr static const auto FAILURE
Definition: StatusCode.h:101

◆ resetCriteria()

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 306 of file EventCollectionSelector.cpp.

306  {
307  MyContextType* ctxt = dynamic_cast<MyContextType*>( &refCtxt );
308  if ( ctxt ) {
309  ctxt->criteria = cr;
310  return StatusCode::SUCCESS;
311  }
312  return StatusCode::FAILURE;
313 }
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
constexpr static const auto FAILURE
Definition: StatusCode.h:101

◆ rewind()

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 271 of file EventCollectionSelector.cpp.

271 { return StatusCode::FAILURE; }
constexpr static const auto FAILURE
Definition: StatusCode.h:101

Member Data Documentation

◆ m_authentication

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

Definition at line 91 of file EventCollectionSelector.h.

◆ m_cntName

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

Definition at line 92 of file EventCollectionSelector.h.

◆ m_criteria

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

Definition at line 94 of file EventCollectionSelector.h.

◆ m_database

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

Definition at line 95 of file EventCollectionSelector.h.

◆ m_dbSvc

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

Definition at line 97 of file EventCollectionSelector.h.

◆ m_dbType

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

Definition at line 96 of file EventCollectionSelector.h.

◆ m_itemName

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

Definition at line 93 of file EventCollectionSelector.h.

◆ m_pAddrCreator

SmartIF<IAddressCreator> EventCollectionSelector::m_pAddrCreator
mutableprotected

Definition at line 86 of file EventCollectionSelector.h.

◆ m_statement

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

Definition at line 98 of file EventCollectionSelector.h.

◆ m_tupleSvc

SmartIF<INTupleSvc> EventCollectionSelector::m_tupleSvc
mutableprotected

Reference to Tuple service.

Definition at line 85 of file EventCollectionSelector.h.

◆ m_tupleSvcName

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

Definition at line 89 of file EventCollectionSelector.h.


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