Inheritance diagram for l1t::MP7BufferDumpToRaw:

Public Member Functions
	MP7BufferDumpToRaw (const edm::ParameterSet &)

	~MP7BufferDumpToRaw ()

Public Member Functions inherited from edm::EDProducer
	EDProducer ()

ModuleDescription const &	moduleDescription () const

virtual	~EDProducer ()

Public Member Functions inherited from edm::ProducerBase
	ProducerBase ()

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

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

virtual	~ProducerBase ()

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

	EDConsumerBase ()

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

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

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

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) const

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

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

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

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Private Member Functions
virtual void	beginJob () override

virtual void	endJob () override

void	formatAMC (amc13::Packet &amc13, const std::vector< Block > &blocks, int iAmc)

void	formatRaw (edm::Event &iEvent, amc13::Packet &amc13, FEDRawData &fed_data)

std::vector< Block >	getBlocks (int iAmc)

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

Private Attributes
std::vector< int >	boardId_

int	evType_

int	fedId_

int	fwVer_

unsigned	iBoard_

bool	mux_

int	muxOffset_

unsigned	nBoard_

unsigned	nFramesPerEvent_

bool	packetisedData_

std::vector< std::vector< int > >	rxBlockLength_

MP7FileReader	rxFileReader_

std::vector< unsigned >	rxIndex_

MP7PacketReader	rxPacketReader_

int	slinkHeaderSize_

int	slinkTrailerSize_

std::vector< std::vector< int > >	txBlockLength_

MP7FileReader	txFileReader_

std::vector< unsigned >	txIndex_

MP7PacketReader	txPacketReader_

Additional Inherited Members
Public Types inherited from edm::EDProducer
typedef EDProducer	ModuleType

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

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

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

Definition at line 57 of file MP7BufferDumpToRaw.cc.

Constructor & Destructor Documentation

l1t::MP7BufferDumpToRaw::MP7BufferDumpToRaw ( const edm::ParameterSet & iConfig )

explicit

Definition at line 134 of file MP7BufferDumpToRaw.cc.

References boardId_, edm::ParameterSet::getUntrackedParameter(), i, LogDebug, bookConverter::max, nBoard_, rxBlockLength_, rxFileReader_, rxIndex_, MP7FileReader::size(), txBlockLength_, txFileReader_, and txIndex_.

                                                                        :
     rxFileReader_(iConfig.getUntrackedParameter<std::string>("rxFile", "rx_summary.txt")),
     txFileReader_(iConfig.getUntrackedParameter<std::string>("txFile", "tx_summary.txt")),
     rxPacketReader_(iConfig.getUntrackedParameter<std::string>("rxFile", "rx_summary.txt")),
     txPacketReader_(iConfig.getUntrackedParameter<std::string>("txFile", "tx_summary.txt")),
     packetisedData_(iConfig.getUntrackedParameter<bool>("packetisedData", true)),
     nFramesPerEvent_(iConfig.getUntrackedParameter<int>("nFramesPerEvent", 6)),
     iBoard_(iConfig.getUntrackedParameter<int>("boardOffset", 0)),
     boardId_(iConfig.getUntrackedParameter<std::vector<int> >("boardId")),
     mux_(iConfig.getUntrackedParameter<bool>("mux", false)),
     fedId_(iConfig.getUntrackedParameter<int>("fedId", 1)),
     evType_(iConfig.getUntrackedParameter<int>("eventType", 1)),
     fwVer_(iConfig.getUntrackedParameter<int>("fwVersion", 1)),
     slinkHeaderSize_(iConfig.getUntrackedParameter<int>("lenSlinkHeader", 8)),
     slinkTrailerSize_(iConfig.getUntrackedParameter<int>("lenSlinkTrailer", 8))
 {
 
   produces<FEDRawDataCollection>();
 
   // check tx/rx file size consistency and number of boards
   if (rxFileReader_.size() != txFileReader_.size()) {
     edm::LogError("L1T") << "Different number of boards in Rx and Tx files";
   }
   nBoard_ = std::max(rxFileReader_.size(), txFileReader_.size());
   LogDebug("L1T") << "# boards : " << nBoard_;
 
   // advance pointers for non packetised data
   rxIndex_ = iConfig.getUntrackedParameter< std::vector<unsigned> >("nFramesOffset");
   if (rxIndex_.size() != nBoard_) {
     edm::LogError("L1T") << "Wrong number of boards in nFramesOffset " << rxIndex_.size();
   }
 
   txIndex_ = iConfig.getUntrackedParameter< std::vector<unsigned> >("nFramesLatency");
   if (txIndex_.size() != nBoard_) {
     edm::LogError("L1T") << "Wrong number of boards in nFramesLatency " << txIndex_.size();
   }
 
   // add latency to offset for Tx
   for (unsigned i=0; i<rxIndex_.size(); ++i) txIndex_.at(i) += rxIndex_.at(i);
 
   // check board IDs
   if (nBoard_ != boardId_.size()) {
     edm::LogError("L1T") << "Found " << nBoard_ << " boards, but given " << boardId_.size() << " IDs";
   }
 
 
   // block length PSet
   std::vector<edm::ParameterSet> vpset = iConfig.getUntrackedParameter< std::vector<edm::ParameterSet> >("blocks");
 
   if (vpset.size() != nBoard_) {
     edm::LogError("L1T") << "Wrong number of block specs " << vpset.size();
   }
 
   for (unsigned i=0; i<nBoard_; ++i) {
     rxBlockLength_.push_back(vpset.at(i).getUntrackedParameter< std::vector<int> >("rxBlockLength") );
     txBlockLength_.push_back(vpset.at(i).getUntrackedParameter< std::vector<int> >("rxBlockLength") );
   }
 
 }

