TAO/tao/LF_CH_Event.cpp

   1 #include "tao/LF_CH_Event.h"
   2 #include "tao/LF_Follower.h"
   3 #include "tao/debug.h"
   4 #include "tao/Connection_Handler.h"
   5 #include "tao/Transport.h"
   6
   7 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   8
   9 TAO_LF_CH_Event::TAO_LF_CH_Event ()
  10   : TAO_LF_Event (),
  11     prev_state_ (TAO_LF_Event::LFS_IDLE)
  12
  13 {
  14 }
  15
  16 TAO_LF_CH_Event::~TAO_LF_CH_Event ()
  17 {
  18 }
  19
  20 int
  21 TAO_LF_CH_Event::bind (TAO_LF_Follower *follower)
  22 {
  23   return this->followers_.bind (follower, 0);
  24 }
  25
  26 int
  27 TAO_LF_CH_Event::unbind (TAO_LF_Follower *follower)
  28 {
  29   return this->followers_.unbind (follower);
  30 }
  31
  32 void
  33 TAO_LF_CH_Event::state_changed_i (LFS_STATE new_state)
  34 {
  35   if (this->state_ != new_state)
  36     {
  37       this->validate_state_change (new_state);
  38
  39       if (TAO_debug_level > 9)
  40         {
  41           size_t id = 0;
  42           TAO_Connection_Handler *ch = nullptr;
  43           if ((ch = dynamic_cast<TAO_Connection_Handler *> (this))
  44               && ch->transport ())
  45             {
  46               id = ch->transport ()->id ();
  47             }
  48
  49           TAOLIB_DEBUG ((LM_DEBUG, "TAO (%P|%t) - TAO_LF_CH_Event[%d]::"
  50                       "state_changed_i, state %C->%C\n",
  51                       id,
  52                       TAO_LF_Event::state_name(prev_state_),
  53                       TAO_LF_Event::state_name(state_)));
  54         }
  55     }
  56
  57   ACE_MT (ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->followers_.mutex ()));
  58
  59   HASH_MAP::iterator end_it = this->followers_.end ();
  60   for (HASH_MAP::iterator it = this->followers_.begin (); it != end_it ; ++it)
  61     {
  62       it->ext_id_->signal ();
  63     }
  64 }
  65
  66 void
  67 TAO_LF_CH_Event::validate_state_change (LFS_STATE new_state)
  68 {
  69   if (this->state_ == TAO_LF_Event::LFS_IDLE)
  70     {
  71       // From the LFS_IDLE state we can only become active.
  72       if (new_state == TAO_LF_Event::LFS_CONNECTION_WAIT)
  73         {
  74           this->prev_state_ = this->state_;
  75           this->state_ = new_state;
  76         }
  77       return;
  78     }
  79   else if (this->state_ == TAO_LF_Event::LFS_CONNECTION_WAIT)
  80     {
  81       // Only a few states are possible from CONNECTION_WAIT states
  82       if (new_state == TAO_LF_Event::LFS_CONNECTION_CLOSED
  83           || new_state == TAO_LF_Event::LFS_SUCCESS)
  84         {
  85           this->prev_state_ = this->state_;
  86           this->state_ = new_state;
  87         }
  88
  89       return;
  90     }
  91   else if (this->state_ == TAO_LF_Event::LFS_SUCCESS)
  92     {
  93       if (new_state == TAO_LF_Event::LFS_CONNECTION_CLOSED)
  94         {
  95           this->prev_state_ = this->state_;
  96           this->state_ = new_state;
  97         }
  98       return;
  99     }
 100   else if (this->state_ == TAO_LF_Event::LFS_TIMEOUT)
 101     {
 102       if (new_state == TAO_LF_Event::LFS_CONNECTION_CLOSED)
 103         {
 104           // Dont reset the previous state
 105           this->state_ = new_state;
 106         }
 107     }
 108   return;
 109 }
 110
 111 bool
 112 TAO_LF_CH_Event::successful_i () const
 113 {
 114   if (this->prev_state_ == TAO_LF_Event::LFS_CONNECTION_WAIT)
 115     return this->state_ == TAO_LF_Event::LFS_SUCCESS;
 116
 117   return this->state_ == TAO_LF_Event::LFS_CONNECTION_CLOSED;
 118 }
 119
 120 bool
 121 TAO_LF_CH_Event::error_detected_i () const
 122 {
 123   if (this->prev_state_ == TAO_LF_Event::LFS_CONNECTION_WAIT)
 124     return this->state_ == TAO_LF_Event::LFS_CONNECTION_CLOSED;
 125
 126   return this->state_ == TAO_LF_Event::LFS_TIMEOUT;
 127 }
 128
 129 void
 130 TAO_LF_CH_Event::set_state (LFS_STATE new_state)
 131 {
 132   // @@ NOTE: Is this still required?
 133   if (!this->is_state_final ()
 134       && new_state == TAO_LF_Event::LFS_TIMEOUT)
 135     {
 136       this->state_ = new_state;
 137       if (TAO_debug_level > 9)
 138         {
 139           size_t id = 0;
 140           TAO_Connection_Handler *ch = nullptr;
 141           if ((ch = dynamic_cast<TAO_Connection_Handler *> (this)) &&
 142               ch->transport ())
 143             {
 144               id = ch->transport ()->id ();
 145             }
 146           TAOLIB_DEBUG ((LM_DEBUG, "TAO (%P|%t) - TAO_LF_CH_Event[%d]::set_state, "
 147                       "state_ is LFS_TIMEOUT\n", id));
 148         }
 149     }
 150 }
 151
 152 bool
 153 TAO_LF_CH_Event::is_state_final () const
 154 {
 155   return this->state_ == TAO_LF_Event::LFS_CONNECTION_CLOSED;
 156 }
 157
 158 TAO_END_VERSIONED_NAMESPACE_DECL