TrigByteStreamCnvSvc Class Reference

A ByteStreamCnvSvc implementation for online use. More...

#include <TrigByteStreamCnvSvc.h>

Inheritance diagram for TrigByteStreamCnvSvc:

Collaboration diagram for TrigByteStreamCnvSvc:

Public Types
typedef std::unordered_map< CLID, WorkerEntry >	Workers

Public Member Functions
	TrigByteStreamCnvSvc (const std::string &name, ISvcLocator *svcLoc)
	Standard constructor. More...
virtual	~TrigByteStreamCnvSvc ()
	Standard destructor. More...
virtual StatusCode	initialize () override
	Required of all Gaudi Services. More...
virtual StatusCode	finalize () override
virtual StatusCode	connectOutput (const std::string &outputFile) override
	In the case of online BS data, this method creates the output FullEventFragment and fills its header. More...
StatusCode	connectOutput (const std::string &outputFile, const EventContext &eventContext)
	In the case of online BS data, this method creates the output FullEventFragment and fills its header. More...
virtual StatusCode	connectOutput (const std::string &outputFile, const std::string &openMode) override
	This overload is kept only for interface compatibility. More...
virtual StatusCode	commitOutput (const std::string &outputFile, bool do_commit) override
	In the case of online BS data, this method binds and sends out the output FullEventFragment. More...
StatusCode	commitOutput (const std::string &outputFile, bool do_commit, const EventContext &eventContext)
	In the case of online BS data, this method binds and sends out the output FullEventFragment. More...
virtual RawEventWrite *	getRawEvent () override
	Return a pointer to the raw event for the current event context. More...
RawEventWrite *	getRawEvent (const EventContext &eventContext) const
	Return a pointer to the raw event for the given event context. More...
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface) override
	Required of all Gaudi services: see Gaudi documentation for details. More...
virtual StatusCode	updateServiceState (IOpaqueAddress *pAddress) override
	Checks whether an IOpaqueAddress is a GenericAddress. More...
virtual void	handle (const Incident &) override
	Implementation of IIncidentListener: Handle for EndEvent incidence. 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 ()
	Gaudi interface id. More...

Protected Attributes
std::vector< std::string >	m_initCnvs
Gaudi::Property< std::vector< std::string > >	m_ROD2ROBmap {this,"ROD2ROBmap",{},"","OrderedSet<std::string>"}

Private Member Functions
RawEventWrite *	setRawEvent (std::unique_ptr< RawEventWrite > &&rawEventWrite, const EventContext &eventContext)
	Store new raw event in the cache. More...
void	clearRawEvent (const EventContext &eventContext)
	Delete raw event from the cache. More...
void	printRawEvent (const EventContext &eventContext) const
	Print contents of the raw event. More...
void	monitorRawEvent (const std::unique_ptr< uint32_t[]> &rawEventPtr) const
	Fill histograms from contents of a FullEventFragment. More...
const EventContext *	currentContext () const
	Hack used in HLT to avoid using ThreadLocalContext, see explanation in the implementation. More...

Private Attributes
ServiceHandle< StoreGateSvc >	m_evtStore {this, "EventStore", "StoreGateSvc"}
ServiceHandle< IROBDataProviderSvc >	m_robDataProviderSvc {this, "ROBDataProvider", "ROBDataProviderSvc"}
ToolHandle< GenericMonitoringTool >	m_monTool {this, "MonTool", "" , "Monitoring tool"}
SG::SlotSpecificObj< std::unique_ptr< RawEventWrite > >	m_rawEventWriteCache
Flags which are not used by this service.
It only serves as an entity storing these values and some other components read it from here. TODO: Remove this solution and move the properties where they are needed.
Gaudi::Property< bool >	m_isSimulation {this, "IsSimulation", false}
Gaudi::Property< bool >	m_isTestbeam {this, "IsTestbeam", false}
	flags for TestBeam EventType More...
Gaudi::Property< bool >	m_isCalibration {this, "IsCalibration", false}
	flags for Calibration EventType More...
Flags which are not used by this service.
It only serves as an entity storing these values and some other components read it from here. TODO: Remove this solution and move the properties where they are needed.
Gaudi::Property< bool >	m_isSimulation {this, "IsSimulation", false}
Gaudi::Property< bool >	m_isTestbeam {this, "IsTestbeam", false}
	flags for TestBeam EventType More...
Gaudi::Property< bool >	m_isCalibration {this, "IsCalibration", false}
	flags for Calibration EventType More...
Flags which are not used by this service.
It only serves as an entity storing these values and some other components read it from here. TODO: Remove this solution and move the properties where they are needed.
Gaudi::Property< bool >	m_isSimulation {this, "IsSimulation", false}
Gaudi::Property< bool >	m_isTestbeam {this, "IsTestbeam", false}
	flags for TestBeam EventType More...
Gaudi::Property< bool >	m_isCalibration {this, "IsCalibration", false}
	flags for Calibration EventType More...

@c IConversionSvc implementation
virtual long	repSvcType () const
	Retrieve the class type of the data store the converter uses. More...
const CLID &	objType () const
	Implementation of IConverter: dummy call. More...
virtual StatusCode	setDataProvider (IDataProviderSvc *pService)
	Implementation of IConverter: Set Data provider service. More...
virtual SmartIF< IDataProviderSvc > &	dataProvider () const
	Implementation of IConverter: Get Data provider service. More...
virtual StatusCode	setConversionSvc (IConversionSvc *svc)
	Implementation of IConverter: Set conversion service the converter is connected to. More...
virtual SmartIF< IConversionSvc > &	conversionSvc () const
	Implementation of IConverter: Get conversion service the converter is connected to. More...
virtual StatusCode	setAddressCreator (IAddressCreator *creator)
	Set address creator facility. More...
virtual SmartIF< IAddressCreator > &	addressCreator () const
	Retrieve address creator facility. More...
virtual StatusCode	createObj (IOpaqueAddress *pAddress, DataObject *&refpObject)
	Implementation of IConverter: Create the transient representation of an object. More...
virtual StatusCode	fillObjRefs (IOpaqueAddress *pAddress, DataObject *pObject)
	Implementation of IConverter: Resolve the references of the created transient object. More...
virtual StatusCode	updateObj (IOpaqueAddress *pAddress, DataObject *refpObject)
	Implementation of IConverter: Update the transient object from the other representation. More...
virtual StatusCode	updateObjRefs (IOpaqueAddress *pAddress, DataObject *pObject)
	Implementation of IConverter: Update the references of an updated transient object. More...
virtual StatusCode	createRep (DataObject *pObject, IOpaqueAddress *&refpAddress)
	Implementation of IConverter: Convert the transient object to the requested representation. More...
virtual StatusCode	fillRepRefs (IOpaqueAddress *pAddress, DataObject *pObject)
	Implementation of IConverter: Resolve the references of the converted object. More...
