Athena::xAODCnvSvc Class Reference

#include <xAODCnvSvc.h>

Inheritance diagram for Athena::xAODCnvSvc:

Collaboration diagram for Athena::xAODCnvSvc:

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

Public Member Functions
	xAODCnvSvc (const std::string &name, ISvcLocator *pSvcLocator)
	Constructor with parameters: More...
virtual	~xAODCnvSvc ()
	Destructor: More...
virtual StatusCode	initialize ()
	Gaudi Service Implementation. More...
virtual StatusCode	finalize ()
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
virtual StatusCode	updateServiceState (IOpaqueAddress *pAddress)
	IConversionSvc and IConverter interfaces More...
virtual StatusCode	createObj (IOpaqueAddress *pAddress, DataObject *&refpObject)
	Implementation of IConverter: Create the transient representation of an object from persistent state. 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	connectOutput (const std::string &outputConnectionSpec, const std::string &openMode)
	Connect the output connection specification to the service with open mode. More...
virtual StatusCode	connectOutput (const std::string &outputConnectionSpec)
	Connect the output connection specification to the service with open mode. More...
virtual StatusCode	commitOutput (const std::string &outputConnectionSpec, bool doCommit)
	Commit pending output. More...
virtual StatusCode	createAddress (long svcType, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
	IAddressCreator interfaces More...
virtual StatusCode	convertAddress (const IOpaqueAddress *pAddress, std::string &refAddress)
	Convert address to string form. More...
virtual StatusCode	createAddress (long svcType, const CLID &clid, const std::string &refAddress, IOpaqueAddress *&refpAddress)
	Create address from string form. More...
MsgStream &	msg () const
MsgStream &	msg (const MSG::Level lvl) const
bool	msgLvl (const MSG::Level lvl) const
@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	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	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...
@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	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	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 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	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	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...

Static Public Member Functions
static const InterfaceID &	interfaceID ()

Protected Member Functions
virtual IConverter *	createConverter (long typ, const CLID &clid, const ICnvFactory *fac)
	Create new Converter using factory (override AthCnvSvc::createConverter) More...

Private Member Functions
	xAODCnvSvc ()
	Default constructor: More...

Friends
class	SvcFactory< Athena::xAODCnvSvc >

@c IAddressCreator interface implementation
virtual SmartIF< IAddressCreator > &	addressCreator ()
	Retrieve address creation interface. 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)
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

Detailed Description

Definition at line 29 of file xAODCnvSvc.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

xAODCnvSvc() [1/2]

Athena::xAODCnvSvc::xAODCnvSvc	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Constructor with parameters:

Definition at line 35 of file xAODCnvSvc.cxx.

                                                       : 
  ::AthCnvSvc( name, pSvcLocator, POOL_ROOTTREE_StorageType )
{
  //
  // Property declaration
  // 
  //declareProperty( "Property", m_nProperty );
 
  // std::cerr << "::xAODCnvSvc(" << name << ")...\n";
}

~xAODCnvSvc()

Athena::xAODCnvSvc::~xAODCnvSvc ( )

virtual

Destructor:

Definition at line 49 of file xAODCnvSvc.cxx.

{}

xAODCnvSvc() [2/2]

Athena::xAODCnvSvc::xAODCnvSvc ( )

private

Default constructor:

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

commitOutput()

StatusCode Athena::xAODCnvSvc::commitOutput ( const std::string &  outputConnectionSpec, bool  doCommit  )

virtual

Commit pending output.

Reimplemented from AthCnvSvc.

Definition at line 196 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("::commitOutput(" << outputConnectionSpec
               << ", " << doCommit << ")...");
  return StatusCode::SUCCESS;
}

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

StatusCode Athena::xAODCnvSvc::connectOutput ( const std::string &  outputConnectionSpec )

virtual

Connect the output connection specification to the service with open mode.

Parameters

outputConnectionSpec

[IN] the name of the output connection specification as string.

Reimplemented from AthCnvSvc.

Definition at line 182 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("::connectOutput(" 
                << outputConnectionSpec << ")");
  // std::cerr << "::connectOutput(" << outputConnectionSpec << ")...\n";
  TFile *f = TFile::Open(outputConnectionSpec.c_str(), "recreate");
  if (f == 0) {
    return StatusCode::FAILURE;
  }
  return StatusCode::SUCCESS;
}

