TextToRaw.cc

Go to the documentation of this file.

#include "L1Trigger/TextToDigi/plugins/TextToRaw.h"

// system
#include <fstream>
#include <iostream>
#include <string>
#include <vector>

// framework
#include "FWCore/MessageLogger/interface/MessageLogger.h"

#include "FWCore/Utilities/interface/Exception.h"

// Raw data collection
#include "DataFormats/FEDRawData/interface/FEDRawDataCollection.h"

using std::cerr;
using std::cout;
using std::endl;
using std::ios;
using std::string;
using std::vector;

const unsigned TextToRaw::EVT_MAX_SIZE;

TextToRaw::TextToRaw(const edm::ParameterSet &iConfig)
    : fedId_(iConfig.getUntrackedParameter<int>("fedId", 745)),
      filename_(iConfig.getUntrackedParameter<std::string>("filename",
                                                           "slinkOutput.txt")),
      fileEventOffset_(
          iConfig.getUntrackedParameter<int>("FileEventOffset", 0)),
      nevt_(0) {
  edm::LogInfo("TextToDigi")
      << "Reading ASCII dump from " << filename_ << std::endl;

  // register the products
  produces<FEDRawDataCollection>();
}

TextToRaw::~TextToRaw() {

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

void TextToRaw::putEmptyDigi(edm::Event &iEvent) {
  std::unique_ptr<FEDRawDataCollection> rawColl(new FEDRawDataCollection());
  // FEDRawData& feddata=rawColl->FEDData(fedId_);
  // feddata.data()[0] = 0;
  iEvent.put(std::move(rawColl));
}

// ------------ method called to produce the data  ------------
void TextToRaw::produce(edm::Event &iEvent, const edm::EventSetup &iSetup) {
  using namespace edm;

  // Skip event if required
  if (nevt_ < fileEventOffset_) {
    putEmptyDigi(iEvent);
    nevt_++;
    return;
  } else if (nevt_ == 0 && fileEventOffset_ < 0) {
    std::string line;
    // skip first fileEventOffset input crossings
    for (unsigned i = 0; i < (unsigned)abs(fileEventOffset_); i++) {
      unsigned iline = 0;
      while (getline(file_, line) && !line.empty()) {
        iline++;
        if (iline * 4 >= EVT_MAX_SIZE)
          throw cms::Exception("TextToRawEventSizeOverflow")
              << "TextToRaw::produce() : "
              << " read too many lines (" << iline << ": " << line << ")"
              << ", maximum event size is " << EVT_MAX_SIZE << std::endl;
      }
    }
  }

  nevt_++;

  // read file
  std::string line;
  unsigned i = 0; // count 32-bit words

  // while not encountering dumb errors
  while (getline(file_, line) && !line.empty()) {

    // bail if we reached the EVT_MAX_SIZE
    if (i * 4 >= EVT_MAX_SIZE) {
      throw cms::Exception("TextToRaw")
          << "Read too many lines from file. Maximum event size is "
          << EVT_MAX_SIZE << " lines" << std::endl;
    }

    // convert string to int
    std::istringstream iss(line);
    unsigned long d;
    iss >> std::hex >> d;

    // copy data
    for (int j = 0; j < 4; j++) {
      if ((i * 4 + j) < EVT_MAX_SIZE) {
        char c = (d >> (8 * j)) & 0xff;
        data_[i * 4 + j] = c;
      }
    }

    ++i;

    // bail if we reached the EVT_MAX_SIZE
    if (i >= EVT_MAX_SIZE) {
      throw cms::Exception("TextToRaw")
          << "Read too many lines from file. Maximum event size is "
          << EVT_MAX_SIZE << " lines" << std::endl;
    }
  }

  unsigned evtSize = i * 4;

  // create the collection
  std::unique_ptr<FEDRawDataCollection> rawColl(new FEDRawDataCollection());
  // retrieve the target buffer
  FEDRawData &feddata = rawColl->FEDData(fedId_);
  // Allocate space for header+trailer+payload
  feddata.resize(evtSize);

  // fill FEDRawData object
  for (unsigned i = 0; i < evtSize; ++i) {
    feddata.data()[i] = data_[i];
  }

  // put the collection in the event
  iEvent.put(std::move(rawColl));
}

// ------------ method called once each job just before starting event loop
// ------------
void TextToRaw::beginJob() {
  // open VME file
  file_.open(filename_.c_str(), std::ios::in);
  if (!file_.good()) {
    edm::LogInfo("TextToDigi")
        << "Failed to open ASCII file " << filename_ << std::endl;
  }
}

// ------------ method called once each job just after ending the event loop
// ------------
void TextToRaw::endJob() { file_.close(); }