virtual StatusCode	updateRep (IOpaqueAddress *pAddress, DataObject *pObject)
	Implementation of IConverter: Update the converted representation of a transient object. More...
virtual StatusCode	updateRepRefs (IOpaqueAddress *pAddress, DataObject *pObject)
	Implementation of IConverter: Update the references of an already converted object. More...
virtual StatusCode	addConverter (const CLID &clid)
	Add converter object to conversion service. More...
virtual StatusCode	addConverter (IConverter *pConverter)
	Add converter object to conversion service. More...
virtual StatusCode	removeConverter (const CLID &clid)
	Remove converter object from conversion service (if present). More...
virtual IConverter *	converter (const CLID &wanted)
	Retrieve converter from list. More...
virtual StatusCode	disconnectOutput (const std::string &output)
	Disconnect output files from the service. More...

@c IAddressCreator interface implementation
virtual StatusCode	createAddress (long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
	Create a Generic address using explicit arguments to identify a single object. More...
virtual StatusCode	createAddress (long svc_type, const CLID &clid, const std::string &refAddress, IOpaqueAddress *&refpAddress)
	Convert an address in string form to object form. More...
virtual StatusCode	convertAddress (const IOpaqueAddress *pAddress, std::string &refAddress)
	Convert an address to string form. More...
SmartIF< IDataProviderSvc >	m_dataSvc
	Pointer to data provider service. More...
SmartIF< IAddressCreator >	m_addressCreator
	Pointer to the address creation service interface. More...
SmartIF< IConversionSvc >	m_cnvSvc
	Pointer to the IConversionSvc interface of this. More...
long	m_type
	Conversion service type. More...
Workers	m_workers
	List of conversion workers. More...
CallMutex	m_conv_mut
typedef std::recursive_mutex	CallMutex
	Mutex to protect Converter creation. More...
virtual SmartIF< IAddressCreator > &	addressCreator ()
	Retrieve address creation interface. More...
virtual IConverter *	createConverter (long typ, const CLID &clid, const ICnvFactory *fac)
	Create new Converter using factory. More...
virtual StatusCode	configureConverter (long typ, const CLID &clid, IConverter *cnv)
	Configure the new converter before initialize is called. More...
virtual StatusCode	initializeConverter (long typ, const CLID &clid, IConverter *cnv)
	Initialize the new converter. More...
virtual StatusCode	activateConverter (long typ, const CLID &clid, IConverter *cnv)
	Activate the new converter after initialization. More...
virtual void	loadConverter (DataObject *pObject)
	Load converter or dictionary needed by the converter. More...
StatusCode	makeCall (int typ, bool ignore_add, bool ignore_obj, bool update, IOpaqueAddress *&pAddress, DataObject *&pObject)

Detailed Description

A ByteStreamCnvSvc implementation for online use.

It overrides the connectOutput and commitOutput methods of the base class. In this implementation, they create the specific online HLT output and send it out directly to the TDAQ infrastructure without using an output service.

Definition at line 22 of file TrigByteStreamCnvSvc.h.

Member Typedef Documentation

CallMutex

typedef std::recursive_mutex AthCnvSvc::CallMutex

protectedinherited

Mutex to protect Converter creation.

Definition at line 323 of file AthCnvSvc.h.

Workers

typedef std::unordered_map<CLID,WorkerEntry> AthCnvSvc::Workers

inherited

Definition at line 106 of file AthCnvSvc.h.

Constructor & Destructor Documentation

TrigByteStreamCnvSvc()

TrigByteStreamCnvSvc::TrigByteStreamCnvSvc	(	const std::string &	name,
		ISvcLocator *	svcLoc
	)

Standard constructor.

Definition at line 86 of file TrigByteStreamCnvSvc.cxx.

: ByteStreamCnvSvcBase(name, svcLoc) {}

~TrigByteStreamCnvSvc()

TrigByteStreamCnvSvc::~TrigByteStreamCnvSvc ( )

virtual

Standard destructor.

Definition at line 92 of file TrigByteStreamCnvSvc.cxx.

{}

Member Function Documentation

activateConverter()

StatusCode AthCnvSvc::activateConverter ( long  typ, const CLID &  clid, IConverter *  cnv  )

protectedvirtualinherited

Activate the new converter after initialization.

Definition at line 536 of file AthCnvSvc.cxx.

{
  if (cnv) {
    return StatusCode::SUCCESS;
  }
  return Status::NO_CONVERTER;
}

addConverter() [1/2]

StatusCode AthCnvSvc::addConverter ( const CLID &  clid )

virtualinherited

Add converter object to conversion service.

Definition at line 336 of file AthCnvSvc.cxx.

{
  // First look for the more specific converter
  long typ = repSvcType();
  IConverter* pConverter = createConverter(typ, clid, 0);
  if ( 0 != pConverter )    {
    StatusCode status = configureConverter( typ, clid, pConverter );
    if ( status.isSuccess() )   {
      status = initializeConverter( typ, clid, pConverter );
      if ( status.isSuccess() )   {
        status = activateConverter( typ, clid, pConverter );
        if ( status.isSuccess() )   {
          long conv_typ  = pConverter->repSvcType();
          const CLID&   conv_clid = pConverter->objType();
          typ      = (typ<0xFF) ? typ : typ&0xFFFFFF00;
          conv_typ = (conv_typ<0xFF) ? conv_typ : conv_typ&0xFFFFFF00;
          if ( conv_typ == typ && conv_clid == clid )   {
            return addConverter(pConverter);
          }
        }
      }
    }
    pConverter->release();
  }
  return Status::NO_CONVERTER;
}

addConverter() [2/2]

StatusCode AthCnvSvc::addConverter ( IConverter *  pConverter )

virtualinherited

Add converter object to conversion service.

Definition at line 365 of file AthCnvSvc.cxx.

{
  if ( 0 != pConverter )    {
    const CLID& clid = pConverter->objType();
    removeConverter(clid).ignore();
    m_workers.insert (std::make_pair(clid,WorkerEntry(clid, pConverter)));
    pConverter->addRef();
    return StatusCode::SUCCESS;
  }
  return Status::NO_CONVERTER;
}

addressCreator() [1/2]

virtual SmartIF<IAddressCreator>& AthCnvSvc::addressCreator ( )

inlineprotectedvirtualinherited

Retrieve address creation interface.

Definition at line 300 of file AthCnvSvc.h.

  {
    return m_addressCreator;
  }

addressCreator() [2/2]

SmartIF< IAddressCreator > & AthCnvSvc::addressCreator ( ) const

virtualinherited

Retrieve address creator facility.

Definition at line 261 of file AthCnvSvc.cxx.

{
  // FIXME: Ideally the return type should be const, but that would require
  //        changes in the Gaudi IConverter base class.
  SmartIF<IAddressCreator>& svc ATLAS_THREAD_SAFE =
    const_cast<SmartIF<IAddressCreator>&>(m_addressCreator);
  return svc;
}

clearRawEvent()

void TrigByteStreamCnvSvc::clearRawEvent ( const EventContext &  eventContext )

private

Delete raw event from the cache.

Definition at line 261 of file TrigByteStreamCnvSvc.cxx.

                                                                         {
  m_rawEventWriteCache.get(eventContext)->reset();
}

commitOutput() [1/2]

StatusCode TrigByteStreamCnvSvc::commitOutput ( const std::string &  outputFile, bool  do_commit  )

overridevirtual

In the case of online BS data, this method binds and sends out the output FullEventFragment.

Reimplemented from AthCnvSvc.

Definition at line 163 of file TrigByteStreamCnvSvc.cxx.

                                                                                         {
  const EventContext* eventContext = currentContext();
  if (eventContext == nullptr) return StatusCode::FAILURE;
  return commitOutput(outputFile, do_commit, *eventContext);
}

commitOutput() [2/2]

StatusCode TrigByteStreamCnvSvc::commitOutput	(	const std::string &	outputFile,
		bool	do_commit,
		const EventContext &	eventContext
	)

In the case of online BS data, this method binds and sends out the output FullEventFragment.

Definition at line 169 of file TrigByteStreamCnvSvc.cxx.

                                                                                                          {
  ATH_MSG_VERBOSE("start of " << __FUNCTION__);
 
  if (msgLvl(MSG::DEBUG)) printRawEvent(eventContext);
 
  RawEventWrite* re = getRawEvent(eventContext);
 
  // Serialise the output FullEventFragment
  std::unique_ptr<uint32_t[]> rawEventPtr;
  try {
    const eformat::write::node_t* top = re->bind();
    uint32_t rawEventSize = re->size_word();
    rawEventPtr = std::make_unique<uint32_t[]>(rawEventSize);
    uint32_t copiedSize = eformat::write::copy(*top,rawEventPtr.get(),rawEventSize);
    if(copiedSize!=rawEventSize) {
      ATH_MSG_ERROR("FullEventFragment serialisation failed");
      return StatusCode::FAILURE;
    }
  }
  catch (const std::exception& e) {
    ATH_MSG_ERROR("FullEventFragment serialisation failed, caught an unexpected std::exception " << e.what());
    clearRawEvent(eventContext);
    return StatusCode::FAILURE;
  }
  catch (...) {
    ATH_MSG_ERROR("FullEventFragment serialisation failed, caught an unexpected exception");
    clearRawEvent(eventContext);
    return StatusCode::FAILURE;
  }
 
  {
    auto t_mon = Monitored::Timer("TIME_monitorRawEvent");
    monitorRawEvent(rawEventPtr);
    Monitored::Group(m_monTool, t_mon);
  }
 
  // Send output to the DataCollector
  StatusCode result = StatusCode::SUCCESS;
  try {
    auto t_eventDone = Monitored::Timer<std::chrono::duration<float, std::milli>>("TIME_eventDone");
    hltinterface::DataCollector::instance()->eventDone(std::move(rawEventPtr));
    Monitored::Group(m_monTool, t_eventDone);
    ATH_MSG_DEBUG("Serialised FullEventFragment with HLT result was returned to DataCollector successfully, "
                  << "the eventDone call took " << (double)t_eventDone << " milliseconds");
  }
  catch (const std::exception& e) {
    ATH_MSG_ERROR("Sending output to DataCollector failed, caught an unexpected std::exception " << e.what());
    result = StatusCode::FAILURE;
  }
  catch (...) {
    ATH_MSG_ERROR("Sending output to DataCollector failed, caught an unexpected exception");
    result = StatusCode::FAILURE;
  }
 
  clearRawEvent(eventContext);
 
  ATH_MSG_VERBOSE("end of " << __FUNCTION__);
  return result;
}

configureConverter()

StatusCode AthCnvSvc::configureConverter ( long  typ, const CLID &  clid, IConverter *  cnv  )

protectedvirtualinherited

Configure the new converter before initialize is called.

Definition at line 510 of file AthCnvSvc.cxx.

{
  if (cnv) {
    cnv->setConversionSvc(this).ignore();
    cnv->setAddressCreator(m_addressCreator).ignore();
    cnv->setDataProvider(m_dataSvc).ignore();
    return StatusCode::SUCCESS;
  }
  return Status::NO_CONVERTER;
 
}

connectOutput() [1/3]

StatusCode TrigByteStreamCnvSvc::connectOutput ( const std::string &  outputFile )

overridevirtual

In the case of online BS data, this method creates the output FullEventFragment and fills its header.

Reimplemented from AthCnvSvc.

Definition at line 125 of file TrigByteStreamCnvSvc.cxx.

                                                                          {
  const EventContext* eventContext = currentContext();
  if (eventContext == nullptr) return StatusCode::FAILURE;
  return connectOutput(outputFile, *eventContext);
}

connectOutput() [2/3]

StatusCode TrigByteStreamCnvSvc::connectOutput	(	const std::string &	outputFile,
		const EventContext &	eventContext
	)

In the case of online BS data, this method creates the output FullEventFragment and fills its header.

Definition at line 131 of file TrigByteStreamCnvSvc.cxx.

                                                                                                   {
  ATH_MSG_VERBOSE("start of " << __FUNCTION__);
 
  ATH_MSG_DEBUG("Creating new RawEventWrite for EventContext = " << eventContext);
  // Create a new RawEventWrite and copy the header from the input RawEvent
  RawEventWrite* re = setRawEvent(std::make_unique<RawEventWrite>(), eventContext);
  const uint32_t* inputRawEvent = m_robDataProviderSvc->getEvent(eventContext)->start();
  if (!inputRawEvent) {
    ATH_MSG_ERROR("Input RawEvent is nullptr, cannot create output");
    return StatusCode::FAILURE;
  }
  re->copy_header(inputRawEvent);
 
  ATH_MSG_VERBOSE("Created RawEventWrite pointer = " << re);
 
  ATH_MSG_VERBOSE("end of " << __FUNCTION__);
  return StatusCode::SUCCESS;
}

connectOutput() [3/3]

StatusCode TrigByteStreamCnvSvc::connectOutput ( const std::string &  outputFile, const std::string &  openMode  )

overridevirtual

This overload is kept only for interface compatibility.

Reimplemented from AthCnvSvc.

Definition at line 154 of file TrigByteStreamCnvSvc.cxx.

                                                                                              {
  return connectOutput(outputFile);
}

conversionSvc()

SmartIF< IConversionSvc > & AthCnvSvc::conversionSvc ( ) const

virtualinherited

Implementation of IConverter: Get conversion service the converter is connected to.

Definition at line 232 of file AthCnvSvc.cxx.

{
  // FIXME: Ideally the return type should be const, but that would require
  //        changes in the Gaudi IConverter base class.
  SmartIF<IConversionSvc>& svc ATLAS_THREAD_SAFE =
    const_cast<SmartIF<IConversionSvc>&>(m_cnvSvc);
  return svc;
}

convertAddress()

StatusCode AthCnvSvc::convertAddress ( const IOpaqueAddress *  pAddress, std::string &  refAddress  )

virtualinherited

Convert an address to string form.

Reimplemented in AthenaPoolCnvSvc, Athena::NtupleCnvSvc, Athena::xAODCnvSvc, and Athena::RootCnvSvc.

Definition at line 459 of file AthCnvSvc.cxx.

{
  refAddress = "";
  return StatusCode::FAILURE;
}

converter()

IConverter * AthCnvSvc::converter ( const CLID &  wanted )

virtualinherited

Retrieve converter from list.

Definition at line 394 of file AthCnvSvc.cxx.

{
  std::lock_guard<CallMutex> lock(m_conv_mut);
  Workers::iterator worker = m_workers.find (clid);
  if ( worker != m_workers.end() ) {
    return worker->second.converter();
  }
  if (addConverter (clid).isSuccess()) {
    worker = m_workers.find (clid);
    if (worker != m_workers.end()) {
      return worker->second.converter();
    }
  } else {
    ATH_MSG_INFO("problem adding converter for CLID [" << clid << "]");
  }
  return 0;
}

createAddress() [1/2]

StatusCode AthCnvSvc::createAddress ( long  svc_type, const CLID &  clid, const std::string &  refAddress, IOpaqueAddress *&  refpAddress  )

virtualinherited

Convert an address in string form to object form.

Reimplemented in Athena::NtupleCnvSvc, Athena::xAODCnvSvc, AthenaPoolCnvSvc, and Athena::RootCnvSvc.

Definition at line 468 of file AthCnvSvc.cxx.

{
  refpAddress = 0;
  return StatusCode::FAILURE;
}

createAddress() [2/2]

StatusCode AthCnvSvc::createAddress ( long  svc_type, const CLID &  clid, const std::string *  par, const unsigned long *  ip, IOpaqueAddress *&  refpAddress  )

virtualinherited

Create a Generic address using explicit arguments to identify a single object.

Reimplemented in Athena::NtupleCnvSvc, Athena::xAODCnvSvc, AthenaPoolCnvSvc, and Athena::RootCnvSvc.

Definition at line 447 of file AthCnvSvc.cxx.

{
  refpAddress = 0;
  return StatusCode::FAILURE;
}

createConverter()

IConverter * AthCnvSvc::createConverter ( long  typ, const CLID &  clid, const ICnvFactory *  fac  )

protectedvirtualinherited

Create new Converter using factory.

Reimplemented in Athena::NtupleCnvSvc, Athena::xAODCnvSvc, and Athena::RootCnvSvc.

Definition at line 491 of file AthCnvSvc.cxx.

{
 
  std::unique_ptr<IConverter> cnv{Converter::Factory::create
    (ConverterID(typ,clid), serviceLocator().get() )};
 
  if (!cnv) {
    typ = (typ<0xFF) ? typ : typ&0xFFFFFF00;
    cnv = Converter::Factory::create
      (ConverterID(typ,clid), serviceLocator().get() );
  }
  return cnv.release();
 
}

createObj()

StatusCode AthCnvSvc::createObj ( IOpaqueAddress *  pAddress, DataObject *&  refpObject  )

virtualinherited

Implementation of IConverter: Create the transient representation of an object.

Reimplemented in Athena::NtupleCnvSvc, Athena::xAODCnvSvc, and AthenaPoolCnvSvc.

Definition at line 273 of file AthCnvSvc.cxx.

{
  return makeCall (CREATE_OBJ, false, true, false, pAddress, refpObject);
}

createRep()

StatusCode AthCnvSvc::createRep ( DataObject *  pObject, IOpaqueAddress *&  refpAddress  )

virtualinherited

Implementation of IConverter: Convert the transient object to the requested representation.

Reimplemented in Athena::NtupleCnvSvc, Athena::xAODCnvSvc, and AthenaPoolCnvSvc.

Definition at line 305 of file AthCnvSvc.cxx.

{
  return makeCall (CREATE_REP, true, false, false, refpAddress, pObject);
}

currentContext()

const EventContext * TrigByteStreamCnvSvc::currentContext ( ) const

private

Hack used in HLT to avoid using ThreadLocalContext, see explanation in the implementation.

Definition at line 230 of file TrigByteStreamCnvSvc.cxx.

                                                               {
  // Get the EventContext via event store because the base class doesn't allow passing it explicitly as an argument
  // and we don't want to use ThreadLocalContext. Don't use ReadHandle here because it calls ThreadLocalContext if
  // not given a context (which we want to retrieve). This relies on IHiveWhiteBoard::selectStore being called on the
  // current thread before we arrive here (it is done in HltEventLoopMgr).
  const EventContext* eventContext = nullptr;
  if (m_evtStore->retrieve(eventContext).isFailure()) {
    ATH_MSG_ERROR("Failed to retrieve EventContext from the event store");
  }
  return eventContext;
}

dataProvider()

SmartIF< IDataProviderSvc > & AthCnvSvc::dataProvider ( ) const

virtualinherited

Implementation of IConverter: Get Data provider service.

Returns

Pointer to data provider service

Definition at line 212 of file AthCnvSvc.cxx.

{
  // FIXME: Ideally the return type should be const, but that would require
  //        changes in the Gaudi IConverter base class.
  SmartIF<IDataProviderSvc>& svc ATLAS_THREAD_SAFE =
    const_cast<SmartIF<IDataProviderSvc>&>(m_dataSvc);
  return svc;
}

disconnectOutput()

StatusCode AthCnvSvc::disconnectOutput ( const std::string &  output )

virtualinherited

Disconnect output files from the service.

Reimplemented in AthenaPoolCnvSvc.

Definition at line 437 of file AthCnvSvc.cxx.

{
  return StatusCode::SUCCESS;
}

fillObjRefs()

StatusCode AthCnvSvc::fillObjRefs ( IOpaqueAddress *  pAddress, DataObject *  pObject  )

virtualinherited

Implementation of IConverter: Resolve the references of the created transient object.

Definition at line 281 of file AthCnvSvc.cxx.

{
  return makeCall (FILL_OBJ_REFS, false, true, true, pAddress, pObject);
}

fillRepRefs()

StatusCode AthCnvSvc::fillRepRefs ( IOpaqueAddress *  pAddress, DataObject *  pObject  )

virtualinherited

Implementation of IConverter: Resolve the references of the converted object.

Reimplemented in Athena::NtupleCnvSvc, Athena::xAODCnvSvc, and AthenaPoolCnvSvc.

Definition at line 313 of file AthCnvSvc.cxx.

{
  return makeCall (FILL_REP_REFS, true, false, false, pAddress, pObject);
}

finalize()

StatusCode TrigByteStreamCnvSvc::finalize ( )

overridevirtual

Reimplemented from AthCnvSvc.

Definition at line 110 of file TrigByteStreamCnvSvc.cxx.

                                          {
  ATH_MSG_VERBOSE("start of " << __FUNCTION__);
  if (m_robDataProviderSvc.release().isFailure())
    ATH_MSG_WARNING("Failed to release service " << m_robDataProviderSvc.typeAndName());
  if (m_evtStore.release().isFailure())
    ATH_MSG_WARNING("Failed to release service " << m_evtStore.typeAndName());
  ATH_MSG_VERBOSE("end of " << __FUNCTION__);
  ATH_CHECK(ByteStreamCnvSvcBase::finalize());
  return StatusCode::SUCCESS;
}

getRawEvent() [1/2]

RawEventWrite * TrigByteStreamCnvSvc::getRawEvent ( )

overridevirtual

Return a pointer to the raw event for the current event context.

Implements IByteStreamEventAccess.

Definition at line 243 of file TrigByteStreamCnvSvc.cxx.

                                                 {
  const EventContext* eventContext = currentContext();
  if (eventContext == nullptr) return nullptr;
  return getRawEvent(*eventContext);
}

getRawEvent() [2/2]

RawEventWrite * TrigByteStreamCnvSvc::getRawEvent

(

const EventContext &

eventContext

)

const

Return a pointer to the raw event for the given event context.

Definition at line 250 of file TrigByteStreamCnvSvc.cxx.

                                                                                       {
  return m_rawEventWriteCache.get(eventContext)->get();
}

handle()

void ByteStreamCnvSvcBase::handle ( const Incident &  )

overridevirtualinherited

Implementation of IIncidentListener: Handle for EndEvent incidence.

Definition at line 63 of file ByteStreamCnvSvcBase.cxx.

                                                   {
   ServiceHandle<IClassIDSvc> clidSvc("ClassIDSvc", name());
   if (!clidSvc.retrieve().isSuccess()) {
      ATH_MSG_ERROR("Cannot get ClassIDSvc.");
      return;
   }
   // Initialize the converters
   for (const std::string& cnv : m_initCnvs) {
      ATH_MSG_DEBUG("Accessing Converter for " << cnv);
      CLID id;
      if (!clidSvc->getIDOfTypeName(cnv, id).isSuccess()) {
         ATH_MSG_WARNING("Cannot get CLID for " << cnv);
      } else {
         IConverter* cnv = converter(id);
         if (cnv == 0) {
        ATH_MSG_WARNING("Cannot get converter for " << cnv);
         } 
      }
   } 
   return;
}

initialize()

StatusCode TrigByteStreamCnvSvc::initialize ( )

overridevirtual

Required of all Gaudi Services.

Initialize the service.

Reimplemented from ByteStreamCnvSvcBase.

Definition at line 97 of file TrigByteStreamCnvSvc.cxx.

                                            {
  ATH_MSG_VERBOSE("start of " << __FUNCTION__);
  ATH_CHECK(ByteStreamCnvSvcBase::initialize());
  ATH_CHECK(m_evtStore.retrieve());
  ATH_CHECK(m_robDataProviderSvc.retrieve());
  if (!m_monTool.empty()) ATH_CHECK(m_monTool.retrieve());
  ATH_MSG_VERBOSE("end of " << __FUNCTION__);
  return StatusCode::SUCCESS;
}

initializeConverter()

StatusCode AthCnvSvc::initializeConverter ( long  typ, const CLID &  clid, IConverter *  cnv  )

protectedvirtualinherited

Initialize the new converter.

Definition at line 525 of file AthCnvSvc.cxx.

{
  if (cnv) {
    return cnv->initialize();
  }
  return Status::NO_CONVERTER;
}

interfaceID()

static const InterfaceID& IByteStreamEventAccess::interfaceID ( )

inlinestaticinherited

Gaudi interface id.

Definition at line 20 of file IByteStreamEventAccess.h.

{ return IID_IByteStreamEventAccess; }

loadConverter()

void AthCnvSvc::loadConverter ( DataObject *  pObject )

protectedvirtualinherited

Load converter or dictionary needed by the converter.

Definition at line 547 of file AthCnvSvc.cxx.

{
}

makeCall()

StatusCode AthCnvSvc::makeCall ( int  typ, bool  ignore_add, bool  ignore_obj, bool  update, IOpaqueAddress *&  pAddress, DataObject *&  pObject  )

protectedinherited

Definition at line 553 of file AthCnvSvc.cxx.

{
  if ( 0 != pAddress || ignore_add )    {
    if ( 0 != pObject  || ignore_obj )    {
      const CLID&  obj_class =
        (0 != pObject && !ignore_obj) ? pObject->clID() 
        : (0 != pAddress && !ignore_add)
        ? pAddress->clID()                       
        : CLID_NULL;
      IConverter*  cnv  = converter(obj_class);
      if ( !cnv && pObject ) {
        //Give it a try to autoload the class (dictionary) for which the converter is needed
        loadConverter( pObject);
        cnv  = converter(obj_class);
      }
      
      StatusCode status(StatusCode::FAILURE);
      if ( 0 != cnv )   {
        switch(typ)   {
        case CREATE_OBJ:
          status = cnv->createObj(pAddress, pObject);
          break;
        case FILL_OBJ_REFS:
          status = cnv->fillObjRefs(pAddress, pObject);
          break;
        case UPDATE_OBJ:
          status = cnv->updateObj(pAddress, pObject);
          break;
        case UPDATE_OBJ_REFS:
          status = cnv->updateObjRefs(pAddress, pObject);
          break;
        case CREATE_REP:
          status = cnv->createRep(pObject, pAddress);
          break;
        case FILL_REP_REFS:
          status = cnv->fillRepRefs(pAddress, pObject);
          break;
        case UPDATE_REP:
          status = cnv->updateRep(pAddress, pObject);
          break;
        case UPDATE_REP_REFS:
          status = cnv->updateRepRefs(pAddress, pObject);
          break;
        default:
          status = StatusCode::FAILURE;
          break;
        }
        if ( status.isSuccess() && update )   {
          status = updateServiceState(pAddress);
        }
        return status;
      }
      status.ignore();
      msg(MSG::INFO) << "No converter for object ";
      if ( pObject != 0 )   {
        msg(MSG::INFO) << System::typeinfoName(typeid(*pObject));
      }
      msg(MSG::INFO) << "  CLID= " << obj_class << endmsg;
      return Status::NO_CONVERTER;
    }
    return Status::INVALID_OBJECT;
  }
  return Status::INVALID_ADDRESS;
}

monitorRawEvent()

void TrigByteStreamCnvSvc::monitorRawEvent ( const std::unique_ptr< uint32_t[]> &  rawEventPtr ) const

private

Fill histograms from contents of a FullEventFragment.

Definition at line 266 of file TrigByteStreamCnvSvc.cxx.

                                                                                             {
  // Create a read fragment from the pointer
  eformat::read::FullEventFragment rawEvent(rawEventPtr.get());
 
  // Monitor error code
  if (rawEvent.nstatus() > 1) {
    HLT::OnlineErrorCode errorCode = static_cast<HLT::OnlineErrorCode>(rawEvent.status()[1]);
    std::ostringstream ss;
    ss << errorCode;
    auto monOnlineErrorCode = Monitored::Scalar<std::string>("OnlineErrorCode", ss.str());
    Monitored::Group(m_monTool, monOnlineErrorCode);
  }
 
  // Decode stream tags
  std::vector<eformat::helper::StreamTag> streamTags;
  try {
    eformat::helper::decode(rawEvent.nstream_tag(), rawEvent.stream_tag(), streamTags);
  }
  catch (const std::exception& ex) {
    ATH_MSG_ERROR("StreamTag decoding failed, caught an unexpected std::exception " << ex.what());
    return;
  }
  catch (...) {
    ATH_MSG_ERROR("StreamTag decoding failed, caught an unexpected exception");
    return;
  }
 
  // Get HLT result sizes
  std::vector<eformat::read::ROBFragment> robs;
  rawEvent.robs(robs);
  std::vector<uint16_t> resultSizeMap_moduleID;
  std::vector<uint32_t> resultSizeMap_size;
  uint32_t totalSizeWords = 0;
  try {
    for (const eformat::read::ROBFragment& rob : robs) {
      eformat::helper::SourceIdentifier sid(rob.rob_source_id());
      if (sid.subdetector_id() != eformat::SubDetector::TDAQ_HLT)
        continue;
      const uint16_t module_id = sid.module_id();
      const uint32_t size = rob.fragment_size_word();
      totalSizeWords += size;
      if (!contains(resultSizeMap_moduleID, module_id)) {
        resultSizeMap_moduleID.push_back(module_id);
        resultSizeMap_size.push_back(size);
      }
      else {
        ATH_MSG_ERROR("HLT result ROB monitoring found multiple HLT ROBs with the same module ID " << module_id);
      }
    }
  }
  catch (const std::exception& ex) {
    ATH_MSG_ERROR("HLT result ROB monitoring failed, caught an unexpected std::exception " << ex.what());
    return;
  }
  catch (...) {
    ATH_MSG_ERROR("HLT result ROB monitoring failed, caught an unexpected exception");
    return;
  }
 
  // Fill helper containers for monitoring
  std::vector<std::string> sdFromRobList;
  std::vector<std::string> sdFromSubDetList;
  std::vector<std::string> streamTagCorrA;
  std::vector<std::string> streamTagCorrB;
  std::vector<float> streamResultSize; // Correlated with streamTags vector
  streamTagCorrA.reserve(streamTags.size() * streamTags.size());
  streamTagCorrB.reserve(streamTags.size() * streamTags.size());
  streamResultSize.reserve(streamTags.size());
  for (const eformat::helper::StreamTag& st : streamTags) {
    bool hasHLTSubDet = st.dets.find(eformat::SubDetector::TDAQ_HLT) != st.dets.end();
    bool includeAll = st.robs.empty() && (st.dets.empty() || hasHLTSubDet);
    // includeAll means a stream with full event building or all HLT results included
    uint32_t sizeWords = includeAll ? totalSizeWords : 0;
    for (const eformat::SubDetector sd : st.dets) {
      const std::string& detName = eformat::helper::SubDetectorDictionary.string(sd);
      if (!contains(sdFromSubDetList, detName)) sdFromSubDetList.push_back(detName);
    }
    for (const uint32_t robid : st.robs) {
      eformat::helper::SourceIdentifier sid(robid);
      const std::string& detName = sid.human_detector();
      if (!contains(sdFromRobList, detName)) sdFromRobList.push_back(detName);
      if (!includeAll && sid.subdetector_id() == eformat::SubDetector::TDAQ_HLT) {
        if (const int ix = index(resultSizeMap_moduleID, sid.module_id()); ix >= 0) {
          sizeWords += resultSizeMap_size[ix];
        }
        else {
          ATH_MSG_WARNING("Stream tag " << st.type << "_" << st.name << " declares " << sid.human()
                          << " in ROB list, but the ROBFragment is missing");
        }
      }
    }
    streamResultSize.push_back(sizeWords*wordsToKiloBytes);
    for (const eformat::helper::StreamTag& st2 : streamTags) {
      streamTagCorrA.push_back(mon_streamTypeName(st));
      streamTagCorrB.push_back(mon_streamTypeName(st2));
    }
  }
 
  // General stream tag monitoring
  auto monStreamTagsNum         = Monitored::Scalar<size_t>("StreamTagsNum", streamTags.size());
  auto monStreamTags            = Monitored::Collection("StreamTags", streamTags, mon_streamTypeName);
  auto monStreamTagsType        = Monitored::Collection("StreamTagsType", streamTags, mon_streamType);
  auto monStreamTagCorrA        = Monitored::Collection("StreamTagCorrA", streamTagCorrA);
  auto monStreamTagCorrB        = Monitored::Collection("StreamTagCorrB", streamTagCorrB);
  // PEB stream tag monitoring
  auto monStreamIsPeb           = Monitored::Collection("StreamTagIsPeb", streamTags, mon_streamIsPeb);
  auto monPebRobsNum            = Monitored::Collection("StreamTagsPebRobsNum", streamTags, mon_streamPebRobsNum);
  auto monPebSubDetsNum         = Monitored::Collection("StreamTagsPebSubDetsNum", streamTags, mon_streamPebSubDetsNum);
  auto monSubDetsFromRobList    = Monitored::Collection("StreamTagsPebSubDetsFromRobList", sdFromRobList);
  auto monSubDetsFromSubDetList = Monitored::Collection("StreamTagsPebSubDetsFromSubDetList", sdFromSubDetList);
  // Result size monitoring
  auto monResultSizeTotal       = Monitored::Scalar<float>("ResultSizeTotal", totalSizeWords*wordsToKiloBytes);
  auto monResultSizeFullEvFrag  = Monitored::Scalar<float>("ResultSizeFullEvFrag", rawEvent.fragment_size_word()*wordsToKiloBytes);
  auto monResultCollModuleID    = Monitored::Collection("ResultModuleID", resultSizeMap_moduleID);
  auto monResultCollModuleSize  = Monitored::Collection("ResultModuleSize", resultSizeMap_size, [](uint32_t sw){return sw*wordsToKiloBytes;});
  auto monResultSizeByStream    = Monitored::Collection("ResultSizeStream", streamResultSize);
  // Collect all variables
  Monitored::Group(m_monTool, monStreamTagsNum, monStreamTags, monStreamTagsType, monStreamTagCorrA,
                   monStreamTagCorrB, monStreamIsPeb, monPebRobsNum, monPebSubDetsNum, monSubDetsFromRobList,
                   monSubDetsFromSubDetList, monResultSizeTotal, monResultSizeFullEvFrag, monResultCollModuleID,
                   monResultCollModuleSize, monResultSizeByStream);
}

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);
  }

