StreamerInputFile.h

Go to the documentation of this file.

#ifndef IOPool_Streamer_StreamerInputFile_h
#define IOPool_Streamer_StreamerInputFile_h

#include "IOPool/Streamer/interface/InitMessage.h"
#include "IOPool/Streamer/interface/EventMessage.h"
#include "IOPool/Streamer/interface/MsgTools.h"
#include "Utilities/StorageFactory/interface/IOTypes.h"
#include "Utilities/StorageFactory/interface/Storage.h"

#include <boost/shared_ptr.hpp>

#include<string>
#include<vector>

namespace edm {
  class EventSkipperByID;
  class StreamerInputFile {
  public:

    explicit StreamerInputFile(std::string const& name,
      int* numberOfEventsToSkip = 0,
      boost::shared_ptr<EventSkipperByID> eventSkipperByID = boost::shared_ptr<EventSkipperByID>());

    explicit StreamerInputFile(std::vector<std::string> const& names,
      int* numberOfEventsToSkip = 0,
      boost::shared_ptr<EventSkipperByID> eventSkipperByID = boost::shared_ptr<EventSkipperByID>());

    ~StreamerInputFile();

    bool next(); 
    InitMsgView const* startMessage() const { return startMsg_.get(); }
    EventMsgView const* currentRecord() const { return currentEvMsg_.get(); }
    bool newHeader() { bool tmp = newHeader_; newHeader_ = false; return tmp;}  
  private:

    void openStreamerFile(std::string const& name);
    IOSize readBytes(char* buf, IOSize nBytes);
    IOOffset skipBytes(IOSize nBytes);

    void readStartMessage();
    int readEventMessage();

    bool openNextFile();
    bool compareHeader();

    void logFileAction(char const* msg);

    boost::shared_ptr<InitMsgView> startMsg_;
    boost::shared_ptr<EventMsgView> currentEvMsg_;

    std::vector<char> headerBuf_; 
    std::vector<char> eventBuf_;  
    unsigned int currentFile_; 
    std::vector<std::string> streamerNames_; 
    bool multiStreams_;  
    std::string currentFileName_;
    bool currentFileOpen_;

    boost::shared_ptr<EventSkipperByID> eventSkipperByID_;

    int* numberOfEventsToSkip_;

    uint32 currRun_;
    uint32 currProto_;

    bool newHeader_;

    boost::shared_ptr<Storage> storage_;

    bool endOfFile_;
  };
}

#endif