---

CdbBdbSMasterRegistryP.cc

Go to the documentation of this file.

// File and Version Information:
//      $Id: CdbBdbSMasterRegistryP.cc,v 1.7 2004/08/06 05:54:24 bartoldu Exp $

/// Implementation file for the CdbBdbSMasterRegistryP class
/**
  * @see CdbBdbSMasterRegistryP
  */

#include "BaBar/BaBar.hh"

#include "CdbBdbShared/CdbBdbSMasterRegistryP.hh"
#include "CdbBdbShared/CdbBdbSUtils.hh"
#include "CdbBdbShared/CdbBdbSOriginP.hh"

#include "BdbClustering/BdbCondIndexClusteringHint.hh"

#include <iostream>
#include <assert.h>

#include <string>
using std::cout;
using std::endl;

CdbStatus
CdbBdbSMasterRegistryP::create( BdbHandle(CdbBdbSRegistryP)& theRegistryH,
                                const char*                  theDescription,
                                const BdbTime&               theCreationTime )
{
    const char* errorStr = "CdbBdbSMasterRegistryP::create() -- ERROR";

    theRegistryH = 0;

    CdbStatus result = CdbStatus::Error;
    do {

      // Verify parameters

        if( 0 == theDescription ) {
            cout << errorStr << endl
                 << "    Invalid description string passed as a parameter. Non-zero" << endl
                 << "    length null terminated string was expected." << endl;
            break;
        }

      // Check if the local registry already exists

        BdbHandle(CdbBdbSRegistryP) localRegistryH;
        if( CdbStatus::Success == findLocal( localRegistryH )) {
            cout << errorStr << endl
                 << "    There local registry already exists in the current Condition/DB." << endl;
            break;
        }

      // Check if the master already exists

        BdbHandle(CdbBdbSRegistryP) masterRegistryH;
        if( CdbStatus::Success == findMaster( masterRegistryH )) {
            cout << errorStr << endl
                 << "    There is already a master registry in the current Condition/DB." << endl;
            break;
        }

      // Find the name of the DBID range of the current federation.
      // Make sure this is the right federation.

        std::string localDbIdRangeName;
        if( CdbStatus::Success != CdbBdbSUtils::getLocalDbIdRange( localDbIdRangeName )) {
            cout << errorStr << endl
                 << "    Failed to find the local DBID range." << endl;
            break;
        }
        if( localDbIdRangeName == defaultDbIdRange( )) {
            cout << errorStr << endl
                 << "    The current federation has inappropriate local DBID range, which" << endl
                 << "    can't be used to create a MASTER kind of database." << endl
                 << "        LOCAL DBID TANGE: " << localDbIdRangeName.c_str( ) << endl;
            break;
        }

      // Generate the hint and create the container

        BdbCondIndexClusteringHint hint( "cdb",
                                         "System",
                                         "database" );

        BdbHandle(BdbContObj) contH = hint.updatedHint( );
        if( BdbIsNull(contH)) {
            cout << errorStr << endl
                 << "    Failed to create a container for persistent objects." << endl;
            break;
        }

      // The following check should always be positive, unless we have
      // an unexpected missmatch between ::findIntervalCont() and ::updatedHint()
      // behavior.

        if( ! hint.newContainerCreated( )) {
            cout << errorStr << endl
                 << "    The clustering hint has not created a new persistent container." << endl;
            break;
        }

      // Create the object.

        theRegistryH = new( contH ) CdbBdbSMasterRegistryP( theDescription,
                                                            theCreationTime );
        if( BdbIsNull(theRegistryH)) {
            cout << errorStr << endl
                 << "    Failed to create a persistent registry object." << endl;
            break;
        }

      // Done

        result = CdbStatus::Success;

    } while( false );

    return result;
}