objType()

const CLID & AthCnvSvc::objType ( ) const

inherited

Implementation of IConverter: dummy call.

Definition at line 179 of file AthCnvSvc.cxx.

{
  return CLID_NULL;
}

printRawEvent()

void TrigByteStreamCnvSvc::printRawEvent ( const EventContext &  eventContext ) const

private

Print contents of the raw event.

Definition at line 390 of file TrigByteStreamCnvSvc.cxx.

                                                                               {
  RawEventWrite* re = getRawEvent(eventContext);
 
  if (!re) {
    ATH_MSG_WARNING("RawEventWrite pointer is null");
    return;
  }
  std::ostringstream ss;
  ss << "Dumping header of the FullEventFragment with HLT result:" << std::endl;
  ss << "--> status              = "
     << printNWordsHex<uint32_t>(re->nstatus(), re->status())
     << std::endl;
  ss << "--> source_id           = " << printWordHex<uint32_t>(re->source_id()) << std::endl;
  ss << "--> checksum_type       = " << printWordHex<uint32_t>(re->checksum_type()) << std::endl;
  ss << "--> compression_type    = " << printWordHex<uint32_t>(re->compression_type()) << std::endl;
  ss << "--> compression_level   = " << re->compression_level() << std::endl;
  ss << "--> bc_time_seconds     = " << re->bc_time_seconds() << std::endl;
  ss << "--> bc_time_nanoseconds = " << re->bc_time_nanoseconds() << std::endl;
  ss << "--> global_id           = " << re->global_id() << std::endl;
  ss << "--> run_type            = " << re->run_type() << std::endl;
  ss << "--> run_no              = " << re->run_no() << std::endl;
  ss << "--> lumi_block          = " << re->lumi_block() << std::endl;
  ss << "--> lvl1_id             = " << re->lvl1_id() << std::endl;
  ss << "--> bc_id               = " << re->bc_id() << std::endl;
  ss << "--> lvl1_trigger_type   = " << printWordHex<uint8_t>(re->lvl1_trigger_type()) << std::endl;
  ss << "--> lvl1_trigger_info   = "
     << printNWordsHex<uint32_t>(re->nlvl1_trigger_info(), re->lvl1_trigger_info())
     << std::endl;
  ss << "--> lvl2_trigger_info   = "
     << printNWordsHex<uint32_t>(re->nlvl2_trigger_info(), re->lvl2_trigger_info())
     << std::endl;
  ss << "--> event_filter_info   = "
     << printNWordsHex<uint32_t>(re->nevent_filter_info(), re->event_filter_info())
     << std::endl;
  ss << "--> hlt_info            = "
     << printNWordsHex<uint32_t>(re->nhlt_info(), re->hlt_info())
     << std::endl;
 
  std::vector<eformat::helper::StreamTag> stream_tags;
  try {
    eformat::helper::decode(re->nstream_tag(), re->stream_tag(), stream_tags);
  }
  catch (const std::exception& ex) {
    ATH_MSG_ERROR("StreamTag decoding failed, caught an unexpected std::exception " << ex.what());
    return;
  }
  catch (...) {
    ATH_MSG_ERROR("StreamTag decoding failed, caught an unexpected exception");
    return;
  }
  ss << "--> stream_tags         = ";
  bool first = true;
  for (const auto& st : stream_tags) {
    if (first) first=false;
    else ss << "                          ";
    ss << "{" << st.name << ", " << st.type << ", obeysLB=" << st.obeys_lumiblock << ", robs=[";
    for (const auto& robid : st.robs) ss << printWordHex<uint32_t>(robid) << ", ";
    ss << "], dets = [";
    for (const auto& detid : st.dets) ss << printWordHex<uint8_t>(detid) << ", ";
    ss << "]}" << std::endl;
  }
 
  ATH_MSG_DEBUG(ss.str());
}

