#include <ByteStreamMergeOutputSvc.h>

Inheritance diagram for ByteStreamMergeOutputSvc:

Collaboration diagram for ByteStreamMergeOutputSvc:

Public Member Functions
	ByteStreamMergeOutputSvc (const std::string &name, ISvcLocator *svcloc)
	Constructors: More...

virtual	~ByteStreamMergeOutputSvc ()
	Destructor. More...

virtual StatusCode	initialize () override

virtual bool	putEvent (const RawEvent *re) override
	Implementation of the ByteStreamOutputSvc interface methods. More...

virtual bool	putEvent (const RawEvent *re, const EventContext &ctx) override
	context-aware method for writing the event More...

StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface) override
	Required of all Gaudi services: see Gaudi documentation for details. More...

MsgStream &	msg () const

MsgStream &	msg (const MSG::Level lvl) const

bool	msgLvl (const MSG::Level lvl) const

Static Public Member Functions
static const InterfaceID &	interfaceID ()
	Retrieve interface ID. More...

Private Member Functions
uint32_t	reducedROBid (uint32_t)

Private Attributes
Gaudi::Property< std::string >	m_inSvcName

Gaudi::Property< std::string >	m_outSvcName

ByteStreamInputSvc *	m_inSvc

ByteStreamOutputSvc *	m_outSvc

Gaudi::Property< std::string >	m_bsOutputStreamName
	stream name for multiple output More...

Gaudi::Property< bool >	m_overwriteHeader

Detailed Description

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.

                                                                                              :
         ByteStreamOutputSvc(name,svcloc), 
                 m_inSvc(0),
                 m_outSvc(0)
 {
    declareProperty("ByteStreamOutputSvc", m_outSvcName);
    declareProperty("ByteStreamInputSvc", m_inSvcName);
    declareProperty("overWriteHeader", m_overwriteHeader = false);
    declareProperty("BSOutputStreamName", m_bsOutputStreamName = name);
 }

◆ ~ByteStreamMergeOutputSvc()

ByteStreamMergeOutputSvc::~ByteStreamMergeOutputSvc ( )

virtual

Destructor.

Definition at line 32 of file ByteStreamMergeOutputSvc.cxx.

32 {

33 }

Member Function Documentation

◆ initialize()

StatusCode ByteStreamMergeOutputSvc::initialize ( )

overridevirtual

Definition at line 36 of file ByteStreamMergeOutputSvc.cxx.

                                                 {
    StatusCode sc = ByteStreamOutputSvc::initialize();
    if (sc != StatusCode::SUCCESS) {
       ATH_MSG_ERROR("Failed to initialize ByteStreamOutputSvc base class");
       return(sc);
    }
    IService* svc;
    sc = service(m_outSvcName.value(), svc);
    if (sc != StatusCode::SUCCESS) {
       ATH_MSG_ERROR("Cannot get ByteStreamOutputSvc");
       return(sc);
    }
    m_outSvc = dynamic_cast<ByteStreamOutputSvc*>(svc);
    if (m_outSvc == 0) {
       ATH_MSG_ERROR("Cannot cast " << m_outSvcName << " to ByteStreamOutputSvc");
       return(StatusCode::FAILURE);
    }
  
    sc = service(m_inSvcName.value(), svc);
    if (sc != StatusCode::SUCCESS) {
       ATH_MSG_ERROR("Cannot get ByteStreamInputSvc");
       return(sc);
    }
    m_inSvc = dynamic_cast<ByteStreamInputSvc*>(svc);
    if (m_inSvc == 0) {
       ATH_MSG_ERROR("Cannot cast " << m_inSvcName << " to ByteStreamInputSvc");
       return(StatusCode::FAILURE);
    }
    return(StatusCode::SUCCESS);
 }

◆ interfaceID()

const InterfaceID & ByteStreamOutputSvc::interfaceID ( )

inlinestaticinherited

Retrieve interface ID.

Declaration of the interface ID ( interface id, major version, minor version)

Definition at line 43 of file ByteStreamOutputSvc.h.

                                                            {
   static const InterfaceID IID_ByteStreamOutputSvc("ByteStreamOutputSvc", 1, 0);
   return(IID_ByteStreamOutputSvc);
 }

◆ msg() [1/2]

MsgStream& AthCommonMsg< Service >::msg ( ) const

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                 {
     return this->msgStream();
   }

◆ msg() [2/2]

MsgStream& AthCommonMsg< Service >::msg ( const MSG::Level lvl ) const

