In This Package:

DybDataSvc Class Reference

A DybDataSvc is the base class for event services. More...

#include <DybDataSvc.h>

Inheritance diagram for DybDataSvc:

[legend]Collaboration diagram for DybDataSvc:[legend]List of all members.

Public Types
typedef std::vector< DataStoreItem >	LoadItems
	SUCCESS
	NO_INTERFACE
	VERSMISMATCH
	LAST_ERROR
	SEPARATOR
	IID_IDataProviderSvc_NO_ERROR
	DOUBL_OBJ_PATH
	INVALID_OBJ_PATH
	INVALID_ROOT
	INVALID_OBJECT
	INVALID_PARENT
	OBJ_NOT_LOADED
	NO_DATA_LOADER
	INVALID_OBJ_ADDR
	DIR_NOT_EMPTY
	NO_MORE_LEVELS
	NO_ACCESS
	LAST
enum	Status
enum	Status
Public Member Functions
virtual StatusCode	initialize ()
	Service initialisation.
virtual StatusCode	reinitialize ()
	Service reinitialisation.
virtual StatusCode	finalize ()
	Service finalization.
	DybDataSvc (const std::string &name, ISvcLocator *svc)
	Standard Constructor.
virtual	~DybDataSvc ()
	Standard Destructor.
IDataProviderSvc *	archiveSvc () const
	Accessors.
StatusCode	setRoot (const std::string &root_path, DataObject *pRootObj)
	Override existing methods.
StatusCode	setRoot (const std::string &root_path, IOpaqueAddress *pRootAddr)
StatusCode	loadObject (IConversionSvc *pLoader, IRegistry *pRegistry)
	Override main 'loadObject' method.
StatusCode	registerAddress (IRegistry *parentObj, const std::string &objPath, IOpaqueAddress *pAddress)
	Override main 'registerObject' method.
StatusCode	registerObject (DataObject *parentObj, const std::string &objPath, DataObject *pObject)
	Override main 'registerObject' method.
