PersistencySvc Class Reference

PersistencySvc class implementation definition. More...

#include <src/PersistencySvc/PersistencySvc.h>

Inheritance diagram for PersistencySvc:

Collaboration diagram for PersistencySvc:

Classes
class	ServiceEntry

Public Member Functions
IPersistencySvc Interface implementation
long	repSvcType () const
	Return default service type. More...
const CLID &	objType () const
	Retrieve the class type of objects the converter produces. (DUMMY) More...
StatusCode	createObj (IOpaqueAddress *pAddress, DataObject *&refpObject) override
	Implementation of IConverter: Create the transient representation of an object. More...
StatusCode	fillObjRefs (IOpaqueAddress *pAddress, DataObject *pObject) override
	Implementation of IConverter: Resolve the references of the created transient object. More...
StatusCode	updateObj (IOpaqueAddress *pAddress, DataObject *refpObject) override
	Implementation of IConverter: Update the transient object from the other representation. More...
StatusCode	updateObjRefs (IOpaqueAddress *pAddress, DataObject *pObject) override
	Implementation of IConverter: Update the references of an updated transient object. More...
StatusCode	createRep (DataObject *pObject, IOpaqueAddress *&refpAddress) override
	Implementation of IConverter: Convert the transient object to the requested representation. More...
StatusCode	fillRepRefs (IOpaqueAddress *pAddress, DataObject *pObject) override
	Implementation of IConverter: Resolve the references of the converted object. More...
StatusCode	updateRep (IOpaqueAddress *pAddress, DataObject *pObject) override
	Implementation of IConverter: Update the converted representation of a transient object. More...
StatusCode	updateRepRefs (IOpaqueAddress *pAddress, DataObject *pObject) override
	Implementation of IConverter: Update the references of an already converted object. More...
StatusCode	setDataProvider (IDataProviderSvc *pStore) override
	Define transient datastore. More...
SmartIF< IDataProviderSvc > &	dataProvider () const override
	Access reference to transient datastore. More...
StatusCode	setConversionSvc (IConversionSvc *svc) override
	Set conversion service the converter is connected to. More...
SmartIF< IConversionSvc > &	conversionSvc () const override
	Get conversion service the converter is connected to. More...
StatusCode	setAddressCreator (IAddressCreator *creator) override
	Set address creator facility. More...
SmartIF< IAddressCreator > &	addressCreator () const override
	Retrieve address creator facility. More...
StatusCode	addConverter (IConverter *pConverter) override
	Add converter object to conversion service. More...
StatusCode	addConverter (const CLID &clid) override
	Add converter object to conversion service. More...
IConverter *	converter (const CLID &clid) override
	Retrieve converter from list. More...
StatusCode	removeConverter (const CLID &clid) override
	Remove converter object from conversion service (if present). More...
StatusCode	connectOutput (const std::string &outputFile, const std::string &openMode) override
	Connect the output file to the service with open mode. More...
StatusCode	connectOutput (const std::string &outputFile) override
	Connect the output file to the service. More...
StatusCode	commitOutput (const std::string &output, bool do_commit) override
	Commit pending output. More...
StatusCode	createAddress (long svc_type, const CLID &clid, const std::string *pars, const unsigned long *ipars, IOpaqueAddress *&refpAddress) override
	Create a Generic address using explicit arguments to identify a single object. More...
StatusCode	convertAddress (const IOpaqueAddress *pAddress, std::string &refAddress) override
	Convert an address to string form. More...
StatusCode	createAddress (long svc_type, const CLID &clid, const std::string &refAddress, IOpaqueAddress *&refpAddress) override
	Convert an address in string form to object form. More...
: IPersistencySvc implementation
StatusCode	addCnvService (IConversionSvc *service) override
	Add a new Service. More...
StatusCode	removeCnvService (long type) override
	Remove a Service. More...
StatusCode	setDefaultCnvService (long type) override
	Set default service type. More...
StatusCode	getService (long service_type, IConversionSvc *&refpSvc) override
	Retrieve conversion service identified by technology. More...
StatusCode	getService (const std::string &service_type, IConversionSvc *&refpSvc) override
	Retrieve conversion service identified by technology. More...
: IService implementation
StatusCode	initialize () override
	Initialize the service. More...
StatusCode	finalize () override
	stop the service. More...
