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

                 

---

/CdbBdbShared/CdbBdbSUtils.cc

Go to the documentation of this file.

/// Implementation file for the CdbBdbSUtils lass
/**
  * @see CdbBdbSCell
  */

#include "BaBar/BaBar.hh"

#include "CdbBdbShared/CdbBdbSUtils.hh"

#include "BdbApplication/BdbDomain.hh"
#include "BdbDistribution/BdbStandardDbIdMgr.hh"
#include "BdbDistribution/BdbDbIdAlloc.hh"
#include "BdbDistribution/BdbFdName.hh"

#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <assert.h>

std::string
CdbBdbSUtils::_localDbIdRange = "";

CdbStatus
CdbBdbSUtils::getLocalDbIdRange( std::string& theName )
{
  // WARNING: The method is using the cached value of the range, which might not
  //          work if there is more than one Objectivity context for the Condition/DB.

    CdbStatus result = CdbStatus::NotFound;
    do {

      // Still need to load the cache?

        if ( _localDbIdRange == "" ) {

          // The following operations are executed withing a separate context
          // in order not to leave locks 

            BdbStatus status;

            status = BdbApplicationOrDomain::activeInstance( )->startNestedRead( );
            if( status != BdbcSuccess ) {
                assert( 0 );
                result = CdbStatus::Error;
                break;
            }
            {
                BdbHandle(BdbFdName) theFdNameH;
                theFdNameH = BdbFdName::localInstance( BdbApplicationOrDomain::activeInstance()->fd( ));

                const char* rangeName = BdbStandardDbIdMgr::findKey( theFdNameH, "con" );
                if ( 0 != rangeName ) _localDbIdRange = rangeName;
            }
            status = BdbApplicationOrDomain::activeInstance( )->commitNested( );
            if( status != BdbcSuccess ) {
                assert( 0 );
                result = CdbStatus::Error;
                break;
            }
        }
        if ( _localDbIdRange != "" ) {
            theName = _localDbIdRange;
            result = CdbStatus::Success;
        }

    } while( false );

    return result;
}

CdbStatus
CdbBdbSUtils::verifyDbIdRange( const char* theName )
{
    CdbStatus result = CdbStatus::NotFound;
    do {

        if( 0 != theName ) {

          // The following operations are executed withing a separate context
          // in order not to leave locks 

            BdbStatus status;

            status = BdbApplicationOrDomain::activeInstance( )->startNestedRead( );
            if( status != BdbcSuccess ) {
                assert( 0 );
                result = CdbStatus::Error;
                break;
            }
            {
                BdbHandle(BdbDbIdAlloc) allocH;
                allocH = BdbDbIdAlloc::localInstance( BdbApplicationOrDomain::activeInstance()->fd( ));
                if( ! BdbIsNull(allocH)) {

                    char** aList = 0;
                    size_t aNum  = 0;
                    
                    aNum = allocH->keys( aList );
                    if(( 0 != aList ) && ( 0 != aNum )) {
                        for( size_t i = 0; i < aNum; ++i ) {
                            if( 0 == strcmp( theName, aList[i] )) result = CdbStatus::Success;
                            delete [] aList[i]; // Don't need this anymore
                        }
                        delete [] aList;    // Don't need the list anymore
                    }
                }
            }
            status = BdbApplicationOrDomain::activeInstance( )->commitNested( );
            if( status != BdbcSuccess ) {
                assert( 0 );
                result = CdbStatus::Error;
                break;
            }
        }

    } while( false );

    return result;
}

CdbStatus
CdbBdbSUtils::findContainer( BdbHandle(BdbContObj)& theContH,
                             const char*            theDatabaseName,
                             const char*            theContainerName,
                             const BdbMode          theOpenMode )
{
    const char* errorStr = "CdbBdbSUtils::findContainer() - ERROR.";

    CdbStatus result = CdbStatus::NotFound;
    do {

      // Find the database

        BdbHandle(BdbDBObj) dH;

        if( CdbStatus::Success != findDatabase( dH,
                                                theDatabaseName,
                                                BdbcRead )) {
            break;
        }

      // Find the container.

        BdbStatus status;

        BdbHandle(BdbContObj) cH;

        if( d_True != cH.exist( dH,
                                theContainerName,
                                BdbcNoOpen )) {
            break;
        }
        status = cH.open( dH,
                          theContainerName,
                          theOpenMode );
        if(( BdbcSuccess != status ) || BdbIsNull(cH)) {
            cout << errorStr << endl
                 << "    Failed to open the container: \"" << theContainerName << "\"" << endl
                 << "    at the database:              \"" << theDatabaseName << "\"" << endl;
            result = CdbStatus::Error;
            break;
        }

      // Done

        theContH = cH;

        result = CdbStatus::Success;

    } while( false );

    return result;
}

