WatcherStreamFileReader.h

Go to the documentation of this file.

#ifndef CalibCalorimetry_EcalLaserSorting_WatcherStreamFileReader_h
#define CalibCalorimetry_EcalLaserSorting_WatcherStreamFileReader_h

#include "IOPool/Streamer/interface/InitMessage.h"
#include "IOPool/Streamer/interface/EventMessage.h"

#include "FWCore/ParameterSet/interface/ParameterSet.h"

#include <string>
#include <iostream>
#include <deque>

namespace edm::streamer {
  class StreamerInputFile;
}

class WatcherStreamFileReader {
public:
  WatcherStreamFileReader(edm::ParameterSet const& pset);
  ~WatcherStreamFileReader();

  const edm::streamer::InitMsgView* getHeader();
  const edm::streamer::EventMsgView* getNextEvent();
  const bool newHeader();

  edm::streamer::StreamerInputFile* getInputFile();

  void closeFile();

private:
  void moveJustReadFile();
  std::string inputDir_;

  std::vector<std::string> filePatterns_;

  std::string inprocessDir_;

  std::string processedDir_;

  std::string corruptedDir_;

  std::unique_ptr<edm::streamer::StreamerInputFile> streamerInputFile_;

  std::string fileName_;

  std::string tokenFile_;

  int timeOut_;

  std::deque<std::string> filesInQueue_;

  bool end_;

  int verbosity_;
};

#endif