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

                 

---

/BdbAccess/BdbFileConfig.cc

Go to the documentation of this file.

//--------------------------------------------------------------------------
// File and Version Information:
//      $Id: BdbFileConfig.cc,v 1.28 2002/06/21 18:30:19 ryd Exp $
//
// Description:
//      Class BdbFileConfig implementation file. This class represents a 
//  configuration of disk file systems.
//
// Environment:
//      Software developed for the BaBar Detector at the SLAC B-Factory.
//
// Author List:
//      David R. Quarrie                Original Author
//
// History:
//      Jean-Noel Albert        Locate a FS by the name of the path
//
//------------------------------------------------------------------------
//-----------------------
// This Class's Header --
//-----------------------
#include "BdbAccess/BdbFileConfig.hh"

//-------------------------------
// Collaborating Class Headers --
//-------------------------------
#ifndef BDBFSGROUP_HH
#include "BdbAccess/BdbFSGroup.hh"
#endif
#ifndef BDBACCESSERRORS_HH
#include "BdbAccess/BdbAccessErrors.hh"
#endif
#ifndef BDBDOMAINSPEC_HH
#include "BdbAccess/BdbDomainSpec.hh"
#endif
#include "BdbAccess/BdbTFileSystem.hh"
#include "BdbAccess/BdbFileSystem.hh"
#include "BdbAccess/BdbTFSGroup.hh"

//-------------
// C Headers --
//-------------
extern "C" {
#include <assert.h>
#include <stddef.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/param.h> 
}

//---------------
// C++ Headers --
//---------------
#include <fstream.h>
#include <iostream.h>

#include <map>
using std::map;
#include <string>
using std::string;

//-----------------------------------------------------------------------
// Local Macros, Typedefs, Structures, Unions and Forward Declarations --
//-----------------------------------------------------------------------

static const char rcsid[] = "$Id: BdbFileConfig.cc,v 1.28 2002/06/21 18:30:19 ryd Exp $";

//              -----------------------------------------------
//              -- Static Data & Function Member Definitions --
//              -----------------------------------------------

BdbHintInit(BdbFileConfig);

const char* BdbFileConfig::_mapName          = "fsGroupMap" ;

//              ----------------------------------------
//              -- Public Function Member Definitions --
//              ----------------------------------------


// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
//
//   C O N S T R U C T O R    /    D E S T R U C T O R
//
// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%

BdbFileConfig::BdbFileConfig()
{
        initializeMap() ;
}


BdbFileConfig::BdbFileConfig(BdbFileConfig& obj)
{
   _theMap = obj._theMap ;
}


BdbFileConfig::~BdbFileConfig()
{}


BdbStatus BdbFileConfig::initializeMap()
{
        BdbHandle(BdbContObj) theHint = ooThis().containedIn() ;

        if ( _theMap.lookupObj(theHint, _mapName, oocUpdate) != BdbcSuccess )
        {       _theMap = new(theHint) ooMap ;
                if ( _theMap == 0 )
                        return BdbSignal(BdbcUserError, BdbAccessErrNewFailed, 0, "BdbFileConfig::initializeMap", "ooMap") ;
                
                _theMap.nameObj(theHint, _mapName) ;
        }
        
        return BdbcSuccess ;
}


// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
//
//       GETTING SIZE, GROUP NAME, FSGROUP
//
// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%

d_ULong 
BdbFileConfig::size(const char* groupName) const
{
        BdbHandle(BdbFSGroup) group ;
        if ( fsGroup(group, groupName) == 0 )
                {       BdbSignal(BdbcUserError, BdbAccessErrRetHNotValid, 0, "BdbFileConfig::size", "fsGroup") ;
                return 0 ;
        }

        return group->size() ;
}


BdbStatus 
BdbFileConfig::fsGroup(BdbHandle(BdbFSGroup)& group, const char* fsGroupName) const 
{
    const char* fn = "BdbFileConfig::fsGroup";

    if ( _theMap == 0 ) {
        return BdbSignal(BdbcUserError, BdbAccessErrHandleNotValid, 0, fn);
    }

    if ( fsGroupName == 0 ) {
        return BdbSignal(BdbcUserError, BdbAccessErrNullParameter, 0, fn);
    }

    _theMap->lookup(fsGroupName, group);
    if ( group == 0 ) {
        return BdbSignal(BdbcUserError, BdbAccessErrIllegalGroup, 0, fn, fsGroupName);
    }

    return BdbcSuccess;
}


d_Boolean 
BdbFileConfig::isValidGroupName(const char* name) const
{
   if ( name == 0 || _theMap == 0 )
   {  BdbSignal(BdbcUserError, BdbAccessErrNullParameter, 0, "BdbFileConfig::isValidGroupName") ;
      return false ;
   }

   if ( ! _theMap->isMember(name) )
   {  BdbSignal(BdbcUserError, BdbAccessErrGrNameNotValid, 0, "BdbFileConfig::isValidGroupName", name) ;
      return false ;
   }

   return true ;
}



// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
//
//                      A D D  
//
// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%

