PSXtcInput/src/XtcIndexInputModule.cpp

Go to the documentation of this file.

//--------------------------------------------------------------------------
// File and Version Information:
//      $Id: XtcIndexInputModule.cpp 7696 2014-02-27 00:40:59Z salnikov@SLAC.STANFORD.EDU $
//
// Description:
//      Class XtcIndexInputModule...
//
// Author List:
//      Christopher O'Grady
//
//------------------------------------------------------------------------

//-----------------------
// This Class's Header --
//-----------------------
#include "PSXtcInput/XtcIndexInputModule.h"

//-----------------
// C/C++ Headers --
//-----------------
#include <boost/make_shared.hpp>
#include <boost/pointer_cast.hpp>

//-------------------------------
// Collaborating Class Headers --
//-------------------------------
#include "PSXtcInput/DgramSourceIndex.h"
#include "MsgLogger/MsgLogger.h"

//-----------------------------------------------------------------------
// Local Macros, Typedefs, Structures, Unions and Forward Declarations --
//-----------------------------------------------------------------------

using namespace PSXtcInput;
PSANA_INPUT_MODULE_FACTORY(XtcIndexInputModule)


//              ----------------------------------------
//              -- Public Function Member Definitions --
//              ----------------------------------------

namespace {
  const char* logger = "PSXtcInput::XtcIndexInputModule";
}

namespace PSXtcInput {

//----------------
// Constructors --
//----------------
XtcIndexInputModule::XtcIndexInputModule (const std::string& name)
  : XtcInputModuleBase(name, boost::make_shared<DgramSourceIndex>())
  , _idx(name,_queue)
{
  // this is ugly. necessary because it's hard to remember the
  // DgramSourceIndex that we give to XtcInputModuleBase.
  boost::shared_ptr<DgramSourceIndex> dgSourceIndex = boost::dynamic_pointer_cast<DgramSourceIndex>(m_dgsource);
  dgSourceIndex->setQueue(_queue);

  // disable features not supported by indexing
  if (skipEvents()!=0) {
    MsgLog(logger, warning, "Skip-events option not supported by indexing input module");
    skipEvents(0);
  }
  if (maxEvents()!=0) {
    MsgLog(logger, warning, "Max-events option not supported by indexing input module");
    maxEvents(0);
  }
  if (skipEpics()) skipEpics(false);
  if (l3tAcceptOnly()) l3tAcceptOnly(false);
  ConfigSvc::ConfigSvc cfg = configSvc();
  bool allowCorruptEpics = cfg.get("psana", "allow-corrupt-epics", false);
  if (allowCorruptEpics) _idx.allowCorruptEpics();
}

//--------------
// Destructor --
//--------------
XtcIndexInputModule::~XtcIndexInputModule ()
{
}

void 
XtcIndexInputModule::beginJob(Event& evt, Env& env)
{
  // to match the behavior of non-indexing mode, so that
  // configuration information is available at beginJob.
  // it feels somewhat awkward that we have run-specific
  // information available at that time, but we already
  // have this idea in the sequential-access mode -cpo

  int runbegin = _idx.runs()[0];
  _idx.setrun(runbegin);

  // now that indexing is set up, do the base class beginJob
  XtcInputModuleBase::beginJob(evt, env);
}

} // namespace PSXtcInput

---