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::auto_ptr<edm::StreamerInputFile> streamerInputFile_;

  static std::string fileName_;

  std::string tokenFile_;

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

  bool end_;
  
  int verbosity_;

};

#endif