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
Fields inherited from class org.omg.PortableServer.Servant |
_delegate, _hasGetInterface |
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.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 |
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
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
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)