ByteStreamMergeOutputSvc Class Reference

This class provides the services for merging FullEventFragment with existing bytestream input. More...

#include <ByteStreamMergeOutputSvc.h>

Inheritance diagram for ByteStreamMergeOutputSvc:

Collaboration diagram for ByteStreamMergeOutputSvc:

Public Member Functions
	ByteStreamMergeOutputSvc (const std::string &name, ISvcLocator *svcloc)
	Constructors:
virtual	~ByteStreamMergeOutputSvc ()=default
	Destructor.
virtual StatusCode	initialize () override
virtual bool	putEvent (const RawEvent *re) override
	Implementation of the IByteStreamOutputSvc interface methods.
virtual bool	putEvent (const RawEvent *re, const EventContext &ctx) override

Private Member Functions
uint32_t	reducedROBid (uint32_t)

Private Attributes
ServiceHandle< IByteStreamInputSvc >	m_inSvc {this, "ByteStreamInputSvc", {}}
ServiceHandle< IByteStreamOutputSvc >	m_outSvc {this, "ByteStreamOutputSvc", {}}
Gaudi::Property< std::string >	m_bsOutputStreamName {this, "BSOutputStreamName", {}, "stream name for multiple output"}
Gaudi::Property< bool >	m_overwriteHeader {this, "overWriteHeader", false}

Detailed Description

This class provides the services for merging FullEventFragment with existing bytestream input.

Mostly meant for adding new L2+EF results

Definition at line 22 of file ByteStreamMergeOutputSvc.h.

Constructor & Destructor Documentation

ByteStreamMergeOutputSvc()

ByteStreamMergeOutputSvc::ByteStreamMergeOutputSvc	(	const std::string &	name,
		ISvcLocator *	svcloc )

Constructors:

Definition at line 20 of file ByteStreamMergeOutputSvc.cxx.

                                                                                             :
   base_class(name,svcloc)
{
   // cppcheck-suppress useInitializationList; deprecated Property constructor
   m_bsOutputStreamName = name;
}

~ByteStreamMergeOutputSvc()

virtual ByteStreamMergeOutputSvc::~ByteStreamMergeOutputSvc ( )

virtualdefault

Destructor.

Member Function Documentation

initialize()

StatusCode ByteStreamMergeOutputSvc::initialize ( )

overridevirtual

Definition at line 28 of file ByteStreamMergeOutputSvc.cxx.

                                                {
   ATH_CHECK( m_outSvc.retrieve() );
   ATH_CHECK( m_inSvc.retrieve() );
 
   return StatusCode::SUCCESS;
}

putEvent() [1/2]

bool ByteStreamMergeOutputSvc::putEvent ( const RawEvent * re )

overridevirtual

Implementation of the IByteStreamOutputSvc interface methods.