CdbStatus
CdbBdbSUtils::findDatabase( BdbHandle(BdbDBObj)& theDatabaseH,
                            const char*          theDatabaseName,
                            const BdbMode        theOpenMode )
{
    const char* errorStr = "CdbBdbSUtils::findDatabase() - ERROR.";

    CdbStatus result = CdbStatus::NotFound;
    do {

        BdbStatus status;

      // Find the database

        BdbHandle(BdbDBObj) dH;

        if( d_True != dH.exist( BdbApplicationOrDomain::activeInstance()->fd( ),
                                theDatabaseName,
                                BdbcNoOpen )) {
            break;
        }
        status = dH.open( BdbApplicationOrDomain::activeInstance()->fd( ),
                          theDatabaseName,
                          theOpenMode );
        if(( BdbcSuccess != status ) || BdbIsNull(dH)) {
            cout << errorStr << endl
                 << "    Failed to open the database: \"" << theDatabaseName << "\"" << endl;
            result = CdbStatus::Error;
            break;
        }

      // Done

        theDatabaseH = dH;

        result = CdbStatus::Success;

    } while( false );

    return result;
}

CdbStatus
CdbBdbSUtils::findMetaData( BdbRef(CdbBdbSMetaDataP)& theRef,
                            const d_UShort            theConditionId,
                            bool                      isPartitionableFlag,
                            d_UShort                  thePartitionId,
                            d_UShort                  theClusterId,
                            d_UShort                  theIncrementNumber,
                            const std::string&        theDbIdRange )
{
    const char* errorStr = "CdbBdbSUtils::findMetaData() -- ERROR";

    CdbStatus result = CdbStatus::Error;
    do {

      // Build the database name

        std::string databaseName( "con_cdb" );

        if( isPartitionableFlag ) {

            char numberStr[12];
            sprintf( numberStr, "%u", thePartitionId );

            databaseName = databaseName +
                           std::string( "_p" ) +
                           std::string( numberStr );
        }
        {
            char numberStr[12];
            sprintf( numberStr, "%u", theClusterId );

            databaseName = databaseName +
                           std::string( "_c" ) +
                           std::string( numberStr );
        }
        {
            char numberStr[12];
            sprintf( numberStr, "%u", theIncrementNumber );

            databaseName = databaseName +
                           std::string( "_i" ) +
                           std::string( numberStr );
        }
        databaseName = databaseName +
                       std::string( "_" ) +
                       theDbIdRange;

      // Build the container name

        char cIdStr[12];
        sprintf( cIdStr, "%u", theConditionId );

        std::string mdContainerName = std::string( "MetaData." ) +
                                      std::string( cIdStr );

      // Try to locate the container and the MetaData object in this
      // container.

        BdbHandle(BdbContObj) mdContH;
        if( CdbStatus::Success != CdbBdbSUtils::findContainer( mdContH,
                                                               databaseName.c_str( ),
                                                               mdContainerName.c_str( ))) {
            cout << errorStr << endl
                 << "    Failed to locate/open a persistent container with meta-data." << endl
                 << "    The database may not be properly initialized/loaded." << endl
                 << "        CONTAINER NAME:     \"" << mdContainerName.c_str( ) << "\"" << endl
                 << "        DATABASE FILE NAME: \"" << databaseName.c_str( ) << "\"" << endl;
            break;
        }

        BdbHandle(CdbBdbSMetaDataP) mdH;
        if( BdbcSuccess != mdH.lookupObj( mdContH,
                                          "MetaData" )) {
            cout << errorStr << endl
                 << "    Failed to locate the \"MetaData\" registry object in the container." << endl
                 << "    The database may not be properly initialized/loaded." << endl
                 << "        CONTAINER NAME:     \"" << mdContainerName.c_str( ) << "\"" << endl
                 << "        DATABASE FILE NAME: \"" << databaseName.c_str( ) << "\"" << endl;
            break;
        }
        assert( mdH->ooIsKindOf( ooTypeN( CdbBdbSMetaDataP )));

      // Done.

        theRef = mdH;

        result = CdbStatus::Success;

    } while( false );

    return result;
}

/////////////////
// End Of File //
/////////////////

 

---

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

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