Public Member Functions inherited from extends< BASE, Interfaces >
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...
StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...
std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...
	~extends () override=default
	Virtual destructor. More...
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...
StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...
std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...
	~extends () override=default
	Virtual destructor. More...
Public Member Functions inherited from extend_interfaces< Interfaces...>
	~extend_interfaces () override=default
	Virtual destructor. More...
	~extend_interfaces () override=default
	Virtual destructor. More...

Protected Types
typedef std::map< long, ServiceEntry >	Services

Protected Member Functions
void	svcNamesHandler (Property &theProp)
	Handlers for Service Names Property. More...

Protected Attributes
long	m_cnvDefType = TEST_StorageType
	Default service type. More...
SmartIF< IDataProviderSvc >	m_dataSvc
	Pointer to datma provider service. More...
Services	m_cnvServices
	List of convermsion workers. More...
SmartIF< IConversionSvc >	m_cnvDefault
	Default output service. More...
StringArrayProperty	m_svcNames
	Names of services to be requested from the service locator and added by default. More...
bool	m_enable = true
	Flag to indicate that the service is enabled. More...
SmartIF< IAddressCreator >	m_addrCreator
	Pointer to the IAddressCreator interface of this, for addressCreator(). More...

: Object implementation
	PersistencySvc (const std::string &name, ISvcLocator *svc)
	Standard Constructor. More...
	~PersistencySvc () override=default
	Standard Destructor. More...
SmartIF< IConversionSvc > &	service (const std::string &nam)
	Retrieve conversion service by name. More...
SmartIF< IConversionSvc > &	service (long service_type)
	Retrieve conversion service from list. More...
SmartIF< IAddressCreator > &	addressCreator (long service_type)
	Retrieve address creator from list. More...
void	encodeAddrHdr (long service_type, const CLID &clid, std::string &address) const
	Retrieve string from storage type and clid. More...
void	decodeAddrHdr (const std::string &address, long &service_type, CLID &clid, std::string &address_trailer) const
	Retrieve storage type and clid from address header of string. More...
StatusCode	makeCall (int typ, IOpaqueAddress *&pAddress, DataObject *&pObject)
	Implementation helper. More...
bool	enable (bool value)
	Set enabled flag. More...

Additional Inherited Members
Public Types inherited from extends< BASE, Interfaces >
typedef extends	base_class
	Typedef to this class. More...
typedef extend_interfaces< Interfaces...>	extend_interfaces_base
	Typedef to the base of this class. More...
typedef extends	base_class
	Typedef to this class. More...
typedef extend_interfaces< Interfaces...>	extend_interfaces_base
	Typedef to the base of this class. More...
Public Types inherited from extend_interfaces< Interfaces...>
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids...>::type
	take union of the ext_iids of all Interfaces... More...

Detailed Description

PersistencySvc class implementation definition.

System: The LHCb Offline System

Package: PersistencySvc

Dependencies:

• STL: <vector>, <algorithm>, <functional>
• Generic service definition: "Kernel/Service.h"
• IConversionSvc definition: "Kernel/IConversionSvc.h"
• PersistencySvc definition: "Kernel/Interfaces/IPersistencySvc.h"

History:

 +---------+----------------------------------------------+---------+
 |    Date |                 Comment                      | Who     |
 +---------+----------------------------------------------+---------+
 | 3/11/98 | Initial version                              | M.Frank |
 +---------+----------------------------------------------+---------+
 

Author

Markus Frank

Version

1.0

Definition at line 50 of file PersistencySvc.h.

Member Typedef Documentation

typedef std::map<long,ServiceEntry> PersistencySvc::Services

protected

Definition at line 95 of file PersistencySvc.h.

Constructor & Destructor Documentation

PersistencySvc::PersistencySvc	(	const std::string &	name,
		ISvcLocator *	svc
	)

Standard Constructor.

Definition at line 566 of file PersistencySvc.cpp.

:  base_class(name, svc)
{
  declareProperty("CnvServices", m_svcNames);
  m_svcNames.declareUpdateHandler( &PersistencySvc::svcNamesHandler, this );
}

PersistencySvc::~PersistencySvc ( )

overridedefault

Standard Destructor.

Member Function Documentation

StatusCode PersistencySvc::addCnvService ( IConversionSvc *  service )

