maciHeartbeatController.h

Go to the documentation of this file.

#ifndef maciHeartbeatController_H
#define maciHeartbeatController_H

/*******************************************************************
* E.S.O. - ACS project
*
* "@(#) $Id: maciHeartbeatController.h,v 1.81 2006/09/01 02:20:54 cparedes Exp $"
*
* who       when        what
* --------  ----------  ----------------------------------------------
* msekoran  2002/02/09  made ping timeout in mutable
* msekoran  2001/12/24  created
*/

#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif

#include <acsutil.h>
#include <maciExport.h>

#include <maciC.h>

#include <ace/Timer_Heap_T.h>
#include <ace/Timer_Queue_Adapters.h>

#include <ace/Hash_Map_Manager.h>

namespace maci {

// Forward declaration
class HeartbeatController;

class HeartbeatHandler : public ACE_Event_Handler
{
  public:

    HeartbeatHandler(HeartbeatController * controller, maci::Handle handle, maci::Client_ptr client);

    virtual int handle_timeout (const ACE_Time_Value &currentTime,
                                const void *arg);

    virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask);

    void setTimerID(long timerID);

    long getTimerID();

    void updateClient(maci::Client_ptr client);

  private:

    static int m_failureLimit;
    
    maci::Handle m_handle;

    long m_timerID;
    
    int m_failureCount;
    
    maci::Client_var m_client;

    HeartbeatController * m_controller;
    
};

class HeartbeatInitializationHandler : public ACE_Event_Handler
{
  public:

    static CORBA::ULong defaultInvocationTimeout;

    HeartbeatInitializationHandler(CORBA::ORB_ptr orb, CORBA::ULong invocationTimeout);

    virtual int handle_timeout (const ACE_Time_Value &currentTime,
                                const void *arg);

    virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask);

  private:
    
    CORBA::ORB_var m_orb;

    CORBA::ULong m_invocationTimeout;

};

class maci_EXPORT HeartbeatController
{

public:


    HeartbeatController(maci::Manager_ptr manager);
    
    ~HeartbeatController();
    
    int start(CORBA::ORB_ptr orb, CORBA::ULong invocationTimeout);

    int stop();
    
    int registerClient(maci::Handle handle, maci::Client_ptr client);

    int deregisterClient(maci::Handle handle);

    maci::Manager_ptr getManager();

  private:

    int removeClient(maci::Handle handle);


    maci::Manager_var m_manager;


    typedef ACE_Timer_Heap_T<ACE_Event_Handler *,
        ACE_Event_Handler_Handle_Timeout_Upcall<ACE_SYNCH_RECURSIVE_MUTEX>,
        ACE_SYNCH_RECURSIVE_MUTEX>
    HB_TIMER_QUEUE;

    typedef ACE_Timer_Heap_Iterator_T<ACE_Event_Handler *,
        ACE_Event_Handler_Handle_Timeout_Upcall<ACE_SYNCH_RECURSIVE_MUTEX>,
        ACE_SYNCH_RECURSIVE_MUTEX>
    HB_TIMER_QUEUE_ITERATOR;
       
    typedef ACE_Thread_Timer_Queue_Adapter<HB_TIMER_QUEUE> HB_TIMER_THREAD;

    HB_TIMER_THREAD m_timerThread;

    typedef ACE_Hash_Map_Manager <maci::Handle, long, ACE_Recursive_Thread_Mutex> HB_HASH_MAP;
    typedef ACE_Hash_Map_Iterator <maci::Handle, long, ACE_Recursive_Thread_Mutex> HB_HASH_MAP_ITER;
    typedef ACE_Hash_Map_Entry <maci::Handle, long> HB_HASH_MAP_ENTRY;

    HB_HASH_MAP m_clients;

    // Deactivated.
    bool m_deactivated;

    friend class HeartbeatHandler;

};

 }; 

#endif  /* maciHeartbeatController_H */

// ************************************************************************