CastorRawToDigi Class Reference

#include <CastorRawToDigi.h>

Inheritance diagram for CastorRawToDigi:

Public Member Functions
void	beginRun (edm::Run const &, edm::EventSetup const &) override
	CastorRawToDigi (const edm::ParameterSet &ps)
void	produce (edm::Event &e, const edm::EventSetup &c) override
	~CastorRawToDigi () override
Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default
	EDProducer (const EDProducer &)=delete
bool	hasAbilityToProduceInBeginLumis () const final
bool	hasAbilityToProduceInBeginProcessBlocks () const final
bool	hasAbilityToProduceInBeginRuns () const final
bool	hasAbilityToProduceInEndLumis () const final
bool	hasAbilityToProduceInEndProcessBlocks () const final
bool	hasAbilityToProduceInEndRuns () const final
const EDProducer &	operator= (const EDProducer &)=delete

Private Attributes
bool	complainEmptyData_
CastorCtdcUnpacker	ctdcunpacker_
edm::InputTag	dataTag_
int	expectedOrbitMessageTime_
std::vector< int >	fedUnpackList_
CastorDataFrameFilter	filter_
int	firstFED_
std::unique_ptr< HcalElectronicsMap >	myEMap
bool	silent_
edm::EDGetTokenT< FEDRawDataCollection >	tok_input_
edm::ESGetToken< CastorDbService, CastorDbRecord >	tok_pSetup_
CastorUnpacker	unpacker_
bool	unpackTTP_
bool	unpackZDC_
bool	usenominalOrbitMessageTime_
bool	usingctdc_
edm::ParameterSet	zdcemap
ZdcUnpacker	zdcunpacker_

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer<>
using	CacheTypes = CacheContexts< T... >
using	GlobalCache = typename CacheTypes::GlobalCache
using	HasAbility = AbilityChecker< T... >
using	InputProcessBlockCache = typename CacheTypes::InputProcessBlockCache
using	LuminosityBlockCache = typename CacheTypes::LuminosityBlockCache
using	LuminosityBlockContext = LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >
using	LuminosityBlockSummaryCache = typename CacheTypes::LuminosityBlockSummaryCache
using	RunCache = typename CacheTypes::RunCache
using	RunContext = RunContextT< RunCache, GlobalCache >
using	RunSummaryCache = typename CacheTypes::RunSummaryCache

Detailed Description

CastorRawToDigi is the EDProducer subclass which runs the Hcal Unpack algorithm.

Author

Alan Campbell

Version

1st Version April 18, 2008

Definition at line 38 of file CastorRawToDigi.h.

Constructor & Destructor Documentation

CastorRawToDigi()

CastorRawToDigi::CastorRawToDigi ( const edm::ParameterSet &  ps )

explicit

Definition at line 16 of file CastorRawToDigi.cc.

References dataTag_, expectedOrbitMessageTime_, fedUnpackList_, mps_fire::i, FEDNumbering::MAXCASTORFEDID, FEDNumbering::MINCASTORFEDID, CastorUnpacker::setExpectedOrbitMessageTime(), contentValuesCheck::ss, tok_input_, tok_pSetup_, unpacker_, and unpackTTP_.

    : dataTag_(conf.getParameter<edm::InputTag>("InputLabel")),
      unpacker_(conf.getParameter<int>("CastorFirstFED"),
                conf.getParameter<int>("firstSample"),
                conf.getParameter<int>("lastSample")),
      zdcunpacker_(conf.getParameter<int>("CastorFirstFED"),
                   conf.getParameter<int>("firstSample"),
                   conf.getParameter<int>("lastSample")),
      ctdcunpacker_(conf.getParameter<int>("CastorFirstFED"),
                    conf.getParameter<int>("firstSample"),
                    conf.getParameter<int>("lastSample")),
      filter_(
          conf.getParameter<bool>("FilterDataQuality"), conf.getParameter<bool>("FilterDataQuality"), false, 0, 0, -1),
      fedUnpackList_(conf.getUntrackedParameter<std::vector<int> >("FEDs", std::vector<int>())),
      firstFED_(conf.getParameter<int>("CastorFirstFED")),
      complainEmptyData_(conf.getUntrackedParameter<bool>("ComplainEmptyData", false)),
      usingctdc_(conf.getParameter<bool>("CastorCtdc")),
      unpackTTP_(conf.getParameter<bool>("UnpackTTP")),
      unpackZDC_(conf.getParameter<bool>("UnpackZDC")),
      silent_(conf.getUntrackedParameter<bool>("silent", true)),
      usenominalOrbitMessageTime_(conf.getParameter<bool>("UseNominalOrbitMessageTime")),
      expectedOrbitMessageTime_(conf.getParameter<int>("ExpectedOrbitMessageTime"))