queryInterface()

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

overridevirtualinherited

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

Reimplemented from AthCnvSvc.

Reimplemented in ByteStreamCnvSvc.

Definition at line 42 of file ByteStreamCnvSvcBase.cxx.

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

removeConverter()

StatusCode AthCnvSvc::removeConverter ( const CLID &  clid )

virtualinherited

Remove converter object from conversion service (if present).

Definition at line 379 of file AthCnvSvc.cxx.

{
  Workers::iterator worker = m_workers.find (clid);
  if ( worker != m_workers.end() ) {
    worker->second.converter()->finalize().ignore();
    worker->second.converter()->release();
 
    m_workers.erase (worker);
    return StatusCode::SUCCESS;
  }
  return Status::NO_CONVERTER;
}

repSvcType()

long AthCnvSvc::repSvcType ( ) const

virtualinherited

Retrieve the class type of the data store the converter uses.

Definition at line 172 of file AthCnvSvc.cxx.

{
  return m_type;
}

setAddressCreator()

StatusCode AthCnvSvc::setAddressCreator ( IAddressCreator *  creator )

virtualinherited

Set address creator facility.

Definition at line 243 of file AthCnvSvc.cxx.

{
  m_addressCreator = creator;
  Workers::iterator stop  = m_workers.end();
  Workers::iterator start = m_workers.begin();
  for(Workers::iterator i=start; i != stop; ++i )    {
    IConverter* cnv = i->second.converter();
    if ( 0 != cnv )   {
      if (cnv->setAddressCreator(m_addressCreator).isFailure()) {
        ATH_MSG_ERROR ("setting Address Creator");
      }
    }
  }
  return StatusCode::SUCCESS;
}

