EventMessage.h

Go to the documentation of this file.

#ifndef IOPool_Streamer_EventMessage_h
#define IOPool_Streamer_EventMessage_h

#include "IOPool/Streamer/interface/MsgTools.h"
#include "IOPool/Streamer/interface/MsgHeader.h"
namespace edm::streamer {
  // ----------------------- event message ------------------------

  struct EventHeader {
    Header header_;
    uint8 protocolVersion_;
    char_uint32 run_;
    char_uint64 event_;
    char_uint32 lumi_;
    char_uint32 origDataSize_;
    char_uint32 outModId_;
    char_uint32 droppedEventsCount_;
  };

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

    uint32 code() const { return head_.code(); }
    uint32 size() const { return head_.size(); }

    const uint8* eventData() const { return event_start_; }
    uint8* startAddress() const { return buf_; }
    uint32 eventLength() const { return event_len_; }
    uint32 headerSize() const { return event_start_ - buf_; }
    uint32 protocolVersion() const;
    uint32 run() const;
    uint64 event() const;
    uint32 lumi() const;
    uint32 origDataSize() const;
    uint32 outModId() const;
    uint32 droppedEventsCount() const;
    bool isEventMetaData() const;

    void l1TriggerBits(std::vector<bool>& put_here) const;
    void hltTriggerBits(uint8* put_here) const;

    uint32 hltCount() const { return hlt_bits_count_; }
    uint32 l1Count() const { return l1_bits_count_; }
    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* hlt_bits_start_;
    uint32 hlt_bits_count_;
    uint8* l1_bits_start_;
    uint32 l1_bits_count_;
    uint8* event_start_;
    uint32 event_len_;
    uint32 adler32_chksum_;
    uint8* host_name_start_;
    uint32 host_name_len_;
    bool v2Detected_;
  };
}  // namespace edm::streamer
#endif