edm::streamer::StreamerOutputFile Class Reference

#include <StreamerOutputFile.h>

Public Member Functions
uint32	adler32 () const
void	close ()
	StreamerOutputFile (const std::string &name, uint32 padding=0)
void	write (const InitMsgBuilder &)
void	write (const InitMsgView &)
uint64	write (const EventMsgBuilder &)
uint64	write (const EventMsgView &)
uint64	writeEventFragment (uint32 fragIndex, uint32 fragCount, const char *dataPtr, uint32 dataSize)
void	writeInitFragment (uint32 fragIndex, uint32 fragCount, const char *dataPtr, uint32 dataSize)
	~StreamerOutputFile ()

Private Member Functions
void	writeEventHeader (const EventMsgView &ineview)
void	writeStart (const InitMsgView &inview)

Private Attributes
edm::propagate_const< std::shared_ptr< edm::streamer::OutputFile > >	streamerfile_

Detailed Description

Class for doing Streamer Write operations

Definition at line 24 of file StreamerOutputFile.h.

Constructor & Destructor Documentation

StreamerOutputFile()

edm::streamer::StreamerOutputFile::StreamerOutputFile ( const std::string &  name, uint32  padding = 0  )

explicit

Definition at line 7 of file StreamerOutputFile.cc.

References streamerfile_.

      : streamerfile_(std::make_shared<edm::streamer::OutputFile>(name, padding)) {
    streamerfile_->set_do_adler(true);
  }

~StreamerOutputFile()

edm::streamer::StreamerOutputFile::~StreamerOutputFile

(

)

CTOR, takes file path name as argument

Definition at line 5 of file StreamerOutputFile.cc.

{}

Member Function Documentation

adler32()

uint32 edm::streamer::StreamerOutputFile::adler32 ( ) const

inline

Definition at line 56 of file StreamerOutputFile.h.

References streamerfile_.

Referenced by evf::GlobalEvFOutputModule::globalBeginRun().

{ return streamerfile_->adler32(); }

close()

void edm::streamer::StreamerOutputFile::close ( void  )

inline

Definition at line 58 of file StreamerOutputFile.h.

References streamerfile_.

Referenced by evf::GlobalEvFOutputModule::globalBeginRun(), esMonitoring.AsyncLineReaderMixin::handle_close(), and esMonitoring.FDJsonServer::handle_close().

{ streamerfile_->close(); }

write() [1/4]

void edm::streamer::StreamerOutputFile::write

(

const InitMsgBuilder &

inview

)

Definition at line 56 of file StreamerOutputFile.cc.

References edm::streamer::InitMsgBuilder::startAddress().

Referenced by evf::GlobalEvFOutputModule::globalBeginRun(), and write().

                                                             {
    InitMsgView tmpView(inview.startAddress());
    return write(tmpView);
  }

write() [2/4]

void edm::streamer::StreamerOutputFile::write

(

const InitMsgView &

inview

)

Performs write on InitMsgBuilder type, Header + Blob, both are written out.

Definition at line 61 of file StreamerOutputFile.cc.

References edm::streamer::InitMsgView::descData(), Exception, edm::streamer::InitMsgView::headerSize(), runTheMatrix::ret, edm::streamer::InitMsgView::size(), streamerfile_, and writeStart().

                                                          {
    writeStart(inview);
    bool ret = streamerfile_->write((const char*)inview.descData(), inview.size() - inview.headerSize(), true);
    if (ret) {
      throw cms::Exception("OutputFile", "write(InitMsgView)")
          << "Error writing streamer header data to " << streamerfile_->fileName() << ".  Possibly the output disk "
          << "is full?" << std::endl;
    }
  }

write() [3/4]

uint64 edm::streamer::StreamerOutputFile::write

(

const EventMsgBuilder &

ineview

)

Definition at line 12 of file StreamerOutputFile.cc.

References edm::streamer::EventMsgBuilder::startAddress(), and write().

                                                                 {
    EventMsgView tmpView(ineview.startAddress());
    return write(tmpView);
  }

write() [4/4]

uint64 edm::streamer::StreamerOutputFile::write

(

const EventMsgView &

ineview

)