setConversionSvc()

StatusCode AthCnvSvc::setConversionSvc ( IConversionSvc *  svc )

virtualinherited

Implementation of IConverter: Set conversion service the converter is connected to.

Definition at line 224 of file AthCnvSvc.cxx.

{
  return StatusCode::FAILURE;
}

setDataProvider()

StatusCode AthCnvSvc::setDataProvider ( IDataProviderSvc *  pDataSvc )

virtualinherited

Implementation of IConverter: Set Data provider service.

Returns

Status code indicating success or failure

Parameters

pService

Pointer to data provider service

Definition at line 189 of file AthCnvSvc.cxx.

{
  if ( !pDataSvc ) return StatusCode::SUCCESS; //Atlas does not use DataSvc
  if ( m_dataSvc ) m_dataSvc->release();
  m_dataSvc = pDataSvc;
  m_dataSvc->addRef();
  Workers::iterator stop  = m_workers.end();
  Workers::iterator start = m_workers.begin();
  for(Workers::iterator i=start; i != stop; ++i )    {
    IConverter* cnv = i->second.converter();
    if ( 0 != cnv )   {
      if (cnv->setDataProvider(m_dataSvc).isFailure()) {
        ATH_MSG_ERROR ("setting Data Provider");
      }
    }
  }
  return StatusCode::SUCCESS;
}

