RdDoubleEventRejector.cc

Go to the documentation of this file.

#include "RdDoubleEventRejector.h"

#include <fwk/CentralConfig.h>
#include <fwk/VModule.h>

#include <utl/ErrorLogger.h>
#include <utl/Reader.h>
#include <utl/config.h>

#include <evt/Event.h>
#include <revt/REvent.h>
#include <revt/Header.h>


using namespace fwk;
using namespace std;
using namespace revt;

namespace RdDoubleEventRejector {

RdDoubleEventRejector::RdDoubleEventRejector() :
    fInfoLevel(0),
    fNRejected(0)
{
}

VModule::ResultFlag RdDoubleEventRejector::Init()
{
  // Initialize your module here. This method
  // is called once at the beginning of the run.
  // The eSuccess flag indicates the method ended
  // successfully.  For other possible return types,
  // see the VModule documentation.

  INFO("RdDoubleEventRejector::Init()");

  // Read in the configurations of the xml file
  utl::Branch topBranch = CentralConfig::GetInstance()->GetTopBranch("RdDoubleEventRejector");

  topBranch.GetChild("InfoLevel").GetData(fInfoLevel);

  return eSuccess;
}

VModule::ResultFlag RdDoubleEventRejector::Run(evt::Event& event)
{
  if (fInfoLevel >= eObscure)
    INFO("RdDoubleEventRejector::Run()");

  // Check if there is an radio event at all
  if (!event.HasREvent()) {
    WARNING("No radio event found!");
    return eContinueLoop;
  }

  // get the event
  REvent& rEvent = event.GetREvent();

  stringstream info;

  const std::pair<int, int> eventIdentifier(rEvent.GetHeader().GetRunNumber(),
                                            rEvent.GetHeader().GetId());
  if (fEventList.size() > 0 && fEventList.find(eventIdentifier) != fEventList.end()) {
    if (fInfoLevel >= eFinal) {
      info.str("");
      info << "The current event " << eventIdentifier.first << "." << eventIdentifier.second
           << " has already been read in before.";
      INFO(info.str());
    }
    fNRejected++;
    return eContinueLoop;
  }
  fEventList.insert(eventIdentifier);
  return eSuccess;
}

VModule::ResultFlag RdDoubleEventRejector::Finish()
{
  // Put any termination or cleanup code here.
  // This method is called once at the end of the run.

  INFO("RdDoubleEventRejector::Finish()");
  stringstream sstr;
  sstr << fNRejected << " events have been rejected" << endl;
  INFO(sstr.str());
  return eSuccess;
}

}