EventMsgBuilder Class Reference

#include <EventMsgBuilder.h>

Public Member Functions
uint32	bufferSize () const
uint8 *	eventAddr () const
	EventMsgBuilder (void *buf, uint32 size, uint32 run, uint64 event, uint32 lumi, uint32 outModId, uint32 droppedEventsCount, std::vector< bool > &l1_bits, uint8 *hlt_bits, uint32 hlt_bit_count, uint32 adler32_chksum, const char *host_name)
uint32	headerSize () const
void	setBufAddr (uint8 *buf_addr)
void	setEventAddr (uint8 *event_addr)
void	setEventLength (uint32 len)
void	setOrigDataSize (uint32)
uint32	size () const
uint8 *	startAddress () const

Private Attributes
uint8 *	buf_
uint8 *	event_addr_
uint32	size_

Detailed Description

Definition at line 8 of file EventMsgBuilder.h.

Constructor & Destructor Documentation

EventMsgBuilder()

EventMsgBuilder::EventMsgBuilder	(	void *	buf,
		uint32	size,
		uint32	run,
		uint64	event,
		uint32	lumi,
		uint32	outModId,
		uint32	droppedEventsCount,
		std::vector< bool > &	l1_bits,
		uint8 *	hlt_bits,
		uint32	hlt_bit_count,
		uint32	adler32_chksum,
		const char *	host_name
	)

Definition at line 9 of file EventMsgBuilder.cc.

    : buf_((uint8*)buf), size_(size) {
  EventHeader* h = (EventHeader*)buf_;
  h->protocolVersion_ = 11;
  convert(run, h->run_);
  convert(event, h->event_);
  convert(lumi, h->lumi_);
  convert(outModId, h->outModId_);
  convert(droppedEventsCount, h->droppedEventsCount_);
  uint8* pos = buf_ + sizeof(EventHeader);
 
  // l1 count
  uint32 l1_count = l1_bits.size();
  convert(l1_count, pos);
  pos = pos + sizeof(uint32);
 
  // set the l1
  uint32 l1_sz = l1_bits.size();
  if (l1_sz != 0)
    l1_sz = 1 + ((l1_sz - 1) / 8);
 
  uint8* pos_end = pos + l1_sz;
  memset(pos, 0x00, pos_end - pos);  // clear the bits
  for (std::vector<bool>::size_type i = 0; i < l1_bits.size(); ++i) {
    uint8 v = l1_bits[i] ? 1 : 0;
    pos[i / 8] |= (v << (i & 0x07));
  }
  pos = pos_end;
 
  // hlt count
  convert(hlt_bit_count, pos);
  pos = pos + sizeof(uint32);
 
  uint32 hlt_sz = hlt_bit_count;
  if (hlt_sz != 0)
    hlt_sz = 1 + ((hlt_sz - 1) / 4);
 
  // copy the hlt bits over
  pos = std::copy(hlt_bits, hlt_bits + hlt_sz, pos);
 
  // adler32 check sum of data blob
  convert(adler_chksum, pos);
  pos = pos + sizeof(uint32);
 
  // put host name (Length and then Name) right after check sum
  //uint32 host_name_len = strlen(host_name);
  // actually make the host_name a fixed length as the event header size appears in the
  // Init message and only one goes to a file whereas events can come from any node
  // We want the max length to be determined inside this Event Message Builder
  uint32 host_name_len = MAX_HOSTNAME_LEN;
  assert(host_name_len < 0x00ff);
  //Put host_name_len
  *pos++ = host_name_len;
 
  //Put host_name
  uint32 real_len = strlen(host_name);
  if (real_len < host_name_len) {
    char hostname_2use[MAX_HOSTNAME_LEN];
    memset(hostname_2use, '\0', host_name_len);
    memcpy(hostname_2use, host_name, real_len);
    memcpy(pos, hostname_2use, host_name_len);
  } else {
    memcpy(pos, host_name, host_name_len);
  }
  pos += host_name_len;
 
  event_addr_ = pos + sizeof(char_uint32);
  setEventLength(0);
}

References cms::cuda::assert(), buf_, fileCollector::convert(), filterCSVwithJSON::copy, event_addr_, mps_fire::i, MAX_HOSTNAME_LEN, writedatasetfile::run, setEventLength(), and findQualityFiles::v.

Member Function Documentation

bufferSize()

uint32 EventMsgBuilder::bufferSize ( ) const

inline

Definition at line 31 of file EventMsgBuilder.h.

{ return size_; }

References size_.

eventAddr()

uint8* EventMsgBuilder::eventAddr ( ) const

inline

Definition at line 28 of file EventMsgBuilder.h.

{ return event_addr_; }

References event_addr_.

headerSize()

uint32 EventMsgBuilder::headerSize ( ) const

inline

Definition at line 29 of file EventMsgBuilder.h.

{ return event_addr_ - buf_; }

References buf_, and event_addr_.

Referenced by InitMsgBuilder::InitMsgBuilder().

setBufAddr()

void EventMsgBuilder::setBufAddr ( uint8 *  buf_addr )

inline

Definition at line 26 of file EventMsgBuilder.h.

{ buf_ = buf_addr; }

References buf_.

setEventAddr()

void EventMsgBuilder::setEventAddr ( uint8 *  event_addr )

inline

Definition at line 27 of file EventMsgBuilder.h.

{ event_addr_ = event_addr; }

References event_addr_.

setEventLength()

void EventMsgBuilder::setEventLength

(

uint32

len

)

Definition at line 95 of file EventMsgBuilder.cc.

                                               {
  convert(len, event_addr_ - sizeof(char_uint32));
  EventHeader* h = (EventHeader*)buf_;
  new (&h->header_) Header(Header::EVENT, event_addr_ - buf_ + len);
}

References buf_, fileCollector::convert(), Header::EVENT, and event_addr_.

Referenced by EventMsgBuilder().

setOrigDataSize()

void EventMsgBuilder::setOrigDataSize

(

uint32

value

)

Definition at line 90 of file EventMsgBuilder.cc.

                                                  {
  EventHeader* h = (EventHeader*)buf_;
  convert(value, h->origDataSize_);
}

References buf_, and fileCollector::convert().

size()

uint32 EventMsgBuilder::size

(

void

)

const

Definition at line 101 of file EventMsgBuilder.cc.

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

References buf_, and findQualityFiles::v.

Referenced by ntupleDataFormat._Collection::__iter__(), and ntupleDataFormat._Collection::__len__().

startAddress()

uint8* EventMsgBuilder::startAddress ( ) const

inline

Definition at line 24 of file EventMsgBuilder.h.

{ return buf_; }

References buf_.

Referenced by StreamerOutputFile::write().

Member Data Documentation

buf_

uint8* EventMsgBuilder::buf_

private

Definition at line 34 of file EventMsgBuilder.h.

Referenced by EventMsgBuilder(), headerSize(), setBufAddr(), setEventLength(), setOrigDataSize(), size(), and startAddress().

event_addr_

uint8* EventMsgBuilder::event_addr_

private

Definition at line 36 of file EventMsgBuilder.h.

Referenced by eventAddr(), EventMsgBuilder(), headerSize(), setEventAddr(), and setEventLength().

size_

uint32 EventMsgBuilder::size_

private

Definition at line 35 of file EventMsgBuilder.h.

Referenced by bufferSize().