WriteEvent Class Reference

Collaboration diagram for WriteEvent:

Public Types
enum class	Status { OK =0 , NOT_OK =1 }

Public Member Functions
	WriteEvent (const Event &readEvent)
Status	status () const
const std::unique_ptr< uint32_t[]> &	blob () const
const eformat::write::FullEventFragment &	frag () const
uint32_t	size () const

Private Attributes
Status	m_status {Status::NOT_OK}
std::unique_ptr< uint32_t[]>	m_blob
eformat::write::FullEventFragment	m_frag
std::vector< eformat::write::ROBFragment >	m_robs
std::vector< std::unique_ptr< uint32_t[]> >	m_robBlobs
uint32_t	m_size {0}

Detailed Description

Definition at line 50 of file trigbs_orderedMerge.cxx.

Member Enumeration Documentation

Status

enum class WriteEvent::Status

strong

Enumerator
OK
NOT_OK

Definition at line 52 of file trigbs_orderedMerge.cxx.

{OK=0, NOT_OK=1};

Constructor & Destructor Documentation

WriteEvent()

WriteEvent::WriteEvent ( const Event & readEvent )

inlineexplicit

Definition at line 63 of file trigbs_orderedMerge.cxx.

                                              {
    m_frag.status(readEvent.frag.nstatus(), readEvent.frag.status());
    m_frag.run_type(readEvent.frag.run_type());
    m_frag.run_no(readEvent.frag.run_no());
    m_frag.global_id(readEvent.frag.global_id());
    m_frag.lumi_block(readEvent.frag.lumi_block());
    m_frag.bc_id(readEvent.frag.bc_id());
    m_frag.bc_time_seconds(readEvent.frag.bc_time_seconds());
    m_frag.bc_time_nanoseconds(readEvent.frag.bc_time_nanoseconds());
    m_frag.lvl1_id(readEvent.frag.lvl1_id());
    m_frag.lvl1_trigger_type(readEvent.frag.lvl1_trigger_type());
    m_frag.lvl1_trigger_info(readEvent.frag.nlvl1_trigger_info(), readEvent.frag.lvl1_trigger_info());
    m_frag.hlt_info(readEvent.frag.nhlt_info(), readEvent.frag.hlt_info());
    m_frag.stream_tag(readEvent.frag.nstream_tag(), readEvent.frag.stream_tag());
    m_frag.compression_type(eformat::Compression::UNCOMPRESSED);
    m_frag.compression_level(0);
    std::vector<eformat::read::ROBFragment> readRobs;
    readEvent.frag.robs(readRobs);
    m_robs.reserve(readRobs.size());
    for (const eformat::read::ROBFragment& rob : readRobs) {
      m_robs.emplace_back(rob.start());
      const eformat::write::node_t* top = m_robs.back().bind();
      const uint32_t writeSize = m_robs.back().size_word();
      m_robBlobs.push_back(std::make_unique<uint32_t[]>(writeSize));
      const uint32_t writtenSize = eformat::write::copy(*top, m_robBlobs.back().get(), writeSize);
      if (writtenSize != writeSize) {
        std::cerr << "Error in ROB serialisation, copied " << writtenSize << " instead of " << writeSize
                  << " words, skipping ROB" << std::endl;
        m_status = Status::NOT_OK;
        continue;
      }
      m_frag.append_unchecked(m_robBlobs.back().get());
    }
 
    const eformat::write::node_t* top = m_frag.bind();
    m_size = m_frag.size_word();
    m_blob = std::make_unique<uint32_t[]>(m_size);
    const uint32_t writtenSize = eformat::write::copy(*top, m_blob.get(), m_size);
    if (writtenSize != m_size) {
      std::cerr << "Error in event serialisation, copied " << writtenSize << " instead of " << m_size << " words" << std::endl;
      m_status = Status::NOT_OK;
    }
 
    m_status = Status::OK;
  }

Member Function Documentation

blob()

const std::unique_ptr< uint32_t[]> & WriteEvent::blob ( ) const

inline

Definition at line 109 of file trigbs_orderedMerge.cxx.

{return m_blob;}

frag()

const eformat::write::FullEventFragment & WriteEvent::frag ( ) const

inline

Definition at line 110 of file trigbs_orderedMerge.cxx.

{return m_frag;}

size()

uint32_t WriteEvent::size ( ) const

inline

Definition at line 111 of file trigbs_orderedMerge.cxx.

{return m_size;}

status()

Status WriteEvent::status ( ) const

inline

Definition at line 108 of file trigbs_orderedMerge.cxx.

{return m_status;}

Member Data Documentation

m_blob

std::unique_ptr<uint32_t[]> WriteEvent::m_blob

private

Definition at line 56 of file trigbs_orderedMerge.cxx.

m_frag

eformat::write::FullEventFragment WriteEvent::m_frag

private

Definition at line 57 of file trigbs_orderedMerge.cxx.

m_robBlobs

std::vector<std::unique_ptr<uint32_t[]> > WriteEvent::m_robBlobs

private

Definition at line 59 of file trigbs_orderedMerge.cxx.

m_robs

std::vector<eformat::write::ROBFragment> WriteEvent::m_robs

private

Definition at line 58 of file trigbs_orderedMerge.cxx.

m_size

uint32_t WriteEvent::m_size {0}

private

Definition at line 60 of file trigbs_orderedMerge.cxx.

{0};

m_status

Status WriteEvent::m_status {Status::NOT_OK}

private

Definition at line 55 of file trigbs_orderedMerge.cxx.

{Status::NOT_OK};

---

The documentation for this class was generated from the following file:

• trigbs_orderedMerge.cxx