---

DbPersistent.cpp

Go to the documentation of this file.

//====================================================================
//      DbPersistent implementation
//--------------------------------------------------------------------
//
//      Package    : DbCnv ( The LHCb Offline System)
//
//  Description: Generic data persistency
//
//      Author     : M.Frank
//  History    :
// +---------+----------------------------------------------+---------
// |    Date |                 Comment                      | Who     
// +---------+----------------------------------------------+---------
// | 11/07/99| Initial version                              | MF
// +---------+----------------------------------------------+---------
//====================================================================
#define DBCNV_DVPERSISTENT_CPP

#include "GaudiDb/DbLink.h"
#include "GaudiDb/DbPersistent.h"
#include "GaudiDb/DbContainer.h"
#include "GaudiDb/DbObjectGuard.h"

void DbPersistent::release()    {
  delete this;
}

DbPersistentGuard* DbPersistent::createGuard()   {
  return new DbObjectGuard();
}

void* DbPersistent::allocate ( const dbHandle<DbContainer>& cntH, const DbTypeInfo& type )   {
  if ( cntH.isValid() )   {
    DbPersistent* persistent = type.create(cntH);
    void* transient          = type.allocate();
    DbObjectGuard* guard     = new DbObjectGuard(type.type(), persistent, cntH);
    DbPersistent::setGuard( (DbObject*)transient, guard );
    return transient;
  }
  return 0;
}

DbObject* DbPersistent::create (const DbTypeInfo* type, DbPersistent* persistent, const dbHandle<DbContainer>& cntH)    {
  void* transient        = type->allocate();
  DbObject* pObj         = type->construct(transient);
  DbObjectGuard* guard   = new DbObjectGuard(type->type(), persistent, cntH);
  DbPersistent::setGuard( pObj, guard );
  return pObj;
}

DbObject* DbPersistent::load (DbPersistent* persistent, const dbHandle<DbContainer>& cntH)    {
  const DbTypeInfo* type = persistent->typeInfo();
  DbObject* pObj = create(type, persistent, cntH);
  persistent->load(pObj);
  return pObj;
}

bool DbPersistent::load(DbObject* pObj)   {
  // Stream here all data items of obj!
  DbPersistentGuard* g = DbPersistent::guard(pObj);
  // Read/Write object buffer
  if ( getBuffer(0, g->objectSize(), g->objBuffer()) )    {
    // Read/Write link buffer
    if ( getBuffer(g->objectSize(), g->size()-g->objectSize(), g->linkBuffer()) )    {
      return true;
    }
  }
  return false;
}

bool DbPersistent::save(const DbObject* pObj)   {
  // Stream here all data items of obj!
  const DbPersistentGuard* g = DbPersistent::guard(pObj);
  long linkSize = g->linkBuffer().buffPointer();
  long objSize  = g->objBuffer().buffPointer();
  // Read/Write object buffer
  if ( setBuffer(0, objSize, g->objBuffer()) )    {
    // Read/Write link buffer
    if ( setBuffer(objSize, linkSize, g->linkBuffer()) )    {
      return true;
    }
  }
  return false;
}

---