---

CdbBdbSSlaveRegistryP.cc

Go to the documentation of this file.

// File and Version Information:
//      $Id: CdbBdbSSlaveRegistryP.cc,v 1.6 2004/08/06 05:54:25 bartoldu Exp $

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

#include "BaBar/BaBar.hh"

#include "CdbBdbShared/CdbBdbSSlaveRegistryP.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
CdbBdbSSlaveRegistryP::create( BdbHandle(CdbBdbSRegistryP)& theRegistryH )
{
    const char* errorStr = "CdbBdbSSlaveRegistryP::create() -- ERROR";

    theRegistryH = 0;

    CdbStatus result = CdbStatus::Error;
    do {

      // 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;
        }

      // Get to the MASTER registry to extract the information about
      // its unique identifier and the origin of the new SLAVE registry. This (origin) record
      // should already exist in the MASTER's collection.

        BdbHandle(CdbBdbSRegistryP) masterRegistryH;
        if( CdbStatus::Success != findMaster( masterRegistryH )) {
            cout << errorStr << endl
                 << "    Failed to locate MASTER registry in the current federation." << endl
                 << "    The federation has to be preloaded with at least a partial" << endl
                 << "    snapshot of the MASTER database in order to initialize a SLAVE one." << 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 SLAVE kind of database." << endl
                 << "        LOCAL RANGE: " << localDbIdRangeName.c_str( ) << endl;
            break;
        }

      // Find the origin corresponding to the DBID range of the current federation.

        BdbHandle(CdbBdbSOriginCollectionP) originCollectionH;

        originCollectionH = masterRegistryH->originCollection( );
        assert( !BdbIsNull(originCollectionH));

        BdbHandle(CdbBdbSOriginP) originH;
        {
            bool failed = false;

            CdbBdbSOriginCollectionP::IteratorOfIdentifiers itr = originCollectionH->iterator_identifiers( );
            while( itr.next( )) {

                d_UShort originId = itr.value( );

                BdbRef(CdbBdbSOriginP) originRef;
                if( CdbStatus::Success != originCollectionH->find( originId,
                                                                   originRef )) {
                    cout << errorStr << endl
                         << "    Failed to find an obejct for origin ID=" << originId << endl;

                    failed = true;
                    break;

                } else {

                  // Check for the SLAVE kind of ORIGIN only

                    if( CdbBdbSOriginP::SLAVE == originRef->type( )) {

                        ooString(32) dbidrange = originRef->dbidrange( );
                        if( 0 == strcmp( localDbIdRangeName.c_str( ), dbidrange.head( ))) {
                            originH = originRef;
                            break;
                        }
                    }
                }
            }
            if( failed ) break;
        }
        if( BdbIsNull(originH)) {
            cout << errorStr << endl
                 << "    Failed to find an origin object with the current DBID range name" << endl
                 << "    in the MASTER's collection." << endl;
            break;
        }

      // Generate the hint and create the container

        std::string databaseSuffix = std::string( "database_" ) + localDbIdRangeName;

        BdbCondIndexClusteringHint hint( "cdb",
                                         "System",
                                         databaseSuffix.c_str( ));

        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 ) CdbBdbSSlaveRegistryP( originH->id( ),
                                                           originH->description( ),
                                                           BdbTime::now( ),
                                                           masterRegistryH->id( ));
        if( BdbIsNull(theRegistryH)) {
            cout << errorStr << endl
                 << "    Failed to create a persistent registry object." << endl;
            break;
        }

      // Done

        result = CdbStatus::Success;

    } while( false );

    return result;
}

CdbBdbSSlaveRegistryP::CdbBdbSSlaveRegistryP( d_UShort       theOriginId,
                                              const char*    theDescription,
                                              const BdbTime& theCreationTime,
                                              const BdbTime& theId ) :
    CdbBdbSRegistryP( theOriginId,
                      theDescription,
                      theCreationTime,
                      theId,
                      true )
{
  // Make sure the specified origin ID is the correct one. It should not be in a list
  // of reserved ones.

    assert( ! CdbBdbSOriginP::isReservedId( theOriginId ));

  // 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 SLAVE kind of databases can NOT be created in the default
      // space of DBID ranges since SLAVE may export databases to MASTER
      // and TEST kinds of databases.

        assert( localRangeName != defaultDbIdRange( ));
    }

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

    _partitionsLayoutRef    = new( ooThis( )) CdbBdbSPartitionsLayoutP ( );

  // WARNING: The cluster collection and its allocator are not used by the SLAVE.
  //          It was a design mistake to introduce them in here.

//  _pClusterCollectionRef  = new( ooThis( )) CdbBdbSClusterCollectionP( );
//  _pClusterRallocatorRef  = new( ooThis( )) CdbBdbSRallocatorP< d_UShort >( );    
}

CdbBdbSSlaveRegistryP::~CdbBdbSSlaveRegistryP( ) 
{
    if( ! BdbIsNull(_partitionsLayoutRef))   BdbDelete(_partitionsLayoutRef);

//  if( ! BdbIsNull(_pClusterCollectionRef)) BdbDelete(_pClusterCollectionRef);
//  if( ! BdbIsNull(_pClusterRallocatorRef)) BdbDelete(_pClusterRallocatorRef);
}

bool
CdbBdbSSlaveRegistryP::isMaster( ) const
{
    return false;
}

BdbRef(CdbBdbSOriginCollectionP)
CdbBdbSSlaveRegistryP::originCollection( ) const
{
    return 0;
}

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

BdbRef(CdbBdbSClusterCollectionP)
CdbBdbSSlaveRegistryP::pClusterCollection( ) const
{
    return 0;
//  return _pClusterCollectionRef;
}

BdbRef(CdbBdbSRallocatorP< d_UShort >)
CdbBdbSSlaveRegistryP::originRallocator( ) const
{
    return 0;
}

BdbRef(CdbBdbSRallocatorP< d_UShort >)
CdbBdbSSlaveRegistryP::partitionRallocator( ) const
{
    return 0;
}

BdbRef(CdbBdbSRallocatorP< d_UShort >)
CdbBdbSSlaveRegistryP::pClusterRallocator( ) const
{
    return 0;
//  return _pClusterRallocatorRef;
}

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

---