Definition at line 48 of file ByteStreamMergeOutputSvc.cxx.

                                                                 {
   // get original event
   const RawEvent* orgEvent = m_inSvc->currentEvent();
 
   ATH_MSG_DEBUG("original BS size = " << 4 * orgEvent->fragment_size_word());
   ATH_MSG_DEBUG("athena BS size = " << 4 * newEvent->fragment_size_word());
 
   // do the merge...
 
   ROBMAP robsToAdd;
   // loop over all ROBs
   auto orgIter = orgEvent->child_iter();
   while (OFFLINE_FRAGMENTS_NAMESPACE::PointerType fp = orgIter.next()) {
      ROBF* rob = new ROBF(fp);
      robsToAdd[reducedROBid(rob->source_id())] = rob;
      ATH_MSG_DEBUG("original ROBFragment, src ID = " << std::hex << rob->source_id());
   }
   // now add/overwrite with newly created robs
   auto newIter = newEvent->child_iter();
   while (OFFLINE_FRAGMENTS_NAMESPACE::PointerType fp = newIter.next()) {
      ROBF* rob = new ROBF(fp);
      ROBMAP::const_iterator it = robsToAdd.find(reducedROBid(rob->source_id()));
      if (it != robsToAdd.end()) {
        delete it->second;
        ATH_MSG_DEBUG("overwriting ROBFragment with src ID = " << std::hex << rob->source_id());
      }
      robsToAdd[reducedROBid(rob->source_id())] = rob;
      ATH_MSG_DEBUG("new ROBFragment, src ID = " << std::hex << rob->source_id());
   }
   RawEventWrite* mergedEventWrite = new RawEventWrite();
   // copy header
   const RawEvent *event = orgEvent;
   if (m_overwriteHeader) {
      event = newEvent;
   }
   mergedEventWrite->source_id(event->source_id());
   mergedEventWrite->bc_time_seconds(event->bc_time_seconds());
   mergedEventWrite->bc_time_nanoseconds(event->bc_time_nanoseconds());
   mergedEventWrite->global_id(event->global_id());
   mergedEventWrite->run_type(event->run_type());
   mergedEventWrite->run_no(event->run_no());
   mergedEventWrite->lumi_block(event->lumi_block());
   mergedEventWrite->lvl1_id(event->lvl1_id());
   mergedEventWrite->bc_id(event->bc_id());
   mergedEventWrite->lvl1_trigger_type(event->lvl1_trigger_type());
   const OFFLINE_FRAGMENTS_NAMESPACE::DataType *tmp;
   event->status(tmp);
   mergedEventWrite->status(event->nstatus(), tmp);
   event->lvl1_trigger_info(tmp);
   mergedEventWrite->lvl1_trigger_info(event->nlvl1_trigger_info(), tmp);
   event->lvl2_trigger_info(tmp);
   mergedEventWrite->lvl2_trigger_info(event->nlvl2_trigger_info(), tmp);
   event->event_filter_info(tmp);
   mergedEventWrite->event_filter_info(event->nevent_filter_info(), tmp);
   event->stream_tag(tmp);
   mergedEventWrite->stream_tag(event->nstream_tag(), tmp);
   mergedEventWrite->checksum_type(event->checksum_type());
   // copy robs
   for(ROBMAP::iterator it = robsToAdd.begin(), itEnd = robsToAdd.end(); it != itEnd; ++it) {
      mergedEventWrite->append(it->second);
   }
   // convert RawEventWrite to RawEvent
   uint32_t rawSize = mergedEventWrite->size_word();
   OFFLINE_FRAGMENTS_NAMESPACE::DataType* buffer = new OFFLINE_FRAGMENTS_NAMESPACE::DataType[rawSize];
   uint32_t count = eformat::write::copy(*(mergedEventWrite->bind()), buffer, rawSize);
   if (count != rawSize) {
      ATH_MSG_ERROR("Memcopy failed " << count << " " << rawSize);
      return false;
   }
   RawEvent newRawEvent(buffer);
   StatusCode sc = m_outSvc->putEvent(&newRawEvent) ? StatusCode::SUCCESS : StatusCode::FAILURE;
   for(ROBMAP::iterator it = robsToAdd.begin(), itEnd = robsToAdd.end(); it != itEnd; ++it) {
      delete it->second; it->second = nullptr;
   }
   delete mergedEventWrite; mergedEventWrite = nullptr;
   delete [] buffer;
   if (sc != StatusCode::SUCCESS) {
      ATH_MSG_ERROR("Failed to put RawEvent");
   }
   return(true);
}

putEvent() [2/2]

bool ByteStreamMergeOutputSvc::putEvent ( const RawEvent * re, const EventContext & ctx )

overridevirtual

Definition at line 130 of file ByteStreamMergeOutputSvc.cxx.

                                                                                {
  ATH_MSG_FATAL(name() << " does not implement the context-aware putEvent method");
  return false;
}

reducedROBid()

uint32_t ByteStreamMergeOutputSvc::reducedROBid ( uint32_t source_id )

private

Definition at line 38 of file ByteStreamMergeOutputSvc.cxx.

                                                                  {
   eformat::helper::SourceIdentifier id = eformat::helper::SourceIdentifier(source_id);
   if (id.subdetector_id() == eformat::TDAQ_LVL2 || id.subdetector_id() == eformat::TDAQ_EVENT_FILTER) {
      return(eformat::helper::SourceIdentifier(id.subdetector_id(), 0).code());
   } else {
      return(source_id);
   }
}

Member Data Documentation

m_bsOutputStreamName

Gaudi::Property<std::string> ByteStreamMergeOutputSvc::m_bsOutputStreamName {this, "BSOutputStreamName", {}, "stream name for multiple output"}

private

Definition at line 41 of file ByteStreamMergeOutputSvc.h.

{this, "BSOutputStreamName", {}, "stream name for multiple output"};

m_inSvc

ServiceHandle<IByteStreamInputSvc> ByteStreamMergeOutputSvc::m_inSvc {this, "ByteStreamInputSvc", {}}

private

Definition at line 38 of file ByteStreamMergeOutputSvc.h.

{this, "ByteStreamInputSvc", {}};

m_outSvc

ServiceHandle<IByteStreamOutputSvc> ByteStreamMergeOutputSvc::m_outSvc {this, "ByteStreamOutputSvc", {}}

private

Definition at line 39 of file ByteStreamMergeOutputSvc.h.

{this, "ByteStreamOutputSvc", {}};

m_overwriteHeader

Gaudi::Property<bool> ByteStreamMergeOutputSvc::m_overwriteHeader {this, "overWriteHeader", false}

private

Definition at line 42 of file ByteStreamMergeOutputSvc.h.

{this, "overWriteHeader", false};

---

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

• ByteStreamMergeOutputSvc.h
• ByteStreamMergeOutputSvc.cxx