override

Add a new Service.

Add data service.

Definition at line 255 of file PersistencySvc.cpp.

                                                                 {
  if ( !servc )   return BAD_STORAGE_TYPE;
  long type = servc->repSvcType();
  long def_typ = ( m_cnvDefault ? m_cnvDefault->repSvcType() : 0 );
  auto it = m_cnvServices.find( type );
  auto cnv_svc = ( it != m_cnvServices.end() ? it->second.conversionSvc() : nullptr );
  if ( type == def_typ ) m_cnvDefault = servc;
  if ( cnv_svc == servc )   return StatusCode::SUCCESS;

  auto iservc = make_SmartIF( servc );
  auto icr = iservc.as<IAddressCreator>();
  if ( icr ) {
    auto isvc = iservc.as<IService>();
    if ( isvc ) {
      if ( cnv_svc ) removeCnvService (type).ignore();
      auto p = m_cnvServices.emplace( type, ServiceEntry(type, isvc, iservc, icr) );
      if( !p.second )    {
        info() << "Cannot add Conversion service of type " << isvc->name() << endmsg;
        return StatusCode::FAILURE;
      }
      info() << "Added successfully Conversion service:" << isvc->name() << endmsg;
      iservc->setAddressCreator(this).ignore();
      iservc->setDataProvider(m_dataSvc).ignore();
      return StatusCode::SUCCESS;
    }
  }
  info() << "Cannot add Conversion service of type " << type << endmsg;
  return StatusCode::FAILURE;
}

StatusCode PersistencySvc::addConverter ( IConverter *  pConverter )

override

Add converter object to conversion service.

Definition at line 199 of file PersistencySvc.cpp.

                                                                 {
  if ( !pConverter ) return NO_CONVERTER;
  IConversionSvc* svc = service(pConverter->repSvcType());
  return  svc ? svc->addConverter(pConverter) : BAD_STORAGE_TYPE;
}

StatusCode PersistencySvc::addConverter ( const CLID &  clid )

override

Add converter object to conversion service.

Definition at line 194 of file PersistencySvc.cpp.

                                                      {
  return StatusCode::FAILURE;
}

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

override

Retrieve address creator facility.

Definition at line 447 of file PersistencySvc.cpp.

                                                                   {
  return m_addrCreator;
}

SmartIF< IAddressCreator > & PersistencySvc::addressCreator ( long  service_type )

protected

Retrieve address creator from list.

Retrieve address creator service from list.

Definition at line 153 of file PersistencySvc.cpp.

                                                                      {
  long typ = type;
  auto it = m_cnvServices.find( typ );
  if( it == m_cnvServices.end() ) {
    IConversionSvc* s = service(type);
    if ( s )   {
      it = m_cnvServices.find( typ );
      if ( it != m_cnvServices.end() ) return it->second.addrCreator();
    }
    static SmartIF<IAddressCreator> no_creator;
    return no_creator;
  }
  return it->second.addrCreator();
}

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

override

Commit pending output.

Definition at line 318 of file PersistencySvc.cpp.

                                                                {
  return StatusCode::SUCCESS;
}

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

override

Connect the output file to the service with open mode.

Definition at line 307 of file PersistencySvc.cpp.

                                                             {
  return connectOutput(outputFile);
}

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

override

Connect the output file to the service.

Definition at line 313 of file PersistencySvc.cpp.

                                                         {
  return StatusCode::SUCCESS;
}

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

override

Get conversion service the converter is connected to.

Definition at line 189 of file PersistencySvc.cpp.

                                                                  {
  return m_cnvDefault;
}

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

override

Convert an address to string form.

Definition at line 335 of file PersistencySvc.cpp.

{
  // Assumuption is that the Persistency service prepends a header
  // and requests the conversion service refered to by the service
  // type to encode the rest
  long svc_type = 0;
  CLID clid = 0;
  if ( pAddress ) {
    svc_type = pAddress->svcType();
    clid     = pAddress->clID();
  }
  IAddressCreator* svc = addressCreator(svc_type);
  StatusCode   status  = BAD_STORAGE_TYPE;        // Preset error
  refAddress.clear();

  if ( svc )   {
    // Found service, set header
    encodeAddrHdr(svc_type, clid, refAddress);
    std::string address;
    // Get rest of address from conversion service
    status = svc->convertAddress(pAddress, address);
    refAddress += address;
  }
  return status;
}