BdbStatus 
BdbFileConfig::addFS(BdbHandle(BdbFileSystem)& theFileSys, const char* groupName)
{
        BdbHandle(BdbFSGroup) group ;
        if ( fsGroup(group, groupName) == 0 )
                return BdbSignal(BdbcUserError, BdbAccessErrRetHNotValid, 0, "BdbFileConfig::addFS", "fsGroup") ;

        if ( group->add(theFileSys) != BdbcSuccess )
                return BdbSignal(BdbcUserError, BdbAccessErrFunctionFailed, 0, "BdbFileConfig::addFS", "while adding FS") ;
   
        return BdbcSuccess ;
}


BdbStatus BdbFileConfig::addGroup(const char* newGroupName)
{
        if ( _theMap == 0 )
                return BdbSignal(BdbcUserError, BdbAccessErrHandleNotValid, 0, "BdbFileConfig::addGroup") ;

   if ( newGroupName == 0 )
      return BdbSignal(BdbcUserError, BdbAccessErrNullParameter, 0, "BdbFileConfig::addGroup") ;

        if ( _theMap->isMember(newGroupName) )
                return BdbcSuccess ;

        BdbRef(BdbFSGroup) groupRef;
        BdbHandle(BdbFSGroup) groupH;
        groupH = new (BdbFileConfig::clustering()) BdbFSGroup;
        groupRef = groupH;

        if ( _theMap->add(newGroupName, groupRef) != BdbcSuccess )
                return BdbSignal(BdbcUserError, BdbAccessErrFunctionFailed, 0, "BdbFileConfig::addGroup", "_theMap->add") ;
        
        return BdbcSuccess ;
}


// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
//
//                   G E T   F S 
//
// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%


BdbStatus BdbFileConfig::item(BdbHandle(BdbFileSystem)& theFileSys, d_ULong index, const char* groupName)
{
        BdbHandle(BdbFSGroup) group ;
        if ( fsGroup(group, groupName) == 0 )
                return BdbSignal(BdbcUserError, BdbAccessErrRetHNotValid, 0, "BdbFileConfig::item", "fsGroup") ;

        if ( group->item(theFileSys, index) != BdbcSuccess )
                return BdbSignal(BdbcUserError, BdbAccessErrFunctionFailed, 0, "BdbFileConfig::item", "in fsGroup->item") ;
   
    return BdbcSuccess ;
}


BdbStatus BdbFileConfig::catalogFS(BdbHandle(BdbFileSystem)& theFileSys)
{
        if ( item(theFileSys, 0, BdbDomainSpec::_catalogGroupName) != BdbcSuccess )
                return BdbSignal(BdbcUserError, BdbAccessErrFunctionFailed, 0, "BdbFileConfig::catalogFS", "in item") ;

        return BdbcSuccess ;
}


BdbStatus BdbFileConfig::lookupFS(BdbTFileSystem& fileSystem, const char* filepath,
                                  const char* host, int port)
{
    _theMap.lookupObj(ooThis().containedIn(), _mapName) ;

    if ( BdbIsNull(_theMap) )
        return BdbcError;       // ASCII file not loaded ?

    ooMapItr mapI(_theMap);
    BdbHandle(BdbFSGroup) group;
    BdbHandle(BdbFileSystem) fs;

    while ( mapI.next()) {
        group = (const BdbRef(BdbFSGroup)&) mapI->oid();

        d_ULong size = group->size();
        for (d_ULong idx = 0; idx < size; idx++) {
            if (BdbcSuccess != group->item(fs, idx))
                break;          // Something wrong ?!

            // Check if the file matches the file system attributes
            if (strncmp(filepath, fs->dirName(), strlen(fs->dirName())) == 0 &&
                (host == 0 || *host == '\0' || fs->hostEqual(host)) &&
                (port == 0 || port == fs->portNr())) 
            {
                fileSystem.setDirName(fs->dirName());
                fileSystem.setHostName(fs->hostName());
                fileSystem.setPortNr(fs->portNr());
                fileSystem.setMinDiskSpace(fs->minDiskSpace());
                return BdbcSuccess;
            }
        }
    }

    return BdbcError;   // No match
}

// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
//
//         D I S P L A Y I N G   D A T A
//
// %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%

BdbStatus BdbFileConfig::displayData()
{
   cout << "\n\nF I L E    C O N F I G\n" ;

        _theMap.lookupObj(ooThis().containedIn(), _mapName) ;

        if ( BdbIsNull(_theMap) )
                return BdbSignal(BdbcUserError, BdbAccessErrMapNotFound, 0, "BdbFileConfig::displayData") ;

        ooMapItr mapI(_theMap) ;

        BdbRef(BdbFSGroup) group ;

        while ( mapI.next())
        {       cout << "Group: " << mapI->name() << endl ;       // display data

        // Fixed by gg 15/10/98 for HP/aCC
                BdbRef(ooObj) groupGG = mapI->oid() ;
                group = (BdbRef(BdbFSGroup)&) groupGG ;

                group->displayData() ;
        }

   cout << endl ;

        return BdbcSuccess ;
}



BdbStatus 
BdbFileConfig::initTransient(BdbAuthMap* tDict)
{
    ooMapItr mapItr(_theMap);

    while ( mapItr.next() ) {
        const char* n =  mapItr->name();
        BdbRef(ooObj) obj = mapItr->oid() ;
        BdbRef(BdbFSGroup) pGroup = (BdbRef(BdbFSGroup)&) obj;
        (*tDict)[new string(n)]=new BdbTFSGroup(pGroup);
    }
    return BdbcSuccess;
}

 

---

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

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