TAO/tao/LF_Multi_Event.cpp

   1 #include "tao/LF_Multi_Event.h"
   2 #include "tao/Connection_Handler.h"
   3 #include "ace/OS_Memory.h"
   4
   5 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   6
   7
   8 TAO_LF_Multi_Event::TAO_LF_Multi_Event ()
   9   : TAO_LF_Event (),
  10     events_ (nullptr),
  11     winner_ (nullptr)
  12 {
  13 }
  14
  15 TAO_LF_Multi_Event::~TAO_LF_Multi_Event ()
  16 {
  17   while (this->events_ != nullptr)
  18     {
  19       Event_Node *n = this->events_->next_;
  20       delete this->events_;
  21       this->events_ = n;
  22     }
  23 }
  24
  25 int
  26 TAO_LF_Multi_Event::bind (TAO_LF_Follower *follower)
  27 {
  28   if (this->TAO_LF_Event::bind(follower) == -1)
  29     {
  30       return -1;
  31     }
  32
  33   for (Event_Node *n = this->events_; n != nullptr; n = n->next_)
  34     if (n->ptr_->bind(follower) == -1)
  35       {
  36         return -1;
  37       }
  38   return 0;
  39 }
  40
  41 int
  42 TAO_LF_Multi_Event::unbind (TAO_LF_Follower *follower)
  43 {
  44   if (this->TAO_LF_Event::unbind (follower) == -1)
  45     {
  46       return -1;
  47     }
  48
  49   for (Event_Node *n = this->events_; n != nullptr; n = n->next_)
  50     if (n->ptr_->unbind (follower) == -1)
  51       {
  52         return -1;
  53       }
  54   return 0;
  55 }
  56
  57
  58 void
  59 TAO_LF_Multi_Event::add_event (TAO_Connection_Handler *ev)
  60 {
  61   Event_Node *node = nullptr;
  62   ACE_NEW (node, Event_Node);
  63   node->next_ = this->events_;
  64   node->ptr_ = ev;
  65
  66   this->events_ = node;
  67 }
  68
  69 TAO_Connection_Handler*
  70 TAO_LF_Multi_Event::winner ()
  71 {
  72   return this->winner_;
  73 }
  74
  75 TAO_Transport *
  76 TAO_LF_Multi_Event::base_transport ()
  77 {
  78   return (this->events_ == nullptr) ? nullptr : this->events_->ptr_->transport();
  79 }
  80
  81 bool
  82 TAO_LF_Multi_Event::successful_i () const
  83 {
  84   for (Event_Node *n = this->events_; n != nullptr; n = n->next_)
  85     if (n->ptr_->successful_i())
  86       {
  87         this->winner_ = n->ptr_;
  88         return true;
  89       }
  90   return false;
  91 }
  92
  93 bool
  94 TAO_LF_Multi_Event::error_detected_i () const
  95 {
  96   for (Event_Node *n = this->events_; n != nullptr; n = n->next_)
  97     {
  98       if (!n->ptr_->error_detected_i ())
  99         {
 100           return false;
 101         }
 102     }
 103   return true;
 104 }
 105
 106 void
 107 TAO_LF_Multi_Event::state_changed_i (LFS_STATE )
 108 {
 109 }
 110
 111 bool
 112 TAO_LF_Multi_Event::is_state_final () const
 113 {
 114   for (Event_Node *n = this->events_; n != nullptr; n = n->next_)
 115     {
 116       if (!n->ptr_->is_state_final ())
 117         {
 118           return false;
 119         }
 120     }
 121   return true;
 122 }
 123
 124 TAO_END_VERSIONED_NAMESPACE_DECL