virtual CLID	rootCLID () const
virtual std::string	rootName () const
virtual StatusCode	registerAddress (const std::string &fullPath, IOpaqueAddress *pAddress)
virtual StatusCode	registerAddress (DataObject *parentObj, const std::string &objectPath, IOpaqueAddress *pAddress)
virtual StatusCode	unregisterAddress (const std::string &fullPath)
virtual StatusCode	unregisterAddress (DataObject *pParent, const std::string &objPath)
virtual StatusCode	unregisterAddress (IRegistry *pParent, const std::string &objPath)
virtual StatusCode	objectLeaves (const DataObject *pObject, std::vector< IRegistry * > &refLeaves)
virtual StatusCode	objectLeaves (const IRegistry *pRegistry, std::vector< IRegistry * > &refLeaves)
virtual StatusCode	objectParent (const DataObject *pObject, IRegistry *&refpParent)
virtual StatusCode	objectParent (const IRegistry *pRegistry, IRegistry *&refpParent)
virtual StatusCode	clearSubTree (const std::string &sub_tree_path)
virtual StatusCode	clearSubTree (DataObject *pObject)
virtual StatusCode	clearStore ()
virtual StatusCode	traverseSubTree (const std::string &sub_tree_path, IDataStoreAgent *pAgent)
virtual StatusCode	traverseSubTree (DataObject *pObject, IDataStoreAgent *pAgent)
virtual StatusCode	traverseTree (IDataStoreAgent *pAgent)
virtual StatusCode	i_setRoot (const std::string &root_name, DataObject *pRootObj)
virtual StatusCode	i_setRoot (const std::string &root_path, IOpaqueAddress *pRootAddr)
virtual StatusCode	setDataLoader (IConversionSvc *svc)
virtual StatusCode	addPreLoadItem (const DataStoreItem &item)
virtual StatusCode	addPreLoadItem (const std::string &itemPath)
virtual StatusCode	removePreLoadItem (const DataStoreItem &item)
virtual StatusCode	removePreLoadItem (const std::string &itemPath)
virtual StatusCode	resetPreLoad ()
virtual StatusCode	preLoad (int depth, int load_depth, DataObject *pObject)
virtual StatusCode	preLoad ()
virtual StatusCode	registerObject (const std::string &fullPath, DataObject *pObject)
virtual StatusCode	registerObject (const std::string &parentPath, const std::string &objPath, DataObject *pObject)
virtual StatusCode	registerObject (const std::string &parentPath, int item, DataObject *pObject)
virtual StatusCode	registerObject (DataObject *parentObj, int item, DataObject *pObject)
virtual StatusCode	unregisterObject (const std::string &fullPath)
virtual StatusCode	unregisterObject (const std::string &parentPath, const std::string &objectPath)
virtual StatusCode	unregisterObject (const std::string &parentPath, int item)
virtual StatusCode	unregisterObject (DataObject *pObject)
virtual StatusCode	unregisterObject (DataObject *pObject, const std::string &objectPath)
virtual StatusCode	unregisterObject (DataObject *pObject, int item)
virtual StatusCode	retrieveObject (IRegistry *pDirectory, const std::string &path, DataObject *&pObject)
virtual StatusCode	retrieveObject (const std::string &fullPath, DataObject *&pObject)
virtual StatusCode	retrieveObject (const std::string &parentPath, const std::string &objPath, DataObject *&pObject)
virtual StatusCode	retrieveObject (const std::string &parentPath, int item, DataObject *&pObject)
virtual StatusCode	retrieveObject (DataObject *parentObj, const std::string &objPath, DataObject *&pObject)
virtual StatusCode	retrieveObject (DataObject *parentObj, int item, DataObject *&pObject)
virtual StatusCode	findObject (const std::string &fullPath, DataObject *&pObject)
virtual StatusCode	findObject (IRegistry *pDirectory, const std::string &path, DataObject *&pObject)
virtual StatusCode	findObject (const std::string &parentPath, const std::string &objPath, DataObject *&pObject)
virtual StatusCode	findObject (const std::string &parentPath, int item, DataObject *&pObject)
virtual StatusCode	findObject (DataObject *parentObj, const std::string &objPath, DataObject *&pObject)
virtual StatusCode	findObject (DataObject *parentObj, int item, DataObject *&pObject)
virtual StatusCode	linkObject (IRegistry *from, const std::string &objPath, DataObject *to)
virtual StatusCode	linkObject (const std::string &fromPath, const std::string &objPath, DataObject *to)
virtual StatusCode	linkObject (DataObject *from, const std::string &objPath, DataObject *to)
virtual StatusCode	linkObject (const std::string &fullPath, DataObject *to)
virtual StatusCode	unlinkObject (IRegistry *from, const std::string &objPath)
virtual StatusCode	unlinkObject (const std::string &fromPath, const std::string &objPath)
virtual StatusCode	unlinkObject (DataObject *fromObj, const std::string &objPath)
virtual StatusCode	unlinkObject (const std::string &fullPath)
virtual StatusCode	updateObject (IRegistry *pDirectory)
virtual StatusCode	updateObject (const std::string &updatePath)
virtual StatusCode	updateObject (DataObject *toUpdate)
virtual StatusCode	updateObject (const std::string &parentPath, const std::string &updatePath)
virtual StatusCode	updateObject (DataObject *pParent, const std::string &updatePath)
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvUnknown)
virtual unsigned long	addRef ()
virtual unsigned long	release ()
virtual const std::string &	name () const
virtual const InterfaceID &	type () const
virtual StatusCode	configure ()
virtual StatusCode	start ()
virtual StatusCode	stop ()
virtual StatusCode	terminate ()
virtual Gaudi::StateMachine::State	FSMState () const
virtual Gaudi::StateMachine::State	targetFSMState () const
virtual StatusCode	restart ()
virtual StatusCode	sysInitialize ()
virtual StatusCode	sysStart ()
virtual StatusCode	sysStop ()
virtual StatusCode	sysFinalize ()
virtual StatusCode	sysReinitialize ()
virtual StatusCode	sysRestart ()
virtual StatusCode	setProperty (const Property &p)
virtual StatusCode	setProperty (const std::string &s)
virtual StatusCode	setProperty (const std::string &n, const std::string &v)
StatusCode	setProperty (const std::string &name, const TYPE &value)
virtual StatusCode	getProperty (Property *p) const
virtual const Property &	getProperty (const std::string &name) const
virtual StatusCode	getProperty (const std::string &n, std::string &v) const
virtual const std::vector< Property * > &	getProperties () const
ISvcLocator *	serviceLocator () const
IMessageSvc *	msgSvc ()
IMessageSvc *	msgSvc () const
IMessageSvc *	messageService ()
IMessageSvc *	messageService () const
StatusCode	setProperties ()
StatusCode	service (const std::string &name, T *&psvc, bool createIf=true) const
StatusCode	service (const std::string &svcType, const std::string &svcName, T *&psvc) const
Property *	declareProperty (const std::string &name, T &property, const std::string &doc="none") const
Property *	declareRemoteProperty (const std::string &name, IProperty *rsvc, const std::string &rname="") const
IAuditorSvc *	auditorSvc () const
Static Public Member Functions
static const InterfaceID &	interfaceID ()
static const InterfaceID &	interfaceID ()
static const InterfaceID &	interfaceID ()
static const InterfaceID &	interfaceID ()
static const InterfaceID &	interfaceID ()
Public Attributes
	SUCCESS
	NO_INTERFACE
	VERSMISMATCH
	LAST_ERROR
	SEPARATOR
	IID_IDataProviderSvc_NO_ERROR
	DOUBL_OBJ_PATH
	INVALID_OBJ_PATH
	INVALID_ROOT
	INVALID_OBJECT
	INVALID_PARENT
	OBJ_NOT_LOADED
	NO_DATA_LOADER
	INVALID_OBJ_ADDR
	DIR_NOT_EMPTY
	NO_MORE_LEVELS
	NO_ACCESS
	LAST