connectOutput() [2/2]

StatusCode Athena::xAODCnvSvc::connectOutput ( const std::string &  outputConnectionSpec, const std::string &  openMode  )

virtual

Connect the output connection specification to the service with open mode.

Parameters

outputConnectionSpec	[IN] the name of the output connection specification as string.
openMode	[IN] the open mode of the file as string.

Reimplemented from AthCnvSvc.

Definition at line 162 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("::connectOutput(" 
                << outputConnectionSpec << ", " 
                << openMode << ")");
  // std::cerr << "::connectOutput(" << outputConnectionSpec << ", openmode="
  //       << openMode << ")...\n";
  TFile *f = TFile::Open(outputConnectionSpec.c_str(), "recreate");
  if (f == 0) {
    return StatusCode::FAILURE;
  }
 
  return StatusCode::SUCCESS;
}

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 Athena::xAODCnvSvc::convertAddress ( const IOpaqueAddress *  pAddress, std::string &  refAddress  )

virtual

Convert address to string form.

Parameters

pAddress	[IN] address to be converted.
refAddress	[OUT] converted string form.

Reimplemented from AthCnvSvc.

Definition at line 233 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("::convertAddress(" << pAddress << ", " 
                << refAddress << ")...");
  if (pAddress) {
    refAddress = *pAddress->par();
    return StatusCode::SUCCESS;
  }
  ATH_MSG_ERROR("::convertAddress: null pointer to IOpaqueAddress !");
  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 Athena::xAODCnvSvc::createAddress ( long  svcType, const CLID &  clid, const std::string &  refAddress, IOpaqueAddress *&  refpAddress  )

virtual

Create address from string form.

Parameters

svcType	[IN] service type of the address.
clid	[IN] class id for the address.
refAddress	[IN] string form to be converted.
refpAddress	[OUT] converted address.

Reimplemented from AthCnvSvc.

Definition at line 252 of file xAODCnvSvc.cxx.

{
  ATH_MSG_VERBOSE("::createAddress(" << svcType << ", " << clid 
               << ", " << refAddress << ", " << refpAddress
               << ")...");
  if (svcType != POOL_ROOTTREE_StorageType) {
    ATH_MSG_ERROR("::createAddress: svcType != root-type");
    ATH_MSG_ERROR("    svcType   = [" << svcType << "]");
    ATH_MSG_ERROR("    root-type = [" << POOL_ROOTTREE_StorageType << "]");
    return StatusCode::FAILURE;
  }
  refpAddress = new GenericAddress(POOL_ROOTTREE_StorageType, clid, refAddress);
  return StatusCode::SUCCESS;
}

createAddress() [2/2]

StatusCode Athena::xAODCnvSvc::createAddress ( long  svcType, const CLID &  clid, const std::string *  par, const unsigned long *  ip, IOpaqueAddress *&  refpAddress  )

virtual

IAddressCreator interfaces

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

Parameters

svcType	[IN] service type of the address.
clid	[IN] class id for the address.
par	[IN] string containing the database name.
ip	[IN] object identifier.
refpAddress	[OUT] converted address.

Reimplemented from AthCnvSvc.

Definition at line 217 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("::createAddress(" << svcType << ", " << clid 
                << ", " << par << ", " << ip << ", " << refpAddress
                << ")...");
  return ::AthCnvSvc::createAddress(svcType, clid, par, ip, refpAddress);
}

createConverter()

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

protectedvirtual

Create new Converter using factory (override AthCnvSvc::createConverter)

Reimplemented from AthCnvSvc.

Definition at line 285 of file xAODCnvSvc.cxx.

{
  ATH_MSG_VERBOSE("xAODCnvSvc::createConverter(" << typ << ", " << clid
                << ", " << fac << ")...");
  IConverter* cnv = new Athena::xAODCnv(clid, serviceLocator());
  ATH_MSG_VERBOSE("xAODCnvSvc::createConverter 2");
  if (cnv) {
    ATH_MSG_VERBOSE("xAODCnvSvc::createConverter 3");
    return cnv;
  }
  ATH_MSG_VERBOSE("xAODCnvSvc::createConverter 4");
  return AthCnvSvc::createConverter(typ, clid, fac);
}

createObj()

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

