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/GenericAddress.h"
#include "GaudiKernel/IEvtSelector.h"
#include "GaudiKernel/NTuple.h"
#include "GaudiKernel/Service.h"

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

class EventCollectionSelector : public extends<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;

  // Properties
  Gaudi::Property<std::string> m_tupleSvcName{this, "CnvService", "EvtTupleSvc",
                                              "name of the event collection service"};
  Gaudi::Property<std::string> m_authentication{this, "Authentication", "", "authentication string (if needed)"};
  Gaudi::Property<std::string> m_cntName{this, "Container", "B2PiPi", "container name"};
  Gaudi::Property<std::string> m_itemName{this, "Item", "Address", "item name"};
  Gaudi::Property<std::string> m_criteria{this, "Criteria", "", "criteria"};
  Gaudi::Property<std::string> m_database{this, "DB", "", "datafile name"};
  Gaudi::Property<std::string> m_dbType{this, "DbType", "", "database type identifier"};
  Gaudi::Property<std::string> m_dbSvc{this, "DbService", "", "database service (exclusive property with db type)"};
  Gaudi::Property<std::string> m_statement{this, "Function", "NTuple::Selector", "selector name"};

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;

  using extends::extends;

  ~EventCollectionSelector() override = default;
};

#endif // GAUDISVC_EventCollectionSelector_EventCollectionSelector_H