#include <InitMessage.h>

Public Member Functions
uint32	adler32_chksum () const

uint32	code () const

const uint8 *	descData () const

uint32	descLength () const

uint32	eventHeaderSize () const

uint32	get_hlt_bit_cnt () const

uint32	get_l1_bit_cnt () const

uint32	headerSize () const

void	hltTriggerNames (Strings &save_here) const

void	hltTriggerSelections (Strings &save_here) const

std::string	hostName () const

uint32	hostName_len () const

	InitMsgView (void *buf)

void	l1TriggerNames (Strings &save_here) const

uint32	outputModuleId () const

std::string	outputModuleLabel () const

std::string	processName () const

uint32	protocolVersion () const

void	pset (uint8 *put_here) const

std::string	releaseTag () const

uint32	run () const

uint32	size () const

uint8 *	startAddress () const

Detailed Description

Definition at line 62 of file InitMessage.h.

Constructor & Destructor Documentation

◆ InitMsgView()

InitMsgView::InitMsgView ( void * buf )

Definition at line 9 of file InitMessage.cc.

References adler32_chksum_, buf_, edm::streamer::convert32(), gather_cfg::cout, desc_len_, desc_start_, hlt_select_count_, hlt_select_len_, hlt_select_start_, hlt_trig_count_, hlt_trig_len_, hlt_trig_start_, host_name_len_, host_name_start_, l1_trig_count_, l1_trig_len_, l1_trig_start_, outputModuleId_, outputModuleLabel_len_, outputModuleLabel_start_, processName_len_, processName_start_, protocolVersion(), release_len_, and release_start_.

     : buf_((uint8*)buf),
       head_(buf),
       release_start_(nullptr),
       release_len_(0),
       processName_start_(nullptr),
       processName_len_(0),
       outputModuleLabel_start_(nullptr),
       outputModuleLabel_len_(0),
       outputModuleId_(0),
       hlt_trig_start_(nullptr),
       hlt_trig_count_(0),
       hlt_trig_len_(0),
       hlt_select_start_(nullptr),
       hlt_select_count_(0),
       hlt_select_len_(0),
       l1_trig_start_(nullptr),
       l1_trig_count_(0),
       l1_trig_len_(0),
       adler32_chksum_(0),
       host_name_start_(nullptr),
       host_name_len_(0),
       desc_start_(nullptr),
       desc_len_(0) {
   if (protocolVersion() == 2) {
     std::cout << "Protocol Version 2 encountered" << std::endl;
     release_start_ = buf_ + sizeof(InitHeader) - (sizeof(uint32) * 2);
     // Minus the size for Init and Event Header size fileds
     // in the InitHeader
   } else {  //For version 3
     release_start_ = buf_ + sizeof(InitHeader);
   }
   release_len_ = *release_start_;
   release_start_ += sizeof(uint8);
   uint8* pos = release_start_ + release_len_;
 
   //Lets get Process Name from right after Release Name
   if (protocolVersion() > 3) {
     //std::cout << "Protocol Version > 3 encountered" << std::endl;
     processName_len_ = *pos;
     processName_start_ = (uint8*)(pos + sizeof(uint8));
     pos = processName_start_ + processName_len_;
 
     // Output Module Label
     if (protocolVersion() > 4) {
       outputModuleLabel_len_ = *pos;
       outputModuleLabel_start_ = (uint8*)(pos + sizeof(uint8));
       pos = outputModuleLabel_start_ + outputModuleLabel_len_;
 
       // Output Module Id
       if (protocolVersion() > 5) {
         outputModuleId_ = convert32(pos);
         pos += sizeof(char_uint32);
       }
     }
   }
 
   hlt_trig_start_ = pos;
   hlt_trig_count_ = convert32(hlt_trig_start_);
   hlt_trig_start_ += sizeof(char_uint32);
   hlt_trig_len_ = convert32(hlt_trig_start_);
   hlt_trig_start_ += sizeof(char_uint32);
   pos = hlt_trig_start_ + hlt_trig_len_;
 
   if (protocolVersion() > 4) {
     hlt_select_start_ = pos;
     hlt_select_count_ = convert32(hlt_select_start_);
     hlt_select_start_ += sizeof(char_uint32);
     hlt_select_len_ = convert32(hlt_select_start_);
     hlt_select_start_ += sizeof(char_uint32);
     pos = hlt_select_start_ + hlt_select_len_;
   }
 
   l1_trig_start_ = pos;
   l1_trig_count_ = convert32(l1_trig_start_);
   l1_trig_start_ += sizeof(char_uint32);
   l1_trig_len_ = convert32(l1_trig_start_);
   l1_trig_start_ += sizeof(char_uint32);
   pos = l1_trig_start_ + l1_trig_len_;
 
   if (protocolVersion() > 7) {
     adler32_chksum_ = convert32(pos);
     pos += sizeof(uint32);
 
     if (protocolVersion() <= 9) {
       host_name_start_ = pos;
       host_name_len_ = *host_name_start_;
       host_name_start_ += sizeof(uint8);
       pos = host_name_start_ + host_name_len_;
     }
   }
 
   desc_start_ = pos;
   desc_len_ = convert32(desc_start_);
   desc_start_ += sizeof(char_uint32);
 }