setRawEvent()

RawEventWrite * TrigByteStreamCnvSvc::setRawEvent ( std::unique_ptr< RawEventWrite > &&  rawEventWrite, const EventContext &  eventContext  )

private

Store new raw event in the cache.

Definition at line 255 of file TrigByteStreamCnvSvc.cxx.

                                                                                                                               {
  *(m_rawEventWriteCache.get(eventContext)) = std::move(rawEventWrite);
  return getRawEvent(eventContext);
}

updateObj()

StatusCode AthCnvSvc::updateObj ( IOpaqueAddress *  pAddress, DataObject *  refpObject  )

virtualinherited

Implementation of IConverter: Update the transient object from the other representation.

Definition at line 289 of file AthCnvSvc.cxx.

{
  return makeCall (UPDATE_OBJ, false, true, false, pAddress, pObject);
}

updateObjRefs()

StatusCode AthCnvSvc::updateObjRefs ( IOpaqueAddress *  pAddress, DataObject *  pObject  )

virtualinherited

Implementation of IConverter: Update the references of an updated transient object.

Definition at line 297 of file AthCnvSvc.cxx.

{
  return makeCall (UPDATE_OBJ_REFS, false, true, true, pAddress, pObject);
}

updateRep()

StatusCode AthCnvSvc::updateRep ( IOpaqueAddress *  pAddress, DataObject *  pObject  )