l1t::MP7BufferDumpToRaw::~MP7BufferDumpToRaw ( )

Definition at line 195 of file MP7BufferDumpToRaw.cc.

 {
  
    // do anything here that needs to be done at desctruction time
    // (e.g. close files, deallocate resources etc.)
 
 }

Member Function Documentation

void l1t::MP7BufferDumpToRaw::beginJob ( void )

overrideprivatevirtual

Reimplemented from edm::EDProducer.

Definition at line 414 of file MP7BufferDumpToRaw.cc.

 {
 
 }

void l1t::MP7BufferDumpToRaw::endJob ( void )

overrideprivatevirtual

Reimplemented from edm::EDProducer.

Definition at line 424 of file MP7BufferDumpToRaw.cc.

 {
 
 }

void l1t::MP7BufferDumpToRaw::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 464 of file MP7BufferDumpToRaw.cc.

References edm::ConfigurationDescriptions::addDefault(), and edm::ParameterSetDescription::setUnknown().

                                                                                {
   //The following says we do not know what parameters are allowed so do no validation
   // Please change this to state exactly what you do use, even if it is no parameters
   edm::ParameterSetDescription desc;
   desc.setUnknown();
   descriptions.addDefault(desc);
 }

void l1t::MP7BufferDumpToRaw::formatAMC	(	amc13::Packet &	amc13,
		const std::vector< Block > &	blocks,
		int	iAmc
	)

private

Definition at line 341 of file MP7BufferDumpToRaw.cc.

References amc13::Packet::add(), createPayload::block, boardId_, i, svgfig::load(), LogDebug, and alignCSCRings::s.

Referenced by produce().

                                                                                             {
 
   LogDebug("L1T") << "Formatting Board " << iBoard;
   
   std::vector<uint32_t> load32;
   // TODO this is an empty word to be replaced with a proper MP7
   // header containing at least the firmware version
   load32.push_back(0);
   for (const auto& block: blocks) {
     LogDebug("L1T") << "Adding block " << block.header().getID() << " with size " << block.payload().size();
     auto load = block.payload();
     
 #ifdef EDM_ML_DEBUG
     std::stringstream s("");
     s << "Block content:" << std::endl << std::hex << std::setfill('0');
     for (const auto& word: load)
       s << std::setw(8) << word << std::endl;
     LogDebug("L1T") << s.str();
 #endif
     
     load32.push_back(block.header().raw());
     load32.insert(load32.end(), load.begin(), load.end());
   }
   
   LogDebug("L1T") << "Converting payload " << iBoard;
   
   std::vector<uint64_t> load64;
   for (unsigned int i = 0; i < load32.size(); i += 2) {
     uint64_t word = load32[i];
     if (i + 1 < load32.size())
       word |= static_cast<uint64_t>(load32[i + 1]) << 32;
     load64.push_back(word);
   }
   
   LogDebug("L1T") << "Creating AMC packet " << iBoard;
   
   amc13.add(iBoard, boardId_.at(iBoard), load64);
 
 }

void l1t::MP7BufferDumpToRaw::formatRaw	(	edm::Event &	iEvent,
		amc13::Packet &	amc13,
		FEDRawData &	fed_data
	)

private

Definition at line 384 of file MP7BufferDumpToRaw.cc.

References edm::EventBase::bunchCrossing(), evf::compute_crc(), FEDRawData::data(), edm::EventID::event(), evType_, fedId_, edm::EventBase::id(), LogDebug, FEDRawData::resize(), FEDTrailer::set(), FEDHeader::set(), amc13::Packet::size(), findQualityFiles::size, slinkHeaderSize_, slinkTrailerSize_, and amc13::Packet::write().