IConverter * PersistencySvc::converter ( const CLID &  clid )

override

Retrieve converter from list.

Definition at line 217 of file PersistencySvc.cpp.

                                                   {
  return nullptr;
}

StatusCode PersistencySvc::createAddress ( long  svc_type, const CLID &  clid, const std::string *  pars, const unsigned long *  ipars, IOpaqueAddress *&  refpAddress  )

override

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

Definition at line 323 of file PersistencySvc.cpp.

                                                                          {
  refpAddress = nullptr;
  IAddressCreator* svc = addressCreator(svc_type);
  return svc ? svc->createAddress(svc_type, clid, pars, ipars, refpAddress)
             : BAD_STORAGE_TYPE;
}

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

override

Convert an address in string form to object form.

Definition at line 363 of file PersistencySvc.cpp.

{
  // Assumption is that the Persistency service decodes that header
  // and requests the conversion service referred to by the service
  // type to decode the rest
  long new_svc_type = 0;
  CLID new_clid = 0;
  std::string address_trailer;
  decodeAddrHdr(refAddress, new_svc_type, new_clid, address_trailer);
  IAddressCreator* svc = addressCreator(new_svc_type);
  return svc ? svc->createAddress( new_svc_type, new_clid, address_trailer, refpAddress)
             : BAD_STORAGE_TYPE;
}

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

override

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

Create the transient representation of an object.

Definition at line 113 of file PersistencySvc.cpp.

                                                                                  {
  return makeCall(CREATE_OBJ, pAddr, refpObj);
}

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

override

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

Convert the transient object to the requested representation.

Definition at line 133 of file PersistencySvc.cpp.

                                                                                 {
  return makeCall(CREATE_REP, refpAddr, pObj);
}

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

override

Access reference to transient datastore.

Access the dataprovider service.

Definition at line 178 of file PersistencySvc.cpp.

                                                                {
  return m_dataSvc;
}

void PersistencySvc::decodeAddrHdr ( const std::string &  address, long &  service_type, CLID &  clid, std::string &  address_trailer  ) const

protected

Retrieve storage type and clid from address header of string.

Definition at line 394 of file PersistencySvc.cpp.

{
  // For address header, use xml-style format of
  // <address_header service_type="xxx" clid="yyy" />
  service_type = 0;
  clid = 0;
  address_trailer.clear();

  // Check for address_header tag
  size_t pos = address.find("<address_header");
  if (std::string::npos != pos) {
    // Get service_type
    pos = address.find("service_type=\"");
    if (std::string::npos != pos) {
      pos += 14;
      size_t end = address.find('"', pos);
      if (std::string::npos != end) {
        service_type = std::stol(address.substr(pos, end-pos));
        // Get clid
        pos = address.find("clid=\"");
        if (std::string::npos != pos) {
          pos += 6;
          end = address.find('\"', pos);
          if (std::string::npos != end) {
            std::istringstream str;
            str.str(address.substr(pos, end-pos));
            str >> clid;
            // Get trailer_address
            pos = address.find('>');
            if (pos < (address.size()-2)) { // this means that '>' was found (pos != npos)
                                            // it is before the last char
              address_trailer = address.substr(pos+1);
            }
          }
        }
      }
    }
  }
}

bool PersistencySvc::enable ( bool  value )

protected

Set enabled flag.

Definition at line 559 of file PersistencySvc.cpp.

{
  std::swap(value,m_enable);
  return value;
}

void PersistencySvc::encodeAddrHdr ( long  service_type, const CLID &  clid, std::string &  address  ) const

protected

Retrieve string from storage type and clid.

Definition at line 381 of file PersistencySvc.cpp.

{
  // For address header, use xml-style format of
  // <addrhdr service_type="xxx" clid="yyy" />
  std::stringstream stream;
  int svctyp = service_type; // must put int into stream, not char
  stream << "<address_header service_type=\"" << svctyp << "\" clid=\"" << clid << "\" /> ";
  address = stream.str();
}

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

override

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

Resolve the references of the created transient object.

Definition at line 118 of file PersistencySvc.cpp.

                                                                                 {
  return makeCall(FILL_OBJ_REFS, pAddr, pObj);
}

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

override

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

