In This Package:

RawDataEvtSelector.cc

Go to the documentation of this file.

#include "GaudiKernel/PropertyMgr.h"
#include "GaudiKernel/IMessageSvc.h"
#include "GaudiKernel/StatusCode.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/DataObject.h"

#include "RawDataIO/IRawDataInputSvc.h"
#include "RawDataEvent.h"
#include "RawDataAddress.h"
#include "RawDataEvtSelector.h"

using namespace std;

RawDataEvtSelector::RawDataEvtSelector(const string& name, ISvcLocator* svcloc)
      : Service(name, svcloc),
      m_rawSvc(0)
{
}

RawDataEvtSelector::~RawDataEvtSelector()
{
   MsgStream log(msgSvc(), name());
   log << MSG::INFO << "RawDataEvtSelector::~RawDataEvtSelector()" << endreq;
}

StatusCode RawDataEvtSelector::initialize()
{
   MsgStream log(msgSvc(), name());
   log << MSG::INFO << "initialize() ... in name " << name() << endreq;

   StatusCode sc = Service::initialize();
   if (sc.isFailure()) return sc;

   sc = service("RawDataInputSvc", m_rawSvc, true);
   if (sc.isFailure()) {
      log << MSG::ERROR << "Cannot get RawDataInputSvc" << endreq;
   }

   return sc;
}

StatusCode RawDataEvtSelector::finalize()
{
   return Service::finalize();
}


StatusCode RawDataEvtSelector::createContext(IEvtSelector::Context*& it) const
{
   //wm m_rawSvc->initialize();
   it =  new RawDataEvtSelector::Context(this);
   return StatusCode::SUCCESS;
}

StatusCode RawDataEvtSelector::next(IEvtSelector::Context& it) const
{
   MsgStream log(msgSvc(), name());
   log << MSG::DEBUG << "next" << endreq;
   return next(it, 1);
}

StatusCode RawDataEvtSelector::next(IEvtSelector::Context& ctxt, int jump) const
{
   MsgStream log(msgSvc(), name());
   log << MSG::DEBUG << "next(" << jump << ")" << endreq;
   StatusCode sc = m_rawSvc->nextEvent();
   if (!sc.isSuccess()) {
      log << MSG::WARNING << "call to RawDataInputSvc->nextEvent() failed!!!" << endreq;
      return sc;
   }
   RawDataEvtSelector::Context* rc = dynamic_cast<RawDataEvtSelector::Context*>(&ctxt);
   if (!rc)
      return StatusCode::FAILURE;
   return setEntry(*rc, rc->m_entry + jump);
}

StatusCode RawDataEvtSelector::previous(IEvtSelector::Context& it) const
{
   return previous(it, 1);
}

StatusCode RawDataEvtSelector::previous(IEvtSelector::Context& it, int jump) const
{
   RawDataEvtSelector::Context* rc = dynamic_cast<RawDataEvtSelector::Context*>(&it);
   if (!rc) return StatusCode::FAILURE;
   rc->m_entry -= jump;
   return setEntry(*rc, rc->m_entry - jump);
}

StatusCode RawDataEvtSelector::last(IEvtSelector::Context&)const
{
   MsgStream log(msgSvc(), name());
   log << MSG::ERROR << "last() not currently supported" << endreq;
   return StatusCode::FAILURE;
}

StatusCode RawDataEvtSelector::resetCriteria(const string& cr, IEvtSelector::Context& c) const
{
   MsgStream log(msgSvc(), name());
   log << MSG::INFO << "resetCriteria(" << cr << ")" << endreq;

   RawDataEvtSelector::Context* rc = dynamic_cast<RawDataEvtSelector::Context*>(&c);
   if (!rc) return StatusCode::FAILURE;
   return StatusCode::SUCCESS;
}

StatusCode RawDataEvtSelector::rewind(IEvtSelector::Context&) const
{
   MsgStream log(msgSvc(), name());
   log << MSG::ERROR << "rewind() not implemented" << endreq;
   return StatusCode::FAILURE;
}

StatusCode RawDataEvtSelector::createAddress(const IEvtSelector::Context& c, IOpaqueAddress*& iop) const
{
   MsgStream log(msgSvc(), name());
   log << MSG::DEBUG << "createAddress" << endreq;
   const RawDataEvtSelector::Context* rc = dynamic_cast<const RawDataEvtSelector::Context*>(&c);
   if (!rc) {
      log << MSG::ERROR << "Failed to get Context" << endreq;
      return StatusCode::FAILURE;
   }

   iop = new RawDataAddress(DataObject::classID(), "Event", "Event");
   log << MSG::DEBUG << "createAddress for /Event" << endreq;
   return StatusCode::SUCCESS;
}

StatusCode RawDataEvtSelector::releaseContext(IEvtSelector::Context*& it) const
{
   RawDataEvtSelector::Context* rc = dynamic_cast<RawDataEvtSelector::Context*>(it);
   if (!rc) return StatusCode::FAILURE;

   delete rc;
   it = 0;
   return StatusCode::SUCCESS;
}

StatusCode RawDataEvtSelector::queryInterface(const InterfaceID& riid, void** ppvInterface)
{
   MsgStream log(msgSvc(), name());
   if (riid == IID_IEvtSelector) {
      *ppvInterface = (IEvtSelector*)this;
      addRef();
      log << MSG::DEBUG << "queryInterface(IID_IEvtSelector)" << endreq;
      return StatusCode::SUCCESS;
   } else if (riid == IID_IProperty) {
      *ppvInterface = (IProperty*)this;
   } else {
      log << MSG::DEBUG << "queryInterface(" << riid << ")" << endreq;
      return Service::queryInterface(riid, ppvInterface);
   }
   addRef();
   return StatusCode::SUCCESS;
}

StatusCode RawDataEvtSelector::setEntry(RawDataEvtSelector::Context& rc, int entry) const
{
   MsgStream log(msgSvc(), name());
   log << MSG::DEBUG << "setEntry(" << entry << ")" << endreq;

   rc.m_entry = entry;
   return StatusCode::SUCCESS;
}

---