---

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 "IOPool/Streamer/interface/IndexRecords.h"
#include "Utilities/StorageFactory/interface/IOTypes.h"
#include "Utilities/StorageFactory/interface/Storage.h"

#include <boost/shared_ptr.hpp>

#include<string>
#include<vector>

class StreamerInputIndexFile;

  class StreamerInputFile
  {
  public:

    explicit StreamerInputFile(const std::string& name);

    explicit StreamerInputFile(const std::string& name, const std::string& order);

    explicit StreamerInputFile(const std::string& name, const StreamerInputIndexFile& order);

    explicit StreamerInputFile(const std::vector<std::string>& names);

    ~StreamerInputFile();

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

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

    void readStartMessage();
    int  readEventMessage();

    bool openNextFile();
    bool compareHeader();

    void logFileAction(const char* msg);

    bool useIndex_;
    StreamerInputIndexFile* index_;
    indexRecIter indexIter_b;
    indexRecIter indexIter_e;

    InitMsgView* startMsg_;
    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_;

    uint32 currRun_;
    uint32 currProto_;

    bool newHeader_;

    boost::shared_ptr<Storage> storage_;

    bool endOfFile_;
  };



#endif

---