Resolve the references of the converted object.

Definition at line 138 of file PersistencySvc.cpp.

                                                                               {
  return makeCall(FILL_REP_REFS, pAddr, pObj);
}

StatusCode PersistencySvc::finalize ( )

override

stop the service.

Definition at line 546 of file PersistencySvc.cpp.

                                         {
  // Release all workers
  m_cnvServices.clear();
  // Release references to this to avoid loops
  m_addrCreator = nullptr;
  return StatusCode::SUCCESS;
}

StatusCode PersistencySvc::getService ( long  service_type, IConversionSvc *&  refpSvc  )

override

Retrieve conversion service identified by technology.

Definition at line 452 of file PersistencySvc.cpp.

                                                                                     {
  refpSvc = service(service_type);
  return refpSvc ? StatusCode::SUCCESS : StatusCode::FAILURE;
}

StatusCode PersistencySvc::getService ( const std::string &  service_type, IConversionSvc *&  refpSvc  )

override

Retrieve conversion service identified by technology.

Definition at line 458 of file PersistencySvc.cpp.

                                                                                                 {
  const char* imp = service_type.c_str();
  long len = service_type.length();
  if ( ::strncasecmp(imp,"SICB", len) == 0 )
    return getService(SICB_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"ZEBRA", len) == 0 )
    return getService(SICB_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"MS Access", len) == 0 )
    return getService(ACCESS_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"Microsoft Access", strlen("Microsoft Access")) == 0 )
    return getService(ACCESS_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"SQL Server", len) == 0 )
    return getService(SQLSERVER_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"Microsoft ODBC for Oracle", len) == 0 )
    return getService(ORACLE_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"Oracle ODBC", strlen("Oracle ODBC")) == 0 )
    return getService(ORACLE_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"Oracle OCI", strlen("Oracle OCI")) == 0 )
    return getService(ORACLE_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"MySQL", len) == 0 )
    return getService(MYSQL_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"ROOT", len) == 0 )
    return getService(ROOT_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"OBJY", len) == 0 )
    return getService(OBJY_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"OBJYECTI", 7) == 0 )
    return getService(OBJY_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"POOL_ROOTKEY", 12) == 0 )
    return getService(POOL_ROOTKEY_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"POOL_ROOTTREE", 12) == 0 )
    return getService(POOL_ROOTTREE_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"POOL_ROOT", 9) == 0 )
    return getService(POOL_ROOT_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"POOL_MySQL", 8) == 0 )
    return getService(POOL_MYSQL_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"POOL_ORACLE", 8) == 0 )
    return getService(POOL_ORACLE_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"POOL_ACCESS", 8) == 0 )
    return getService(POOL_ACCESS_StorageType, refpSvc);
  else if ( ::strncasecmp(imp,"POOL", 4) == 0 )
    return getService(POOL_StorageType, refpSvc);

  for(const auto& i : m_cnvServices) {
    SmartIF<IService> svc(i.second.conversionSvc());
    if ( svc )  {
      // Check wether this is already an active service: first check by service name
      if ( svc->name() == service_type )  {
        refpSvc = i.second.conversionSvc();
        return StatusCode::SUCCESS;
      }
      // Check wether this is already an active service: now check by service type
      if ( System::typeinfoName(typeid(*(svc.get()))) == service_type )  {
        refpSvc = i.second.conversionSvc();
        return StatusCode::SUCCESS;
      }
    }
  }
  // if not, check if the service is in the list and may be requested
  for(const auto& i : m_svcNames.value() ) {
    Gaudi::Utils::TypeNameString itm(i);
    if ( itm.name() == service_type || itm.type() == service_type )  {
      IConversionSvc* svc = service(i);
      if ( svc )  {
        refpSvc = svc;
        return StatusCode::SUCCESS;
      }
    }
  }
  return StatusCode::FAILURE;
}

StatusCode PersistencySvc::initialize ( )

override

Initialize the service.

Definition at line 535 of file PersistencySvc.cpp.

                                          {
  m_addrCreator = this; // initialize internal pointer to IAddressCreator interface
  // Initialize basic service
  StatusCode status = Service::initialize();
  if ( UNLIKELY(!status.isSuccess()) )   {
    error() << "Error initializing Service base class." << endmsg;
  }
  return status;
}