Member Function Documentation

◆ adler32_chksum()

uint32 edm::streamer::InitMsgView::adler32_chksum ( ) const

inline

Definition at line 90 of file InitMessage.h.

References adler32_chksum_.

Referenced by edm::streamer::StreamerInputSource::deserializeRegistry().

90 { return adler32_chksum_; }

edm::streamer::InitMsgView::adler32_chksum_

uint32 adler32_chksum_

Definition: InitMessage.h:117

◆ code()

uint32 edm::streamer::InitMsgView::code ( ) const

inline

Definition at line 66 of file InitMessage.h.

References edm::streamer::HeaderView::code(), and head_.

Referenced by edm::streamer::StreamerInputSource::deserializeRegistry().

66 { return head_.code(); }

edm::streamer::InitMsgView::head_

HeaderView head_

Definition: InitMessage.h:96

edm::streamer::HeaderView::code

uint32 code() const

Definition: MsgHeader.h:45

◆ descData()

const uint8* edm::streamer::InitMsgView::descData ( ) const

inline

Definition at line 87 of file InitMessage.h.

References desc_start_.

Referenced by edm::streamer::StreamerInputSource::deserializeRegistry(), and edm::streamer::StreamerOutputFile::write().

87 { return desc_start_; }

edm::streamer::InitMsgView::desc_start_

uint8 * desc_start_

Definition: InitMessage.h:123

◆ descLength()

uint32 edm::streamer::InitMsgView::descLength ( ) const

inline

Definition at line 86 of file InitMessage.h.

References desc_len_.

Referenced by edm::streamer::StreamerInputSource::deserializeRegistry().

86 { return desc_len_; }

edm::streamer::InitMsgView::desc_len_

uint32 desc_len_

Definition: InitMessage.h:124

◆ eventHeaderSize()

uint32 InitMsgView::eventHeaderSize ( ) const

This is estimated size of event header for Protocol Version 2.

Definition at line 160 of file InitMessage.cc.

References buf_, edm::streamer::convert32(), get_hlt_bit_cnt(), get_l1_bit_cnt(), h, and protocolVersion().

                                           {
   if (protocolVersion() == 2) {
     uint32 hlt_sz = get_hlt_bit_cnt();
     if (hlt_sz != 0)
       hlt_sz = 1 + ((hlt_sz - 1) / 4);
 
     uint32 l1_sz = get_l1_bit_cnt();
     if (l1_sz != 0)
       l1_sz = 1 + ((l1_sz - 1) / 8);
 
     return 1 + (4 * 8) + hlt_sz + l1_sz;
   }
 
   InitHeader* h = reinterpret_cast<InitHeader*>(buf_);
   return convert32(h->event_header_size_);
 }

◆ get_hlt_bit_cnt()

uint32 edm::streamer::InitMsgView::get_hlt_bit_cnt ( ) const

inline

Definition at line 82 of file InitMessage.h.

References hlt_trig_count_.

Referenced by eventHeaderSize().

82 { return hlt_trig_count_; }

edm::streamer::InitMsgView::hlt_trig_count_

uint32 hlt_trig_count_

Definition: InitMessage.h:109

◆ get_l1_bit_cnt()

uint32 edm::streamer::InitMsgView::get_l1_bit_cnt ( ) const

inline

Definition at line 83 of file InitMessage.h.

References l1_trig_count_.

Referenced by eventHeaderSize().

83 { return l1_trig_count_; }

edm::streamer::InitMsgView::l1_trig_count_

uint32 l1_trig_count_

Definition: InitMessage.h:115

◆ headerSize()

uint32 edm::streamer::InitMsgView::headerSize ( ) const

