rqsglobal.h

Go to the documentation of this file.

// OSB library ************************************************ -*- C++ -*-
/*
  AUTHOR(S): Stephan Broennimann (vb)

  RCS information
   $Name: OSB_060808 $
   $Revision: 1.8 $

  License
   OSB rating and billing library for communication networks
   Copyright (C) 2004, 2005, 2006  OSB systems

   This file may be distributed and/or modify under the terms of the
   GNU General Public License (GPL) as published by the Free Software
   Foundation which is provided in the file LICENSE.GPL included in the
   packaging of this file.

   The file is distributed in the hope that it will be useful, but WITHOUT
   ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
   FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
   for more details.

   Holders of a OSB Commercial License may use this file under the terms
   and conditions of this commercial license.
 */
#ifndef _RQSGLOBAL_H_
#define _RQSGLOBAL_H_

// ************************************************************************
// included header files
// + standard includes
#include <memory>

// + libraries

// + local headers

// + class declarations
namespace OSB_DB {
    class Session;
}

namespace OSB_LIB {
    class Mutex;
    class RequestHandler;
}

namespace corba {
  namespace common {
    class ServerInfo;
  }
}

// ************************************************************************
// forward declarations
    class RqsGlobal;
    extern RqsGlobal& rqsGlobal;

// ************************************************************************
// class definitions

    class RhGuard {
        static OSB_LIB::Mutex mutex_;
    public:
        RhGuard();
        ~RhGuard();

        OSB_LIB::RequestHandler& get();
    private:
        RhGuard(const RhGuard&);
        RhGuard& operator=(const RhGuard&);
    };                                  // class RhGuard

    class RqsGlobal {
        friend class RhGuard;
    public:
        typedef std::auto_ptr<corba::common::ServerInfo> ServerInfoPtr;

    public:
        RqsGlobal();
        virtual ~RqsGlobal();
    public:
        virtual ServerInfoPtr srvInfo() = 0;
    private:
        virtual OSB_LIB::RequestHandler& srqHandler() = 0;
    private:
        RqsGlobal(const RqsGlobal&);
        RqsGlobal& operator=(const RqsGlobal&);
    };                                  // class RqsGlobal

    // ********************************************************************
    // Database session guards.
    class SessionGuardBase {
        static OSB_LIB::Mutex   mutex_;
        static OSB_DB::Session* pSession_;

        friend int main(int, char**);

    protected:
        SessionGuardBase();
        SessionGuardBase(bool noWait);
        virtual ~SessionGuardBase() = 0;

    protected:
        bool locked() const;
        void lock(bool noWait);
        OSB_DB::Session& get();

    private:
        bool locked_;
    private:
        SessionGuardBase(const SessionGuardBase&);
        SessionGuardBase& operator=(const SessionGuardBase&);
    };

    struct ReadSession : private SessionGuardBase {
        ReadSession();
        ReadSession(bool noWait);
    public:
        bool locked() const;
        void lock(bool noWait);
        const OSB_DB::Session& get();
    };

    struct WriteSession : private SessionGuardBase {
        WriteSession();
        WriteSession(bool noWait);
        ~WriteSession();
    public:
        bool locked() const;
        void lock(bool noWait);
        const OSB_DB::Session& getConst();
        OSB_DB::Session& get();
        void commit();
        void rollback();
    private:
        bool dirty_;
    };

// ************************************************************************
// inline definitions
#endif                                  // #ifndef _RQSGLOBAL_H_

---