#include <CastorRawToDigi.h>

Inheritance diagram for CastorRawToDigi:

Public Member Functions
virtual void	beginRun (edm::Run const &, edm::EventSetup const &) override

	CastorRawToDigi (const edm::ParameterSet &ps)

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

virtual	~CastorRawToDigi ()

Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default

Public Member Functions inherited from edm::stream::EDProducerBase
	EDProducerBase ()

ModuleDescription const &	moduleDescription () const

virtual	~EDProducerBase ()

Public Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const

	ProducerBase ()

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...

void	resolvePutIndicies (BranchType iBranchType, std::unordered_multimap< std::string, edm::ProductResolverIndex > const &iIndicies, std::string const &moduleLabel)

virtual	~ProducerBase () noexcept(false)

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

virtual	~EDConsumerBase () noexcept(false)

Private Attributes
bool	complainEmptyData_

CastorCtdcUnpacker	ctdcunpacker_

edm::InputTag	dataTag_

int	expectedOrbitMessageTime_

std::vector< int >	fedUnpackList_

CastorDataFrameFilter	filter_

int	firstFED_

std::auto_ptr< HcalElectronicsMap >	myEMap

bool	silent_

edm::EDGetTokenT< FEDRawDataCollection >	tok_input_

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<>
typedef CacheContexts< T... >	CacheTypes

typedef CacheTypes::GlobalCache	GlobalCache

typedef AbilityChecker< T... >	HasAbility

typedef CacheTypes::LuminosityBlockCache	LuminosityBlockCache

typedef LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >	LuminosityBlockContext

typedef CacheTypes::LuminosityBlockSummaryCache	LuminosityBlockSummaryCache

typedef CacheTypes::RunCache	RunCache

typedef RunContextT< RunCache, GlobalCache >	RunContext

typedef CacheTypes::RunSummaryCache	RunSummaryCache

Public Types inherited from edm::stream::EDProducerBase
typedef EDProducerAdaptorBase	ModuleType

Public Types inherited from edm::ProducerBase
typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Static Public Member Functions inherited from edm::stream::EDProducerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

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 35 of file CastorRawToDigi.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 19 of file CastorRawToDigi.cc.

References dataTag_, expectedOrbitMessageTime_, fedUnpackList_, mps_fire::i, FEDNumbering::MAXCASTORFEDID, FEDNumbering::MINCASTORFEDID, CastorUnpacker::setExpectedOrbitMessageTime(), tok_input_, 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_);
 
 }

CastorRawToDigi::~CastorRawToDigi ( )

virtual

Definition at line 60 of file CastorRawToDigi.cc.

60 { }

Member Function Documentation

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

overridevirtual

Reimplemented from edm::stream::EDProducerBase.

Definition at line 217 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_);
     }
 }

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

overridevirtual

Definition at line 63 of file CastorRawToDigi.cc.

References CastorDataFrameFilter::active(), castorDigitizer_cfi::castor, CastorRawCollections::castorCont, complainEmptyData_, ctdcunpacker_, FEDRawDataCollection::FEDData(), fedUnpackList_, CastorDataFrameFilter::filter(), filter_, edm::EventSetup::get(), edm::Event::getByToken(), CastorDbService::getCastorMapping(), mps_fire::i, eostools::move(), parseEventContent::prod, edm::Event::put(), edmIntegrityCheck::report, FEDRawData::size(), edm::SortedCollection< T, SORT >::swap(), tok_input_, CastorCtdcUnpacker::unpack(), CastorUnpacker::unpack(), ZdcUnpacker::unpack(), unpacker_, unpackTTP_, unpackZDC_, usingctdc_, cms::Exception::what(), hcalSimParameters_cfi::zdc, and zdcunpacker_.

Referenced by JSONExport.JsonExport::export(), HTMLExport.HTMLExport::export(), and HTMLExport.HTMLExportStatic::export().

 {
   // Step A: Get Inputs 
   edm::Handle<FEDRawDataCollection> rawraw;  
   e.getByToken(tok_input_,rawraw);
   // get the mapping
   edm::ESHandle<CastorDbService> pSetup;
   es.get<CastorDbRecord>().get( 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

bool CastorRawToDigi::complainEmptyData_

private

Definition at line 51 of file CastorRawToDigi.h.

Referenced by produce().

CastorCtdcUnpacker CastorRawToDigi::ctdcunpacker_

private

Definition at line 47 of file CastorRawToDigi.h.

Referenced by produce().

edm::InputTag CastorRawToDigi::dataTag_

private

Definition at line 44 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi().

int CastorRawToDigi::expectedOrbitMessageTime_

private

Definition at line 57 of file CastorRawToDigi.h.

Referenced by beginRun(), and CastorRawToDigi().

std::vector<int> CastorRawToDigi::fedUnpackList_

private

Definition at line 49 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi(), and produce().

CastorDataFrameFilter CastorRawToDigi::filter_

private

Definition at line 48 of file CastorRawToDigi.h.

Referenced by produce().

int CastorRawToDigi::firstFED_

private

Definition at line 50 of file CastorRawToDigi.h.

std::auto_ptr<HcalElectronicsMap> CastorRawToDigi::myEMap

private

Definition at line 58 of file CastorRawToDigi.h.

bool CastorRawToDigi::silent_

private

Definition at line 55 of file CastorRawToDigi.h.

edm::EDGetTokenT<FEDRawDataCollection> CastorRawToDigi::tok_input_

private

Definition at line 59 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi(), and produce().

CastorUnpacker CastorRawToDigi::unpacker_

private

Definition at line 45 of file CastorRawToDigi.h.

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

bool CastorRawToDigi::unpackTTP_

private

Definition at line 53 of file CastorRawToDigi.h.

Referenced by CastorRawToDigi(), and produce().

bool CastorRawToDigi::unpackZDC_

private

Definition at line 54 of file CastorRawToDigi.h.

Referenced by produce().

bool CastorRawToDigi::usenominalOrbitMessageTime_

private

Definition at line 56 of file CastorRawToDigi.h.

Referenced by beginRun().

bool CastorRawToDigi::usingctdc_

private

Definition at line 52 of file CastorRawToDigi.h.

Referenced by produce().

edm::ParameterSet CastorRawToDigi::zdcemap

private

Definition at line 60 of file CastorRawToDigi.h.

ZdcUnpacker CastorRawToDigi::zdcunpacker_

private

Definition at line 46 of file CastorRawToDigi.h.

Referenced by produce().

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation