StreamerOutputFile.h

Go to the documentation of this file.

#ifndef IOPool_Streamer_StreamerOutputFile_h
#define IOPool_Streamer_StreamerOutputFile_h

#include "IOPool/Streamer/interface/MsgTools.h"

#include "IOPool/Streamer/interface/InitMsgBuilder.h"
#include "IOPool/Streamer/interface/InitMessage.h"

#include "IOPool/Streamer/interface/EventMsgBuilder.h"
#include "IOPool/Streamer/interface/EventMessage.h"

#include "IOPool/Streamer/interface/StreamerFileIO.h"
#include "boost/shared_ptr.hpp"

#include <exception>
#include <fstream>
#include <iostream>

class StreamerOutputFile
  {
  public:
     explicit StreamerOutputFile(const std::string& name);
     ~StreamerOutputFile();

     void write(const InitMsgBuilder&);
     void write(const InitMsgView&);

     void writeInitFragment(uint32 fragIndex, uint32 fragCount,
                            const char *dataPtr, uint32 dataSize);

     uint64 write(const EventMsgBuilder&);
     uint64 write(const EventMsgView&);

     uint64 writeEventFragment(uint32 fragIndex, uint32 fragCount,
                               const char *dataPtr, uint32 dataSize);

     //Returns how many bytes were written out
     uint32 writeEOF(uint32 statusCode,
                     const std::vector<uint32>& hltStats);

     uint32 adler32() const { return streamerfile_->adler32(); }

  private:
     void writeEventHeader(const EventMsgView& ineview);
     void writeStart(const InitMsgView& inview);

  private:
     boost::shared_ptr<OutputFile> streamerfile_;
};

#endif