AthCnvSvc Class Reference

#include <AthenaBaseComps/AthCnvSvc.h>

Inheritance diagram for AthCnvSvc:

Collaboration diagram for AthCnvSvc:

Classes
class	WorkerEntry

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

Public Member Functions
	AthCnvSvc (const std::string &name, ISvcLocator *pSvcLocator, long type)
	Constructor with parameters: More...
virtual StatusCode	initialize ()
	Gaudi Service Implementation. More...
virtual StatusCode	finalize ()
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
MsgStream &	msg () const
MsgStream &	msg (const MSG::Level lvl) const
bool	msgLvl (const MSG::Level lvl) const

Friends
class	SvcFactory< AthCnvSvc >

@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	connectOutput (const std::string &outputFile, const std::string &openMode)
	Connect the output file to the service with open mode. More...
virtual StatusCode	connectOutput (const std::string &output)
	Connect the output file to the service. More...
virtual StatusCode	commitOutput (const std::string &output, bool do_commit)
	Commit pending output. More...
virtual StatusCode	disconnectOutput (const std::string &output)
	Disconnect output files from the service. More...

@c IAddressCreator interface implementation
typedef std::recursive_mutex	CallMutex
	Mutex to protect Converter creation. 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
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	convertAddress (const IOpaqueAddress *pAddress, std::string &refAddress)
	Convert an address to string form. 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	updateServiceState (IOpaqueAddress *pAddress)
	Update state of the service. More...
	AthCnvSvc ()
	Default constructor: More...
	AthCnvSvc (const AthCnvSvc &)
AthCnvSvc &	operator= (const AthCnvSvc &)
virtual	~AthCnvSvc ()
	Destructor: 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...
virtual SmartIF< IAddressCreator > &	addressCreator ()
	Retrieve address creation interface. More...
StatusCode	makeCall (int typ, bool ignore_add, bool ignore_obj, bool update, IOpaqueAddress *&pAddress, DataObject *&pObject)

Detailed Description

Base class for all conversion services. It manages a set of Converters that are specialized for conversions of specific objects.

This supports self learning converters: User hooks include the following (overridable) entries:

• findCnvFactory: returns a suitable converter factory
• createConverter: the actual converter creation
• configureConverter: configure converter before initialize
• initializeConverter: initializes the converter
• activateConverter: any additional configuration to be done after initialize.

configureConverter and activateConverter are user hooks, where the converter can be manipulated by the hosting service and knowledge can be supplied, which a "generic" converter cannot acquire itself.

These hooks allow any sub-classed conversion service to override the calls and create converters, which acquire the knowledge about their persistency type and the object type they convert during the initialization.

Only AFTER these three steps the converter must satisfy the storage type of the hosting service and the class type of the required object type.

Author

Markus Frank

Version

1.0

Definition at line 63 of file AthCnvSvc.h.

Member Typedef Documentation

CallMutex

typedef std::recursive_mutex AthCnvSvc::CallMutex

protected

Mutex to protect Converter creation.

Definition at line 323 of file AthCnvSvc.h.

Workers

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

Definition at line 106 of file AthCnvSvc.h.

Constructor & Destructor Documentation

AthCnvSvc() [1/3]

AthCnvSvc::AthCnvSvc	(	const std::string &	name,
		ISvcLocator *	pSvcLocator,
		long	type
	)

Constructor with parameters:

Definition at line 46 of file AthCnvSvc.cxx.

                                 : 
  ::AthService (name, pSvcLocator),
  m_dataSvc    (0),
  m_addressCreator(0),
  m_type       (type),
  m_workers    ( )
{
  //
  // Property declaration
  // 
  //declareProperty( "Property", m_nProperty );
  AthCnvSvc::setAddressCreator(this).ignore();
 
  m_cnvSvc = this;
}

AthCnvSvc() [2/3]

AthCnvSvc::AthCnvSvc ( )

private

Default constructor:

AthCnvSvc() [3/3]

AthCnvSvc::AthCnvSvc ( const AthCnvSvc &  )

private

~AthCnvSvc()

AthCnvSvc::~AthCnvSvc ( )

protectedvirtual

Destructor:

Definition at line 66 of file AthCnvSvc.cxx.

{ 
  // the following is hopefully (!) temporary hack to prevent deleting
  // services we hold a reference count to.
  // the problem is that these references might point back to us (so we
  // end up recursively calling the d-tor) or be double-deleted later on
  // by the ServiceManager.
  // the correct fix is to have everybody use SmartIF<T> all over the code...
  //
  // "temporary hack" ha ha! (CGL 5/2014)
  //
  if (m_cnvSvc) {
    m_cnvSvc->addRef();
    m_cnvSvc = 0;
  }
  if (m_addressCreator) {
    m_addressCreator->addRef();
    m_addressCreator = 0;
  }
  if (m_dataSvc) {
    m_dataSvc->addRef();
    m_dataSvc = 0;
  }
 
  ATH_MSG_DEBUG ("release-ing all workers (" << m_workers.size() << ")...");
  for ( Workers::iterator
      i    = m_workers.begin(),
      iend = m_workers.end();
    i != iend;
    ++i ) {
    IConverter *cnv = i->second.m_converter;
    if (cnv) {
      
      if (!cnv->release()) {
        i->second.m_converter = 0;
      }
    }
  }
  ATH_MSG_DEBUG ("release-ing all workers (" << m_workers.size() << ")... [done]");
  m_workers.clear();
 
}

Member Function Documentation

activateConverter()

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

protectedvirtual

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 )

virtual

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 )

virtual

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 ( )

inlineprotectedvirtual

Retrieve address creation interface.

Definition at line 300 of file AthCnvSvc.h.

  {
    return m_addressCreator;
  }