Protected Member Functions
bool	checkRoot ()
virtual IConversionSvc *	getDataLoader (IRegistry *pReg)
virtual DataObject *	createDefaultObject () const
virtual StatusCode	loadObject (IRegistry *pNode)
StatusCode	retrieveEntry (DataSvcHelpers::RegistryEntry *pNode, const std::string &path, DataSvcHelpers::RegistryEntry *&pEntry)
DataObject *	handleDataFault (IRegistry *pReg, const std::string &path="")
int	outputLevel () const
Protected Attributes
CLID	m_rootCLID
std::string	m_rootName
IConversionSvc *	m_dataLoader
IIncidentSvc *	m_incidentSvc
LoadItems	m_preLoads
bool	m_forceLeaves
bool	m_enableAccessHdlr
bool	m_enableFaultHdlr
DataSvcHelpers::RegistryEntry *	m_root
DataSvcHelpers::InhibitMap *	m_inhibitMap
std::vector< std::string >	m_inhibitPathes
std::string	m_accessName
std::string	m_faultName
IntegerProperty	m_outputLevel
Gaudi::StateMachine::State	m_state
Gaudi::StateMachine::State	m_targetState
IMessageSvc *	m_messageSvc
Private Member Functions
StatusCode	archiveObject (DataObject *pObject)
StatusCode	sequenceObject (DataObject *pObject)
Private Attributes
StringProperty	m_regSeqPath
IDataProviderSvc *	m_archiveSvc
IConversionSvc *	m_cnvSvc
bool	m_useAes
Friends
class	SvcFactory< DybDataSvc >
friend class	ServiceManager

---

Detailed Description

A DybDataSvc is the base class for event services.

Author:

S. Patton

Definition at line 15 of file DybDataSvc.h.

---

Constructor & Destructor Documentation

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

Standard Constructor.