StatusCode PersistencySvc::makeCall ( int  typ, IOpaqueAddress *&  pAddress, DataObject *&  pObject  )

protected

Implementation helper.

Definition at line 56 of file PersistencySvc.cpp.

                                                               {
  if ( m_enable )    {
    IConversionSvc* svc    = nullptr;
    switch(typ)   {
    case CREATE_REP:
    case FILL_REP_REFS:
    case UPDATE_REP:
    case UPDATE_REP_REFS:
      svc = m_cnvDefault;
      break;
    default:
      if ( !pAddress ) return INVALID_ADDRESS;
      svc = service(pAddress->svcType());
      if ( !svc )   return BAD_STORAGE_TYPE;
      break;
    }

    StatusCode status(StatusCode::FAILURE,true);
    switch( typ )     {
    case CREATE_OBJ:
      pObject = nullptr;
      status = svc->createObj(pAddress, pObject);
      break;
    case FILL_OBJ_REFS:
      status = svc->fillObjRefs(pAddress, pObject);
      break;
    case UPDATE_OBJ:
      status = svc->updateObj(pAddress, pObject);
      break;
    case UPDATE_OBJ_REFS:
      status = svc->updateObjRefs(pAddress, pObject);
      break;
    case CREATE_REP:
      status = svc->createRep(pObject, pAddress);
      break;
    case FILL_REP_REFS:
      status = svc->fillRepRefs(pAddress, pObject);
      break;
    case UPDATE_REP:
      status = svc->updateRep(pAddress, pObject);
      break;
    case UPDATE_REP_REFS:
      status = svc->updateRepRefs(pAddress, pObject);
      break;
    default:
      status = StatusCode::FAILURE;
      break;
    }
    status.ignore();
    return status;
  }
  return StatusCode::SUCCESS;
}

const CLID & PersistencySvc::objType

(

)

const

Retrieve the class type of objects the converter produces. (DUMMY)

Retrieve the class type of objects the converter produces.

Definition at line 530 of file PersistencySvc.cpp.

                                             {
  return CLID_NULL;
}

StatusCode PersistencySvc::removeCnvService ( long  type )

override

Remove a Service.

Remove conversion service.

Definition at line 286 of file PersistencySvc.cpp.

                                                           {
  auto it = m_cnvServices.find( svctype );
  if( it == m_cnvServices.end() ) return BAD_STORAGE_TYPE;
  it->second.service()->release();
  it->second.addrCreator()->release();
  m_cnvServices.erase(it);
  return StatusCode::SUCCESS;
}

StatusCode PersistencySvc::removeConverter ( const CLID &  clid )

override

Remove converter object from conversion service (if present).

Definition at line 206 of file PersistencySvc.cpp.

                                                            {
  // Remove converter type from all services
  StatusCode status = NO_CONVERTER, iret = StatusCode::SUCCESS;
  for ( auto& i : m_cnvServices ) {
    iret = i.second.conversionSvc()->removeConverter(clid);
    if ( iret.isSuccess() ) status = iret;
  }
  return status;
}

long PersistencySvc::repSvcType

(

)

const

Return default service type.

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

Definition at line 296 of file PersistencySvc.cpp.

                                      {
  return m_cnvDefault ? m_cnvDefault->repSvcType() : 0;
}

SmartIF< IConversionSvc > & PersistencySvc::service ( const std::string &  nam )

protected

Retrieve conversion service by name.

Definition at line 222 of file PersistencySvc.cpp.

                                                                         {
  Gaudi::Utils::TypeNameString tn(nam);
  auto it = std::find_if( m_cnvServices.begin(), m_cnvServices.end(),
                          [&](Services::const_reference i) {
        return i.second.service()->name() == tn.name();
  } );
  if (it!=m_cnvServices.end()) return it->second.conversionSvc();

  auto svc = Service::service<IConversionSvc>(nam, true);
  if ( svc && addCnvService(svc.get()).isSuccess() ) {
      return service(nam); // now it is in the list
  }

  info() << "Cannot access Conversion service:" << nam << endmsg;
  static SmartIF<IConversionSvc> no_svc;
  return no_svc;
}

SmartIF< IConversionSvc > & PersistencySvc::service ( long  service_type )

protected

Retrieve conversion service from list.

