---

DQMEventMsgBuilder Class Reference

This class is used to build and view the DQM Event data that is exchanged between the filter units and the storage manager. More...

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

List of all members.

Public Member Functions
uint32	bufferSize () const
	DQMEventMsgBuilder (void *buf, uint32 bufSize, uint32 run, uint32 event, edm::Timestamp timeStamp, uint32 lumiSection, uint32 updateNumber, std::string const &releaseTag, std::string const &topFolderName, DQMEvent::TObjectTable monitorElementsBySubFolder)
	This class is used to build and view the DQM Event data that is exchanged between the filter units and the storage manager.
uint8 *	eventAddress () const
uint32	headerSize () const
void	setCompressionFlag (uint32)
	Sets the value of the compression flag in the header.
void	setEventLength (uint32 len)
	Sets the length of the event (payload).
void	setFUGuid (uint32)
	Sets the value of the filter unit GUID in the header.
void	setFUProcessId (uint32)
	Sets the value of the filter unit process ID in the header.
void	setReserved (uint32)
	Sets the value of the reserved word in the header.
uint32	size () const
	Returns the size of the message.
uint8 *	startAddress () const
Private Attributes
uint8 *	buf_
uint32	bufSize_
uint8 *	eventAddr_

---

Detailed Description

This class is used to build and view the DQM Event data that is exchanged between the filter units and the storage manager.

09-Feb-2007 - Initial Implementation DQM Event Message Format:

• Code (1 byte)
• Size (4 bytes)
• Protocol Version (4 bytes)
• Header Size (4 bytes)
• Run Number (4 bytes)
• Event Number at Update (4 bytes)
• Luminosity Section (4 bytes)
• Update Number (4 bytes)
• Compression Flag (4 bytes) | size of data before compression
• Filter Unit Process ID (4 bytes)
• Filter Unit Unique ID [GUID] (4 bytes)
• Reserved Word (4 bytes)
• Release Tag Length (4 bytes)
• Release Tag (varies)
• Top-level Folder Name Length (4 bytes)
• Top-level Folder Name (varies)
• Number of Subfolders (4 bytes)
• Number of Monitor Elements in Subfolder I (4 bytes) | Repeated
• Subfolder I Name Length (4 bytes) | for each
• Subfolder I Name (varies) | subfolder
• DQM Event Data Length (4 bytes)
• DQM Event Data (varies)

Definition at line 44 of file DQMEventMsgBuilder.h.

---

Constructor & Destructor Documentation

DQMEventMsgBuilder::DQMEventMsgBuilder	(	void *	buf,
		uint32	bufSize,
		uint32	run,
		uint32	event,
		edm::Timestamp	timeStamp,
		uint32	lumiSection,
		uint32	updateNumber,
		std::string const &	releaseTag,
		std::string const &	topFolderName,
		DQMEvent::TObjectTable	monitorElementsBySubFolder
	)

This class is used to build and view the DQM Event data that is exchanged between the filter units and the storage manager.

09-Feb-2007 - Initial Implementation Constructor.

Definition at line 15 of file DQMEventMsgBuilder.cc.

