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

                 

---

/BdbClusteringServer/BdbSrvAbsBaseClustH.hh

Go to the documentation of this file.

//------------------------------------------------------------------------------
// File:
//      BdbSrvAbsBaseClustH.hh
//
// Description:
//      Abstract class
//      
//
// Environment:
//      Software developed for the BaBar Detector at the SLAC B-Factory
//
// Author List:
//      Jacek Becla                Original Author
//
// Copyright Information:
//      Copyright (C) 1997      Stanford Linear Accelerator Center
//
//------------------------------------------------------------------------------

#ifndef BDBSRVABSBASECLUSTH_HH
#define BDBSRVABSBASECLUSTH_HH

#include "BdbUtil/Bdb.hh"
#include "BdbApplication/BdbDomain.hh"
#include "BbrStdUtils/CollectionUtils.hh"

class BdbComponent;
class BdbClSrvCRef;
#include <set>
#include <vector>
#include <string>
class BdbErrorSignal;


class BdbSrvAbsBaseClustH : public BdbClusteringHint
{
private:

    static std::set<BdbClSrvCRef*,babar::Collection::PtrLess>*         _contsToBeReturned;
    
protected: // temporarily for BdbSpClustering hint Jacek

    const BdbDomain*      _domain;

private:

    BdbDomain::AuthLevels _authLevel;
    char*                 _authName;
    char*                 _compName;
    char*                 _streamName;

    d_Boolean             _compChanged;
    d_Boolean             _streamChanged;

    d_ULong               _maxNoPages;  // exceeding this value == full container
    
    std::vector<std::string>*       _usedDbs;     // list of all databases which have been used

    std::set<BdbClSrvCRef*,babar::Collection::PtrLess>*                _assignedConts; // set of all containers assigned to 
                                          // this clustering hint instance
    BdbClSrvCRef*              _currentRef;    // pointer to BdbClSrvCRef representing
                                          // currently used container

    d_ULong               _recentTransID;
    d_ULong               _maxWaitTime; // max time I should wait for each container to be opened
    d_Boolean             _quietMode;
    
    d_Boolean             _newDbFlag;
    d_Boolean             _newContFlag;

protected:

    BdbErrorSignal*       _es;
    d_Boolean             _changeAuthLevel;

private:

    BdbStatus internalSetComp(const char* name, d_Boolean applyRestr);
    static d_Boolean myStrcmp(const char* s1, const char* s2);
    
    // ----------------------
    // Protected functions --
    // ----------------------
protected:

    // Constructor(s)
    BdbSrvAbsBaseClustH(const BdbDomain& domain, 
                     d_ULong maxWaitTime=7200, 
                     d_Boolean quiet=d_False);
    BdbSrvAbsBaseClustH(const BdbSrvAbsBaseClustH& obj);

    // Operations
    virtual BdbStatus setStream(const char* name);
    BdbStatus requestContainer();
    BdbStatus lockTheHint();
    BdbStatus refreshSettings();
    d_Boolean conditionsChanged();
    virtual void setHint( BdbHandleAny& theHint );
    virtual void setHint( BdbRefAny& theHint );
    virtual BdbRefAny resetHint();

    // registry of used databases
    BdbStatus registerCurrentDbAsUsed();
    void printUsedDbs() const;

    // Get methods
    inline d_ULong maxWaitTime() const;
    d_Boolean currentContIsFull();
    
    
    BdbStatus changeAuthL(BdbDomain::AuthLevels authLevel, 
                          const char* name=0);

    d_Boolean transactionChanged();
    
// -------------------
// Public Interface --
// -------------------
public:

    // Destructor
    virtual ~BdbSrvAbsBaseClustH();

    virtual BdbRefAny hint();

    virtual void prepareHint();

    virtual BdbStatus setComponent(const char* name);
    BdbStatus setMaxWaitTime(d_ULong value);

    d_Boolean compIsValid() const  { return 0 != _compName; }
    const char* compName() const   { return _compName;      }
    const char* streamName() const { return _streamName;    }
    
    d_Boolean newDatabaseCreated();
    d_Boolean newContainerCreated();

    virtual void      internalCollectReturnedConts();       // should be static
    virtual BdbStatus internalReturnCollectedConts() const; // should be static
      // but cannot be because BdbModules should not depend on this package
      // so we call it using 'virtual'
};


// ------------------------------------------------------
// --  I  N  L  I  N  E      F  U  N  C  T  I  O  N  S --
// ------------------------------------------------------

inline d_ULong BdbSrvAbsBaseClustH::maxWaitTime() const  { return _maxWaitTime; }

#endif /* BDBSRVABSBASECLUSTH_HH */

 

---

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

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