heartbeatimpl.hpp

"More for C++" is a class library that provides some features that are usually common for object ori

//
//  This file is part of the "More for C++" library
//
//  Copyright (c) 1999-2003 by Thorsten Goertz ([e-mail])
//
//  The "More for C++" library is free software; you can redistribute it and/or
//  modify it under the terms of the license that comes with this package.
//
//  Read "license.txt" for more details.
//
//  THIS PACKAGE IS PROVIDED "AS IS" AND WITHOUT ANY EXPRESS OR IMPLIED
//  WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED WARRANTIES
//  OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.

////////////////////////////////////////////////////////////////////////////////

#ifndef HEARTBEATIMPL_HPP
#define HEARTBEATIMPL_HPP

////////////////////////////////////////////////////////////////////////////////

#include <more/util/heartbeat.hpp>
#include <more/util/singleton.hpp>
#include <more/util/vector.hpp>
#include <more/os/mutex.hpp>
#include <more/os/thread.hpp>
#include "singletoncreator.hpp"

////////////////////////////////////////////////////////////////////////////////

namespace more
{
  namespace util
  {
    class HeartbeatImpl: public Singleton<HeartbeatImpl>
    {
      public:
        HeartbeatImpl( );
        void destroy( );

        void init( );
        void shutDown( );
        p<Heartbeat::Handle> addHandler( const p<Heartbeat::Handler>& );

      protected:
        void run( const p<more::os::Thread::Controller>& );

      private:
        class HandleImpl: public Heartbeat::Handle
        {
          public:
            HandleImpl( const p<Heartbeat::Handler>& );
            void passHeartbeat( );
            bool removed( );
            virtual void removeHandler( );

          private:
            p<more::os::Mutex>    m_pMutex;
            p<Heartbeat::Handler> m_pHandler;
            bool                  m_bRemoved;
        };

        class HeartbeatRunner: public more::os::Thread::Runnable
        {
          public:
            HeartbeatRunner( const p<HeartbeatImpl>& );
            virtual void run( const p<more::os::Thread::Controller>& );

          private:
            p<HeartbeatImpl> m_pHeartbeatImpl;
        };

        friend class HeartbeatRunner;

        static SingletonCreator<HeartbeatImpl> singletonCreator;

        p<more::os::Mutex>                      m_pMutex;
        p<more::util::Vector<p<HandleImpl> > >  m_pHandles;
        size_t                                  m_nInitCounter;
        p<more::os::Thread>                     m_pHeartbeatThread;
    };
  }
}

////////////////////////////////////////////////////////////////////////////////

#endif