org.omg.FT
Class FaultMonitor_impl

java.lang.Object
  |
  +--org.omg.PortableServer.Servant
        |
        +--org.omg.FT.FaultMonitorPOA
              |
              +--org.omg.FT.FaultMonitor_impl
All Implemented Interfaces:
FaultMonitorOperations, org.omg.CORBA.portable.InvokeHandler

public class FaultMonitor_impl
extends FaultMonitorPOA

Class implementing the FaultMonitor interface It is used to monitor application CORBA object for failures


Inner Class Summary
private  class FaultMonitor_impl.MonitorThread
           
 
Field Summary
(package private)  FaultNotifier fault_notifier
           
(package private)  java.lang.String ftDomId
           
(package private)  java.lang.String location
           
(package private)  java.util.Hashtable monitor_threads_objects
           
(package private)  org.omg.CORBA.ORB orb
           
 
Fields inherited from class org.omg.FT.FaultMonitorPOA
_ids_list
 
Fields inherited from class org.omg.PortableServer.Servant
_delegate, _hasGetInterface
 
Constructor Summary
FaultMonitor_impl(FaultNotifier f_n, java.lang.String f_t_d, java.lang.String loc, org.omg.CORBA.ORB o)
          Constructor
 
Method Summary
 void do_monitor(PullMonitorable obj, long o_g_id, int mon_gran, FaultMonitoringIntervalAndTimeoutValue fmiv)
          Method called to request the fault monitor to create a new thread for monitoring a new application object
private  boolean monitors_obj_type(java.lang.String type)
           
private  boolean monitors_obj()
           
protected  void object_failed(PullMonitorable obj, FaultMonitor_impl.MonitorThread mt)
           
private  void remove_threads_loc_or_type_loc(java.lang.String type_id)
           
private  void remove_threads_loc()
           
private  void remove_threads_type_loc(java.lang.String type_id)
           
 void stop_monitor(org.omg.CORBA.Object obj)
          Method called to stop the monitoring process of a CORBA object
 
Methods inherited from class org.omg.FT.FaultMonitorPOA
_all_interfaces, _invoke, _this, _this
 
Methods inherited from class org.omg.PortableServer.Servant
_default_POA, _get_delegate, _get_interface_def, _get_interface, _is_a, _non_existent, _object_id, _orb, _orb, _poa, _set_delegate, _this_object, _this_object
 
Methods inherited from class java.lang.Object
, clone, equals, finalize, getClass, hashCode, notify, notifyAll, registerNatives, toString, wait, wait, wait
 

Field Detail

fault_notifier

FaultNotifier fault_notifier

ftDomId

java.lang.String ftDomId

location

java.lang.String location

monitor_threads_objects

java.util.Hashtable monitor_threads_objects

orb

org.omg.CORBA.ORB orb
Constructor Detail

FaultMonitor_impl

public FaultMonitor_impl(FaultNotifier f_n,
                         java.lang.String f_t_d,
                         java.lang.String loc,
                         org.omg.CORBA.ORB o)
Constructor
Parameters:
f_n - the fault notifier to which the fault events are sent f_t_d the fault tolerance domain loc the location (host name) of this fault notifier o the ORB in which the fault monitor is running
Method Detail

monitors_obj

private boolean monitors_obj()

monitors_obj_type

private boolean monitors_obj_type(java.lang.String type)

do_monitor

public void do_monitor(PullMonitorable obj,
                       long o_g_id,
                       int mon_gran,
                       FaultMonitoringIntervalAndTimeoutValue fmiv)
Method called to request the fault monitor to create a new thread for monitoring a new application object
Parameters:
obj - the application CORBA object to monitor o_g_id the object group identifier of the monitored object mon_gran the monitoring granularity for the monitored object fmiv fault monitoring interval and timeout value

stop_monitor

public void stop_monitor(org.omg.CORBA.Object obj)
Method called to stop the monitoring process of a CORBA object
Parameters:
the - object reference of the application object that is monitored

remove_threads_loc_or_type_loc

private void remove_threads_loc_or_type_loc(java.lang.String type_id)

remove_threads_type_loc

private void remove_threads_type_loc(java.lang.String type_id)

remove_threads_loc

private void remove_threads_loc()

object_failed

protected void object_failed(PullMonitorable obj,
                             FaultMonitor_impl.MonitorThread mt)