Streamer/src/InitMsgBuilder.cc

0001 #include "IOPool/Streamer/interface/InitMsgBuilder.h"
0002 #include "IOPool/Streamer/interface/EventMsgBuilder.h"
0003 #include "IOPool/Streamer/interface/MsgHeader.h"
0004 #include <cassert>
0005 #include <cstring>
0006 #include <cstdint>
0007 #include <unistd.h>
0008
0009 using namespace edm::streamer;
0010
0011 InitMsgBuilder::InitMsgBuilder(void* buf,
0012                                uint32 size,
0013                                uint32 run,
0014                                const Version& v,
0015                                const char* release_tag,
0016                                const char* process_name,
0017                                const char* output_module_label,
0018                                uint32 output_module_id,
0019                                const Strings& hlt_names,
0020                                const Strings& hlt_selections,
0021                                const Strings& l1_names,
0022                                uint32 adler_chksum)
0023     : buf_((uint8*)buf), size_(size) {
0024   InitHeader* h = (InitHeader*)buf_;
0025   // fixed length parts
0026   new (&h->version_) Version(v);
0027   convert(run, h->run_);
0028   // variable length parts
0029   uint32 tag_len = strlen(release_tag);
0030   assert(tag_len < 0x00ff);
0031   uint8* pos = buf_ + sizeof(InitHeader);
0032
0033   *pos++ = tag_len;                   // length of release tag
0034   memcpy(pos, release_tag, tag_len);  // copy release tag in
0035   pos += tag_len;
0036
0037   //Lets put Process Name (Length and then Name) right after release_tag
0038   uint32 process_name_len = strlen(process_name);
0039   assert(process_name_len < 0x00ff);
0040   //Put process_name_len
0041   *pos++ = process_name_len;
0042   //Put process_name
0043   memcpy(pos, process_name, process_name_len);
0044   pos += process_name_len;
0045
0046   // output module label next
0047   uint32 outmod_label_len = strlen(output_module_label);
0048   assert(outmod_label_len < 0x00ff);
0049   *pos++ = outmod_label_len;
0050   memcpy(pos, output_module_label, outmod_label_len);
0051   pos += outmod_label_len;
0052
0053   // output module ID next
0054   convert(output_module_id, pos);
0055   pos += sizeof(char_uint32);
0056
0057   pos = MsgTools::fillNames(hlt_names, pos);
0058   pos = MsgTools::fillNames(hlt_selections, pos);
0059   pos = MsgTools::fillNames(l1_names, pos);
0060
0061   // adler32 check sum of data blob
0062   convert(adler_chksum, pos);
0063   pos = pos + sizeof(uint32);
0064
0065   data_addr_ = pos + sizeof(char_uint32);
0066   setDataLength(0);
0067
0068   // Two news fileds added to InitMsg in Proto V3 init_header_size, and event_header_size.
0069   //Set the size of Init Header Start of buf to Start of desc.
0070   convert((uint32)(data_addr_ - buf_), h->init_header_size_);
0071
0072   //Size of Event Header
0073   uint32 eventHeaderSize = EventMsgBuilder::computeHeaderSize(l1_names.size(), hlt_names.size());
0074   convert(eventHeaderSize, h->event_header_size_);
0075 }
0076
0077 void InitMsgBuilder::setDataLength(uint32 len) {
0078   convert(len, data_addr_ - sizeof(char_uint32));
0079   InitHeader* h = (InitHeader*)buf_;
0080   new (&h->header_) Header(Header::INIT, data_addr_ - buf_ + len);
0081 }
0082
0083 uint32 InitMsgBuilder::size() const {
0084   HeaderView v(buf_);
0085   return v.size();
0086 }
0087
0088 uint32 InitMsgBuilder::run() const {
0089   InitHeader* h = (InitHeader*)buf_;
0090   return convert32(h->run_);
0091 }