References buf_, bufSize_, convert(), eventAddr_, DQMEventHeader::eventNumber_, Exception, DQMEventHeader::headerSize_, len, DQMEventHeader::lumiSection_, DQMEventHeader::protocolVersion_, DQMEventHeader::runNumber_, setCompressionFlag(), setEventLength(), setFUGuid(), setFUProcessId(), setReserved(), DQMEventHeader::timeStamp_, DQMEventHeader::updateNumber_, and edm::Timestamp::value().

                                                                            :
  buf_((uint8*)buf),bufSize_(bufSize)
{
  DQMEventHeader* evtHdr;
  uint8* bufPtr;
  uint32 len;
  uint32 protocolVersion = 2;

  // fill in event header information
  bufPtr = buf_ + sizeof(DQMEventHeader);
  if (((uint32) (bufPtr - buf_)) > bufSize_)
    {
      throw cms::Exception("MessageBuilding", "DQMEventMsgBuilder")
        << "Input buffer size is too small for required header "
        << "information.  Size = " << bufSize_
        << ", necessary size is >= "
        << ((uint32) (bufPtr - buf_)) << ".\n";
    }

  evtHdr = (DQMEventHeader*) buf_;
  convert(protocolVersion, evtHdr->protocolVersion_);
  convert(run, evtHdr->runNumber_);
  convert(event, evtHdr->eventNumber_);

  convert(timeStamp.value(), evtHdr->timeStamp_);

  convert(lumiSection, evtHdr->lumiSection_);
  convert(updateNumber, evtHdr->updateNumber_);

  // copy the release tag into the message
  len = releaseTag.length();
  if (((uint32) (bufPtr + len + sizeof(uint32) - buf_)) > bufSize_)
    {
      throw cms::Exception("MessageBuilding", "DQMEventMsgBuilder")
        << "Input buffer size is too small for required header "
        << "information.  Size = " << bufSize_
        << ", necessary size is >= "
        << ((uint32) (bufPtr + len + sizeof(uint32) - buf_)) << ".\n";
    }
  convert(len, bufPtr);
  bufPtr += sizeof(uint32);
  releaseTag.copy((char*) bufPtr, len);
  bufPtr += len;

  // copy the top folder name into the message
  len = topFolderName.length();
  if (((uint32) (bufPtr + len + sizeof(uint32) - buf_)) > bufSize_)
    {
      throw cms::Exception("MessageBuilding", "DQMEventMsgBuilder")
        << "Input buffer size is too small for required header "
        << "information.  Size = " << bufSize_
        << ", necessary size is >= "
        << ((uint32) (bufPtr + len + sizeof(uint32) - buf_)) << ".\n";
    }
  convert(len, bufPtr);
  bufPtr += sizeof(uint32);
  topFolderName.copy((char*) bufPtr, len);
  bufPtr += len;

  // copy the subfolder count into the message
  convert(static_cast<uint32>(monitorElementsBySubFolder.size()), bufPtr);
  bufPtr += sizeof(uint32);

  // copy the ME count and name for each subfolder into the message
  DQMEvent::TObjectTable::const_iterator sfIter;
  for (sfIter = monitorElementsBySubFolder.begin();
       sfIter != monitorElementsBySubFolder.end(); sfIter++)
    {
      std::string subFolderName = sfIter->first;
      std::vector<TObject *> toList = sfIter->second;

      convert(static_cast<uint32>(toList.size()), bufPtr);
      bufPtr += sizeof(uint32);

      len = subFolderName.length();
      convert(len, bufPtr);
      bufPtr += sizeof(uint32);
      subFolderName.copy((char*) bufPtr, len);
      bufPtr += len;
    }

  // set the header size and the event address, taking into account the
  // size of the event length field
  if (((uint32) (bufPtr + sizeof(uint32) - buf_)) > bufSize_)
    {
      throw cms::Exception("MessageBuilding", "DQMEventMsgBuilder")
        << "Input buffer size is too small for required header "
        << "information.  Size = " << bufSize_
        << ", necessary size is >= "
        << ((uint32) (bufPtr + sizeof(uint32) - buf_)) << ".\n";
    }
  convert(((uint32) (bufPtr - buf_)), evtHdr->headerSize_);
  bufPtr += sizeof(uint32);
  eventAddr_ = bufPtr;

  // set the event length to 0 initially.  (The setEventLength method
  // sets the message code and message size for us.  It shouldn't be called
  // until *after* the event address is set.)
  setEventLength(0);

  // initialize the compression flag to zero
  setCompressionFlag(0);

  // initialize the filter unit process ID to zero
  setFUProcessId(0);

  // initialize the filter unit GUID to zero
  setFUGuid(0);

  // initialize the reserved word to zero
  setReserved(0);
}

---

Member Function Documentation

uint32 DQMEventMsgBuilder::bufferSize

(

)

const [inline]

Definition at line 54 of file DQMEventMsgBuilder.h.

References bufSize_.

{ return bufSize_; }

uint8* DQMEventMsgBuilder::eventAddress

(

)

const [inline]

Definition at line 61 of file DQMEventMsgBuilder.h.

References eventAddr_.

Referenced by StreamDQMOutputFile::write().

{ return eventAddr_; }

uint32 DQMEventMsgBuilder::headerSize

(

)

const [inline]

Definition at line 56 of file DQMEventMsgBuilder.h.

References buf_, and eventAddr_.

Referenced by setEventLength(), StreamDQMOutputFile::write(), and StreamDQMOutputFile::writeDQMEventHeader().

{ return eventAddr_-buf_; }

void DQMEventMsgBuilder::setCompressionFlag

(

uint32

value

)

Sets the value of the compression flag in the header.

Definition at line 157 of file DQMEventMsgBuilder.cc.

References buf_, DQMEventHeader::compressionFlag_, and convert().

Referenced by DQMEventMsgBuilder().

{
  DQMEventHeader* evtHdr = (DQMEventHeader*) buf_;
  convert(value, evtHdr->compressionFlag_);
}

void DQMEventMsgBuilder::setEventLength

(

uint32

len

)

Sets the length of the event (payload).

This method verifies that the buffer in which we are building the message is large enough and updates the size of the message taking into account the new event length.

Definition at line 140 of file DQMEventMsgBuilder.cc.

References buf_, bufSize_, convert(), Header::DQM_EVENT, eventAddr_, Exception, DQMEventHeader::header_, and headerSize().

Referenced by DQMEventMsgBuilder().

{
  if (((uint32) (eventAddr_ + len - buf_)) > bufSize_)
    {
      throw cms::Exception("MessageBuilding", "DQMEventMsgBuilder")
        << "Event data overflows buffer. Buffer size = " << bufSize_
        << ", header size = " << this->headerSize()
        << ", event size = " << len << ".\n";
    }
  convert(len, eventAddr_ - sizeof(char_uint32));
  DQMEventHeader* evtHdr = (DQMEventHeader*) buf_;
  new (&evtHdr->header_) Header(Header::DQM_EVENT, (eventAddr_ - buf_ + len));
}

void DQMEventMsgBuilder::setFUGuid

(

uint32

value

)

Sets the value of the filter unit GUID in the header.

Definition at line 175 of file DQMEventMsgBuilder.cc.

References buf_, convert(), and DQMEventHeader::fuGuid_.

Referenced by DQMEventMsgBuilder().

{
  DQMEventHeader* evtHdr = (DQMEventHeader*) buf_;
  convert(value, evtHdr->fuGuid_);
}

void DQMEventMsgBuilder::setFUProcessId

(

uint32

value

)

Sets the value of the filter unit process ID in the header.

Definition at line 166 of file DQMEventMsgBuilder.cc.

References buf_, convert(), and DQMEventHeader::fuProcessId_.

Referenced by DQMEventMsgBuilder().

{
  DQMEventHeader* evtHdr = (DQMEventHeader*) buf_;
  convert(value, evtHdr->fuProcessId_);
}

void DQMEventMsgBuilder::setReserved

(

uint32

value

)

Sets the value of the reserved word in the header.

Definition at line 184 of file DQMEventMsgBuilder.cc.

References buf_, convert(), and DQMEventHeader::reserved_.

Referenced by DQMEventMsgBuilder().

{
  DQMEventHeader* evtHdr = (DQMEventHeader*) buf_;
  convert(value, evtHdr->reserved_);
}

uint32 DQMEventMsgBuilder::size

(

void

)

const

Returns the size of the message.

Definition at line 193 of file DQMEventMsgBuilder.cc.

References buf_, HeaderView::size(), and v.

Referenced by StreamDQMOutputFile::write(), and FUShmDQMOutputService::writeShmDQMData().

{
  HeaderView v(buf_);
  return v.size();
}

uint8* DQMEventMsgBuilder::startAddress

(

)

const [inline]

Definition at line 55 of file DQMEventMsgBuilder.h.

References buf_.

Referenced by StreamDQMOutputFile::writeDQMEventHeader(), and FUShmDQMOutputService::writeShmDQMData().

{ return buf_; }

---

Member Data Documentation

uint8* DQMEventMsgBuilder::buf_ [private]

Definition at line 66 of file DQMEventMsgBuilder.h.

Referenced by DQMEventMsgBuilder(), headerSize(), setCompressionFlag(), setEventLength(), setFUGuid(), setFUProcessId(), setReserved(), size(), and startAddress().

uint32 DQMEventMsgBuilder::bufSize_ [private]

Definition at line 67 of file DQMEventMsgBuilder.h.

Referenced by bufferSize(), DQMEventMsgBuilder(), and setEventLength().

uint8* DQMEventMsgBuilder::eventAddr_ [private]

Definition at line 68 of file DQMEventMsgBuilder.h.

Referenced by DQMEventMsgBuilder(), eventAddress(), headerSize(), and setEventLength().

---

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

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

---