l1t::MP7BufferDumpToRaw Class Reference

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
	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
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	fillBlocks (int iAmc)
void	formatRaw (FEDRawData &feddata, int bx, int evtId, int orbit)
virtual void	produce (edm::Event &, const edm::EventSetup &) override

Private Attributes
std::vector< Block >	blocks_
int	evType_
int	fedId_
int	fwVer_
int	lenAMC13Header_
int	lenAMC13Trailer_
int	lenAMCHeader_
int	lenAMCTrailer_
int	lenSlinkHeader_
int	lenSlinkTrailer_
unsigned	nFramesPerEvent_
bool	packetisedData_
std::vector< int >	rxBlockLength_
MP7FileReader	rxFileReader_
unsigned	rxIndex_
std::vector< int >	txBlockLength_
MP7FileReader	txFileReader_
unsigned	txIndex_

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 52 of file MP7BufferDumpToRaw.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 126 of file MP7BufferDumpToRaw.cc.

References edm::ParameterSet::getUntrackedParameter(), packetisedData_, rxIndex_, and txIndex_.

                                                                       :
    rxFileReader_(iConfig.getUntrackedParameter<std::string>("rxFile", "rx_summar\
y.txt")),
    txFileReader_(iConfig.getUntrackedParameter<std::string>("txFile", "tx_summar\
y.txt")),
    rxIndex_(0),
    txIndex_(0),
    packetisedData_(iConfig.getUntrackedParameter<bool>("packetisedData", true)),
    nFramesPerEvent_(iConfig.getUntrackedParameter<unsigned>("nFramesPerEvent", 6)),
    fedId_(iConfig.getUntrackedParameter<int>("fedId", 1)),
    evType_(iConfig.getUntrackedParameter<int>("eventType", 1)),
    fwVer_(iConfig.getUntrackedParameter<int>("fwVersion", 1)),
    lenSlinkHeader_(iConfig.getUntrackedParameter<int>("lenSlinkHeader", 16)),
    lenSlinkTrailer_(iConfig.getUntrackedParameter<int>("lenSlinkTrailer", 16)),
    lenAMC13Header_(iConfig.getUntrackedParameter<int>("lenAMC13Header", 0)),
    lenAMC13Trailer_(iConfig.getUntrackedParameter<int>("lenAMC13Trailer", 0)),
    lenAMCHeader_(iConfig.getUntrackedParameter<int>("lenAMCHeader", 12)),
    lenAMCTrailer_(iConfig.getUntrackedParameter<int>("lenAMCTrailer", 8)),
    rxBlockLength_(iConfig.getUntrackedParameter< std::vector<int> >("rxBlockLength")),
    txBlockLength_(iConfig.getUntrackedParameter< std::vector<int> >("txBlockLength"))
{

  produces<FEDRawDataCollection>();

  // advance pointers for non packetised data
  if (!packetisedData_) {
    rxIndex_ += iConfig.getUntrackedParameter<int>("nFramesOffset", 0);
    txIndex_ += rxIndex_;
    txIndex_ += iConfig.getUntrackedParameter<int>("nFramesLatency", 0);
  }

}

l1t::MP7BufferDumpToRaw::~MP7BufferDumpToRaw

(

)

Definition at line 160 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 444 of file MP7BufferDumpToRaw.cc.

{



}

void l1t::MP7BufferDumpToRaw::endJob ( void  )

overrideprivatevirtual

Reimplemented from edm::EDProducer.

Definition at line 454 of file MP7BufferDumpToRaw.cc.

{


}

void l1t::MP7BufferDumpToRaw::fillBlocks ( int  iAmc )

private

Definition at line 206 of file MP7BufferDumpToRaw.cc.

References createPayload::block, blocks_, data, MP7FileReader::get(), i, FileData::link(), nFramesPerEvent_, packetisedData_, rxBlockLength_, rxFileReader_, rxIndex_, findQualityFiles::size, txBlockLength_, txFileReader_, and txIndex_.

Referenced by produce().