Definition at line 27 of file DybDataSvc.cpp.

    : DataSvc(name,svc)
    , m_archiveSvc(0)
    , m_cnvSvc(0)
    , m_useAes(true)
{


  declareProperty("RegSeqPath",
                  m_regSeqPath=RegistrationSequence::defaultLocation(),
                  "Path, in the TES, where the RegistrationSequnce object is kept");
  declareProperty("UseAes",m_useAes,
                  "Whether or not to use the AES, default is true");
  setProperty("ForceLeaves", "true");

  {
    MsgStream log(msgSvc(), "DybDataSvc::DybDataSvc()");
    log << MSG::DEBUG
        << "initializing"
        << endreq;
  }
}

DybDataSvc::~DybDataSvc

(

)

[virtual]

Standard Destructor.

Definition at line 52 of file DybDataSvc.cpp.

{
  if (0 != m_archiveSvc) {
    m_archiveSvc->release();
  }

  if (0 != m_cnvSvc) {
    m_cnvSvc->release();
  }
}

---

Member Function Documentation

StatusCode DybDataSvc::initialize

(

)

[virtual]

Service initialisation.

Reimplemented from DataSvc.

Definition at line 64 of file DybDataSvc.cpp.

{
  StatusCode status  = DataSvc::initialize();
  if (status.isFailure()) {
    throw GaudiException("Could not initialize super class",
                         name(),
                         status);
  }

  MsgStream log(msgSvc(), "DybDataSvc::initialize()");
  log << MSG::DEBUG << "initializing DybDataSvc @"
      << (void*)this
      << " named " << name()
      << " UseAes is " << m_useAes
      << " ForceLeaves is " << m_forceLeaves
      << endreq;

  ISvcLocator*    svc_loc = serviceLocator();

  status = svc_loc->service("EventPersistencySvc",
                            m_cnvSvc,
                            true);
  if( status.isFailure() ) {
    throw GaudiException("Service [EventPersistencySvc] not found",
                         name(),
                         status);
  }
  status = setDataLoader( m_cnvSvc );
  if( status.isFailure() ) {
    throw GaudiException("Could not set DataLoader",
                         name(),
                         status);
  }

  log << MSG::DEBUG << "DybDataSvc @" << (void*)this
      << " has UseAes = " << m_useAes << endreq;

  if (m_useAes) {
    log << MSG::INFO
        << "Using [EvtDataSvc] as the archive service"
        << endreq;

    status = svc_loc->service("EventDataArchiveSvc", m_archiveSvc, true);
    if( status.isFailure() || !m_archiveSvc ) {
      log << MSG::ERROR << "Service [EventDataArchiveSvc] not found" << endreq;
      return status;
    }
    SmartIF<IProperty> property(m_archiveSvc);
    if (!property) {
      log << MSG::ERROR
          << "The EvtDataSvc has no property interface" << endreq;
      return StatusCode::FAILURE;
    }
    property->setProperty("ForceLeaves","true");
  }
  else {
    log << MSG::DEBUG
        << "DybDataSvc @"
        << (void*)this
        << ", not using Archive Event Store (AES)"
        << endreq;
  }
  return status;
}

StatusCode DybDataSvc::reinitialize

(

)

[virtual]

Service reinitialisation.

Reimplemented from DataSvc.

Definition at line 130 of file DybDataSvc.cpp.

{
  // Do nothing for this service
  return StatusCode::SUCCESS;
}

StatusCode DybDataSvc::finalize

(

)

[virtual]

Service finalization.

Reimplemented from DataSvc.

Definition at line 137 of file DybDataSvc.cpp.

{
  if( 0 != m_archiveSvc ) {
    m_archiveSvc->release();
  }
  m_archiveSvc = 0;

  if( 0 != m_cnvSvc ) {
    m_cnvSvc->release();
  }
  m_cnvSvc = 0;

  DataSvc::finalize().ignore();
  return StatusCode::SUCCESS ;
}

IDataProviderSvc * DybDataSvc::archiveSvc

(

)

const

Accessors.

Definition at line 154 of file DybDataSvc.cpp.

{
  return m_archiveSvc;
}

