Bdb packages | Design docs | Source docs | Guidelines | Recent releases
	Search | Site Map .

                 

---

/BdbCond/BdbEnvProxy.cc

Go to the documentation of this file.

#ifndef BDBENVPROXY_CC
#define BDBENVPROXY_CC

#include "BaBar/BaBar.hh"
#include "ProxyDict/AbsArgCast.hh"
#include "ProxyDict/IfdKey.hh"
#include "BdbTime/BdbIntervalBase.hh"
#include "BdbCond/BdbEnvProxy.hh"
#include "BdbCond/BdbInterval.hh"
#include "BdbCond/BdbConditions.hh"
#include "BdbCond/BdbObject.hh"
#include "BdbCond/BdbObsoleteDatabase.hh"
#include "BdbCond/BdbCondDefStrategy.hh"
#include "EidData/EidCondKeyTriplet.hh"
#include "ErrLogger/ErrLog.hh"
#include <string>
using std::string;

template< class T, class TP >
BdbEnvProxy< T, TP >::BdbEnvProxy( const std::string& container,
                                   const std::string& dbName,
                                   BdbCondDefStrategy *strategy)
 : _container ( container ),
  _dbName( dbName ),
  _transient( 0 ),
  _db( 0 ),
  _strategy(strategy)
{
}

template< class T, class TP  >
BdbEnvProxy< T, TP >::~BdbEnvProxy()
{
}

template< class T, class TP  >
T*
BdbEnvProxy< T, TP >::faultHandler( IfdProxyDict* thedict,
                                    const IfdKey& thekey,
                                    AbsArg& timearg)
{
  // local variables to optimise database access
  // Decode the time from the AbsArg
  BdbTime t;
  if (_strategy.get()==0) { // go for the specified time
    BdbTime* time = AbsArgCast< BdbTime >::value( timearg );
    if (time==0) ErrMsg(fatal) << "you _must_ specify a time " << endmsg;
    t = *time;
  } else { // ignore any external time
    t = _strategy->defaultKey().key();
  }
  if ( _transient.get() == 0 || ! _transientInterval.inInterval( t ) ) {
    startTransaction() ;
    if( _db.get() == 0 ) _db.reset( new BdbObsoleteDatabase( _dbName.c_str() ) );
    // get a handle to the persistent object and its transient validity interval
    // in a single call.
    BdbHandle ( TP ) handle;
    _db->fetch( handle, _transientInterval, _container.c_str(), t );
    _transient.reset( handle.isValid() ? handle->transient() : 0 );
    endTransaction() ;
    if (_transient.get() == 0) {
              ErrMsg(fatal) << "Could not find Persistent object in container " << _container
                            << " for time: " << t << endmsg;
    }
//    ErrMsg(warning) << "Fetched "
//                    << (*_transient)
//                    << " for time " <<  time
//                    << " from container " << _container
//                    << " with validity " << _valid << endmsg;
  }
  setCacheIsValid(); // validate the cache
  return _transient.get(); // return the cache
}

template< class T, class TP  >
void BdbEnvProxy< T, TP >::storeHandler( IfdProxyDict*, const IfdKey&, AbsArg&, T* )
{
  ErrMsg(warning) << "Cannot directly store a transient Object" << endmsg;
}

template< class T, class TP  >
void BdbEnvProxy< T, TP >::testCache()
{
  setCacheInvalid();
}

#endif // BDBENVPROXY_CC

 

---

BaBar Public Site | SLAC | News | Links | Who's Who | Contact Us

Page Owner: Jacek Becla
Last Update: October 04, 2002