{

  // Rx blocks first
  for (unsigned i=0; i<rxBlockLength_.size(); ++i) {
    
    unsigned id   = i*2;
    unsigned size = rxBlockLength_.at(i);

    std::vector<uint32_t> data;
    for (unsigned iFrame=rxIndex_; iFrame<size; ++iFrame) {
      if (!packetisedData_) {
    data.push_back( rxFileReader_.get(iAmc).link(i).at(iFrame) );
      }
    }
    
    Block block(id, data);
    blocks_.push_back(block);
    
  }
  
  // then Tx blocks
  for (unsigned i=0; i<txBlockLength_.size(); ++i) {
    
    unsigned id   = (i*2)+1;
    unsigned size = txBlockLength_.at(i);

    std::vector<uint32_t> data(size);
    for (unsigned iFrame=txIndex_; iFrame<size; ++iFrame) {
      if (!packetisedData_) {
    data.push_back( txFileReader_.get(iAmc).link(i).at(iFrame) );
      }
    }
    
    Block block(id, data);

    blocks_.push_back(block);

  }

  // advance pointers to next event
  if (!packetisedData_) {
    rxIndex_ += nFramesPerEvent_;
    txIndex_ += nFramesPerEvent_;
  }
  
}    

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

static

Definition at line 494 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::formatRaw ( FEDRawData &  feddata, int  bx, int  evtId, int  orbit  )

private

Definition at line 256 of file MP7BufferDumpToRaw.cc.

References blocks_, FEDRawData::data(), evType_, fedId_, fwVer_, i, lenAMC13Header_, lenAMC13Trailer_, lenAMCHeader_, lenAMCTrailer_, lenSlinkHeader_, lenSlinkTrailer_, FEDRawData::resize(), rxBlockLength_, and txBlockLength_.

Referenced by produce().