virtualinherited

Implementation of IConverter: Update the converted representation of a transient object.

Definition at line 321 of file AthCnvSvc.cxx.

{
  return makeCall (UPDATE_REP, true, false, false, pAddress, pObject);
}

updateRepRefs()

StatusCode AthCnvSvc::updateRepRefs ( IOpaqueAddress *  pAddress, DataObject *  pObject  )

virtualinherited

Implementation of IConverter: Update the references of an already converted object.

Definition at line 329 of file AthCnvSvc.cxx.

{
  return makeCall (UPDATE_REP_REFS, true, false, false, pAddress, pObject);
}

updateServiceState()

StatusCode ByteStreamCnvSvcBase::updateServiceState ( IOpaqueAddress *  pAddress )

overridevirtualinherited

Checks whether an IOpaqueAddress is a GenericAddress.

Reimplemented from AthCnvSvc.

Definition at line 53 of file ByteStreamCnvSvcBase.cxx.

                                                                            {
   if (pAddress != 0) {
      GenericAddress* pAddr = dynamic_cast<GenericAddress*>(pAddress);
      if (pAddr != 0) {
         return(StatusCode::SUCCESS);
      }
   }
   return(StatusCode::FAILURE);
}

Member Data Documentation

m_addressCreator

SmartIF<IAddressCreator> AthCnvSvc::m_addressCreator