Referenced by produce().

 {
 
   unsigned int size = slinkHeaderSize_ + slinkTrailerSize_ + amc13.size() * 8;
   fed_data.resize(size);
   unsigned char * payload = fed_data.data();
   unsigned char * payload_start = payload;
 
   auto bxId = iEvent.bunchCrossing();
   auto evtId = iEvent.id().event();
 
   LogDebug("L1T") << "Creating FEDRawData ID " << fedId_ << ", size " << size;
 
   FEDHeader header(payload);
   header.set(payload, evType_, evtId, bxId, fedId_);
 
   payload += slinkHeaderSize_;
 
   amc13.write(iEvent, payload, size - slinkHeaderSize_ - slinkTrailerSize_);
 
   payload += amc13.size() * 8;
 
   FEDTrailer trailer(payload);
   trailer.set(payload, size / 8, evf::compute_crc(payload_start, size), 0, 0);
 
 }

std::vector< Block > l1t::MP7BufferDumpToRaw::getBlocks ( int iAmc )

private

Definition at line 249 of file MP7BufferDumpToRaw.cc.

References PacketData::begin(), createPayload::block, gather_cfg::blocks, data, MP7PacketReader::get(), MP7FileReader::get(), i, FileData::link(), MainPageGenerator::link, LogDebug, nFramesPerEvent_, AlCaHLTBitMon_ParallelJobs::p, packetisedData_, rxBlockLength_, rxFileReader_, rxIndex_, rxPacketReader_, findQualityFiles::size, txBlockLength_, txFileReader_, txIndex_, and txPacketReader_.

Referenced by produce().

 {
 
   LogDebug("L1T") << "Getting blocks from board " << iBoard; 
 
   std::vector<Block> blocks;
 
   // Rx blocks first
   for (unsigned link=0; link<rxBlockLength_.at(iBoard).size(); ++link) {
     
     unsigned id   = link*2;
     unsigned size = rxBlockLength_.at(iBoard).at(link);
 
     if (size==0) continue;
 
     std::vector<uint32_t> data;
     if (packetisedData_) {
 
       const PacketData& p = rxPacketReader_.get(iBoard);
       PacketData::const_iterator itr = p.begin();
       for (unsigned i=0; i<rxIndex_.at(iBoard); i++) itr++;
 
       LogDebug("L1T") << "Found packet [" << itr->first_ << ", " << itr->last_ << "]";
       LogDebug("L1T") << "Link " << link << " has " << itr->links_.find(link)->second.size() << " frames";
 
       for (unsigned iFrame=0; iFrame<itr->links_.find(link)->second.size(); ++iFrame) {
     uint64_t d = itr->links_.find(link)->second.at(iFrame);
         data.push_back(d);
       }
     }
     else {
       for (unsigned iFrame=rxIndex_.at(iBoard); iFrame<rxIndex_.at(iBoard)+size; ++iFrame) {
     uint64_t d = rxFileReader_.get(iBoard).link(link).at(iFrame);
     //  LogDebug("L1T") << "Frame " << iFrame << " : " << std::hex << d;
     if ((d & 0x100000000) > 0) data.push_back( d & 0xffffffff );
       }
       rxIndex_.at(iBoard) += nFramesPerEvent_;
     }
     
     LogDebug("L1T") << "AMC " << iBoard << " block " << id << ", size " << data.size();
 
     Block block(id, data);
     blocks.push_back(block);
     
   }
   
   // then Tx blocks
   for (unsigned link=0; link<txBlockLength_.at(iBoard).size(); ++link) {
     
     unsigned id   = (link*2)+1;
     unsigned size = txBlockLength_.at(iBoard).at(link);
 
     if (size==0) continue;
 
     std::vector<uint32_t> data;
     if (packetisedData_) {
       const PacketData& p = txPacketReader_.get(iBoard);
       PacketData::const_iterator itr = p.begin();
       for (unsigned i=0; i<txIndex_.at(iBoard); i++) itr++;
       for (unsigned iFrame=itr->first_; iFrame<itr->last_; ++iFrame) {
     uint64_t d = itr->links_.find(link)->second.at(iFrame);
     data.push_back(d);
       }
     }
     else {
       for (unsigned iFrame=txIndex_.at(iBoard); iFrame<txIndex_.at(iBoard)+size; ++iFrame) {
     uint64_t d = txFileReader_.get(iBoard).link(link).at(iFrame);
     //  LogDebug("L1T") << "Frame " << iFrame << " : " << std::hex << d;
     if ((d & 0x100000000) > 0) data.push_back( d & 0xffffffff );
       }
       txIndex_.at(iBoard) += nFramesPerEvent_;
     }
     
     LogDebug("L1T") << "AMC " << iBoard << " block " << id << ", size " << data.size();
 
     Block block(id, data);
 
     blocks.push_back(block);
 
 
 
 
   }
 
   LogDebug("L1T") << "AMC " << iBoard << ", read " << blocks.size() << " blocks";
 
   return blocks;
   
 }    