{

  // now create the raw data array
  int capEvtSize = 0;
  for (std::vector<Block>::const_iterator itr=blocks_.begin(); itr!=blocks_.end(); ++itr) {
    capEvtSize += itr->getSize() + 1;
  }

  int amcSize = 0;
  for (unsigned i=0; i<rxBlockLength_.size(); ++i) amcSize += 4 * (rxBlockLength_.at(i) + 1);
  for (unsigned i=0; i<txBlockLength_.size(); ++i) amcSize += 4 * (txBlockLength_.at(i) + 1);

  int fedSize = amcSize;
  fedSize += lenSlinkHeader_;
  fedSize += lenSlinkTrailer_;
  fedSize += lenAMC13Header_;
  fedSize += lenAMC13Trailer_;
  fedSize += lenAMCHeader_;
  fedSize += lenAMCTrailer_;
  fedSize = (fedSize+7) & ~0x7;// round up to multiple of 8

  edm::LogInfo("mp7") << "Captured event size=" << capEvtSize << ", AMCsize=" << amcSize << ", FED size=" << fedSize << std::endl;

  // event info for headers
  edm::LogInfo("mp7") << "Event : " << evtId << " orbit=" << orbit << " bx=" << bx << std::endl;


  // Allocate space for header+trailer+payload
  feddata.resize(fedSize);

  int iWord = 0;

  // write SLINK header
  feddata.data()[iWord+1] |= fedId_ & 0xff;
  feddata.data()[iWord+2] |= (fedId_>>8) & 0xf;

  feddata.data()[iWord+2] |= (bx<<4) & 0xff;
  feddata.data()[iWord+3] |= (bx>>4) & 0xff;

  feddata.data()[iWord+4] = evtId & 0xff;
  feddata.data()[iWord+5] = (evtId>>8) & 0xff;
  feddata.data()[iWord+6] = (evtId>>16) & 0xff;

  feddata.data()[iWord+7] |= evType_ & 0xf;
  feddata.data()[iWord+7] |= 0x50;


  // write AMC13 header
  iWord += lenSlinkHeader_;

  // do nothing for now

  // write AMC header
  iWord += lenAMC13Header_;

  feddata.data()[iWord+0] = evtId & 0xff;
  feddata.data()[iWord+1] = (evtId>>8) & 0xff;
  feddata.data()[iWord+2] = (evtId>>16) & 0xff;

  feddata.data()[iWord+4] |= (orbit<<4) & 0xff;
  feddata.data()[iWord+5] |= (orbit>>4) & 0xff;
  feddata.data()[iWord+6] |= (orbit>>12) & 0xff;

  feddata.data()[iWord+6] |= (bx>>4) & 0xff;
  feddata.data()[iWord+7] |= (bx>>12) & 0xff;

  feddata.data()[iWord+8] = evType_ & 0xff;

  feddata.data()[iWord+9]  = (amcSize/4) & 0xff;
  feddata.data()[iWord+10] = ((amcSize/4) >> 8) & 0xff;

  feddata.data()[iWord+11] = fwVer_ & 0xff;


  // now add payload

  iWord += lenAMCHeader_;
  std::ostringstream payloadInfo;

  //  for (int iBlock=0; iBlock<nRxLinks_ && iWord<fedSize; ++iBlock) {

  //    int blockId     = 2*iBlock;
  //    int blockLength = rxBlockLength_.at(iBlock);

    // write block header
  //    feddata.data()[iWord+2] = blockLength & 0xff;
  //    feddata.data()[iWord+3] = blockId & 0xff;
  //    iWord+=4;

  //    if (blockLength!=0) {
  //      payloadInfo << ", " << (blockId&0xff) << " (" << (blockLength&0xff) << ")";
  //    }

  //    if (blockLength>(int)rxData.at(iBlock).size()) {
  //      edm::LogError("mp7") << "Read insufficient data for block " << blockId <<". Expected " << rxBlockLength_.at(iBlock) << " read " << rxData.at(iBlock).size() << " from Rx link " << iBlock << std::endl;
  //      continue;
  //    }

  //    for (int i=0; i<blockLength; ++i) {
  //      if(i < (int)rxData.at(iBlock).size()) {
  //    feddata.data()[iWord]   = rxData.at(iBlock).at(i) & 0xff;
  //    feddata.data()[iWord+1] = (rxData.at(iBlock).at(i) >> 8) & 0xff;
  //    feddata.data()[iWord+2] = (rxData.at(iBlock).at(i) >> 16) & 0xff;
  //    feddata.data()[iWord+3] = (rxData.at(iBlock).at(i) >> 24) & 0xff;
  //    iWord+=4;
  //      }
  //      else {
  //    feddata.data()[iWord]   = 0;
  //    feddata.data()[iWord+1] = 0;
  //    feddata.data()[iWord+2] = 0;
  //    feddata.data()[iWord+3] = 0;
  //    iWord+=4;
  //      }
  //    }

  //  }

  //  edm::LogInfo("mp7") << "Rx blocks : " << payloadInfo.str() << std::endl;

  // now do Tx links
  // strictly these will appear in the wrong place
  // they should be interspersed with Rx channels, not appended

  //  payloadInfo.str("");

  //  for (int iBlock=0; iBlock<nTxLinks_ && iWord<fedSize; ++iBlock) {

  //    int blockId     = (2*iBlock)+1;
  //    int blockLength = txBlockLength_.at(iBlock);

  //    // write block header
  //    feddata.data()[iWord+2] = blockLength & 0xff;
  //    feddata.data()[iWord+3] = blockId & 0xff;
  //    iWord+=4;

  //    payloadInfo << ", " << (blockId&0xff) << "(" << (blockLength&0xff) << ")";

  //    if (blockLength>(int)txData.at(iBlock).size()) {
  //      edm::LogError("mp7") << "Read insufficient data for block " << blockId <<". Expected " << blockLength << " read " << txData.at(iBlock).size() << " from Tx link " << iBlock << std::endl;
  //      continue;
  //    }

  //    for (int i=0; i<blockLength; ++i) {
  //      if (i<(int)txData.at(iBlock).size()) {
  //    feddata.data()[iWord]   = txData.at(iBlock).at(i) & 0xff;
  //    feddata.data()[iWord+1] = (txData.at(iBlock).at(i) >> 8) & 0xff;
  //    feddata.data()[iWord+2] = (txData.at(iBlock).at(i) >> 16) & 0xff;
  //    feddata.data()[iWord+3] = (txData.at(iBlock).at(i) >> 24) & 0xff;
  //    iWord+=4;
  //      }
  //      else {
  //    feddata.data()[iWord]   = 0;
  //    feddata.data()[iWord+1] = 0;
  //    feddata.data()[iWord+2] = 0;
  //    feddata.data()[iWord+3] = 0;
  //    iWord+=4;
  //      }
  //    }

  //  }

  //  edm::LogInfo("mp7") << "Tx blocks : " << payloadInfo.str() << std::endl;

  // write AMC trailer
  feddata.data()[iWord]   = evtId & 0xff;
  feddata.data()[iWord+1] = (evtId>>8) & 0xff;

  // write AMC13 trailer
  iWord += lenAMCTrailer_;

  // write SLINK trailer
  iWord += lenAMC13Trailer_;
  iWord = (iWord+7) & ~0x7;  // move to next 64 bit boundary
  feddata.data()[iWord+4] = (fedSize/8) & 0xff;
  feddata.data()[iWord+5] = ((fedSize/8)>>8) & 0xff;
  feddata.data()[iWord+6] = ((fedSize/8)>>16) & 0xff;

  feddata.data()[iWord+7] |= 0xa0;

  edm::LogInfo("mp7") << "End of packet after " << iWord+8 << " bytes  of " << fedSize << std::endl;


}

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