inlineinherited

Definition at line 27 of file AthCommonMsg.h.

                                                   {
     return this->msgStream(lvl);
   }

◆ msgLvl()

bool AthCommonMsg< Service >::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                                {
     return this->msgLevel(lvl);
   }

◆ putEvent() [1/2]

bool ByteStreamMergeOutputSvc::putEvent ( const RawEvent * re )

overridevirtual

Implementation of the ByteStreamOutputSvc interface methods.

Implements ByteStreamOutputSvc.

Definition at line 80 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...
    // get all the ROBFragments
    const size_t MAX_ROBFRAGMENTS = 2048;
    OFFLINE_FRAGMENTS_NAMESPACE::PointerType orgRobF[MAX_ROBFRAGMENTS];
    OFFLINE_FRAGMENTS_NAMESPACE::PointerType newRobF[MAX_ROBFRAGMENTS];
    size_t orgrobcount = orgEvent->children(orgRobF, MAX_ROBFRAGMENTS);
    if (orgrobcount == MAX_ROBFRAGMENTS) {
       ATH_MSG_ERROR("ROB buffer overflow");
       return false;
    }
    size_t newrobcount = newEvent->children(newRobF,MAX_ROBFRAGMENTS);
    if (newrobcount == MAX_ROBFRAGMENTS) {
       ATH_MSG_ERROR("ROB buffer overflow");
       return false;
    }
  
    ROBMAP robsToAdd;
    // loop over all ROBs
    for (size_t irob = 0; irob < orgrobcount; ++irob) {
       ROBF* rob = new ROBF(orgRobF[irob]);
       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
    for (size_t irob = 0; irob < newrobcount; ++irob) {
       ROBF* rob = new ROBF(newRobF[irob]);
       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 = 0;
    }
    delete mergedEventWrite; mergedEventWrite = 0;
    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

context-aware method for writing the event

Implements ByteStreamOutputSvc.

Definition at line 174 of file ByteStreamMergeOutputSvc.cxx.

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

◆ queryInterface()

StatusCode ByteStreamMergeOutputSvc::queryInterface	(	const InterfaceID &	riid,
		void **	ppvInterface
	)

override

Required of all Gaudi services: see Gaudi documentation for details.

Definition at line 179 of file ByteStreamMergeOutputSvc.cxx.

                                                                                                 {
   if (ByteStreamOutputSvc::interfaceID().versionMatch(riid)) {
     *ppvInterface = dynamic_cast<ByteStreamOutputSvc*>(this);
   } else {
     // Interface is not directly available: try out a base class
     return(::AthService::queryInterface(riid, ppvInterface));
   }
   addRef();
   return(StatusCode::SUCCESS);
 }

◆ reducedROBid()

uint32_t ByteStreamMergeOutputSvc::reducedROBid ( uint32_t source_id )

private

Definition at line 70 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

private

stream name for multiple output

Definition at line 45 of file ByteStreamMergeOutputSvc.h.

◆ m_inSvc

ByteStreamInputSvc* ByteStreamMergeOutputSvc::m_inSvc

private

Definition at line 43 of file ByteStreamMergeOutputSvc.h.

◆ m_inSvcName

Gaudi::Property<std::string> ByteStreamMergeOutputSvc::m_inSvcName

private

Definition at line 41 of file ByteStreamMergeOutputSvc.h.

◆ m_outSvc

ByteStreamOutputSvc* ByteStreamMergeOutputSvc::m_outSvc

private

Definition at line 44 of file ByteStreamMergeOutputSvc.h.

◆ m_outSvcName

Gaudi::Property<std::string> ByteStreamMergeOutputSvc::m_outSvcName

private

Definition at line 42 of file ByteStreamMergeOutputSvc.h.

◆ m_overwriteHeader

Gaudi::Property<bool> ByteStreamMergeOutputSvc::m_overwriteHeader

private

Definition at line 46 of file ByteStreamMergeOutputSvc.h.

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

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ ByteStreamMergeOutputSvc()

◆ ~ByteStreamMergeOutputSvc()

Member Function Documentation

◆ initialize()

◆ interfaceID()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ putEvent() [1/2]

◆ putEvent() [2/2]

◆ queryInterface()

◆ reducedROBid()

Member Data Documentation

◆ m_bsOutputStreamName

◆ m_inSvc

◆ m_inSvcName

◆ m_outSvc

◆ m_outSvcName

◆ m_overwriteHeader