IOPool/Streamer/interface/StreamerOutputFile.h - master - githubmirror/cmssw

IOPool/Streamer/interface/StreamerOutputFile.h

68 строк2 KB

Chris Jones

Moved code to edm::streamer namespace

02 май 2024, 00:33

02 май 2024, 00:33bcbcf69

#ifndef IOPool_Streamer_StreamerOutputFile_h
#define IOPool_Streamer_StreamerOutputFile_h

/** StreamerOutputFile: Class for doing Streamer Write operations */

#include "FWCore/Utilities/interface/propagate_const.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 <memory>

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

namespace edm::streamer {
  class StreamerOutputFile
  /**
  Class for doing Streamer Write operations
  */
  {
  public:
    explicit StreamerOutputFile(const std::string& name, uint32 padding = 0);
    /**
      CTOR, takes file path name as argument
     */
    ~StreamerOutputFile();

    void write(const InitMsgBuilder&);
    /**
      Performs write on InitMsgBuilder type,
      Header + Blob, both are written out.
     */
    void write(const InitMsgView&);

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

    uint64 write(const EventMsgBuilder&);
    /**
      Performs write on EventMsgBuilder type,
      Header + Blob, both are written out.
      RETURNS the Offset in Stream while at
              which EventForOutputwas written.
     */
    uint64 write(const EventMsgView&);

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

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

    void close() { streamerfile_->close(); }

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

  private:
    edm::propagate_const<std::shared_ptr<edm::streamer::OutputFile>> streamerfile_;
  };
}  // namespace edm::streamer
#endif