inline

Definition at line 88 of file InitMessage.h.

References buf_, and desc_start_.

Referenced by edm::streamer::StreamerOutputFile::write(), and edm::streamer::StreamerOutputFile::writeStart().

88 { return desc_start_ - buf_; }

edm::streamer::InitMsgView::desc_start_

uint8 * desc_start_

Definition: InitMessage.h:123

edm::streamer::InitMsgView::buf_

uint8 * buf_

Definition: InitMessage.h:95

◆ hltTriggerNames()

void InitMsgView::hltTriggerNames ( Strings & save_here ) const

Definition at line 143 of file InitMessage.cc.

References edm::streamer::MsgTools::getNames(), hlt_trig_len_, and hlt_trig_start_.

                                                           {
   MsgTools::getNames(hlt_trig_start_, hlt_trig_len_, save_here);
 }

◆ hltTriggerSelections()

void InitMsgView::hltTriggerSelections ( Strings & save_here ) const

Definition at line 147 of file InitMessage.cc.

References Exception, edm::streamer::MsgTools::getNames(), hlt_select_len_, hlt_select_start_, and protocolVersion().

                                                                {
   if (protocolVersion() < 5)
     throw cms::Exception("Invalid Message Version", "InitMsgView")
         << "HLT trigger selections are only supported in Protocol Version 5 and above"
         << ".\n";
 
   MsgTools::getNames(hlt_select_start_, hlt_select_len_, save_here);
 }

◆ hostName()

std::string InitMsgView::hostName ( ) const

Definition at line 186 of file InitMessage.cc.

References newFWLiteAna::found, host_name_len_, host_name_start_, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by edm::streamer::StreamerInputSource::deserializeRegistry().

                                       {
   if (host_name_start_) {
     std::string host_name(reinterpret_cast<char*>(host_name_start_), host_name_len_);
     size_t found = host_name.find('\0');
     if (found != std::string::npos) {
       return std::string(host_name, 0, found);
     } else {
       return host_name;
     }
   } else {
     return "n/a";
   }
 }

◆ hostName_len()

uint32 edm::streamer::InitMsgView::hostName_len ( ) const

inline

Definition at line 92 of file InitMessage.h.

References host_name_len_.

92 { return host_name_len_; }

edm::streamer::InitMsgView::host_name_len_

uint32 host_name_len_

Definition: InitMessage.h:119

◆ l1TriggerNames()

void InitMsgView::l1TriggerNames ( Strings & save_here ) const

Definition at line 156 of file InitMessage.cc.

References edm::streamer::MsgTools::getNames(), l1_trig_len_, and l1_trig_start_.

                                                          {
   MsgTools::getNames(l1_trig_start_, l1_trig_len_, save_here);
 }

◆ outputModuleId()

uint32 edm::streamer::InitMsgView::outputModuleId ( ) const

inline

Definition at line 76 of file InitMessage.h.

References outputModuleId_.

76 { return outputModuleId_; }

edm::streamer::InitMsgView::outputModuleId_

uint32 outputModuleId_

Definition: InitMessage.h:106

◆ outputModuleLabel()

std::string InitMsgView::outputModuleLabel ( ) const

Definition at line 134 of file InitMessage.cc.