void l1t::MP7BufferDumpToRaw::produce	(	edm::Event &	iEvent,
		const edm::EventSetup &	iSetup
	)

overrideprivatevirtual

Implements edm::EDProducer.

Definition at line 210 of file MP7BufferDumpToRaw.cc.

References gather_cfg::blocks, boardId_, fedId_, formatAMC(), formatRaw(), getBlocks(), iBoard_, LogDebug, mux_, nBoard_, and edm::Event::put().

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

 {
   using namespace edm;
 
   // AMC 13 packet
   amc13::Packet amc13;    
 
   // create AMC formatted data
   if (mux_) {
     std::vector<Block> blocks = getBlocks(iBoard_);
     formatAMC(amc13, blocks, boardId_.at(iBoard_));
     iBoard_++;  //advance to next AMC for next event...
     iBoard_ = iBoard_ % nBoard_;
   }
   else {
     for (unsigned iBoard=0; iBoard<nBoard_; ++iBoard) {
       std::vector<Block> blocks = getBlocks(iBoard);
       formatAMC(amc13, blocks, iBoard);
     }
   }
 
   LogDebug("L1T") << "AMC13 size " << amc13.size();  
 
   // prepare the raw data collection
   std::auto_ptr<FEDRawDataCollection> raw_coll(new FEDRawDataCollection());
   FEDRawData& fed_data = raw_coll->FEDData(fedId_);
 
   formatRaw(iEvent, amc13, fed_data);
 
   LogDebug("L1T") << "Packing FED ID " << fedId_ << " size " << fed_data.size();
   
   // put the collection in the event
   iEvent.put(raw_coll);  
   
 }

Member Data Documentation

std::vector<int> l1t::MP7BufferDumpToRaw::boardId_

private

Definition at line 106 of file MP7BufferDumpToRaw.cc.

Referenced by formatAMC(), MP7BufferDumpToRaw(), and produce().

int l1t::MP7BufferDumpToRaw::evType_

private

Definition at line 116 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::fedId_

private

Definition at line 115 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw(), and produce().

int l1t::MP7BufferDumpToRaw::fwVer_

private

Definition at line 117 of file MP7BufferDumpToRaw.cc.

unsigned l1t::MP7BufferDumpToRaw::iBoard_

private

Definition at line 105 of file MP7BufferDumpToRaw.cc.

Referenced by produce().

bool l1t::MP7BufferDumpToRaw::mux_

private

Definition at line 111 of file MP7BufferDumpToRaw.cc.

Referenced by produce().

int l1t::MP7BufferDumpToRaw::muxOffset_

private

Definition at line 112 of file MP7BufferDumpToRaw.cc.

unsigned l1t::MP7BufferDumpToRaw::nBoard_

private

Definition at line 104 of file MP7BufferDumpToRaw.cc.

Referenced by MP7BufferDumpToRaw(), and produce().

unsigned l1t::MP7BufferDumpToRaw::nFramesPerEvent_

private

Definition at line 99 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks().

bool l1t::MP7BufferDumpToRaw::packetisedData_

private

Definition at line 96 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks().

std::vector< std::vector<int> > l1t::MP7BufferDumpToRaw::rxBlockLength_

private

Definition at line 109 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks(), and MP7BufferDumpToRaw().

MP7FileReader l1t::MP7BufferDumpToRaw::rxFileReader_

private

Definition at line 84 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks(), and MP7BufferDumpToRaw().

std::vector<unsigned> l1t::MP7BufferDumpToRaw::rxIndex_

private

Definition at line 86 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks(), and MP7BufferDumpToRaw().

MP7PacketReader l1t::MP7BufferDumpToRaw::rxPacketReader_

private

Definition at line 90 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks().

int l1t::MP7BufferDumpToRaw::slinkHeaderSize_

private

Definition at line 118 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::slinkTrailerSize_

private

Definition at line 119 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

std::vector< std::vector<int> > l1t::MP7BufferDumpToRaw::txBlockLength_

private

Definition at line 110 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks(), and MP7BufferDumpToRaw().

MP7FileReader l1t::MP7BufferDumpToRaw::txFileReader_

private

Definition at line 85 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks(), and MP7BufferDumpToRaw().

std::vector<unsigned> l1t::MP7BufferDumpToRaw::txIndex_

private

Definition at line 87 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks(), and MP7BufferDumpToRaw().

MP7PacketReader l1t::MP7BufferDumpToRaw::txPacketReader_

private

Definition at line 91 of file MP7BufferDumpToRaw.cc.

Referenced by getBlocks().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation