---

ConsRegRequestBuilder Class Reference

These classes are used to build and view the registration requests and replies that are exchanged between individual event consumers and the event server. More...

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

List of all members.

Public Member Functions
uint32	bufferSize () const
	ConsRegRequestBuilder (void *buf, uint32 bufSize, std::string const &consumerName, std::string const &consumerPriority, std::string const &requestParameterSet)
	These classes are used to build and view the registration requests and replies that are exchanged between individual event consumers and the event server.
uint32	size () const
	Returns the size of the consumer registration request.
uint8 *	startAddress ()
Private Attributes
uint8 *	buf_
uint32	bufSize_

---

Detailed Description

These classes are used to build and view the registration requests and replies that are exchanged between individual event consumers and the event server.

15-Aug-2006 - KAB - Initial Implementation

Definition at line 18 of file ConsRegMessage.h.

---

Constructor & Destructor Documentation

ConsRegRequestBuilder::ConsRegRequestBuilder	(	void *	buf,
		uint32	bufSize,
		std::string const &	consumerName,
		std::string const &	consumerPriority,
		std::string const &	requestParamSet
	)

These classes are used to build and view the registration requests and replies that are exchanged between individual event consumers and the event server.

15-Aug-2006 - KAB - Initial Implementation Constructor for the consumer registration request builder.

Definition at line 16 of file ConsRegMessage.cc.

References buf_, bufSize_, Header::CONS_REG_REQUEST, convert(), and len.

                                                                              :
  buf_((uint8*)buf),bufSize_(bufSize)
{
  uint8* bufPtr;
  uint32 len;

  // update the buffer pointer to just beyond the header
  bufPtr = buf_ + sizeof(Header);
  //std::cout << "bufPtr = 0x" << hex << ((uint32) bufPtr) << dec << std::endl;
  //std::cout << "buf_ = 0x" << hex << ((uint32) buf_) << dec << std::endl;
  //std::cout << "bufSize_ = " << bufSize_ << std::endl;
  assert(((uint32) (bufPtr - buf_)) <= bufSize_);

  // copy the consumer name into the message
  len = consumerName.length();
  assert(((uint32) (bufPtr + len + sizeof(uint32) - buf_)) <= bufSize_);
  convert(len, bufPtr);
  bufPtr += sizeof(uint32);
  consumerName.copy((char *) bufPtr, len);
  bufPtr += len;

  // copy the consumer priority into the message
  len = consumerPriority.length();
  assert(((uint32) (bufPtr + len + sizeof(uint32) - buf_)) <= bufSize_);
  convert(len, bufPtr);
  bufPtr += sizeof(uint32);
  consumerPriority.copy((char *) bufPtr, len);
  bufPtr += len;

  // copy the request parameter set into the message
  len = requestParamSet.length();
  assert(((uint32) (bufPtr + len + sizeof(uint32) - buf_)) <= bufSize_);
  convert(len, bufPtr);
  bufPtr += sizeof(uint32);
  requestParamSet.copy((char *) bufPtr, len);
  bufPtr += len;

  // create the message header now that we now the full size
  //std::cout << "bufPtr = 0x" << hex << ((uint32) bufPtr) << dec << std::endl;
  //std::cout << "buf_ = 0x" << hex << ((uint32) buf_) << dec << std::endl;
  new (buf_) Header(Header::CONS_REG_REQUEST, (bufPtr - buf_));
}

---

Member Function Documentation

uint32 ConsRegRequestBuilder::bufferSize

(

)

const [inline]

Definition at line 26 of file ConsRegMessage.h.

References bufSize_.

{ return bufSize_; }

uint32 ConsRegRequestBuilder::size

(

void

)

const

Returns the size of the consumer registration request.

Definition at line 65 of file ConsRegMessage.cc.

References buf_, and HeaderView::size().

Referenced by edm::DQMHttpSource::registerWithDQMEventServer(), stor::DataProcessManager::registerWithDQMSM(), edm::EventStreamHttpReader::registerWithEventServer(), edm::OnlineHttpReader::registerWithEventServer(), and stor::DataProcessManager::registerWithSM().

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

uint8* ConsRegRequestBuilder::startAddress

(

)

[inline]

Definition at line 27 of file ConsRegMessage.h.

References buf_.

Referenced by edm::DQMHttpSource::registerWithDQMEventServer(), stor::DataProcessManager::registerWithDQMSM(), edm::EventStreamHttpReader::registerWithEventServer(), edm::OnlineHttpReader::registerWithEventServer(), and stor::DataProcessManager::registerWithSM().

{ return buf_; }

---

Member Data Documentation

uint8* ConsRegRequestBuilder::buf_ [private]

Definition at line 31 of file ConsRegMessage.h.

Referenced by ConsRegRequestBuilder(), size(), and startAddress().

uint32 ConsRegRequestBuilder::bufSize_ [private]

Definition at line 32 of file ConsRegMessage.h.

Referenced by bufferSize(), and ConsRegRequestBuilder().

---

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

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

---