ByteStreamRDP_OutputSvc Class Reference

Writing the data to ROBDataProviderSvc for transient BS. More...

#include <ByteStreamRDP_OutputSvc.h>

Inheritance diagram for ByteStreamRDP_OutputSvc:

Collaboration diagram for ByteStreamRDP_OutputSvc:

Classes
struct	EventCache

Public Member Functions
	ByteStreamRDP_OutputSvc (const std::string &name, ISvcLocator *svcloc)
	Constructors: More...
virtual StatusCode	initialize () override
	Required of all Gaudi Services. More...
virtual bool	putEvent (const RawEvent *re) override
	Implementation of the IByteStreamOutputSvc interface methods. More...
virtual bool	putEvent (const RawEvent *re, const EventContext &ctx) override

Private Attributes
SG::SlotSpecificObj< EventCache >	m_eventsCache
	Cache of event data for each slot. More...
ServiceHandle< IROBDataProviderSvc >	m_robProvider
Gaudi::Property< std::string >	m_bsOutputStreamName

Detailed Description

Writing the data to ROBDataProviderSvc for transient BS.

        RDP == RobDataProvider

Description: An class for writing FullEventFragment into RobDataProvider this class implements the interface IByteStreamOutputSvc for the conversion service to write the output.

Definition at line 26 of file ByteStreamRDP_OutputSvc.h.

Constructor & Destructor Documentation

ByteStreamRDP_OutputSvc()

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

Constructors:

Definition at line 17 of file ByteStreamRDP_OutputSvc.cxx.

    : base_class(name, svcloc) {
      if (m_bsOutputStreamName.empty()) m_bsOutputStreamName = name;
}

Member Function Documentation

initialize()

StatusCode ByteStreamRDP_OutputSvc::initialize ( )

overridevirtual

Required of all Gaudi Services.

Definition at line 23 of file ByteStreamRDP_OutputSvc.cxx.

                                               {
   ATH_MSG_INFO("Initializing");
 
   // Retrieve ROBDataProviderSvc
   ATH_CHECK( m_robProvider.retrieve() );
 
   return(StatusCode::SUCCESS);
}

putEvent() [1/2]

bool ByteStreamRDP_OutputSvc::putEvent ( const RawEvent *  re )

overridevirtual

Implementation of the IByteStreamOutputSvc interface methods.

Definition at line 33 of file ByteStreamRDP_OutputSvc.cxx.

                                                         {
   return putEvent(re, Gaudi::Hive::currentContext());
}

putEvent() [2/2]

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

overridevirtual

Definition at line 38 of file ByteStreamRDP_OutputSvc.cxx.

                                                                                  {
   EventCache* cache = m_eventsCache.get(ctx);
   cache->releaseEvent();
   const uint32_t reSize = re->fragment_size_word();
   const uint32_t* reStart = re->start();
   cache->dataBuffer = std::make_unique<uint32_t[]>(reSize);
   std::copy(reStart, reStart+reSize, cache->dataBuffer.get());
 
   // Create a cached RawEvent object from the cached data buffer
   cache->rawEvent = std::make_unique<RawEvent>(cache->dataBuffer.get());
 
   // Give the RawEvent to ROBDataProvider
   m_robProvider->setNextEvent(ctx, cache->rawEvent.get());
 
   return true;
}

Member Data Documentation

m_bsOutputStreamName

Gaudi::Property<std::string> ByteStreamRDP_OutputSvc::m_bsOutputStreamName

private

Initial value:

{
      this, "BSOutputStreamName", "", "Stream name for multiple output"}

Definition at line 51 of file ByteStreamRDP_OutputSvc.h.

m_eventsCache

SG::SlotSpecificObj<EventCache> ByteStreamRDP_OutputSvc::m_eventsCache

private

Cache of event data for each slot.

Definition at line 47 of file ByteStreamRDP_OutputSvc.h.

m_robProvider

ServiceHandle<IROBDataProviderSvc> ByteStreamRDP_OutputSvc::m_robProvider

private

Initial value:

{
      this, "ROBDataProviderSvc", "ROBDataProviderSvc", "ROB data provider"}

Definition at line 49 of file ByteStreamRDP_OutputSvc.h.

---

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

• ByteStreamRDP_OutputSvc.h
• ByteStreamRDP_OutputSvc.cxx