StatusCode DybDataSvc::setRoot	(	const std::string &	root_path,
		DataObject *	pRootObj
	)			[virtual]

Override existing methods.

Reimplemented from DataSvc.

Definition at line 161 of file DybDataSvc.cpp.

                                                     {
  StatusCode result = DataSvc::setRoot(root_path,
                                       pRootObj);
  if (m_useAes) {
    DataObject* existingRoot = 0;
    archiveSvc()->retrieveObject(root_path,
                                 existingRoot).ignore();
    if ( 0 == existingRoot ) {
      IDataManagerSvc* archiveMgr = dynamic_cast<IDataManagerSvc*>(archiveSvc());
      StatusCode status = archiveMgr->setRoot(root_path,
                                              new DybArchiveList());
      if (status.isFailure()) return status;
    }
  }
  return result;
}

StatusCode DybDataSvc::setRoot	(	const std::string &	root_path,
		IOpaqueAddress *	pRootAddr
	)			[virtual]

Reimplemented from DataSvc.

Definition at line 181 of file DybDataSvc.cpp.

                                                          {
  StatusCode result = DataSvc::setRoot(root_path,
                                       pRootAddr);
  if (m_useAes) {
    DataObject* existingRoot = 0;
    archiveSvc()->retrieveObject(root_path,
                                 existingRoot).ignore();
    if ( 0 == existingRoot ) {
      IDataManagerSvc* archiveMgr = dynamic_cast<IDataManagerSvc*>(archiveSvc());
      StatusCode status = archiveMgr->setRoot(root_path,
                                              new DybArchiveList());
      if (status.isFailure()) return status;
    }
  }
  return result;
}

StatusCode DybDataSvc::loadObject	(	IConversionSvc *	pLoader,
		IRegistry *	pRegistry
	)			[virtual]

Override main 'loadObject' method.

Get loaded object an place in archive collection

Reimplemented from DataSvc.

Definition at line 200 of file DybDataSvc.cpp.

                                                        {

  {
    MsgStream log(msgSvc(), "DybDataSvc::loadObject()");
    log << MSG::DEBUG
        << "loading "<<pRegistry->identifier()
        << " with loader "<<pLoader
        << endreq;
  }
  
  StatusCode result = DataSvc::loadObject(pLoader,
                                          pRegistry);

  RegEntry *pEntry = CAST_REGENTRY(RegEntry*,pRegistry);
  DataObject* pObject = pEntry->object();

  if (0 == pObject) {
    return result;
  }

  {
    MsgStream log(msgSvc(), "DybDataSvc::loadObject()");
    log << MSG::DEBUG
        << " registry->identifier() == " << pRegistry->identifier()
        << " pObject->registry()->identifier() == " << pObject->registry()->identifier()
        << endreq;
  }

  result = sequenceObject(pObject);
  if (result.isFailure()) return result;

  if (m_useAes) {
    result = archiveObject(pObject);
  }
  return result;
}

StatusCode DybDataSvc::registerAddress	(	IRegistry *	parentObj,
		const std::string &	objPath,
		IOpaqueAddress *	pAddress
	)			[virtual]

Override main 'registerObject' method.

Do NOT 'archive' address ... wait for loadObject to be called.

Reimplemented from DataSvc.

Definition at line 240 of file DybDataSvc.cpp.

{
  MsgStream log(msgSvc(), "DybDataSvc::registerAddress()");

  StatusCode result = DataSvc::registerAddress(parentObj,
                                               objPath,
                                               pAddress);
  if (result.isFailure()) {
      return result;
  }

  // Do nothing more if there is no parent object (as this will be
  // handled later by the recursion).
  if (0 == parentObj ) {
    return result;
  }

  // Do nothing more if the object path contains a separator (as this
  // will be handled later by the recursion).
  std::string::size_type sep = objPath.find(SEPARATOR,1);
  if ( sep != std::string::npos ) {
    return result;
  }

  // Get the full path of the registered object.
  if (0 == pAddress) {
    return result;
  }

  IRegistry* entry = pAddress->registry();
  if (0 == entry) {
    return result;
  }

  if (m_useAes) {
    // Retrieve collection
    DataObject* collection=0;
    archiveSvc()->retrieveObject(entry->identifier(),
                                 collection).ignore();

    if (0 == collection) {
      StatusCode status = archiveSvc()->registerObject(entry->identifier(),
                                                       new DybArchiveList());
      if (status.isFailure()) return status;
    }
  }


  return StatusCode::SUCCESS;
}