virtual

Implementation of IConverter: Create the transient representation of an object from persistent state.

Parameters

pAddress	[IN] pointer to IOpaqueAddress of the representation.
refpObject	[OUT] pointer to DataObject to be created.

Reimplemented from AthCnvSvc.

Definition at line 107 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("-->createObj(" << pAddress->par()[0] << "/" << pAddress->par()[1]
                << ", " << refpObject << ")...");
  GenericAddress *addr = dynamic_cast<GenericAddress*>(pAddress);
  if (!addr) {
    ATH_MSG_DEBUG(pAddress->par()[0] << "/" << pAddress->par()[1]
                  << " is NOT a GenericAddress!");
    return StatusCode::FAILURE;
  }
  ATH_MSG_DEBUG("  par:  " << pAddress->par()[0] << "/" << pAddress->par()[1]
                << endmsg <<
                "  ipar: " << *pAddress->ipar());
  return AthCnvSvc::createObj(pAddress, refpObject);
}

createRep()

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

virtual

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

Parameters

pObject	[IN] pointer to DataObject.
refpAddress	[OUT] pointer to IOpaqueAddress of the representation to be created.

Reimplemented from AthCnvSvc.

Definition at line 129 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("::createRep(" << refpAddress << ", " << pObject << ")...");
  //std::cerr << "::NCS::createRep(" << this->name() << ", " << pObject << ")...\n";
  if (0==pObject) {
    ATH_MSG_ERROR("::createRep: received null ptr to DataObject");
    return StatusCode::FAILURE;
  }
  return ::AthCnvSvc::createRep(pObject, refpAddress);
}

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 Athena::xAODCnvSvc::fillRepRefs ( IOpaqueAddress *  pAddress, DataObject *  pObject  )

virtual

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

Parameters

pAddress	[IN] pointer to IOpaqueAddress of the representation to be resolved.
pObject	[IN] pointer to DataObject to be created.

Reimplemented from AthCnvSvc.

Definition at line 146 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("::fillRepRefs(" << pAddress << ", " << pObject << ")...");
  if (0==pAddress || 0==pObject) {
    ATH_MSG_ERROR("::fillRepRefs: null ptr received! (paddr=" << pAddress
                  << ", pobj=" << pObject << ")");
    return StatusCode::FAILURE;
  }
  return ::AthCnvSvc::fillRepRefs(pAddress, pObject);
}

finalize()

StatusCode Athena::xAODCnvSvc::finalize ( )

virtual

Reimplemented from AthCnvSvc.

Definition at line 63 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG ("Finalizing " << name() << "...");
 
  return AthCnvSvc::finalize();
}

initialize()

StatusCode Athena::xAODCnvSvc::initialize ( )

virtual

Gaudi Service Implementation.

Reimplemented from AthCnvSvc.

Definition at line 55 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG ("Initializing " << name() << "...");
 
  return AthCnvSvc::initialize();
}

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

const InterfaceID & Athena::xAODCnvSvc::interfaceID ( )

inlinestatic

Definition at line 185 of file xAODCnvSvc.h.

{ 
  return IConversionSvc::interfaceID(); 
}

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

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

queryInterface()

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

virtual

Reimplemented from AthCnvSvc.

Definition at line 76 of file xAODCnvSvc.cxx.

{
  if ( IConversionSvc::interfaceID().versionMatch(riid) ) {
    *ppvInterface = dynamic_cast<IConversionSvc*>(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;
}

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

virtual

IConversionSvc and IConverter interfaces

update the service state (well, just check the IOpaqueAddress is in fact a GenericAddress )

Reimplemented from AthCnvSvc.

Definition at line 91 of file xAODCnvSvc.cxx.

{
  ATH_MSG_DEBUG("updateServiceState(" << pAddress << ")...");
  if (pAddress) {
    return dynamic_cast<GenericAddress*>(pAddress) 
      ? StatusCode::SUCCESS
      : StatusCode::FAILURE;
  }
  return StatusCode::FAILURE;
}

Friends And Related Function Documentation

SvcFactory< Athena::xAODCnvSvc >

friend class SvcFactory< Athena::xAODCnvSvc >

friend

Definition at line 185 of file xAODCnvSvc.h.

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_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:

• xAODCnvSvc.h
• xAODCnvSvc.cxx