addressCreator() [2/2]

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

virtual

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

commitOutput()

StatusCode AthCnvSvc::commitOutput ( const std::string &  output, bool  do_commit  )

virtual

Commit pending output.

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

Definition at line 429 of file AthCnvSvc.cxx.

{
  return StatusCode::SUCCESS;
}

configureConverter()

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

protectedvirtual

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/2]

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

virtual

Connect the output file to the service.

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

Definition at line 422 of file AthCnvSvc.cxx.

{
  return StatusCode::SUCCESS;
}

connectOutput() [2/2]

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

virtual

Connect the output file to the service with open mode.

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

Definition at line 414 of file AthCnvSvc.cxx.

{
  return connectOutput (outputFile);
}

conversionSvc()

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

virtual

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  )

virtual

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 )

virtual

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  )

virtual

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  )

virtual

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  )

protectedvirtual

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  )

virtual

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  )

virtual

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

dataProvider()

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

virtual

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 )

virtual

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  )

virtual

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  )

virtual

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 AthCnvSvc::finalize ( )

virtual

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

Definition at line 116 of file AthCnvSvc.cxx.

{
  ATH_MSG_DEBUG ("releasing all workers");
  for ( Workers::iterator 
      i    = m_workers.begin(),
      iend = m_workers.end();
    i != iend;
    ++i ) {
    if (!i->second.converter()->finalize().isSuccess()) {
      ATH_MSG_ERROR ("finalizing worker w/ clid=[" << i->first << "]");
    }
    i->second.converter()->release();
  }
  //m_workers.clear();
  Workers().swap (m_workers);
 
  if (m_addressCreator) m_addressCreator->addRef();
  if (m_dataSvc) m_dataSvc->addRef();
  if (m_cnvSvc) m_cnvSvc->addRef();
 
  m_addressCreator = 0;
  m_dataSvc = 0;
  m_cnvSvc = 0;
 
  return StatusCode::SUCCESS;
}

initialize()

StatusCode AthCnvSvc::initialize ( )

virtual

Gaudi Service Implementation.

Reimplemented in ByteStreamCnvSvc, TrigByteStreamCnvSvc, ByteStreamCnvSvcBase, Athena::NtupleCnvSvc, Athena::xAODCnvSvc, AthenaPoolCnvSvc, Athena::RootCnvSvc, and MuonCalibStreamCnvSvc.

Definition at line 111 of file AthCnvSvc.cxx.

{
  return StatusCode::SUCCESS;
}

initializeConverter()

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

protectedvirtual

Initialize the new converter.

Definition at line 525 of file AthCnvSvc.cxx.

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

loadConverter()

void AthCnvSvc::loadConverter ( DataObject *  pObject )

protectedvirtual

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  )

protected

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

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

Implementation of IConverter: dummy call.

Definition at line 179 of file AthCnvSvc.cxx.

{
  return CLID_NULL;
}

operator=()

AthCnvSvc& AthCnvSvc::operator= ( const AthCnvSvc &  )

private

queryInterface()

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

virtual

Reimplemented in ByteStreamCnvSvc, ByteStreamCnvSvcBase, AthenaPoolCnvSvc, Athena::NtupleCnvSvc, Athena::xAODCnvSvc, Athena::RootCnvSvc, and MuonCalibStreamCnvSvc.

Definition at line 149 of file AthCnvSvc.cxx.

{
  if ( riid == IConversionSvc::interfaceID() )  {
    *ppvInterface = (IConversionSvc*)this;
  }
  else if ( riid == IConverter::interfaceID() )  {
    *ppvInterface = (IConverter*)this;
  }
  else if ( riid == IAddressCreator::interfaceID() )  {
    *ppvInterface = (IAddressCreator*)this;
  }
  else  {
    // Interface is not directly available: try out a base class
    return AthService::queryInterface(riid, ppvInterface);
  }
  addRef();
  return StatusCode::SUCCESS;
}

removeConverter()

StatusCode AthCnvSvc::removeConverter ( const CLID &  clid )

virtual

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

virtual

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 )

virtual

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 )

virtual

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 )

virtual

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

updateObj()

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

virtual

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  )

virtual

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  )

virtual

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  )

virtual

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 AthCnvSvc::updateServiceState ( IOpaqueAddress *  pAddress )

virtual

Update state of the service.

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

Definition at line 479 of file AthCnvSvc.cxx.

{
  return StatusCode::SUCCESS;
}

Friends And Related Function Documentation

SvcFactory< AthCnvSvc >

friend class SvcFactory< AthCnvSvc >

friend

Definition at line 1 of file AthCnvSvc.h.

Member Data Documentation

m_addressCreator

SmartIF<IAddressCreator> AthCnvSvc::m_addressCreator

protected

Pointer to the address creation service interface.

Definition at line 315 of file AthCnvSvc.h.

m_cnvSvc

SmartIF<IConversionSvc> AthCnvSvc::m_cnvSvc

protected

Pointer to the IConversionSvc interface of this.

Definition at line 317 of file AthCnvSvc.h.

m_conv_mut

CallMutex AthCnvSvc::m_conv_mut

protected

Definition at line 324 of file AthCnvSvc.h.

m_dataSvc

SmartIF<IDataProviderSvc> AthCnvSvc::m_dataSvc

protected

Pointer to data provider service.

Definition at line 313 of file AthCnvSvc.h.

m_type

long AthCnvSvc::m_type

protected

Conversion service type.

Definition at line 319 of file AthCnvSvc.h.

m_workers

Workers AthCnvSvc::m_workers

protected

List of conversion workers.

Definition at line 321 of file AthCnvSvc.h.

---

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

• AthCnvSvc.h
• AthCnvSvc.cxx