---

StreamerInputIndexFile.h

Go to the documentation of this file.

#ifndef IOPool_Streamer_StreamerInputIndexFile_h
#define IOPool_Streamer_StreamerInputIndexFile_h

#include "IOPool/Streamer/interface/MsgTools.h"
#include "IOPool/Streamer/interface/IndexRecords.h"
#include <string>

  class StreamerInputIndexFile
  {
  public:
    explicit StreamerInputIndexFile(const std::string& name);
    explicit StreamerInputIndexFile(const std::vector<std::string>& names);

    ~StreamerInputIndexFile();

    const StartIndexRecord* startMessage() const { return startMsg_; }

    bool eof() {return eof_; }

    const indexRecIter begin() { return indexes_.begin(); }
    const indexRecIter end() { return indexes_.end(); }
    indexRecIter sort();

  private:

    void readStartMessage(); 
    int  readEventMessage(); 
    std::ifstream* ist_;

    StartIndexRecord* startMsg_;

    bool eof_;

    uint64 eventBufPtr_;

    std::vector<char> headerBuf_;
    std::vector<char> eventBuf_;
    uint32 eventHeaderSize_;

    std::vector<EventIndexRecord*> indexes_;
  };




#endif

---