---

edm::StreamerFileWriter Class Reference

#include <IOPool/Streamer/src/StreamerFileWriter.h>

List of all members.

Public Member Functions
void	doOutputEvent (EventMsgView const &msg)
void	doOutputEvent (EventMsgBuilder const &msg)
void	doOutputHeader (InitMsgView const &init_message)
void	doOutputHeader (InitMsgBuilder const &init_message)
uint32	get_adler32_index () const
uint32	get_adler32_stream () const
uint32	getIndexEOFSize () const
uint32	getStreamEOFSize () const
void	start ()
void	stop ()
	StreamerFileWriter (std::string const &fileName, std::string const &indexFileName)
	StreamerFileWriter (edm::ParameterSet const &ps)
	~StreamerFileWriter ()
Private Member Functions
void	updateHLTStats (std::vector< uint8 > const &packedHlt)
Private Attributes
uint32	hltCount_
std::vector< uint32 >	hltStats_
uint32	index_eof_size_
std::auto_ptr < StreamerOutputIndexFile >	index_writer_
uint32	stream_eof_size_
std::auto_ptr< StreamerOutputFile >	stream_writer_

---

Detailed Description

Definition at line 23 of file StreamerFileWriter.h.

---

Constructor & Destructor Documentation

edm::StreamerFileWriter::StreamerFileWriter

(

edm::ParameterSet const &

ps

)

[explicit]

Definition at line 7 of file StreamerFileWriter.cc.

                                                               :
  stream_writer_(new StreamerOutputFile(
                    ps.getUntrackedParameter<std::string>("fileName","teststreamfile.dat"))),
  index_writer_(new StreamerOutputIndexFile(
                    ps.getUntrackedParameter<std::string>("indexFileName","testindexfile.ind"))),
  hltCount_(0),
  index_eof_size_(0),
  stream_eof_size_(0)
  {
  }

edm::StreamerFileWriter::StreamerFileWriter	(	std::string const &	fileName,
		std::string const &	indexFileName
	)			[explicit]

Definition at line 19 of file StreamerFileWriter.cc.

                                                                                               :
  stream_writer_(new StreamerOutputFile(fileName)),
  index_writer_(new StreamerOutputIndexFile(indexFileName)),
  hltCount_(0),
  index_eof_size_(0),
  stream_eof_size_(0)
  {
  }

edm::StreamerFileWriter::~StreamerFileWriter

(

)

Definition at line 29 of file StreamerFileWriter.cc.

  {
  }

---

Member Function Documentation

void edm::StreamerFileWriter::doOutputEvent

(

EventMsgView const &

msg

)

Definition at line 74 of file StreamerFileWriter.cc.

References hltCount_, EventMsgView::hltTriggerBits(), index_writer_, stream_writer_, and updateHLTStats().

  {
    //Write the Event Message to Streamer file
    uint64 event_offset = stream_writer_->write(msg);
    
    index_writer_->write(msg, event_offset);
    
    // Lets update HLT Stat, know how many 
    // Events for which Trigger are being written
    
    //get the HLT Packed bytes
    std::vector<uint8> packedHlt;
    uint32 hlt_sz = 0;
    if (hltCount_ != 0) hlt_sz = 1 + ((hltCount_-1)/4); 
    packedHlt.resize(hlt_sz);
    msg.hltTriggerBits(&packedHlt[0]);
    updateHLTStats(packedHlt); 
  }

void edm::StreamerFileWriter::doOutputEvent

(

EventMsgBuilder const &

msg

)

Definition at line 94 of file StreamerFileWriter.cc.

References EventMsgBuilder::startAddress().

  {

    EventMsgView eview(msg.startAddress());
    doOutputEvent(eview);
 
  }

void edm::StreamerFileWriter::doOutputHeader

(

InitMsgView const &

init_message

)

Definition at line 54 of file StreamerFileWriter.cc.

References InitMsgView::get_hlt_bit_cnt(), hltCount_, hltStats_, i, index_writer_, and stream_writer_.

  {

    //Write the Init Message to Streamer file
    stream_writer_->write(init_message);

    uint32 magic = 22;
    uint64 reserved = 666;
    index_writer_->writeIndexFileHeader(magic, reserved);
    index_writer_->write(init_message);

    //HLT Count
    hltCount_ = init_message.get_hlt_bit_cnt();

    //Initialize the HLT Stat vector with all ZEROs
    for(uint32 i = 0; i != hltCount_; ++i)
       hltStats_.push_back(0);
  }