{
  if (fedUnpackList_.empty()) {
    for (int i = FEDNumbering::MINCASTORFEDID; i <= FEDNumbering::MAXCASTORFEDID; i++)
      fedUnpackList_.push_back(i);
  }

  unpacker_.setExpectedOrbitMessageTime(expectedOrbitMessageTime_);
  std::ostringstream ss;
  for (unsigned int i = 0; i < fedUnpackList_.size(); i++)
    ss << fedUnpackList_[i] << " ";
  edm::LogInfo("CASTOR") << "CastorRawToDigi will unpack FEDs ( " << ss.str() << ")";

  // products produced...
  produces<CastorDigiCollection>();
  produces<ZDCDigiCollection>();
  produces<CastorTrigPrimDigiCollection>();
  produces<HcalUnpackerReport>();
  if (unpackTTP_)
    produces<HcalTTPDigiCollection>();

  tok_input_ = consumes<FEDRawDataCollection>(dataTag_);
  tok_pSetup_ = esConsumes<CastorDbService, CastorDbRecord>();
}

~CastorRawToDigi()

CastorRawToDigi::~CastorRawToDigi ( )

override

Definition at line 64 of file CastorRawToDigi.cc.

{}

Member Function Documentation

beginRun()

void CastorRawToDigi::beginRun ( edm::Run const &  irun, edm::EventSetup const &  es  )

override

Definition at line 197 of file CastorRawToDigi.cc.

References expectedOrbitMessageTime_, edm::RunBase::run(), CastorUnpacker::setExpectedOrbitMessageTime(), unpacker_, and usenominalOrbitMessageTime_.

                                                                          {
  if (usenominalOrbitMessageTime_) {
    if (irun.run() > 132640) {
      expectedOrbitMessageTime_ = 3560;
    } else if (irun.run() > 132174) {
      expectedOrbitMessageTime_ = 3559;
    } else if (irun.run() > 124371) {
      expectedOrbitMessageTime_ = 3557;
    } else if (irun.run() > 123984) {
      expectedOrbitMessageTime_ = 3559;
    } else if (irun.run() > 123584) {
      expectedOrbitMessageTime_ = 2;
    } else {
      expectedOrbitMessageTime_ = 3562;
    }
    unpacker_.setExpectedOrbitMessageTime(expectedOrbitMessageTime_);
  }
}

produce()

void CastorRawToDigi::produce ( edm::Event &  e, const edm::EventSetup &  c  )

override

Definition at line 67 of file CastorRawToDigi.cc.

