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