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

                 

---

/BdbClustering/BdbCustomClustH.cc

Go to the documentation of this file.

//------------------------------------------------------------------------------
// File:
//      BdbCustomClustH.cc
//
// Description:
//      Clustering hint class which allows a user to specify both 
//      database and container name.
//
// Environment:
//      Software developed for the BaBar Detector at the SLAC B-Factory
//
// Author List:
//      Jacek Becla                Original Author
//
// Copyright Information:
//      Copyright (C) 1997-98      Stanford Linear Accelerator Center
//
//------------------------------------------------------------------------------

// -------------------------
// -- This Class's Header --
// -------------------------

#include "BdbClustering/BdbCustomClustH.hh"

// ---------------------------------
// -- Collaborating Class Headers --
// ---------------------------------
#include "BdbApplication/BdbDomain.hh"
#include "BdbApplication/BdbErrorSignal.hh"
#include "BdbAccess/BdbFSMgr.hh"
#include "BdbClustering/BdbClusteringErrors.hh"
#include "BdbClustering/BdbComponent.hh"

// ---------------
// -- C Headers --
// ---------------

extern "C" {
#include <assert.h>
}

// -------------------------------
// -- Constructors / Destructor --
// -------------------------------

BdbCustomClustH::BdbCustomClustH(const BdbDomain& domain, 
                                 const char* compName, 
                                 const char* dbName, 
                                 d_ULong maxWaitTime, 
                                 d_Boolean quiet)
                : BdbAbsBaseClustH(domain, maxWaitTime, quiet),
                  _useDefaultFS(d_False)
{
    if ( compName != 0 ) {
        setComponent(compName) ;
    }
    if ( dbName != 0 ) {
        setDatabaseName(dbName) ;
    }

    resetHints() ;
}


BdbCustomClustH::~BdbCustomClustH()
{
}



BdbStatus 
BdbCustomClustH::setComponent(const char* name)
{
    if ( BdbAbsBaseClustH::setComponent(name) != BdbcSuccess ) {
        return _es->BdbESig(BdbClusteringErrFunctionFailed, 
                "BdbCustomClustH::setComponent", "in BdbAbsBaseClustH::setComponent") ;
    }
    
    _changeAuthLevel = d_True ;

    return BdbcSuccess ;
}



/**  
 **  Input:  name of a database
 **         
 **  Output: error status (BdbcSuccess or BdbcError)
 **
 **  Modifier. The function sets database name.
 **            After this call, next call to hint() function
 **            will close current database and open 
 **            or create a new database with the name
 **            specified here.
 **/

BdbStatus
BdbCustomClustH::setDatabaseName(const char* dbName)
{
    if ( dbName == (char*)0) { 
        _es->BdbESig(BdbClusteringErrNameNotValid, 0, 
                  "BdbCustomClustH::setDatabaseName") ;
    }

    _dbName.resize(strlen(dbName)+1) ;
    _dbName = dbName ;

    _rebuildDb = 1 ;

    return BdbcSuccess ;
}



/**  
 **  Input:  name of a container
 **         
 **  Output: error status (BdbcSuccess or BdbcError)
 **
 **  Modifier. The function sets container name.
 **            After this call, next call to hint() function
 **            will close current container and create 
 **            container with the name specified here
 **            (in current database).
 **/

BdbStatus
BdbCustomClustH::setContainerName(const char* contName)
{
    if ( contName == (char*)0) { 
        _es->BdbESig(BdbClusteringErrNameNotValid, 
                  "BdbCustomClustH::setContainerName") ;
    }

    _contName.resize(strlen(contName)+1) ;
    _contName = contName ;
    
    _rebuildCont = 1 ;

    return BdbcSuccess ;
}







BdbRefAny 
BdbCustomClustH::updatedHint()
{
    if ( compObj()->isIllegal() ) {
        _es->BdbESig(BdbClusteringErrComponentNotValid, 
                  "BdbCustomClustH::updatedHint") ;
        assert(0) ;
    }

    if ( _changeAuthLevel ) {
        if ( changeAuthL(BdbDomain::Group, compObj()->name()) != BdbcSuccess ) {
            _es->BdbESig(BdbClusteringErrFunctionFailed, 
                      "BdbCustomClustH::updatedHint", "in changeAuthL") ;
            assert(0) ;
        }
    }

    BdbApplicationOrDomain* theApp = BdbApplicationOrDomain::activeInstance();
    d_Long oldWait = theApp->lockWait();
    if ( oldWait != maxWaitTime() ) {
        theApp->setLockWait( maxWaitTime() );
    }

    if ( compObj()->componentChanged() || authLevelChanged() || authNameChanged() ) {
        if ( fsMgr()->rebuildFSInfo( domain()->domainName(), 
                                     domain()->authLevelName(),
                                     domain()->authName(), 
                                     ccompObj()->name()) != BdbcSuccess ) {
            ;  // be quiet on errors
        }
        _rebuildDb = 1 ;
    }

    refreshCurrentAuthLevel() ;
    refreshCurrentAuthName();

    if ( _rebuildDb ) {
        resetHints() ;
    }

    resetContHint() ;

    if ( reload() != BdbcSuccess ) {
        theApp->setLockWait(oldWait);
        _es->BdbESig(BdbClusteringErrFunctionFailed, 
                  "BdbCustomClustH::updatedHint", "in reload") ;
        resetContHint();
        return contHint();
    }
    
    if ( BdbIsNull(contHint()) ) {
        theApp->setLockWait(oldWait);
        _es->BdbESig(BdbClusteringErrHandleNotValid, 
                  "BdbCustomClustH::updatedHint") ;
        resetContHint();
        return contHint(); 
    }

    theApp->setLockWait(oldWait);

    oovTopDB = dbHint() ;
    return contHint() ;
}