protectedinherited

Pointer to the address creation service interface.

Definition at line 315 of file AthCnvSvc.h.

m_cnvSvc

SmartIF<IConversionSvc> AthCnvSvc::m_cnvSvc

protectedinherited

Pointer to the IConversionSvc interface of this.

Definition at line 317 of file AthCnvSvc.h.

m_conv_mut

CallMutex AthCnvSvc::m_conv_mut

protectedinherited

Definition at line 324 of file AthCnvSvc.h.

m_dataSvc

SmartIF<IDataProviderSvc> AthCnvSvc::m_dataSvc

protectedinherited

Pointer to data provider service.

Definition at line 313 of file AthCnvSvc.h.

m_evtStore

ServiceHandle<StoreGateSvc> TrigByteStreamCnvSvc::m_evtStore {this, "EventStore", "StoreGateSvc"}

private

Definition at line 65 of file TrigByteStreamCnvSvc.h.

m_initCnvs

std::vector<std::string> ByteStreamCnvSvcBase::m_initCnvs

protectedinherited

Definition at line 40 of file ByteStreamCnvSvcBase.h.

m_isCalibration

Gaudi::Property<bool> ByteStreamCnvSvcBase::m_isCalibration {this, "IsCalibration", false}

privateinherited

flags for Calibration EventType

Definition at line 55 of file ByteStreamCnvSvcBase.h.

m_isSimulation

Gaudi::Property<bool> ByteStreamCnvSvcBase::m_isSimulation {this, "IsSimulation", false}

privateinherited

flags for Simulation EventType

Definition at line 51 of file ByteStreamCnvSvcBase.h.

m_isTestbeam

Gaudi::Property<bool> ByteStreamCnvSvcBase::m_isTestbeam {this, "IsTestbeam", false}

privateinherited

flags for TestBeam EventType

Definition at line 53 of file ByteStreamCnvSvcBase.h.

m_monTool

ToolHandle<GenericMonitoringTool> TrigByteStreamCnvSvc::m_monTool {this, "MonTool", "" , "Monitoring tool"}

private

Definition at line 67 of file TrigByteStreamCnvSvc.h.

m_rawEventWriteCache

SG::SlotSpecificObj<std::unique_ptr<RawEventWrite> > TrigByteStreamCnvSvc::m_rawEventWriteCache

private

Definition at line 70 of file TrigByteStreamCnvSvc.h.

m_robDataProviderSvc

ServiceHandle<IROBDataProviderSvc> TrigByteStreamCnvSvc::m_robDataProviderSvc {this, "ROBDataProvider", "ROBDataProviderSvc"}

private

Definition at line 66 of file TrigByteStreamCnvSvc.h.

m_ROD2ROBmap

Gaudi::Property<std::vector<std::string> > ByteStreamCnvSvcBase::m_ROD2ROBmap {this,"ROD2ROBmap",{},"","OrderedSet<std::string>"}

protectedinherited

Definition at line 42 of file ByteStreamCnvSvcBase.h.

m_type

long AthCnvSvc::m_type

protectedinherited

Conversion service type.

Definition at line 319 of file AthCnvSvc.h.

m_workers

Workers AthCnvSvc::m_workers

protectedinherited

List of conversion workers.

Definition at line 321 of file AthCnvSvc.h.

---

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

• TrigByteStreamCnvSvc.h
• TrigByteStreamCnvSvc.cxx