Performs write on EventMsgBuilder type, Header + Blob, both are written out. RETURNS the Offset in Stream while at which EventForOutputwas written.

Offset where current event starts

Definition at line 17 of file StreamerOutputFile.cc.

References edm::streamer::EventMsgView::eventData(), Exception, edm::streamer::EventMsgView::headerSize(), runTheMatrix::ret, edm::streamer::EventMsgView::size(), streamerfile_, and writeEventHeader().

                                                              {
    uint64 offset_to_return = streamerfile_->current_offset();

    writeEventHeader(ineview);
    bool ret = streamerfile_->write((const char*)ineview.eventData(), ineview.size() - ineview.headerSize(), true);
    if (ret) {
      throw cms::Exception("OutputFile", "write(EventMsgView)")
          << "Error writing streamer event data to " << streamerfile_->fileName() << ".  Possibly the output disk "
          << "is full?" << std::endl;
    }
    return offset_to_return;
  }

writeEventFragment()

uint64 edm::streamer::StreamerOutputFile::writeEventFragment	(	uint32	fragIndex,
		uint32	fragCount,
		const char *	dataPtr,
		uint32	dataSize
	)

Offset where current event starts

Definition at line 31 of file StreamerOutputFile.cc.

References Exception, runTheMatrix::ret, and streamerfile_.

                                                                 {
    uint64 offset_to_return = streamerfile_->current_offset();

    bool ret = streamerfile_->write(dataPtr, dataSize);
    if (ret) {
      throw cms::Exception("OutputFile", "writeEventFragment()")
          << "Error writing streamer event data to " << streamerfile_->fileName() << ".  Possibly the output disk "
          << "is full?" << std::endl;
    }
    return offset_to_return;
  }

writeEventHeader()

void edm::streamer::StreamerOutputFile::writeEventHeader ( const EventMsgView &  ineview )

private

Definition at line 47 of file StreamerOutputFile.cc.

References Exception, edm::streamer::EventMsgView::headerSize(), runTheMatrix::ret, edm::streamer::EventMsgView::startAddress(), and streamerfile_.

Referenced by write().

                                                                       {
    bool ret = streamerfile_->write((const char*)ineview.startAddress(), ineview.headerSize());
    if (ret) {
      throw cms::Exception("OutputFile", "writeEventHeader")
          << "Error writing streamer event data to " << streamerfile_->fileName() << ".  Possibly the output disk "
          << "is full?" << std::endl;
    }
  }

writeInitFragment()

void edm::streamer::StreamerOutputFile::writeInitFragment	(	uint32	fragIndex,
		uint32	fragCount,
		const char *	dataPtr,
		uint32	dataSize
	)

Definition at line 71 of file StreamerOutputFile.cc.

References Exception, runTheMatrix::ret, and streamerfile_.

                                                                                                                     {
    bool ret = streamerfile_->write((const char*)dataPtr, dataSize);
    if (ret) {
      throw cms::Exception("OutputFile", "writeInitFragment()")
          << "Error writing streamer header data to " << streamerfile_->fileName() << ".  Possibly the output disk "
          << "is full?" << std::endl;
    }
  }

writeStart()

void edm::streamer::StreamerOutputFile::writeStart ( const InitMsgView &  inview )

private

Definition at line 80 of file StreamerOutputFile.cc.

References Exception, edm::streamer::InitMsgView::headerSize(), runTheMatrix::ret, edm::streamer::InitMsgView::startAddress(), and streamerfile_.

Referenced by write().

                                                               {
    bool ret = streamerfile_->write((const char*)inview.startAddress(), inview.headerSize());
    if (ret) {
      throw cms::Exception("OutputFile", "writeStart")
          << "Error writing streamer header data to " << streamerfile_->fileName() << ".  Possibly the output disk "
          << "is full?" << std::endl;
    }
  }

Member Data Documentation

streamerfile_

edm::propagate_const<std::shared_ptr<edm::streamer::OutputFile> > edm::streamer::StreamerOutputFile::streamerfile_

private

Definition at line 65 of file StreamerOutputFile.h.

Referenced by adler32(), close(), StreamerOutputFile(), write(), writeEventFragment(), writeEventHeader(), writeInitFragment(), and writeStart().