CdbBdbSMasterRegistryP::CdbBdbSMasterRegistryP( const char*    theDescription,
                                                const BdbTime& theCreationTime ) :
    CdbBdbSRegistryP( CdbBdbSOriginP::MASTER_ID,    // origin identifier
                      theDescription,               //
                      theCreationTime,              //
                      theCreationTime,              // unique database identifier
                      true ),                       // has local collections
    _originCollectionRef(0),
    _partitionsLayoutRef(0),
    _pClusterCollectionRef(0),
    _originRallocatorRef(0),
    _partitionRallocatorRef(0),
    _pClusterRallocatorRef(0)
{
    assert( 0 != theDescription );

  // Make sure the code is run against the right federation (DBID range)

    std::string localRangeName;
    {
        CdbStatus result = CdbBdbSUtils::getLocalDbIdRange( localRangeName );
        assert( CdbStatus::Success == result );

      // The MASTER kind of databases can NOT be created in the default
      // space of DBID ranges since MASTER may export databases to SLAVE
      // and TEST kinds of databases.

        assert( localRangeName != defaultDbIdRange( ));
    }

  // Create master's collections and resources allocators.
  //
  // NOTE: To minimiza lock conflicts these collections can be created in
  //       other (than the current) containers.

    _originCollectionRef    = new( ooThis( )) CdbBdbSOriginCollectionP ( );
    _partitionsLayoutRef    = new( ooThis( )) CdbBdbSPartitionsLayoutP ( );
    _pClusterCollectionRef  = new( ooThis( )) CdbBdbSClusterCollectionP( );

    _originRallocatorRef    = new( ooThis( )) CdbBdbSRallocatorP< d_UShort >( );
    _partitionRallocatorRef = new( ooThis( )) CdbBdbSRallocatorP< d_UShort >( );
    _pClusterRallocatorRef  = new( ooThis( )) CdbBdbSRallocatorP< d_UShort >( );

  // Create and register the predefined origins using:
  //
  // - use predefined identifiers (their allocation is "force"-ed)
  // - appropriate (in each particular case) local range of DBID-s
  // - use the same creation time
  // - put origin objects into the same container

    CdbStatus              status;
    BdbRef(CdbBdbSOriginP) originRef;

  // MASTER:

    originRef = new( ooThis( )) CdbBdbSOriginP( CdbBdbSOriginP::type2name( CdbBdbSOriginP::MASTER ),
                                                CdbBdbSOriginP::MASTER_ID,
                                                CdbBdbSOriginP::MASTER,
                                                theCreationTime,
                                                "The origin for any kind of MASTER databases.",
                                                localRangeName.c_str( ));

    status = _originCollectionRef->insert( originRef );
    assert( CdbStatus::Success == status );

  // TEST:

    originRef = new( ooThis( )) CdbBdbSOriginP( CdbBdbSOriginP::type2name( CdbBdbSOriginP::TEST ),
                                                CdbBdbSOriginP::TEST_ID,
                                                CdbBdbSOriginP::TEST,
                                                theCreationTime,
                                                "The origin for any kind of TEST databases.",
                                                defaultDbIdRange( ));

    status = _originCollectionRef->insert( originRef );
    assert( CdbStatus::Success == status );

  // Force allocation for reserved origin identifiers, including those once
  // used above.

    d_UShort first = CdbBdbSOriginP::FIRST_ID;
    d_UShort last  = CdbBdbSOriginP::LAST_ID;

    for( d_UShort id = first; id <= last; ++id ) {
        status = _originRallocatorRef->force( id );
        assert( CdbStatus::Success == status );
    }
    
}

CdbBdbSMasterRegistryP::~CdbBdbSMasterRegistryP( ) 
{
    if( ! BdbIsNull(_originCollectionRef))    BdbDelete(_originCollectionRef);
    if( ! BdbIsNull(_partitionsLayoutRef))    BdbDelete(_partitionsLayoutRef);
    if( ! BdbIsNull(_pClusterCollectionRef))  BdbDelete(_pClusterCollectionRef);

    if( ! BdbIsNull(_originRallocatorRef))    BdbDelete(_originRallocatorRef);
    if( ! BdbIsNull(_partitionRallocatorRef)) BdbDelete(_partitionRallocatorRef);
    if( ! BdbIsNull(_pClusterRallocatorRef))  BdbDelete(_pClusterRallocatorRef);
}

bool
CdbBdbSMasterRegistryP::isMaster( ) const
{
    return true;
}

BdbRef(CdbBdbSOriginCollectionP)
CdbBdbSMasterRegistryP::originCollection( ) const
{
    return _originCollectionRef;
}

BdbRef(CdbBdbSPartitionsLayoutP)
CdbBdbSMasterRegistryP::partitionsLayout( ) const
{
    return _partitionsLayoutRef;
}

BdbRef(CdbBdbSClusterCollectionP)
CdbBdbSMasterRegistryP::pClusterCollection( ) const
{
    return _pClusterCollectionRef;
}

BdbRef(CdbBdbSRallocatorP< d_UShort >)
CdbBdbSMasterRegistryP::originRallocator( ) const
{
    return _originRallocatorRef;
}

BdbRef(CdbBdbSRallocatorP< d_UShort >)
CdbBdbSMasterRegistryP::partitionRallocator( ) const
{
    return _partitionRallocatorRef;
}

BdbRef(CdbBdbSRallocatorP< d_UShort >)
CdbBdbSMasterRegistryP::pClusterRallocator( ) const
{
    return _pClusterRallocatorRef;
}

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

---