WatcherStreamFileReader.h

Go to the documentation of this file.

#ifndef IOPool_Streamer_StreamerFileReader_h
#define IOPool_Streamer_StreamerFileReader_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 {
  class StreamerInputFile;
}
 
class WatcherStreamFileReader {
public:
  WatcherStreamFileReader(edm::ParameterSet const& pset);
  ~WatcherStreamFileReader();
 
  const InitMsgView* getHeader();
  const EventMsgView* getNextEvent();
  const bool newHeader();
 
  edm::StreamerInputFile* getInputFile();
 
  void closeFile();
 
private:
  std::string inputDir_;
 
  std::vector<std::string> filePatterns_;
 
  std::string inprocessDir_;
 
  std::string processedDir_;
 
  std::string corruptedDir_;
 
  std::unique_ptr<edm::StreamerInputFile> streamerInputFile_;
 
  std::string fileName_;
 
  std::string tokenFile_;
 
  int timeOut_;
 
  std::deque<std::string> filesInQueue_;
 
  bool end_;
 
  int verbosity_;
};
 
#endif