The Gaudi Framework  v29r0 (ff2e7097)
Gaudi::RootEvtSelector Class Reference

Concrete event selector implementation to access ROOT files. More...

#include <GAUDIROOT/RootEvtSelector.h>

Inheritance diagram for Gaudi::RootEvtSelector:
Collaboration diagram for Gaudi::RootEvtSelector:

Public Member Functions

 ~RootEvtSelector () override=default
 Standard destructor. More...
 
StatusCode initialize () override
 IService implementation: Db event selector override. More...
 
StatusCode finalize () override
 IService implementation: Service finalization. More...
 
StatusCode createContext (Context *&refpCtxt) const override
 Create a new event loop context. More...
 
StatusCode last (Context &refContext) const override
 Access last item in the iteration. 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 *&) 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...
 
- 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...
 
 ~extends () override=default
 Virtual destructor. 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
 
 ~PropertyHolder () override=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, TYPE &value, const std::string &doc="none") const
 
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
 
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, GaudiHandleBase &ref, const std::string &doc="none")
 Specializations for various GaudiHandles. More...
 
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, GaudiHandleArrayBase &ref, const std::string &doc="none")
 
Gaudi::Details::PropertyBasedeclareProperty (const std::string &name, DataObjectHandleBase &ref, const std::string &doc="none")
 
- Public Member Functions inherited from CommonMessagingBase
virtual ~CommonMessagingBase ()=default
 Virtual destructor. More...
 
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...
 
MSG::Level msgLevel () const
 get the output level from the embedded MsgStream More...
 
MSG::Level outputLevel () const __attribute__((deprecated))
 Backward compatibility function for getting the output level. More...
 
bool msgLevel (MSG::Level lvl) const
 get the output level from the embedded MsgStream More...
 
- Public Member Functions inherited from extend_interfaces< Interfaces... >
 ~extend_interfaces () override=default
 Virtual destructor. More...
 

Protected Attributes

RootCnvSvcm_dbMgr
 Reference to the corresponding conversion service. More...
 
CLID m_rootCLID = CLID_NULL
 Class id of root node to create opaque address. More...
 
Gaudi::Property< std::stringm_persName
 
Gaudi::Property< std::stringm_dummy {this, "DbType", "", "dummy property to fake backwards compatibility"}
 
std::string m_cnvSvcName = "Gaudi::RootCnvSvc/RootCnvSvc"
 Property; Name of the concversion service used to create opaque addresses. More...
 
std::string m_rootName
 Property: Name of the ROOT entry name. More...
 
std::string m_criteria
 Property: File criteria to define item iteration. More...
 
- 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...
 

Private Member Functions

StatusCode error (const std::string &msg) const
 Helper method to issue error messages. 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
typedef Gaudi::PluginService::Factory< IService *, const std::string &, ISvcLocator * > Factory
 
- 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 > >
void updateMsgStreamOutputLevel (int level)
 Update the output level of the cached MsgStream. More...
 

Detailed Description

Concrete event selector implementation to access ROOT files.

Author
M.Frank
Version
1.0
Date
20/12/2009

Definition at line 40 of file RootEvtSelector.h.

Constructor & Destructor Documentation

Gaudi::RootEvtSelector::~RootEvtSelector ( )
overridedefault

Standard destructor.

Member Function Documentation

StatusCode RootEvtSelector::createAddress ( const Context &  refCtxt,
IOpaqueAddress *&  pAddr 
) const
override

Create new Opaque address corresponding to the current record.

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

Definition at line 272 of file RootEvtSelector.cpp.