StatusCode DybDataSvc::registerObject	(	DataObject *	parentObj,
		const std::string &	objPath,
		DataObject *	pObject
	)			[virtual]

Override main 'registerObject' method.

Reimplemented from DataSvc.

Definition at line 295 of file DybDataSvc.cpp.

{
  MsgStream log(msgSvc(), "DybDataSvc::registerObject()");
  log << MSG::DEBUG
      << "use aes = " << m_useAes << " "
      << "parent = \"" << (parentObj ? parentObj->name() : "(none)")  << "\" "
      << "path = \"" << objPath << "\" "
      << "obj = \"" << (pObject ? pObject->name() : "(none)") << "\""
      << endreq;

  // wangzhe
  // The following part makes sure put() method can deal with TES, AES
  // smoothly. User will not worry about AES usage and unregisterObject again.
  // When the second header object comes into TES, the existing object in that 
  // path will be unregistered.
  // By doing this the last data object produced is always in TES.
  // When the event rate is low the data in TES in top stage using in Fifteen
  // is the same as push method
  if(m_useAes) {
    // This story is not about usual data object.
    if( pObject->clID() != DataObject::classID() ) {
      // If choose to use AES, firstly check whether that path exists 
      // and whether there are data object with it.
      // Because some data object might already be there.
      // If it really exists unregister it since it is in AES now.
      // It is safe to remove it from TES.
      DataObject* pEstObj=0;
      StatusCode sc = DataSvc::findObject(parentObj,objPath,pEstObj);
      if(sc.isSuccess()) {
        if(pEstObj!=0) {
          DataSvc::unregisterObject(pEstObj);
          // Why there is a release? See DocDB 3242, page 2 memo
          // Gaudi isn't perfect and has defect.
          pEstObj->release();
        }
      }
    }
  } else {
    // If AES is not chosen to use, then ignore this step.
    // For the case of only using TES, such an operation will possibly remove that
    // object from memory if there is no other place holding it.
    // From this point of view it is dangerous to unregister an object like this.
    // If user really want to register two objects in the same path,
    // it is strongly encouraged that he/she should do it by themselves.
  }
  // wz

  StatusCode result = DataSvc::registerObject(parentObj,
                                              objPath,
                                              pObject);

  // Do nothing more if there is no parent object (as this will be
  // handled later by the recursion).
  if (0 == parentObj ) {
    return result;
  }

  // Do nothing more if the object path contains a separator (as this
  // will be handled later by the recursion).
  std::string::size_type sep = objPath.find(SEPARATOR,1);
  if ( sep != std::string::npos ) {
    return result;
  }

  // Get the full path of the registered object.
  if (0 == pObject) {
    return result;
  }

  IRegistry* pRegistry = pObject->registry();
  if (0 == pRegistry) {
    return result;
  }

  result = sequenceObject(pObject);
  if (result.isFailure()) return result;

  if (m_useAes) {
    result = archiveObject(pObject);
  }
  return result;
}

StatusCode DybDataSvc::archiveObject

(

DataObject *

pObject

)

[private]