void edm::StreamerFileWriter::doOutputHeader

(

InitMsgBuilder const &

init_message

)

Definition at line 46 of file StreamerFileWriter.cc.

References InitMsgBuilder::startAddress().

  {

    //Let us turn it into a View
    InitMsgView view(init_message.startAddress());
    doOutputHeader(view);

  }

uint32 edm::StreamerFileWriter::get_adler32_index

(

)

const [inline]

Definition at line 47 of file StreamerFileWriter.h.

References index_writer_.

{ return index_writer_->adler32();}

uint32 edm::StreamerFileWriter::get_adler32_stream

(

)

const [inline]

Definition at line 46 of file StreamerFileWriter.h.

References stream_writer_.

{ return stream_writer_->adler32();}

uint32 edm::StreamerFileWriter::getIndexEOFSize

(

)

const [inline]

Definition at line 44 of file StreamerFileWriter.h.

References index_eof_size_.

{return index_eof_size_;}

uint32 edm::StreamerFileWriter::getStreamEOFSize

(

)

const [inline]

Definition at line 43 of file StreamerFileWriter.h.

References stream_eof_size_.

{return stream_eof_size_;}

void edm::StreamerFileWriter::start

(

void

)

[inline]

Definition at line 39 of file StreamerFileWriter.h.

{}

void edm::StreamerFileWriter::stop

(

)

Definition at line 33 of file StreamerFileWriter.cc.

References hltStats_, index_eof_size_, index_writer_, stream_eof_size_, and stream_writer_.

  {

    // User code of this class MUST call method

    //Write the EOF Record Both at the end of Streamer file and Index file
    uint32 dummyStatusCode = 1234;
    
    index_eof_size_ = index_writer_->writeEOF(dummyStatusCode, hltStats_);
    stream_eof_size_ = stream_writer_->writeEOF(dummyStatusCode, hltStats_);
    
  }

void edm::StreamerFileWriter::updateHLTStats

(

std::vector< uint8 > const &

packedHlt

)

[private]

Definition at line 103 of file StreamerFileWriter.cc.

References hltCount_, hltStats_, and i.

Referenced by doOutputEvent().

   {
    unsigned int packInOneByte = 4;
    unsigned char testAgaint = 0x01;
    for(unsigned int i = 0; i != hltCount_; ++i)
    {
       unsigned int whichByte = i/packInOneByte;
       unsigned int indxWithinByte = i % packInOneByte;
       if ((testAgaint << (2 * indxWithinByte)) & (packedHlt.at(whichByte))) {
           ++hltStats_[i];
       }
       //else  std::cout <<"Bit "<<i<<" is not set"<< std::endl;
    }
   }

---

Member Data Documentation

uint32 edm::StreamerFileWriter::hltCount_ [private]

Definition at line 54 of file StreamerFileWriter.h.

Referenced by doOutputEvent(), doOutputHeader(), and updateHLTStats().

std::vector<uint32> edm::StreamerFileWriter::hltStats_ [private]

Definition at line 55 of file StreamerFileWriter.h.

Referenced by doOutputHeader(), stop(), and updateHLTStats().

uint32 edm::StreamerFileWriter::index_eof_size_ [private]

Definition at line 56 of file StreamerFileWriter.h.

Referenced by getIndexEOFSize(), and stop().

std::auto_ptr<StreamerOutputIndexFile> edm::StreamerFileWriter::index_writer_ [private]

Definition at line 53 of file StreamerFileWriter.h.

Referenced by doOutputEvent(), doOutputHeader(), get_adler32_index(), and stop().

uint32 edm::StreamerFileWriter::stream_eof_size_ [private]

Definition at line 57 of file StreamerFileWriter.h.

Referenced by getStreamEOFSize(), and stop().

std::auto_ptr<StreamerOutputFile> edm::StreamerFileWriter::stream_writer_ [private]

Definition at line 52 of file StreamerFileWriter.h.

Referenced by doOutputEvent(), doOutputHeader(), get_adler32_stream(), and stop().

---

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

• IOPool/Streamer/src/StreamerFileWriter.h
• IOPool/Streamer/src/StreamerFileWriter.cc

---