TAO/tao/Wait_On_Leader_Follower.cpp

   1 #include "tao/Wait_On_Leader_Follower.h"
   2 #include "tao/LF_Follower.h"
   3 #include "tao/Leader_Follower.h"
   4 #include "tao/Transport.h"
   5 #include "tao/Synch_Reply_Dispatcher.h"
   6 #include "tao/ORB_Core.h"
   7
   8 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   9
  10 TAO_Wait_On_Leader_Follower::TAO_Wait_On_Leader_Follower
  11   (TAO_Transport *transport)
  12   : TAO_Wait_Strategy (transport)
  13 {
  14 }
  15
  16 int
  17 TAO_Wait_On_Leader_Follower::register_handler ()
  18 {
  19   if (!this->is_registered_)
  20     {
  21       return this->transport_->register_handler ();
  22     }
  23
  24   return 1;
  25 }
  26
  27 bool
  28 TAO_Wait_On_Leader_Follower::non_blocking () const
  29 {
  30   return true;
  31 }
  32
  33 int
  34 TAO_Wait_On_Leader_Follower::sending_request (TAO_ORB_Core *orb_core,
  35                                               TAO_Message_Semantics msg_semantics)
  36 {
  37   // Register the handler.
  38   if (!this->is_registered_)
  39     {
  40       this->transport_->register_handler ();
  41     }
  42
  43   return this->TAO_Wait_Strategy::sending_request (orb_core, msg_semantics);
  44 }
  45
  46 int
  47 TAO_Wait_On_Leader_Follower::wait (ACE_Time_Value *max_wait_time,
  48                                    TAO_Synch_Reply_Dispatcher &rd)
  49 {
  50   TAO_Leader_Follower &leader_follower =
  51     this->transport_->orb_core ()->leader_follower ();
  52   return leader_follower.wait_for_event (&rd, this->transport_, max_wait_time);
  53 }
  54
  55 bool
  56 TAO_Wait_On_Leader_Follower::can_process_upcalls () const
  57 {
  58   return true;
  59 }
  60
  61 TAO_END_VERSIONED_NAMESPACE_DECL