org.omg.FT
Class LoggingRecoveryControllerPOATie

java.lang.Object
  |
  +--org.omg.PortableServer.Servant
        |
        +--org.omg.FT.LoggingRecoveryControllerPOA
              |
              +--org.omg.FT.LoggingRecoveryControllerPOATie
All Implemented Interfaces:
org.omg.CORBA.portable.InvokeHandler, LoggingRecoveryControllerOperations

public class LoggingRecoveryControllerPOATie
extends LoggingRecoveryControllerPOA


Field Summary
private  org.omg.PortableServer.POA _poa
           
private  LoggingRecoveryControllerOperations _tie
           
 
Fields inherited from class org.omg.FT.LoggingRecoveryControllerPOA
_ids_list, _ops_Hash
 
Fields inherited from class org.omg.PortableServer.Servant
_delegate, _hasGetInterface
 
Constructor Summary
LoggingRecoveryControllerPOATie(LoggingRecoveryControllerOperations tieObject)
           
LoggingRecoveryControllerPOATie(LoggingRecoveryControllerOperations tieObject, org.omg.PortableServer.POA poa)
           
 
Method Summary
 org.omg.PortableServer.POA _default_POA()
           
 LoggingRecoveryControllerOperations _delegate()
           
 void _delegate(LoggingRecoveryControllerOperations delegate_)
           
 ResultResultArgs call_reply(long target, java.lang.String client_id, int retention_id)
           
 void do_checkpointing(Checkpointable checkpointed_obj, long obj_id, long checkpoint_interval, Checkpointable[] transfer_to, boolean transfer, boolean periodic)
           
 void do_updating(Updateable updated_obj, long obj_id, long update_interval, Updateable[] transfer_to, boolean transfer, boolean periodic)
           
 void react_set_st_upd_reply(long o_i)
           
 ResultResultArgs record_method_call_as(long target, java.lang.String operation, byte[] buff, boolean big_e, org.omg.GIOP.Version vers, java.lang.String client_id, int retention_id, long expiration_time, char method_type, boolean broadcast)
           
 ResultResultArgs record_method_call_par(long target, java.lang.String operation, org.omg.Dynamic.Parameter[] arguments, java.lang.String client_id, int retention_id, long expiration_time, char method_type, long time_s, boolean broadcast)
           
 void record_method_no_wait_as(long objI, java.lang.String oper, byte[] buffer, boolean big_e, org.omg.GIOP.Version vers, java.lang.String client_id, int retention_id, long expiration_time, char met_type, long mess_id)
           
 void record_method_no_wait_par(long objI, java.lang.String oper, org.omg.Dynamic.Parameter[] args, java.lang.String client_id, int retention_id, long expiration_time, char meth_type, long mess_id)
           
 void record_part_get_st_upd_reply(long o_id, int c_r_i, java.lang.String oper)
           
 void record_replies(LogRecord[] r)
           
 void record_reply_exc(long source, java.lang.String client_id, int retention_id, char m_t)
           
 void record_reply_no_notify(long objI, java.lang.String client_id, int retention_id, org.omg.CORBA.Any result, org.omg.CORBA.Any[] result_arguments, char m_t)
           
 void record_reply_stateless(long o_i, java.lang.String cl_id, int ret_id, long exp_time, org.omg.CORBA.Any repl, org.omg.CORBA.Any[] repls)
           
 void record_reply(long source, java.lang.String client_id, int retention_id, org.omg.CORBA.Any reply, org.omg.CORBA.Any[] reply_args, char m_t, boolean broadcast)
           
 void record_request_repl(java.lang.String cl_id, org.omg.CORBA.Object to, java.lang.String operation, org.omg.CORBA.Any[] arguments, int retention_id, org.omg.CORBA.Any reply)
           
 void recover_new_replica_ch(long o_id, LoggingRecoveryController lrc, Checkpointable to_recover, int repl_s)
           
 void recover_new_replica_st_ch(long o_id, LoggingRecoveryController new_lrc, Checkpointable to_recover, Checkpointable failed_obj)
           
 void recover_new_replica_upd(long o_id, LoggingRecoveryController lrc, Updateable to_recover, int repl_s)
           
 void remove_log(long o_id)
           
 void replay_last_requests(org.omg.CORBA.Object stub, LogRecord[] l_r, long objI, int crt_ret_id, int repl_s)
           
 ResultResultArgs request_reply(java.lang.String cl_id, int retention_id, org.omg.CORBA.Object to)
           
 void set_neighbours(LoggingRecoveryController[] rm)
           
 void stop_checkpointing(Checkpointable ch_o)
           
 void stop_updating(Updateable up_o)
           
 
Methods inherited from class org.omg.FT.LoggingRecoveryControllerPOA
_all_interfaces, _invoke, _this, _this,
 
Methods inherited from class org.omg.PortableServer.Servant
_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

_tie

private LoggingRecoveryControllerOperations _tie

_poa

private org.omg.PortableServer.POA _poa
Constructor Detail

LoggingRecoveryControllerPOATie

