---

StreamerOutputFile Class Reference

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

#include <IOPool/Streamer/interface/StreamerOutputFile.h>

List of all members.

Public Member Functions
uint32	adler32 () const
	StreamerOutputFile (const std::string &name)
uint64	write (const EventMsgView &)
	Performs write on EventMsgBuilder type, Header + Blob, both are written out.
uint64	write (const EventMsgBuilder &)
void	write (const InitMsgView &)
	Performs write on InitMsgBuilder type, Header + Blob, both are written out.
void	write (const InitMsgBuilder &)
uint32	writeEOF (uint32 statusCode, const std::vector< uint32 > &hltStats)
	~StreamerOutputFile ()
	CTOR, takes file path name as argument.
Private Member Functions
void	writeEventHeader (const EventMsgView &ineview)
void	writeStart (const InitMsgView &inview)
Private Attributes
OutputFile *	streamerfile_

---

Detailed Description

StreamerOutputFile: Class for doing Streamer Write operations.

Class for doing Streamer Write operations

Definition at line 20 of file StreamerOutputFile.h.

---

Constructor & Destructor Documentation

StreamerOutputFile::StreamerOutputFile

(

const std::string &

name

)

[explicit]

Definition at line 10 of file StreamerOutputFile.cc.

References OutputFile::set_do_adler(), and streamerfile_.

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

StreamerOutputFile::~StreamerOutputFile

(

)

CTOR, takes file path name as argument.

Definition at line 5 of file StreamerOutputFile.cc.

References streamerfile_.

  {
    delete streamerfile_;
  }

---

Member Function Documentation

uint32 StreamerOutputFile::adler32

(

)

const [inline]

Definition at line 52 of file StreamerOutputFile.h.

References OutputFile::adler32(), and streamerfile_.

{ return streamerfile_->adler32(); }

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

Offset of last written event

Definition at line 22 of file StreamerOutputFile.cc.

References OutputFile::current_offset(), lat::endl(), EventMsgView::eventData(), Exception, OutputFile::fileName(), EventMsgView::headerSize(), OutputFile::inc_events(), OutputFile::set_last_event_offset(), EventMsgView::size(), streamerfile_, OutputFile::write(), and writeEventHeader().

  {
    uint64 offset_to_return = streamerfile_->current_offset();

    streamerfile_->set_last_event_offset(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;
    }

    streamerfile_->inc_events();

    return offset_to_return;
  }

uint64 StreamerOutputFile::write

(

const EventMsgBuilder &

ineview

)

Definition at line 16 of file StreamerOutputFile.cc.

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

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

void StreamerOutputFile::write

(

const InitMsgView &

inview

)

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

Offset of first event to be written

Definition at line 64 of file StreamerOutputFile.cc.

References OutputFile::current_offset(), InitMsgView::descData(), lat::endl(), Exception, OutputFile::fileName(), InitMsgView::headerSize(), OutputFile::set_first_event_offset(), InitMsgView::size(), streamerfile_, OutputFile::write(), 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;
    }

    streamerfile_->set_first_event_offset(streamerfile_->current_offset());
  }

void StreamerOutputFile::write

(

const InitMsgBuilder &

inview

)

Definition at line 58 of file StreamerOutputFile.cc.

References InitMsgBuilder::startAddress().

Referenced by write().

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

uint32 StreamerOutputFile::writeEOF	(	uint32	statusCode,
		const std::vector< uint32 > &	hltStats
	)

Definition at line 94 of file StreamerOutputFile.cc.

References lat::endl(), outputToXml::eof, OutputFile::events(), Exception, OutputFile::fileName(), OutputFile::first_event_offset(), OutputFile::last_event_offset(), OutputFile::run(), streamerfile_, and OutputFile::write().

  {
    EOFRecordBuilder eof(streamerfile_->run(), 
                         streamerfile_->events(),
                         statusCode,
                         hltStats,
                         streamerfile_->first_event_offset(),
                         streamerfile_->last_event_offset());

    bool ret = streamerfile_->write((const char*) 
                                    eof.recAddress(), 
                                    eof.size());  
    if (ret) {
      throw cms::Exception("OutputFile", "writeEOF")
        << "Error writing streamer end-of-file to "
        << streamerfile_->fileName() << ".  Possibly the output disk "
        << "is full?" << std::endl;
    }
    return eof.size();  
  }

void StreamerOutputFile::writeEventHeader

(

const EventMsgView &

ineview

)

[private]

Definition at line 45 of file StreamerOutputFile.cc.

References lat::endl(), Exception, OutputFile::fileName(), EventMsgView::headerSize(), EventMsgView::startAddress(), streamerfile_, and OutputFile::write().

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::writeStart

(

const InitMsgView &

inview

)

[private]

Definition at line 80 of file StreamerOutputFile.cc.

References lat::endl(), Exception, OutputFile::fileName(), InitMsgView::headerSize(), InitMsgView::run(), OutputFile::set_run(), InitMsgView::startAddress(), streamerfile_, and OutputFile::write().

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;
    }
    streamerfile_->set_run(inview.run()); 
  }

---

Member Data Documentation

OutputFile* StreamerOutputFile::streamerfile_ [private]

Definition at line 59 of file StreamerOutputFile.h.

Referenced by adler32(), StreamerOutputFile(), write(), writeEOF(), writeEventHeader(), writeStart(), and ~StreamerOutputFile().

---

The documentation for this class was generated from the following files:

• IOPool/Streamer/interface/StreamerOutputFile.h
• IOPool/Streamer/src/StreamerOutputFile.cc

---