Definition at line 380 of file DybDataSvc.cpp.

                                                        {

  std::string path = pObject->registry()->identifier();

  MsgStream log(msgSvc(), "DybDataSvc::archiveObject()");

  if (!m_useAes) {
    log << MSG::ERROR << "archiveObject() called but told not to use AES"
        << endreq;
    return StatusCode::FAILURE;
  }

  if (pObject->clID() == DataObject::classID()) {
      log << MSG::DEBUG
          << "Not archiving plain DataObject at "
          << path << endreq;
      return StatusCode::SUCCESS;
  }

  // Retrieve collection and add object.
  DataObject* collection=0;
  StatusCode sc =  archiveSvc()->retrieveObject(path, collection);
  sc.ignore();
  //if (sc.isFailure()) {
  //    log << MSG::WARNING << "failed to retrieve list at "
  //        << pRegistry->identifier()
  //        << " will register new one" << endreq;
  //}

  DybArchiveList* list = 0;
  if (0 == collection) {
    list = new DybArchiveList();
    StatusCode status = archiveSvc()->registerObject(path, list);
    if (!status.isSuccess()) {
      log << MSG::WARNING << "failed to register list at "
          << path << endreq;
      return StatusCode(status.getCode(),
                        status.severity());
    }
  } else {
    list = dynamic_cast<DybArchiveList*>(collection);
  }

  list->push_front((DybArchiveList::const_reference)pObject);

  return StatusCode::SUCCESS;
}

StatusCode DybDataSvc::sequenceObject

(

DataObject *

pObject

)

[private]

Definition at line 428 of file DybDataSvc.cpp.

{
  // Record registration sequence of this object.

  // Don't sequence base DataObject, they just make up directory structure.
  if (pObject->clID() == CLID_DataObject) return StatusCode::SUCCESS;

  MsgStream log(msgSvc(), "DybDataSvc::sequenceObject()");

  std::string path = pObject->registry()->identifier();

  // Do not sequence the RegistrationSequnce to avoid infinite loop
  if (m_regSeqPath.value() == path) {
    return StatusCode::SUCCESS;
  }

  {
      DataObject* dobj = 0;
      StatusCode sc = retrieveObject("/Event",dobj);
      if (sc.isFailure()) {
          log << MSG::ERROR << "falied to retrieve /Event" << endreq;
          return sc;
      }
      else {
          //log << MSG::INFO << "got /Event" << endreq;
      }
  }

  // Retieve registration sequence object.
  DataObject* object = 0;
  StatusCode sc = retrieveObject(m_regSeqPath.value(),object);
  sc.ignore();
  //if (sc.isFailure()) {
  //    log << MSG::WARNING << "failed to retrieve reg seq obj from "
  //        << m_regSeqPath.value() << " will register new one " << endreq;
  //}
  RegistrationSequence* regSeq = 0;
  if (0 == object) {
    regSeq = new RegistrationSequence();
    StatusCode status = registerObject(0,m_regSeqPath.value(),regSeq);
    if (!status.isSuccess()) {
      log << MSG::WARNING << "failed to register object "
          << m_regSeqPath.value() << endreq;

      return StatusCode(status.getCode(),
                        status.severity());
    }
  } else {
    regSeq = dynamic_cast<RegistrationSequence*>(object);
  }
  log << MSG::DEBUG << "inserting into RegSeq: " << path << endreq;

  regSeq->insert(pObject->registry(), pObject, true);

  return StatusCode::SUCCESS;
}

---

Friends And Related Function Documentation

friend class SvcFactory< DybDataSvc > [friend]

Definition at line 16 of file DybDataSvc.h.

---

Member Data Documentation

StringProperty DybDataSvc::m_regSeqPath [private]

Definition at line 53 of file DybDataSvc.h.

IDataProviderSvc* DybDataSvc::m_archiveSvc [private]

Definition at line 55 of file DybDataSvc.h.

IConversionSvc* DybDataSvc::m_cnvSvc [private]

Definition at line 56 of file DybDataSvc.h.

bool DybDataSvc::m_useAes [private]

Definition at line 57 of file DybDataSvc.h.

---

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

• /home/dayabay/installs/trunk_2011_04_11_opt/NuWa-trunk/dybgaudi/DybSvc/DybEventMgr/src/DybDataSvc.h
• /home/dayabay/installs/trunk_2011_04_11_opt/NuWa-trunk/dybgaudi/DybSvc/DybEventMgr/src/DybDataSvc.cpp

---