public LoggingRecoveryControllerPOATie(LoggingRecoveryControllerOperations tieObject)

LoggingRecoveryControllerPOATie

public LoggingRecoveryControllerPOATie(LoggingRecoveryControllerOperations tieObject,
                                       org.omg.PortableServer.POA poa)
Method Detail

_delegate

public LoggingRecoveryControllerOperations _delegate()

_delegate

public void _delegate(LoggingRecoveryControllerOperations delegate_)

_default_POA

public org.omg.PortableServer.POA _default_POA()
Overrides:
_default_POA in class org.omg.PortableServer.Servant

record_part_get_st_upd_reply

public void record_part_get_st_upd_reply(long o_id,
                                         int c_r_i,
                                         java.lang.String oper)

record_method_call_par

public ResultResultArgs record_method_call_par(long target,
                                               java.lang.String operation,
                                               org.omg.Dynamic.Parameter[] arguments,
                                               java.lang.String client_id,
                                               int retention_id,
                                               long expiration_time,
                                               char method_type,
                                               long time_s,
                                               boolean broadcast)

record_method_call_as

public ResultResultArgs record_method_call_as(long target,
                                              java.lang.String operation,
                                              byte[] buff,
                                              boolean big_e,
                                              org.omg.GIOP.Version vers,
                                              java.lang.String client_id,
                                              int retention_id,
                                              long expiration_time,
                                              char method_type,
                                              boolean broadcast)

record_reply

public void record_reply(long source,
                         java.lang.String client_id,
                         int retention_id,
                         org.omg.CORBA.Any reply,
                         org.omg.CORBA.Any[] reply_args,
                         char m_t,
                         boolean broadcast)

record_reply_exc

public void record_reply_exc(long source,
                             java.lang.String client_id,
                             int retention_id,
                             char m_t)

react_set_st_upd_reply

public void react_set_st_upd_reply(long o_i)

call_reply

public ResultResultArgs call_reply(long target,
                                   java.lang.String client_id,
                                   int retention_id)

request_reply

public ResultResultArgs request_reply(java.lang.String cl_id,
                                      int retention_id,
                                      org.omg.CORBA.Object to)

record_request_repl

public void record_request_repl(java.lang.String cl_id,
                                org.omg.CORBA.Object to,
                                java.lang.String operation,
                                org.omg.CORBA.Any[] arguments,
                                int retention_id,
                                org.omg.CORBA.Any reply)

record_reply_stateless

public void record_reply_stateless(long o_i,
                                   java.lang.String cl_id,
                                   int ret_id,
                                   long exp_time,
                                   org.omg.CORBA.Any repl,
                                   org.omg.CORBA.Any[] repls)

do_checkpointing

public void do_checkpointing(Checkpointable checkpointed_obj,
                             long obj_id,
                             long checkpoint_interval,
                             Checkpointable[] transfer_to,
                             boolean transfer,
                             boolean periodic)

stop_checkpointing

public void stop_checkpointing(Checkpointable ch_o)

do_updating

public void do_updating(Updateable updated_obj,
                        long obj_id,
                        long update_interval,
                        Updateable[] transfer_to,
                        boolean transfer,
                        boolean periodic)

stop_updating

public void stop_updating(Updateable up_o)

set_neighbours

public void set_neighbours(LoggingRecoveryController[] rm)

replay_last_requests

public void replay_last_requests(org.omg.CORBA.Object stub,
                                 LogRecord[] l_r,
                                 long objI,
                                 int crt_ret_id,
                                 int repl_s)

record_replies

public void record_replies(LogRecord[] r)

recover_new_replica_ch

public void recover_new_replica_ch(long o_id,
                                   LoggingRecoveryController lrc,
                                   Checkpointable to_recover,
                                   int repl_s)

recover_new_replica_st_ch

public void recover_new_replica_st_ch(long o_id,
                                      LoggingRecoveryController new_lrc,
                                      Checkpointable to_recover,
                                      Checkpointable failed_obj)

recover_new_replica_upd

public void recover_new_replica_upd(long o_id,
                                    LoggingRecoveryController lrc,
                                    Updateable to_recover,
                                    int repl_s)

remove_log

public void remove_log(long o_id)

record_method_no_wait_par

public void record_method_no_wait_par(long objI,
                                      java.lang.String oper,
                                      org.omg.Dynamic.Parameter[] args,
                                      java.lang.String client_id,
                                      int retention_id,
                                      long expiration_time,
                                      char meth_type,
                                      long mess_id)

record_method_no_wait_as

public void record_method_no_wait_as(long objI,
                                     java.lang.String oper,
                                     byte[] buffer,
                                     boolean big_e,
                                     org.omg.GIOP.Version vers,
                                     java.lang.String client_id,
                                     int retention_id,
                                     long expiration_time,
                                     char met_type,
                                     long mess_id)

record_reply_no_notify

public void record_reply_no_notify(long objI,
                                   java.lang.String client_id,
                                   int retention_id,
                                   org.omg.CORBA.Any result,
                                   org.omg.CORBA.Any[] result_arguments,
                                   char m_t)