InitMessage.h

Go to the documentation of this file.

#ifndef IOPool_Streamer_InitMessage_h
#define IOPool_Streamer_InitMessage_h

#include "IOPool/Streamer/interface/MsgTools.h"
#include "IOPool/Streamer/interface/MsgHeader.h"

namespace edm::streamer {
  struct Version {
    Version(const uint8* pset) : protocol_(11) { std::copy(pset, pset + sizeof(pset_id_), &pset_id_[0]); }

    uint8 protocol_;             // version of the protocol
    unsigned char pset_id_[16];  // parameter set ID
  };

  struct InitHeader {
    InitHeader(const Header& h, uint32 run, const Version& v, uint32 init_header_size = 0, uint32 event_header_size = 0)
        : header_(h), version_(v) {
      convert(run, run_);
      convert(init_header_size, init_header_size_);
      convert(event_header_size, event_header_size_);
    }

    Header header_;
    Version version_;
    char_uint32 run_;
    char_uint32 init_header_size_;
    char_uint32 event_header_size_;
  };

  class InitMsgView {
  public:
    InitMsgView(void* buf);

    uint32 code() const { return head_.code(); }
    uint32 size() const { return head_.size(); }
    uint8* startAddress() const { return buf_; }

    uint32 run() const;
    uint32 protocolVersion() const;
    void pset(uint8* put_here) const;
    std::string releaseTag() const;
    std::string processName() const;
    std::string outputModuleLabel() const;
    uint32 outputModuleId() const { return outputModuleId_; }

    void hltTriggerNames(Strings& save_here) const;
    void hltTriggerSelections(Strings& save_here) const;
    void l1TriggerNames(Strings& save_here) const;

    uint32 get_hlt_bit_cnt() const { return hlt_trig_count_; }
    uint32 get_l1_bit_cnt() const { return l1_trig_count_; }

    // needed for streamer file
    uint32 descLength() const { return desc_len_; }
    const uint8* descData() const { return desc_start_; }
    uint32 headerSize() const { return desc_start_ - buf_; }
    uint32 eventHeaderSize() const;
    uint32 adler32_chksum() const { return adler32_chksum_; }
    std::string hostName() const;
    uint32 hostName_len() const { return host_name_len_; }

  private:
    uint8* buf_;
    HeaderView head_;

    uint8* release_start_;  // points to the string
    uint32 release_len_;

    uint8* processName_start_;  // points to the string
    uint32 processName_len_;

    uint8* outputModuleLabel_start_;  // points to the string
    uint32 outputModuleLabel_len_;
    uint32 outputModuleId_;

    uint8* hlt_trig_start_;    // points to the string
    uint32 hlt_trig_count_;    // number of strings
    uint32 hlt_trig_len_;      // length of strings character array only
    uint8* hlt_select_start_;  // points to the string
    uint32 hlt_select_count_;  // number of strings
    uint32 hlt_select_len_;    // length of strings character array only
    uint8* l1_trig_start_;     // points to the string
    uint32 l1_trig_count_;     // number of strings
    uint32 l1_trig_len_;       // length of strings character array only
    uint32 adler32_chksum_;
    uint8* host_name_start_;
    uint32 host_name_len_;

    // does not need to be present in the message sent over the network,
    // but is needed for the index file
    uint8* desc_start_;  // point to the bytes
    uint32 desc_len_;
  };
}  // namespace edm::streamer
#endif