EventCollectionSelector.h

Go to the documentation of this file.

//====================================================================
//  EventCollectionSelector.h
//--------------------------------------------------------------------
//
//  Package    : EventCollectionSelector  (LHCb Event Selector Package)
//
//  Author     : M.Frank
//  Created    : 4/10/00
//
//====================================================================
#ifndef GAUDISVC_EventCollectionSelector_EventCollectionSelector_H
#define GAUDISVC_EventCollectionSelector_EventCollectionSelector_H 1

// Include files
#include "GaudiKernel/Service.h"
#include "GaudiKernel/GenericAddress.h"
#include "GaudiKernel/IEvtSelector.h"
#include "GaudiKernel/NTuple.h"

// Forward declarations
class INTuple;
class INTupleSvc;
class IAddressCreator;
class EventSelectorDataStream;
template <class TYPE> class EventIterator;

class EventCollectionSelector : public extends1<Service, IEvtSelector> {
public:
  class MyContextType : public IEvtSelector::Context {
  public:
    std::string                    criteria;
    NTuple::Tuple*                 tuple;
    NTuple::Item<IOpaqueAddress*>* item;
    IOpaqueAddress*                addressBuffer;
    MyContextType(NTuple::Tuple* t, NTuple::Item<IOpaqueAddress*>* i)    {
      addressBuffer = new GenericAddress();
      addressBuffer->addRef();
      tuple = t;
      item = i;
    }
    MyContextType(MyContextType* ctxt=nullptr)  {
      addressBuffer = new GenericAddress();
      addressBuffer->addRef();
      tuple = (ctxt) ? ctxt->tuple : nullptr;
      item  = (ctxt) ? ctxt->item : nullptr;
    }
    MyContextType(const MyContextType& ctxt)
      : IEvtSelector::Context(ctxt)
    {
      addressBuffer = new GenericAddress();
      addressBuffer->addRef();
      tuple = ctxt.tuple;
      item  = ctxt.item;
    }
    ~MyContextType() override {
      addressBuffer->release();
    }
    void* identifier() const override {
      return (void*)addressBuffer;
    }
    void setAddress(IOpaqueAddress* pAddr);
  };
protected:
  mutable SmartIF<INTupleSvc>      m_tupleSvc;
  mutable SmartIF<IAddressCreator> m_pAddrCreator;
  std::string              m_tupleSvcName;
  std::string              m_authentication;
  std::string              m_cntName;
  std::string              m_itemName;
  std::string              m_criteria;
  std::string              m_database;
  std::string              m_dbType;
  std::string              m_dbSvc;
  std::string              m_statement;
public:

  StatusCode initialize() override;
  StatusCode finalize() override;


  StatusCode createContext(Context*& refpCtxt) const override;


  StatusCode next(Context& refCtxt) const override;


  StatusCode next(Context& refCtxt,int jump) const override;


  StatusCode previous(Context& refCtxt) const override;


  StatusCode previous(Context& refCtxt,int jump) const override;


  StatusCode rewind(Context& refCtxt) const override;


  StatusCode createAddress(const Context& refCtxt, IOpaqueAddress*& refpAddr) const override;


  StatusCode releaseContext(Context*& refCtxt) const override;

  StatusCode resetCriteria(const std::string& cr,Context& c) const override;

  StatusCode last(Context& refCtxt) const override;

  virtual StatusCode connectCollection(MyContextType* ctxt) const;

  virtual StatusCode connectDataSource(const std::string& db, const std::string& typ) const;
  virtual StatusCode connectTuple(const std::string& nam, const std::string& itName, NTuple::Tuple*& tup, NTuple::Item<IOpaqueAddress*>*& item) const;
  virtual StatusCode connectStatement(const std::string& typ, const std::string& crit, INTuple* tuple) const;
  virtual StatusCode getNextRecord(NTuple::Tuple* tuple)  const;
  virtual StatusCode getPreviousRecord(NTuple::Tuple* tuple)  const;

  EventCollectionSelector( const std::string& name, ISvcLocator* svcloc );
  ~EventCollectionSelector() override = default;
};

#endif  // GAUDISVC_EventCollectionSelector_EventCollectionSelector_H