BdbStatus 
BdbCustomClustH::reload()
{
    if ( localDbName() == 0 ) {
        return _es->BdbESig(BdbClusteringErrInvDbName, 
                         "BdbCustomClustH::reload") ;
    }
    if ( localContName() == 0 ) {
        return _es->BdbESig(BdbClusteringErrInvContName, 
                         "BdbCustomClustH::reload") ;
    }

    if ( rebuildDbHint() != BdbcSuccess ) {
        return _es->BdbESig(BdbClusteringErrFunctionFailed,
                         "BdbCustomClustH::reload", "in rebuildDbHint") ;
    }

    if ( rebuildContHint() != BdbcSuccess ) {
        return _es->BdbESig(BdbClusteringErrFunctionFailed,
                         "BdbCustomClustH::reload", "in rebuildContHint") ;  
    }
   
    compObj()->resetComponentChanged() ;
    _rebuildDb   = 0 ;
    _rebuildCont = 0 ;

    return BdbcSuccess ;
}



BdbStatus 
BdbCustomClustH::rebuildDirectories()
{
  // Set catalogFS/defaultFS switch if enabled

    d_Boolean defaultFS = d_False ;
    if ( _useDefaultFS ) {
        defaultFS = allowRemoteFS() ;
    }

    ooVString dbName( currentDbName() ) ;    // this function should not alter _currentDbName
    ooVString path( currentPath() ) ;        // this function should not alter _currentPath

    if ( buildBaseDirectories(defaultFS) != BdbcSuccess ) { // catalogFS or defaultFS
        return _es->BdbESig(BdbClusteringErrFunctionFailed, 
                         "BdbCustomClustH::rebuildDirectories", "in buildBaseDirectories()") ;
    }

  // Now we have to check if we use the components sub-dirs in
  // current domain.
  
    if (((BdbDomain*) domain())->getDBFSUseComponentSubDir()) {
        strcatPath( compObj()->name() ) ;
        if ( fsMgr()->mkDir(currentPath(), defaultFS) != BdbcSuccess ) { // catalogFS or defaultFS
            return _es->BdbESig(BdbClusteringErrFunctionFailed, 
                         "BdbCustomClustH::rebuildDirectories", "in mkDir") ;
        }
    }

  // Restore previous values of the path and database name.

    strcpyDbName( dbName.head() ) ;
    strcpyPath( path.head() ) ;

    return BdbcSuccess ;
}



BdbStatus 
BdbCustomClustH::rebuildDbHint()
{
    if ( ! BdbIsNull(dbHint()) ) {
        return BdbcSuccess ;
    }

    if ( rebuildDirectories() != BdbcSuccess ) {
        return _es->BdbESig(BdbClusteringErrFunctionFailed, 
                         "BdbCustomClustH::rebuildDbHint", "in rebuildDirectories") ;
    }

    if ( prepareDbName() != BdbcSuccess ) {
        return _es->BdbESig(BdbClusteringErrFunctionFailed,
                         "BdbCustomClustH::rebuildDbHint", "in prepareDbName") ;
    }


    if ( newDb() != BdbcSuccess ) {
        return _es->BdbESig(BdbClusteringErrFunctionFailed,
                         "BdbCustomClustH::rebuildDbHint", "in newDb") ;  
    }
    return BdbcSuccess ;
}



BdbStatus 
BdbCustomClustH::rebuildContHint()
{
    if ( newContainer(localContName()) != BdbcSuccess ) {
        return _es->BdbESig(BdbClusteringErrFunctionFailed, 
                         "BdbCustomClustH::rebuildContHint", "in newContainer") ;
    }

    return BdbcSuccess ;
}



BdbStatus 
BdbCustomClustH::prepareDbName()
{
  // Set catalogFS/defaultFS switch if enabled

    d_Boolean defaultFS = d_False ;
    if ( _useDefaultFS ) {
        defaultFS = allowRemoteFS() ;
    }

    if ( prepareNameSpec(defaultFS) != BdbcSuccess ) { // d_False: catalogFS or defaultFS
        return _es->BdbESig(BdbClusteringErrFunctionFailed, 
                         "BdbCustomClustH::prepareDbName", "in prepareNameSpec") ;
    }

// WARNING: This line wqs commented out because it seems to be unnessesary.
//
//    strcatBoth( compObj()->name() ) ;

    strcatDbName( localDbName(), d_True) ;

    return BdbcSuccess ;
}

 

---

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

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