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 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 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 ByteStreamOutputSvc for the conversion service to write the output.

Definition at line 25 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.

    : ByteStreamOutputSvc(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");
   if (!ByteStreamOutputSvc::initialize().isSuccess()) {
      ATH_MSG_FATAL("Cannot initialize ByteStreamOutputSvc base class.");
      return(StatusCode::FAILURE);
   }
 
   // Retrieve ROBDataProviderSvc
   if (!m_robProvider.retrieve().isSuccess()) {
      ATH_MSG_FATAL("Cannot get ROBDataProviderSvc");
      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 ByteStreamRDP_OutputSvc::putEvent ( const RawEvent *  re )

overridevirtual

Implementation of the ByteStreamOutputSvc interface methods.

Implements ByteStreamOutputSvc.

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

context-aware method for writing the event

Implements ByteStreamOutputSvc.

Definition at line 44 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;
}

queryInterface()

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

override

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

Definition at line 61 of file ByteStreamRDP_OutputSvc.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);
}

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 53 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 49 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 51 of file ByteStreamRDP_OutputSvc.h.

---

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

• ByteStreamRDP_OutputSvc.h
• ByteStreamRDP_OutputSvc.cxx