overrideprivatevirtual

Implements edm::EDProducer.

Definition at line 175 of file MP7BufferDumpToRaw.cc.

References blocks_, edm::EventBase::bunchCrossing(), edm::EventID::event(), fedId_, fillBlocks(), formatRaw(), edm::EventBase::id(), edm::EventBase::orbitNumber(), and edm::Event::put().

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

{
  using namespace edm;

  // fill the block structure
  blocks_.clear();

  int iAmc=0;
  fillBlocks(iAmc);

  // create the collection
  std::auto_ptr<FEDRawDataCollection> rawColl(new FEDRawDataCollection()); 
  
  // retrieve the target buffer
  FEDRawData& feddata=rawColl->FEDData(fedId_);

  // fill the RAW data
  int bx = iEvent.bunchCrossing();
  int evtId = iEvent.id().event();
  long int orbit = iEvent.orbitNumber();
  
  formatRaw(feddata, bx, evtId, orbit);

  // put the collection in the event
  iEvent.put(rawColl);  

}

Member Data Documentation

std::vector<Block> l1t::MP7BufferDumpToRaw::blocks_

private

Definition at line 111 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks(), formatRaw(), and produce().

int l1t::MP7BufferDumpToRaw::evType_

private

Definition at line 98 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::fedId_

private

Definition at line 97 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw(), and produce().

int l1t::MP7BufferDumpToRaw::fwVer_

private

Definition at line 99 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::lenAMC13Header_

private

Definition at line 102 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::lenAMC13Trailer_

private

Definition at line 103 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::lenAMCHeader_

private

Definition at line 104 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::lenAMCTrailer_

private

Definition at line 105 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::lenSlinkHeader_

private

Definition at line 100 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

int l1t::MP7BufferDumpToRaw::lenSlinkTrailer_

private

Definition at line 101 of file MP7BufferDumpToRaw.cc.

Referenced by formatRaw().

unsigned l1t::MP7BufferDumpToRaw::nFramesPerEvent_

private

Definition at line 91 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks().

bool l1t::MP7BufferDumpToRaw::packetisedData_

private

Definition at line 88 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks(), and MP7BufferDumpToRaw().

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

private

Definition at line 106 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks(), and formatRaw().

MP7FileReader l1t::MP7BufferDumpToRaw::rxFileReader_

private

Definition at line 77 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks().

unsigned l1t::MP7BufferDumpToRaw::rxIndex_

private

Definition at line 79 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks(), and MP7BufferDumpToRaw().

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

private

Definition at line 107 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks(), and formatRaw().

MP7FileReader l1t::MP7BufferDumpToRaw::txFileReader_

private

Definition at line 78 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks().

unsigned l1t::MP7BufferDumpToRaw::txIndex_

private

Definition at line 80 of file MP7BufferDumpToRaw.cc.

Referenced by fillBlocks(), and MP7BufferDumpToRaw().