273 {
274  const RootEvtSelectorContext* pctxt = dynamic_cast<const RootEvtSelectorContext*>( &ctxt );
275  if ( pctxt ) {
276  long ent = pctxt->entry();
277  if ( ent >= 0 ) {
278  auto fileit = pctxt->fileIterator();
279  if ( fileit != pctxt->files().end() ) {
280  const string par[2] = {pctxt->fid(), m_rootName};
281  const unsigned long ipar[2] = {0, (unsigned long)ent};
282  return m_dbMgr->createAddress( m_dbMgr->repSvcType(), m_rootCLID, &par[0], &ipar[0], pAddr );
283  }
284  }
285  }
286  pAddr = nullptr;
287  return StatusCode::FAILURE;
288 }
const Files & files() const
Access to the file container.
Files::const_iterator fileIterator() const
Access to the file iterator.
StatusCode createAddress(long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress) override
IAddressCreator implementation: Address creation.
Definition: RootCnvSvc.cpp:371
T end(T...args)
RootCnvSvc * m_dbMgr
Reference to the corresponding conversion service.
ROOT specific event selector context.
const std::string & fid() const
Access connection fid.
long repSvcType() const override
Retrieve the class type of the data store the converter uses.
CLID m_rootCLID
Class id of root node to create opaque address.
long entry() const
Access to the current event entry number.
std::string m_rootName
Property: Name of the ROOT entry name.
StatusCode RootEvtSelector::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 162 of file RootEvtSelector.cpp.

163 {
164  refpCtxt = new RootEvtSelectorContext( this );
165  return StatusCode::SUCCESS;
166 }
ROOT specific event selector context.
StatusCode RootEvtSelector::error ( const std::string msg) const
private

Helper method to issue error messages.

Definition at line 104 of file RootEvtSelector.cpp.

105 {
106  MsgStream log( msgSvc(), name() );
107  log << MSG::ERROR << msg << endmsg;
108  return StatusCode::FAILURE;
109 }
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:24
const std::string & name() const override
Retrieve name of the service.
Definition: Service.cpp:289
SmartIF< IMessageSvc > & msgSvc() const
The standard message service.
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode RootEvtSelector::finalize ( )
override

IService implementation: Service finalization.

Definition at line 153 of file RootEvtSelector.cpp.

154 {
155  // Initialize base class
156  if ( m_dbMgr ) m_dbMgr->release();
157  m_dbMgr = nullptr; // release
158  return Service::finalize();
159 }
StatusCode finalize() override
Definition: Service.cpp:174
RootCnvSvc * m_dbMgr
Reference to the corresponding conversion service.
StatusCode RootEvtSelector::initialize ( )
override

IService implementation: Db event selector override.

Definition at line 112 of file RootEvtSelector.cpp.

113 {
114  // Initialize base class
115  StatusCode status = Service::initialize();
116  if ( !status.isSuccess() ) {
117  return error( "Error initializing base class Service!" );
118  }
119 
120  auto ipers = serviceLocator()->service<IPersistencySvc>( m_persName );
121  if ( !ipers ) {
122  return error( "Unable to locate IPersistencySvc interface of " + m_persName );
123  }
124  IConversionSvc* cnvSvc = nullptr;
126  status = ipers->getService( itm.name(), cnvSvc );
127  if ( !status.isSuccess() ) {
128  status = ipers->getService( itm.type(), cnvSvc );
129  if ( !status.isSuccess() ) {
130  return error( "Unable to locate IConversionSvc interface of database type " + m_cnvSvcName );
131  }
132  }
133  m_dbMgr = dynamic_cast<RootCnvSvc*>( cnvSvc );
134  if ( !m_dbMgr ) {
135  cnvSvc->release();
136  return error( "Unable to localize service:" + m_cnvSvcName );
137  }
138  m_dbMgr->addRef();
139 
140  // Get DataSvc
141  auto eds = serviceLocator()->service<IDataManagerSvc>( "EventDataSvc" );
142  if ( !eds ) {
143  return error( "Unable to localize service EventDataSvc" );
144  }
145  m_rootCLID = eds->rootCLID();
146  m_rootName = eds->rootName();
147  MsgStream log( msgSvc(), name() );
148  log << MSG::DEBUG << "Selection root:" << m_rootName << " CLID:" << m_rootCLID << endmsg;
149  return status;
150 }
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:24
StatusCode initialize() override
Definition: Service.cpp:64
const std::string & name() const override
Retrieve name of the service.
Definition: Service.cpp:289
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:75
Description:
Definition: RootCnvSvc.h:53
Gaudi::Property< std::string > m_persName
RootCnvSvc * m_dbMgr
Reference to the corresponding conversion service.
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)
Helper class to parse a string of format "type/name".
std::string m_cnvSvcName
Property; Name of the concversion service used to create opaque addresses.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:28
virtual unsigned long release()=0
Release Interface instance.
SmartIF< IMessageSvc > & msgSvc() const
The standard message service.
Data persistency service interface.
CLID m_rootCLID
Class id of root node to create opaque address.
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Definition: Service.cpp:292
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
std::string m_rootName
Property: Name of the ROOT entry name.
StatusCode RootEvtSelector::last ( Context &  refContext) const
override

