TAO/tao/Connection_Handler.inl

   1 // -*- C++ -*-
   2 //
   3 #include "tao/Transport.h"
   4
   5 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   6
   7 ACE_INLINE TAO_ORB_Core *
   8 TAO_Connection_Handler::orb_core ()
   9 {
  10   return this->orb_core_;
  11 }
  12
  13 ACE_INLINE TAO_Transport *
  14 TAO_Connection_Handler::transport ()
  15 {
  16   return this->transport_;
  17 }
  18
  19 ACE_INLINE bool
  20 TAO_Connection_Handler::is_closed () const
  21 {
  22   return (this->state_ == TAO_LF_Event::LFS_CONNECTION_CLOSED ||
  23           this->state_ == TAO_LF_Event::LFS_TIMEOUT || this->is_closed_);
  24 }
  25
  26 ACE_INLINE bool
  27 TAO_Connection_Handler::is_timeout () const
  28 {
  29   return (this->state_ == TAO_LF_Event::LFS_TIMEOUT);
  30 }
  31
  32 ACE_INLINE bool
  33 TAO_Connection_Handler::is_open () const
  34 {
  35   return this->state_ == TAO_LF_Event::LFS_SUCCESS;
  36 }
  37
  38 ACE_INLINE bool
  39 TAO_Connection_Handler::is_connecting () const
  40 {
  41   return this->state_ == TAO_LF_Event::LFS_CONNECTION_WAIT;
  42 }
  43
  44 ACE_INLINE void
  45 TAO_Connection_Handler::connection_pending ()
  46 {
  47   if (!this->connection_pending_)
  48     {
  49       this->connection_pending_ = true;
  50       this->transport()->add_reference();
  51     }
  52 }
  53
  54 ACE_INLINE void
  55 TAO_Connection_Handler::cancel_pending_connection ()
  56 {
  57   if (this->connection_pending_)
  58     {
  59       this->connection_pending_ = false;
  60       this->transport()->remove_reference();
  61     }
  62 }
  63
  64 /// Derived classes should implement this for proper support with the
  65 /// Blocking Flushing Strategy.
  66 ACE_INLINE int
  67 TAO_Connection_Handler::handle_write_ready (const ACE_Time_Value *)
  68 {
  69   return 0;
  70 }
  71
  72 TAO_END_VERSIONED_NAMESPACE_DECL