LmfSource.h

Go to the documentation of this file.

#ifndef SourceModule_H
#define SourceModule_H
 
#include <vector>
#include <string>
#include <cinttypes>
#include <fstream>
 
#include "FWCore/Sources/interface/ProducerSourceBase.h"
#include "DataFormats/FEDRawData/interface/FEDRawData.h"
#include "DataFormats/FEDRawData/interface/FEDRawDataCollection.h"
#include "DataFormats/Provenance/interface/Timestamp.h"
 
class LmfSource : public edm::ProducerSourceBase {
private:
  struct IndexRecord {
    uint32_t orbit;
    uint32_t filePos;
    //    bool operator<(const IndexRecord& i) const { return orbit < i.orbit; }
  };
 
public:
  LmfSource(const edm::ParameterSet& pset, const edm::InputSourceDescription& isd);
  ~LmfSource() override {}
 
private:
  void produce(edm::Event& e) override;
 
  bool setRunAndEventInfo(edm::EventID& id,
                          edm::TimeValue_t& time,
                          edm::EventAuxiliary::ExperimentType& eType) override;
 
  bool openFile(int iFile);
 
  bool readFileHeader();
 
  bool readEventWithinFile(bool doSkip);
 
  std::string toString(edm::TimeValue_t& t) const;
 
private:
  std::vector<std::string> fileNames_;
 
  int iFile_;
 
  FEDRawDataCollection fedColl_;
 
  FEDRawData emptyFedBlock_;
 
  int fedId_;
 
  std::vector<uint32_t> header_;
 
  static const unsigned fileHeaderSize;
 
  std::vector<uint32_t> fileHeader_;
 
  static const unsigned char minDataFormatVersion_;
 
  static const unsigned char maxDataFormatVersion_;
 
  bool filter() const;
 
  bool readEvent(bool doSkip = false);
 
  bool nextEventWithinFile();
 
  void checkFileNames();
 
  void readIndexTable();
 
  uint64_t timeStamp_;
  uint32_t lumiBlock_;
  uint32_t runNum_;
  uint32_t bx_;
  uint32_t eventNum_;
  uint32_t orbitNum_;
 
  unsigned char dataFormatVers_;
 
  std::ifstream in_;
 
  bool rcRead_;
 
  unsigned preScale_;
 
  uint32_t iEvent_;
 
  uint32_t iEventInFile_;
 
  uint32_t indexTablePos_;
 
  int calibTrig_;
 
  int nFeds_;
 
  std::vector<IndexRecord> indexTable_;
 
  static const unsigned maxEvents_ = 1 << 20;
 
  static const unsigned maxEventSize_ = 1 << 20;  //1MB. (full DCC event is 49kB)
 
  bool orderedRead_;
 
  bool watchFileList_;
 
  std::string fileListName_;
 
  std::string inputDir_;
 
  std::string currentFileName_;
 
  std::ifstream fileList_;
 
  int nSecondsToSleep_;
 
  int verbosity_;
};
#endif  //SourceModule_H not defined