StreamerOutputFile Class Reference

#include <StreamerOutputFile.h>

Public Member Functions
uint32	adler32 () const
	StreamerOutputFile (const std::string &name)
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
std::shared_ptr< OutputFile >	streamerfile_

Detailed Description

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

Definition at line 21 of file StreamerOutputFile.h.

Constructor & Destructor Documentation

StreamerOutputFile::StreamerOutputFile ( const std::string &  name )

explicit

Definition at line 7 of file StreamerOutputFile.cc.

References streamerfile_.

                                                             :
  streamerfile_(new OutputFile(name))
  {
    streamerfile_->set_do_adler(1);
  }

StreamerOutputFile::~StreamerOutputFile

(

)

CTOR, takes file path name as argument

Definition at line 4 of file StreamerOutputFile.cc.

                                          {
  }

Member Function Documentation

uint32 StreamerOutputFile::adler32 ( ) const

inline

Definition at line 55 of file StreamerOutputFile.h.

References streamerfile_.

{ return streamerfile_->adler32(); }

void StreamerOutputFile::write

(

const InitMsgBuilder &

inview

)

Definition at line 66 of file StreamerOutputFile.cc.

References InitMsgBuilder::startAddress().

Referenced by write().

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

void StreamerOutputFile::write

(

const InitMsgView &

inview

)

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

Definition at line 72 of file StreamerOutputFile.cc.

References InitMsgView::descData(), Exception, InitMsgView::headerSize(), run_regression::ret, InitMsgView::size(), streamerfile_, and writeStart().

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

uint64 StreamerOutputFile::write

(

const EventMsgBuilder &

ineview

)

Definition at line 13 of file StreamerOutputFile.cc.

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

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

uint64 StreamerOutputFile::write

(

const EventMsgView &

ineview

)

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

Offset where current event starts

Definition at line 19 of file StreamerOutputFile.cc.

References EventMsgView::eventData(), Exception, EventMsgView::headerSize(), run_regression::ret, 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());
    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;
  }

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

Offset where current event starts

Definition at line 37 of file StreamerOutputFile.cc.

References Exception, run_regression::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;
  }

void StreamerOutputFile::writeEventHeader ( const EventMsgView &  ineview )

private

Definition at line 53 of file StreamerOutputFile.cc.

References Exception, EventMsgView::headerSize(), run_regression::ret, 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;
    }
  }

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

Definition at line 86 of file StreamerOutputFile.cc.

References Exception, run_regression::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;
    }
  }

void StreamerOutputFile::writeStart ( const InitMsgView &  inview )

private

Definition at line 98 of file StreamerOutputFile.cc.

References Exception, InitMsgView::headerSize(), run_regression::ret, 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

std::shared_ptr<OutputFile> StreamerOutputFile::streamerfile_

private

Definition at line 62 of file StreamerOutputFile.h.

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