StreamerOutputFile Class Reference

#include <StreamerOutputFile.h>

Public Member Functions
uint32	adler32 () const
void	close ()
	StreamerOutputFile (const std::string &name)
uint64	write (const EventMsgBuilder &)
uint64	write (const EventMsgView &)
void	write (const InitMsgBuilder &)
void	write (const InitMsgView &)
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< OutputFile > >	streamerfile_

Detailed Description

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

Definition at line 23 of file StreamerOutputFile.h.

Constructor & Destructor Documentation

StreamerOutputFile()

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

explicit

Definition at line 6 of file StreamerOutputFile.cc.

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

References streamerfile_.

~StreamerOutputFile()

StreamerOutputFile::~StreamerOutputFile

(

)

CTOR, takes file path name as argument

Definition at line 4 of file StreamerOutputFile.cc.

{}

Member Function Documentation

adler32()

uint32 StreamerOutputFile::adler32 ( ) const

inline

Definition at line 55 of file StreamerOutputFile.h.

{ return streamerfile_->adler32(); }

References streamerfile_.

Referenced by evf::EvFOutputModule::beginRun().

close()

void StreamerOutputFile::close ( void  )

inline

Definition at line 57 of file StreamerOutputFile.h.

{ streamerfile_->close(); }

References streamerfile_.

Referenced by evf::EvFOutputModule::beginRun(), esMonitoring.AsyncLineReaderMixin::handle_close(), and esMonitoring.FDJsonServer::handle_close().

write() [1/4]

uint64 StreamerOutputFile::write

(

const EventMsgBuilder &

ineview

)

Definition at line 10 of file StreamerOutputFile.cc.

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

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

write() [2/4]

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 EventForOutputwas written.

Offset where current event starts

Definition at line 15 of file StreamerOutputFile.cc.

                                                            {
  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;
}

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

write() [3/4]

void StreamerOutputFile::write

(

const InitMsgBuilder &

inview

)

Definition at line 51 of file StreamerOutputFile.cc.

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

References InitMsgBuilder::startAddress().

Referenced by evf::EvFOutputModule::beginRun(), and write().

write() [4/4]

void StreamerOutputFile::write

(

const InitMsgView &

inview

)

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

Definition at line 56 of file StreamerOutputFile.cc.

                                                        {
  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;
  }
}

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

writeEventFragment()

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

Offset where current event starts

Definition at line 29 of file StreamerOutputFile.cc.

                                                                                                                      {
  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;
}

References Exception, runTheMatrix::ret, and streamerfile_.

writeEventHeader()

void StreamerOutputFile::writeEventHeader ( const EventMsgView &  ineview )

private

Definition at line 42 of file StreamerOutputFile.cc.

                                                                     {
  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;
  }
}

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

Referenced by write().

writeInitFragment()

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

Definition at line 66 of file StreamerOutputFile.cc.

                                                                                                                   {
  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;
  }
}

References Exception, runTheMatrix::ret, and streamerfile_.

writeStart()

void StreamerOutputFile::writeStart ( const InitMsgView &  inview )

private

Definition at line 75 of file StreamerOutputFile.cc.

                                                             {
  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;
  }
}

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

Referenced by write().

Member Data Documentation

streamerfile_

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

private

Definition at line 64 of file StreamerOutputFile.h.

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