Definition at line 241 of file PersistencySvc.cpp.

                                                              {
  // Check wether this is already an active service
  auto it = m_cnvServices.find( type );
  if( it != m_cnvServices.end() ) return it->second.conversionSvc();
  // if not, check if the service is in the list and may be requested
  for ( const auto& i : m_svcNames.value() ) {
    auto& svc = service(i);
    if ( svc &&  svc->repSvcType() == type )  return svc;
  }
  static SmartIF<IConversionSvc> no_svc;
  return no_svc;
}

StatusCode PersistencySvc::setAddressCreator ( IAddressCreator *  creator )

override

Set address creator facility.

Definition at line 438 of file PersistencySvc.cpp.

                                                                {
  // The persistency service is a address creation dispatcher istelf.
  // The persistency service can NEVER create addresses itself.
  // The entry point must only be provided in order to fulfill the needs of the
  // implementing interfaces.
  return StatusCode::FAILURE;
}

StatusCode PersistencySvc::setConversionSvc ( IConversionSvc *  svc )

override

Set conversion service the converter is connected to.

Definition at line 183 of file PersistencySvc.cpp.

                                                                 {
  m_cnvDefault = svc;
  return StatusCode(StatusCode::SUCCESS,true);
}

StatusCode PersistencySvc::setDataProvider ( IDataProviderSvc *  pStore )

override

Define transient datastore.

Define transient data store.

Definition at line 169 of file PersistencySvc.cpp.

                                                                        {
  m_dataSvc = pDataSvc;
  for (auto& i : m_cnvServices) {
    i.second.conversionSvc()->setDataProvider(m_dataSvc).ignore();
  }
  return StatusCode(StatusCode::SUCCESS,true);
}

StatusCode PersistencySvc::setDefaultCnvService ( long  type )

override

Set default service type.

Set default conversion service.

Definition at line 301 of file PersistencySvc.cpp.

                                                             {
  m_cnvDefault = service(type);
  return StatusCode::SUCCESS;
}

void PersistencySvc::svcNamesHandler ( Property &  theProp )

protected

Handlers for Service Names Property.

Definition at line 554 of file PersistencySvc.cpp.

                                                      {
  DEBMSG << p << endmsg;
}

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

override

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

Update the transient object from the other representation.

Definition at line 123 of file PersistencySvc.cpp.

                                                                              {
  return makeCall(UPDATE_OBJ, pAddr, pObj);
}

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

override

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

Update the references of an updated transient object.

Definition at line 128 of file PersistencySvc.cpp.

                                                                                 {
  return makeCall(UPDATE_OBJ_REFS, pAddr, pObj);
}

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

override

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

Update the converted representation of a transient object.

Definition at line 143 of file PersistencySvc.cpp.

                                                                             {
  return makeCall(UPDATE_REP, pAddr, pObj);
}

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

override

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

Update the references of an already converted object.

Definition at line 148 of file PersistencySvc.cpp.

                                                                                   {
  return makeCall(UPDATE_REP_REFS, pAddr, pObj);
}

Member Data Documentation

SmartIF<IAddressCreator> PersistencySvc::m_addrCreator

mutableprotected

Pointer to the IAddressCreator interface of this, for addressCreator().

Definition at line 282 of file PersistencySvc.h.

SmartIF<IConversionSvc> PersistencySvc::m_cnvDefault

mutableprotected

Default output service.

Definition at line 273 of file PersistencySvc.h.

long PersistencySvc::m_cnvDefType = TEST_StorageType

protected

Default service type.

Definition at line 267 of file PersistencySvc.h.

Services PersistencySvc::m_cnvServices

protected

List of convermsion workers.

Definition at line 271 of file PersistencySvc.h.

SmartIF<IDataProviderSvc> PersistencySvc::m_dataSvc

mutableprotected

Pointer to datma provider service.

Definition at line 269 of file PersistencySvc.h.

bool PersistencySvc::m_enable = true

protected

Flag to indicate that the service is enabled.

Definition at line 279 of file PersistencySvc.h.

StringArrayProperty PersistencySvc::m_svcNames

protected

Names of services to be requested from the service locator and added by default.

Definition at line 277 of file PersistencySvc.h.

---

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

• GaudiCommonSvc/src/PersistencySvc/PersistencySvc.h
• GaudiCommonSvc/src/PersistencySvc/PersistencySvc.cpp