Access last item in the iteration.

Parameters
refContext[IN/OUT] Reference to the Context object.

Definition at line 169 of file RootEvtSelector.cpp.

StatusCode RootEvtSelector::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 172 of file RootEvtSelector.cpp.

173 {
174  RootEvtSelectorContext* pCtxt = dynamic_cast<RootEvtSelectorContext*>( &ctxt );
175  if ( pCtxt ) {
176  TBranch* b = pCtxt->branch();
177  if ( !b ) {
178  auto fileit = pCtxt->fileIterator();
179  pCtxt->setBranch( nullptr );
180  pCtxt->setEntry( -1 );
181  if ( fileit != pCtxt->files().end() ) {
182  RootDataConnection* con = nullptr;
183  string in = *fileit;
185  if ( sc.isSuccess() ) {
186  string section = m_rootName[0] == '/' ? m_rootName.substr( 1 ) : m_rootName;
187  b = con->getBranch( section, m_rootName );
188  if ( b ) {
189  pCtxt->setFID( con->fid() );
190  pCtxt->setBranch( b );
191  return next( ctxt );
192  }
193  }
194  m_dbMgr->disconnect( in ).ignore();
195  pCtxt->setFileIterator( ++fileit );
196  return next( ctxt );
197  }
198  return StatusCode::FAILURE;
199  }
200  long ent = pCtxt->entry();
201  Long64_t nent = b->GetEntries();
202  if ( nent > ( ent + 1 ) ) {
203  pCtxt->setEntry( ++ent );
204  return StatusCode::SUCCESS;
205  }
206  auto fit = pCtxt->fileIterator();
207  pCtxt->setFileIterator( ++fit );
208  pCtxt->setEntry( -1 );
209  pCtxt->setBranch( nullptr );
210  pCtxt->setFID( "" );
211  return next( ctxt );
212  }
213  return StatusCode::FAILURE;
214 }
const Files & files() const
Access to the file container.
Files::const_iterator fileIterator() const
Access to the file iterator.
const std::string & fid() const
Access file id.
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:75
T end(T...args)
StatusCode connectDatabase(const std::string &dataset, int mode, RootDataConnection **con)
Connect the output file to the service with open mode.
Definition: RootCnvSvc.cpp:211
RootCnvSvc * m_dbMgr
Reference to the corresponding conversion service.
ROOT specific event selector context.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:28
TBranch * getBranch(const std::string &section, const std::string &branch_name)
Access data branch by name: Get existing branch in read only mode.
virtual StatusCode disconnect(const std::string &dbName)
Disconnect from an existing data stream.
Definition: RootCnvSvc.cpp:364
void setBranch(TBranch *b)
Set the top level branch (typically /Event) used to iterate.
StatusCode next(Context &refCtxt) const override
Get next iteration item from the event loop context.
void setEntry(long e)
Set current event entry number.
void setFID(const std::string &fid)
Set connection FID.
T substr(T...args)
void setFileIterator(Files::const_iterator i)
Set file iterator.
TBranch * branch() const
Access to the top level branch (typically /Event) used to iterate.
void ignore() const
Definition: StatusCode.h:109
Concrete implementation of the IDataConnection interface to access ROOT files.
long entry() const
Access to the current event entry number.
std::string m_rootName
Property: Name of the ROOT entry name.
StatusCode RootEvtSelector::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 217 of file RootEvtSelector.cpp.

