LmfSource.h

Go to the documentation of this file.

#ifndef SourceModule_H
#define SourceModule_H

#include <vector>
#include <string>
#include <inttypes.h>
#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{
    int orbit;
    std::streampos filePos;
    //    bool operator<(const IndexRecord& i) const { return orbit < i.orbit; }
  };
  
public:
  LmfSource(const edm::ParameterSet& pset,
           const edm::InputSourceDescription& isd);
  virtual ~LmfSource(){}
  
private:
  virtual void produce(edm::Event &e);

  virtual bool setRunAndEventInfo(edm::EventID& id, edm::TimeValue_t& time);

  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 unsigned fileHeaderSize;
  
  std::vector<uint32_t> fileHeader_;


  static unsigned char minDataFormatVersion_;
  
  static 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