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