References CastorDataFrameFilter::active(), castorDigitizer_cfi::castor, CastorRawCollections::castorCont, complainEmptyData_, ctdcunpacker_, MillePedeFileConverter_cfg::e, FEDRawDataCollection::FEDData(), fedUnpackList_, CastorDataFrameFilter::filter(), filter_, CastorDbService::getCastorMapping(), edm::EventSetup::getHandle(), mps_fire::i, eostools::move(), copyEcalPFRecHitThresholds_cfg::prod, zeeHLT_cff::report, FEDRawData::size(), edm::SortedCollection< T, SORT >::swap(), tok_input_, tok_pSetup_, CastorCtdcUnpacker::unpack(), CastorUnpacker::unpack(), ZdcUnpacker::unpack(), unpacker_, unpackTTP_, unpackZDC_, usingctdc_, hcalSimParameters_cfi::zdc, and zdcunpacker_.

                                                                  {
  // Step A: Get Inputs
  edm::Handle<FEDRawDataCollection> rawraw;
  e.getByToken(tok_input_, rawraw);
  // get the mapping
  edm::ESHandle<CastorDbService> pSetup = es.getHandle(tok_pSetup_);
  const CastorElectronicsMap* readoutMap = pSetup->getCastorMapping();

  // Step B: Create empty output  : three vectors for three classes...
  std::vector<CastorDataFrame> castor;
  std::vector<ZDCDataFrame> zdc;
  std::vector<HcalTTPDigi> ttp;
  std::vector<CastorTriggerPrimitiveDigi> htp;

  auto report = std::make_unique<HcalUnpackerReport>();

  CastorRawCollections colls;
  colls.castorCont = &castor;
  colls.zdcCont = &zdc;
  if (unpackTTP_)
    colls.ttp = &ttp;
  colls.tpCont = &htp;

  // Step C: unpack all requested FEDs
  const FEDRawData& fed722 = rawraw->FEDData(722);
  const int fed722size = fed722.size();
  const FEDRawData& fed693 = rawraw->FEDData(693);
  const int fed693size = fed693.size();
  for (std::vector<int>::const_iterator i = fedUnpackList_.begin(); i != fedUnpackList_.end(); i++) {
    const FEDRawData& fed = rawraw->FEDData(*i);
    //std::cout<<"Fed number "<<*i<<"is being worked on"<<std::endl;
    if (*i == 693 && fed693size == 0 && fed722size != 0)
      continue;
    if (*i == 722 && fed722size == 0 && fed693size != 0)
      continue;

    if (*i != 693 && *i != 722) {
      if (fed.size() == 0) {
        if (complainEmptyData_) {
          edm::LogWarning("EmptyData") << "No data for FED " << *i;
          report->addError(*i);
        }
      } else if (fed.size() < 8 * 3) {
        edm::LogWarning("EmptyData") << "Tiny data " << fed.size() << " for FED " << *i;
        report->addError(*i);
      } else {
        try {
          if (usingctdc_) {
            ctdcunpacker_.unpack(fed, *readoutMap, colls, *report);
          } else {
            unpacker_.unpack(fed, *readoutMap, colls, *report);
          }
          report->addUnpacked(*i);
        } catch (cms::Exception& e) {
          edm::LogWarning("Unpacking error") << e.what();
          report->addError(*i);
        } catch (...) {
          edm::LogWarning("Unpacking exception");
          report->addError(*i);
        }
      }
    }

    if (*i == 693 && unpackZDC_) {
      if (fed.size() == 0) {
        if (complainEmptyData_) {
          edm::LogWarning("EmptyData") << "No data for FED " << *i;
          report->addError(*i);
        }
      }
      if (fed.size() != 0) {
        zdcunpacker_.unpack(fed, *readoutMap, colls, *report);
        report->addUnpacked(*i);
      }
    }

    if (*i == 722 && unpackZDC_) {
      if (fed.size() == 0) {
        if (complainEmptyData_) {
          edm::LogWarning("EmptyData") << "No data for FED " << *i;
          report->addError(*i);
        }
      }
      if (fed.size() != 0) {
        zdcunpacker_.unpack(fed, *readoutMap, colls, *report);
        report->addUnpacked(*i);
      }
    }

  }  //end of loop over feds

  // Step B: encapsulate vectors in actual collections
  auto castor_prod = std::make_unique<CastorDigiCollection>();
  auto htp_prod = std::make_unique<CastorTrigPrimDigiCollection>();

  castor_prod->swap_contents(castor);
  htp_prod->swap_contents(htp);

  // Step C2: filter FEDs, if required
  if (filter_.active()) {
    CastorDigiCollection filtered_castor = filter_.filter(*castor_prod, *report);

    castor_prod->swap(filtered_castor);
  }

  // Step D: Put outputs into event
  // just until the sorting is proven
  castor_prod->sort();
  htp_prod->sort();

  if (unpackZDC_) {
    auto zdc_prod = std::make_unique<ZDCDigiCollection>();
    zdc_prod->swap_contents(zdc);

    zdc_prod->sort();
    e.put(std::move(zdc_prod));
  }

  e.put(std::move(castor_prod));
  e.put(std::move(htp_prod));

  if (unpackTTP_) {
    auto prod = std::make_unique<HcalTTPDigiCollection>();
    prod->swap_contents(ttp);

    prod->sort();
    e.put(std::move(prod));
  }
  e.put(std::move(report));
}

