org.omg.FT
Class GatewayForActiveRepl_impl

java.lang.Object
  |
  +--org.omg.PortableServer.Servant
        |
        +--org.omg.FT.GatewayForActiveReplPOA
              |
              +--org.omg.FT.GatewayForActiveRepl_impl
All Implemented Interfaces:
GatewayForActiveReplOperations, org.omg.CORBA.portable.InvokeHandler

public class GatewayForActiveRepl_impl
extends GatewayForActiveReplPOA

Class instantiated whenever an actively replicated group is created by the Replication Manager


Inner Class Summary
private  class GatewayForActiveRepl_impl.CallStr
           
private  class GatewayForActiveRepl_impl.CountObj
           
(package private)  class GatewayForActiveRepl_impl.GatewayStructuredPushConsumer
           
private  class GatewayForActiveRepl_impl.ReplyStr
           
 
Field Summary
(package private)  java.util.Hashtable group_members_loc
           
(package private)  org.omg.CORBA.Object[] new_group_members
           
(package private)  java.util.Vector notified
           
(package private)  byte[] obj_id
           
(package private)  org.omg.CORBA.Object[] old_group_members
           
(package private)  org.omg.CORBA.ORB orb
           
(package private)  java.util.Vector replies
           
(package private)  java.util.Vector synch_objects
           
 
Fields inherited from class org.omg.FT.GatewayForActiveReplPOA
_ids_list
 
Fields inherited from class org.omg.PortableServer.Servant
_delegate, _hasGetInterface
 
Constructor Summary
GatewayForActiveRepl_impl(org.omg.CORBA.ORB o, byte[] oid)
          Constructor
 
Method Summary
 void change_membership(org.omg.CORBA.Object[] new_memb, java.lang.String[] location)
          Method called when the membership of the group changes, usually due to failures
private  void connect_to_fault_notifier()
           
 org.omg.CORBA.Object[] group_members()
           
 void init_membership(ObjectLocStr[] members)
          Method called when the group is created and its membership is communicated to the gateway
 org.omg.CORBA.Any invoke(org.omg.CORBA.Object target, java.lang.String type_id, int ret_id, java.lang.String client_id, long req_start_time, java.lang.String oper, ParametersHolder arguments, org.omg.CORBA.TypeCode[] exceptions, boolean resp_e, org.omg.CORBA.Any result)
           
 org.omg.CORBA.Object[] new_group_members()
           
 org.omg.CORBA.Object[] old_group_members()
           
private  GatewayForActiveRepl_impl.CountObj synch_obj(org.omg.CORBA.Object target, int retention_id)
           
private  void update_memb_remove(java.lang.String location)
           
 
Methods inherited from class org.omg.FT.GatewayForActiveReplPOA
_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

group_members_loc

java.util.Hashtable group_members_loc

synch_objects

java.util.Vector synch_objects

replies

java.util.Vector replies

notified

java.util.Vector notified

orb

org.omg.CORBA.ORB orb

old_group_members

org.omg.CORBA.Object[] old_group_members

new_group_members

org.omg.CORBA.Object[] new_group_members

obj_id

byte[] obj_id
Constructor Detail

GatewayForActiveRepl_impl

public GatewayForActiveRepl_impl(org.omg.CORBA.ORB o,
                                 byte[] oid)
Constructor
Parameters:
o - the ORB on which this CORBA object runs oid the object identifier of the active group
Method Detail

update_memb_remove

private void update_memb_remove(java.lang.String location)

synch_obj

private GatewayForActiveRepl_impl.CountObj synch_obj(org.omg.CORBA.Object target,
                                                     int retention_id)

init_membership

public void init_membership(ObjectLocStr[] members)
Method called when the group is created and its membership is communicated to the gateway
Parameters:
members - the list of {location,replica object} coresponding to the initial group membership

change_membership

public void change_membership(org.omg.CORBA.Object[] new_memb,
                              java.lang.String[] location)
Method called when the membership of the group changes, usually due to failures
Parameters:
new_memb - list of new members of the CORBA object group location list of the locations where the new members reside

old_group_members

public org.omg.CORBA.Object[] old_group_members()

new_group_members

public org.omg.CORBA.Object[] new_group_members()

group_members

public org.omg.CORBA.Object[] group_members()
Returns:
the current composition of te active CORBA object group

connect_to_fault_notifier

private void connect_to_fault_notifier()

invoke

public org.omg.CORBA.Any invoke(org.omg.CORBA.Object target,
                                java.lang.String type_id,
                                int ret_id,
                                java.lang.String client_id,
                                long req_start_time,
                                java.lang.String oper,
                                ParametersHolder arguments,
                                org.omg.CORBA.TypeCode[] exceptions,
                                boolean resp_e,
                                org.omg.CORBA.Any result)