218 {
219  if ( jump > 0 ) {
220  for ( int i = 0; i < jump; ++i ) {
221  StatusCode status = next( ctxt );
222  if ( !status.isSuccess() ) {
223  return status;
224  }
225  }
226  return StatusCode::SUCCESS;
227  }
228  return StatusCode::FAILURE;
229 }
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:75
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:28
StatusCode next(Context &refCtxt) const override
Get next iteration item from the event loop context.
StatusCode RootEvtSelector::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 232 of file RootEvtSelector.cpp.

233 {
234  return error( "EventSelector Iterator, operator -- not supported " );
235 }
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
StatusCode RootEvtSelector::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 238 of file RootEvtSelector.cpp.

239 {
240  if ( jump > 0 ) {
241  for ( int i = 0; i < jump; ++i ) {
242  StatusCode status = previous( ctxt );
243  if ( !status.isSuccess() ) {
244  return status;
245  }
246  }
247  return StatusCode::SUCCESS;
248  }
249  return StatusCode::FAILURE;
250 }
bool isSuccess() const
Test for a status code of SUCCESS.
Definition: StatusCode.h:75
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:28
StatusCode previous(Context &refCtxt) const override
Get previous iteration item from the event loop context.
StatusCode RootEvtSelector::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 291 of file RootEvtSelector.cpp.

292 {
293  RootEvtSelectorContext* pCtxt = dynamic_cast<RootEvtSelectorContext*>( ctxt );
294  if ( pCtxt ) {
295  delete pCtxt;
296  return StatusCode::SUCCESS;
297  }
298  return StatusCode::FAILURE;
299 }
ROOT specific event selector context.
StatusCode RootEvtSelector::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.

Parameters
crThe new criteria string.
cReference pointer to the Context object.

Definition at line 303 of file RootEvtSelector.cpp.

304 {
305  MsgStream log( msgSvc(), name() );
306  RootEvtSelectorContext* ctxt = dynamic_cast<RootEvtSelectorContext*>( &context );
307  string db, typ, item, sel, stmt, aut, addr;
308  if ( ctxt ) {
309  if ( criteria.compare( 0, 5, "FILE " ) == 0 ) {
310  // The format for the criteria is:
311  // FILE filename1, filename2 ...
312  db = criteria.substr( 5 );
313  } else {
314  using Parser = Gaudi::Utils::AttribStringParser;
315  for ( auto attrib : Parser( criteria ) ) {
316  string tmp = attrib.tag.substr( 0, 3 );
317  if ( tmp == "DAT" ) {
318  db = std::move( attrib.value );
319  } else if ( tmp == "OPT" ) {
320  if ( attrib.value.compare( 0, 3, "REA" ) != 0 ) {
321  log << MSG::ERROR << "Option:\"" << attrib.value << "\" not valid" << endmsg;
322  return StatusCode::FAILURE;
323  }
324  } else if ( tmp == "TYP" ) {
325  typ = std::move( attrib.value );
326  } else if ( tmp == "ADD" ) {
327  item = std::move( attrib.value );
328  } else if ( tmp == "SEL" ) {
329  sel = std::move( attrib.value );
330  } else if ( tmp == "FUN" ) {
331  stmt = std::move( attrib.value );
332  } else if ( tmp == "AUT" ) {
333  aut = std::move( attrib.value );
334  } else if ( tmp == "COL" ) {
335  addr = std::move( attrib.value );
336  }
337  }
338  }
339  // It's now time to parse the criteria for the event selection
340  // The format for the criteria is:
341  // FILE filename1, filename2 ...
342  // JOBID number1-number2, number3, ...
344  string rest = db;
345  files.clear();
346  while ( true ) {
347  int ipos = rest.find_first_not_of( " ," );
348  if ( ipos == -1 ) break;
349  rest = rest.substr( ipos, string::npos ); // remove blanks before
350  int lpos = rest.find_first_of( " ," ); // locate next blank
351  files.push_back( rest.substr( 0, lpos ) ); // insert in list
352  if ( lpos == -1 ) break;
353  rest = rest.substr( lpos, string::npos ); // get the rest
354  }
355  ctxt->setFiles( files );
356  ctxt->setFileIterator( ctxt->files().begin() );
357  return StatusCode::SUCCESS;
358  }
359  return error( "Invalid iteration context." );
360 }
Parse attribute strings allowing iteration over the various attributes.
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:24
const Files & files() const
Access to the file container.
const std::string & name() const override
Retrieve name of the service.
Definition: Service.cpp:289
T find_first_not_of(T...args)
sel
Definition: IOTest.py:95
T push_back(T...args)
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
ROOT specific event selector context.
T find_first_of(T...args)
T clear(T...args)
T move(T...args)
void setFiles(const Files &f)
Set the file container.
T begin(T...args)
SmartIF< IMessageSvc > & msgSvc() const
The standard message service.
T substr(T...args)
void setFileIterator(Files::const_iterator i)
Set file iterator.
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:209
StatusCode RootEvtSelector::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 253 of file RootEvtSelector.cpp.