Member Data Documentation

complainEmptyData_

bool CastorRawToDigi::complainEmptyData_

private

Definition at line 53 of file CastorRawToDigi.h.

Referenced by produce().

ctdcunpacker_

CastorCtdcUnpacker CastorRawToDigi::ctdcunpacker_

private

Definition at line 49 of file CastorRawToDigi.h.

Referenced by produce().

dataTag_

edm::InputTag CastorRawToDigi::dataTag_

private

Definition at line 46 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi().

expectedOrbitMessageTime_

int CastorRawToDigi::expectedOrbitMessageTime_

private

Definition at line 59 of file CastorRawToDigi.h.

Referenced by beginRun(), and CastorRawToDigi().

fedUnpackList_

std::vector<int> CastorRawToDigi::fedUnpackList_

private

Definition at line 51 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi(), and produce().

filter_

CastorDataFrameFilter CastorRawToDigi::filter_

private

Definition at line 50 of file CastorRawToDigi.h.

Referenced by produce().

firstFED_

int CastorRawToDigi::firstFED_

private

Definition at line 52 of file CastorRawToDigi.h.

myEMap

std::unique_ptr<HcalElectronicsMap> CastorRawToDigi::myEMap

private

Definition at line 60 of file CastorRawToDigi.h.

silent_

bool CastorRawToDigi::silent_

private

Definition at line 57 of file CastorRawToDigi.h.

tok_input_

edm::EDGetTokenT<FEDRawDataCollection> CastorRawToDigi::tok_input_

private

Definition at line 61 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi(), and produce().

tok_pSetup_

edm::ESGetToken<CastorDbService, CastorDbRecord> CastorRawToDigi::tok_pSetup_

private

Definition at line 63 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi(), and produce().

unpacker_

CastorUnpacker CastorRawToDigi::unpacker_

private

Definition at line 47 of file CastorRawToDigi.h.

Referenced by beginRun(), CastorRawToDigi(), and produce().

unpackTTP_

bool CastorRawToDigi::unpackTTP_

private

Definition at line 55 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi(), and produce().

unpackZDC_

bool CastorRawToDigi::unpackZDC_

private

Definition at line 56 of file CastorRawToDigi.h.

Referenced by produce().

usenominalOrbitMessageTime_

bool CastorRawToDigi::usenominalOrbitMessageTime_

private

Definition at line 58 of file CastorRawToDigi.h.

Referenced by beginRun().

usingctdc_

bool CastorRawToDigi::usingctdc_

private

Definition at line 54 of file CastorRawToDigi.h.

Referenced by produce().

zdcemap

edm::ParameterSet CastorRawToDigi::zdcemap

private

Definition at line 62 of file CastorRawToDigi.h.

zdcunpacker_

ZdcUnpacker CastorRawToDigi::zdcunpacker_

private

Definition at line 48 of file CastorRawToDigi.h.

Referenced by produce().