References Exception, outputModuleLabel_len_, outputModuleLabel_start_, protocolVersion(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                {
   if (protocolVersion() < 5)
     throw cms::Exception("Invalid Message Version", "InitMsgView")
         << "Output Module Label is only supported in Protocol Version 5 and above"
         << ".\n";
 
   return std::string(reinterpret_cast<char*>(outputModuleLabel_start_), outputModuleLabel_len_);
 }

◆ processName()

std::string InitMsgView::processName ( ) const

Definition at line 125 of file InitMessage.cc.

References Exception, processName_len_, processName_start_, protocolVersion(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by edm::streamer::StreamerInputSource::deserializeRegistry().

                                          {
   if (protocolVersion() < 4)
     throw cms::Exception("Invalid Message Version", "InitMsgView")
         << "Process Name is only supported in Protocol Version 4 and above"
         << ".\n";
 
   return std::string(reinterpret_cast<char*>(processName_start_), processName_len_);
 }

◆ protocolVersion()

uint32 InitMsgView::protocolVersion ( ) const

Definition at line 111 of file InitMessage.cc.

References buf_, and h.

Referenced by edm::streamer::StreamerInputSource::deserializeRegistry(), eventHeaderSize(), hltTriggerSelections(), InitMsgView(), outputModuleLabel(), and processName().

                                           {
   InitHeader* h = reinterpret_cast<InitHeader*>(buf_);
   return h->version_.protocol_;
 }

◆ pset()

void InitMsgView::pset ( uint8 * put_here ) const

Definition at line 116 of file InitMessage.cc.

References buf_, and h.

                                             {
   InitHeader* h = reinterpret_cast<InitHeader*>(buf_);
   memcpy(put_here, h->version_.pset_id_, sizeof(h->version_.pset_id_));
 }

◆ releaseTag()

std::string InitMsgView::releaseTag ( ) const

Definition at line 121 of file InitMessage.cc.

References release_len_, release_start_, and AlCaHLTBitMon_QueryRunRegistry::string.

                                         {
   return std::string(reinterpret_cast<char*>(release_start_), release_len_);
 }

◆ run()

uint32 InitMsgView::run ( ) const

Definition at line 106 of file InitMessage.cc.

References buf_, edm::streamer::convert32(), and h.

                               {
   InitHeader* h = reinterpret_cast<InitHeader*>(buf_);
   return convert32(h->run_);
 }

◆ size()

uint32 edm::streamer::InitMsgView::size ( void ) const

inline

Definition at line 67 of file InitMessage.h.

References head_, and edm::streamer::HeaderView::size().

Referenced by ntupleDataFormat._Collection::__iter__(), ntupleDataFormat._Collection::__len__(), and edm::streamer::StreamerOutputFile::write().

67 { return head_.size(); }

edm::streamer::InitMsgView::head_

HeaderView head_

Definition: InitMessage.h:96

edm::streamer::HeaderView::size

uint32 size() const

Definition: MsgHeader.h:46

◆ startAddress()

uint8* edm::streamer::InitMsgView::startAddress ( ) const

inline

Definition at line 68 of file InitMessage.h.

References buf_.

Referenced by edm::streamer::StreamerOutputFile::writeStart().

68 { return buf_; }

edm::streamer::InitMsgView::buf_

uint8 * buf_

Definition: InitMessage.h:95

Member Data Documentation

◆ adler32_chksum_

uint32 edm::streamer::InitMsgView::adler32_chksum_

private

Definition at line 117 of file InitMessage.h.

Referenced by adler32_chksum(), and InitMsgView().

◆ buf_

uint8* edm::streamer::InitMsgView::buf_

private

Definition at line 95 of file InitMessage.h.

Referenced by eventHeaderSize(), headerSize(), InitMsgView(), protocolVersion(), pset(), run(), and startAddress().

◆ desc_len_

uint32 edm::streamer::InitMsgView::desc_len_

private

Definition at line 124 of file InitMessage.h.

Referenced by descLength(), and InitMsgView().

◆ desc_start_

uint8* edm::streamer::InitMsgView::desc_start_

private

Definition at line 123 of file InitMessage.h.

Referenced by descData(), headerSize(), and InitMsgView().

◆ head_

HeaderView edm::streamer::InitMsgView::head_

private

Definition at line 96 of file InitMessage.h.

Referenced by code(), and size().

◆ hlt_select_count_

uint32 edm::streamer::InitMsgView::hlt_select_count_

private

Definition at line 112 of file InitMessage.h.

Referenced by InitMsgView().

◆ hlt_select_len_

uint32 edm::streamer::InitMsgView::hlt_select_len_

private

Definition at line 113 of file InitMessage.h.

Referenced by hltTriggerSelections(), and InitMsgView().

◆ hlt_select_start_

uint8* edm::streamer::InitMsgView::hlt_select_start_

private

Definition at line 111 of file InitMessage.h.

Referenced by hltTriggerSelections(), and InitMsgView().

◆ hlt_trig_count_

uint32 edm::streamer::InitMsgView::hlt_trig_count_

private

Definition at line 109 of file InitMessage.h.

Referenced by get_hlt_bit_cnt(), and InitMsgView().

◆ hlt_trig_len_

uint32 edm::streamer::InitMsgView::hlt_trig_len_

private

Definition at line 110 of file InitMessage.h.

Referenced by hltTriggerNames(), and InitMsgView().

◆ hlt_trig_start_

uint8* edm::streamer::InitMsgView::hlt_trig_start_

private

Definition at line 108 of file InitMessage.h.

Referenced by hltTriggerNames(), and InitMsgView().

◆ host_name_len_

uint32 edm::streamer::InitMsgView::host_name_len_

private

Definition at line 119 of file InitMessage.h.

Referenced by hostName(), hostName_len(), and InitMsgView().

◆ host_name_start_

uint8* edm::streamer::InitMsgView::host_name_start_

private

Definition at line 118 of file InitMessage.h.

Referenced by hostName(), and InitMsgView().

◆ l1_trig_count_

uint32 edm::streamer::InitMsgView::l1_trig_count_

private

Definition at line 115 of file InitMessage.h.

Referenced by get_l1_bit_cnt(), and InitMsgView().

◆ l1_trig_len_

uint32 edm::streamer::InitMsgView::l1_trig_len_

private

Definition at line 116 of file InitMessage.h.

Referenced by InitMsgView(), and l1TriggerNames().

◆ l1_trig_start_

uint8* edm::streamer::InitMsgView::l1_trig_start_

private

Definition at line 114 of file InitMessage.h.

Referenced by InitMsgView(), and l1TriggerNames().

◆ outputModuleId_

uint32 edm::streamer::InitMsgView::outputModuleId_

private

Definition at line 106 of file InitMessage.h.

Referenced by InitMsgView(), and outputModuleId().

◆ outputModuleLabel_len_

uint32 edm::streamer::InitMsgView::outputModuleLabel_len_

private

Definition at line 105 of file InitMessage.h.

Referenced by InitMsgView(), and outputModuleLabel().

◆ outputModuleLabel_start_

uint8* edm::streamer::InitMsgView::outputModuleLabel_start_

private

Definition at line 104 of file InitMessage.h.

Referenced by InitMsgView(), and outputModuleLabel().

◆ processName_len_

uint32 edm::streamer::InitMsgView::processName_len_

private

Definition at line 102 of file InitMessage.h.

Referenced by InitMsgView(), and processName().

◆ processName_start_

uint8* edm::streamer::InitMsgView::processName_start_

private

Definition at line 101 of file InitMessage.h.

Referenced by InitMsgView(), and processName().

◆ release_len_

uint32 edm::streamer::InitMsgView::release_len_

private

Definition at line 99 of file InitMessage.h.

Referenced by InitMsgView(), and releaseTag().

◆ release_start_

uint8* edm::streamer::InitMsgView::release_start_

private

Definition at line 98 of file InitMessage.h.

Referenced by InitMsgView(), and releaseTag().

Private Attributes
uint32	adler32_chksum_

uint8 *	buf_

uint32	desc_len_

uint8 *	desc_start_

HeaderView	head_

uint32	hlt_select_count_

uint32	hlt_select_len_

uint8 *	hlt_select_start_

uint32	hlt_trig_count_

uint32	hlt_trig_len_

uint8 *	hlt_trig_start_

uint32	host_name_len_

uint8 *	host_name_start_

uint32	l1_trig_count_

uint32	l1_trig_len_

uint8 *	l1_trig_start_

uint32	outputModuleId_

uint32	outputModuleLabel_len_

uint8 *	outputModuleLabel_start_

uint32	processName_len_

uint8 *	processName_start_

uint32	release_len_

uint8 *	release_start_

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ InitMsgView()

Member Function Documentation

◆ adler32_chksum()

◆ code()

◆ descData()

◆ descLength()

◆ eventHeaderSize()

◆ get_hlt_bit_cnt()

◆ get_l1_bit_cnt()

◆ headerSize()

◆ hltTriggerNames()

◆ hltTriggerSelections()

◆ hostName()

◆ hostName_len()

◆ l1TriggerNames()

◆ outputModuleId()

◆ outputModuleLabel()

◆ processName()

◆ protocolVersion()

◆ pset()

◆ releaseTag()

◆ run()

◆ size()

◆ startAddress()

Member Data Documentation

◆ adler32_chksum_

◆ buf_

◆ desc_len_

◆ desc_start_

◆ head_

◆ hlt_select_count_

◆ hlt_select_len_

◆ hlt_select_start_

◆ hlt_trig_count_

◆ hlt_trig_len_

◆ hlt_trig_start_

◆ host_name_len_

◆ host_name_start_

◆ l1_trig_count_

◆ l1_trig_len_

◆ l1_trig_start_

◆ outputModuleId_

◆ outputModuleLabel_len_

◆ outputModuleLabel_start_

◆ processName_len_

◆ processName_start_

◆ release_len_

◆ release_start_