254 {
255  RootEvtSelectorContext* pCtxt = dynamic_cast<RootEvtSelectorContext*>( &ctxt );
256  if ( pCtxt ) {
257  auto fileit = pCtxt->fileIterator();
258  if ( fileit != pCtxt->files().end() ) {
259  string input = *fileit;
260  m_dbMgr->disconnect( input ).ignore();
261  }
262  pCtxt->setFID( "" );
263  pCtxt->setEntry( -1 );
264  pCtxt->setBranch( nullptr );
265  pCtxt->setFileIterator( pCtxt->files().begin() );
266  return StatusCode::SUCCESS;
267  }
268  return StatusCode::FAILURE;
269 }
const Files & files() const
Access to the file container.
Files::const_iterator fileIterator() const
Access to the file iterator.
T end(T...args)
RootCnvSvc * m_dbMgr
Reference to the corresponding conversion service.
ROOT specific event selector context.
virtual StatusCode disconnect(const std::string &dbName)
Disconnect from an existing data stream.
Definition: RootCnvSvc.cpp:364
void setBranch(TBranch *b)
Set the top level branch (typically /Event) used to iterate.
void setEntry(long e)
Set current event entry number.
T begin(T...args)
void setFID(const std::string &fid)
Set connection FID.
void setFileIterator(Files::const_iterator i)
Set file iterator.
void ignore() const
Definition: StatusCode.h:109

Member Data Documentation

std::string Gaudi::RootEvtSelector::m_cnvSvcName = "Gaudi::RootCnvSvc/RootCnvSvc"
protected

Property; Name of the concversion service used to create opaque addresses.

Definition at line 142 of file RootEvtSelector.h.

std::string Gaudi::RootEvtSelector::m_criteria
protected

Property: File criteria to define item iteration.

Definition at line 146 of file RootEvtSelector.h.

RootCnvSvc* Gaudi::RootEvtSelector::m_dbMgr
mutableprotected

Reference to the corresponding conversion service.

Definition at line 133 of file RootEvtSelector.h.

Gaudi::Property<std::string> Gaudi::RootEvtSelector::m_dummy {this, "DbType", "", "dummy property to fake backwards compatibility"}
protected

Definition at line 139 of file RootEvtSelector.h.

Gaudi::Property<std::string> Gaudi::RootEvtSelector::m_persName
protected
Initial value:
{this, "EvtPersistencySvc", "EventPersistencySvc",
"Name of the persistency service to search for conversion service"}

Definition at line 137 of file RootEvtSelector.h.

CLID Gaudi::RootEvtSelector::m_rootCLID = CLID_NULL
protected

Class id of root node to create opaque address.

Definition at line 135 of file RootEvtSelector.h.

std::string Gaudi::RootEvtSelector::m_rootName
protected

Property: Name of the ROOT entry name.

Definition at line 144 of file RootEvtSelector.h.


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