TAO/tao/Incoming_Message_Queue.cpp

   1 #include "tao/Incoming_Message_Queue.h"
   2 #include "tao/Queued_Data.h"
   3 #include "tao/debug.h"
   4
   5 #include "ace/Log_Msg.h"
   6 #include "ace/Malloc_Base.h"
   7
   8 #if !defined (__ACE_INLINE__)
   9 # include "tao/Incoming_Message_Queue.inl"
  10 #endif /* __ACE_INLINE__ */
  11
  12 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  13
  14 TAO_Incoming_Message_Queue::~TAO_Incoming_Message_Queue ()
  15 {
  16   CORBA::ULong const sz = this->size_;
  17
  18   // Delete all the nodes left behind
  19   for (CORBA::ULong i = 0;
  20        i < sz;
  21        ++i)
  22     {
  23       TAO_Queued_Data *qd = this->dequeue_head ();
  24       TAO_Queued_Data::release (qd);
  25     }
  26 }
  27
  28
  29 TAO_Queued_Data *
  30 TAO_Incoming_Message_Queue::dequeue_head ()
  31 {
  32   if (this->size_ == 0)
  33     return nullptr;
  34
  35   // Get the node on the head of the queue...
  36   TAO_Queued_Data * const head = this->last_added_->next ();
  37
  38   // Reset the head node..
  39   this->last_added_->next (head->next ());
  40
  41   // Decrease the size and reset last_added_ if empty
  42   if (--this->size_ == 0)
  43     this->last_added_ = nullptr;
  44
  45   return head;
  46 }
  47
  48 TAO_Queued_Data *
  49 TAO_Incoming_Message_Queue::dequeue_tail ()
  50 {
  51   // This is a bit painful stuff...
  52   if (this->size_ == 0)
  53     return nullptr;
  54
  55   // Get the node on the head of the queue...
  56   TAO_Queued_Data *head = this->last_added_->next ();
  57
  58   while (head->next () != this->last_added_)
  59     {
  60       head = head->next ();
  61     }
  62
  63   // Put the head in tmp.
  64   head->next (this->last_added_->next ());
  65
  66   TAO_Queued_Data *ret_qd = this->last_added_;
  67
  68   this->last_added_ = head;
  69
  70   // Decrease the size
  71   if (--this->size_ == 0)
  72     this->last_added_ = nullptr;
  73
  74  return ret_qd;
  75 }
  76
  77 int
  78 TAO_Incoming_Message_Queue::enqueue_tail (TAO_Queued_Data *nd)
  79 {
  80   if (this->size_ == 0)
  81     {
  82       this->last_added_ = nd;
  83       this->last_added_->next (this->last_added_);
  84     }
  85   else
  86     {
  87       nd->next (this->last_added_->next ());
  88       this->last_added_->next (nd);
  89       this->last_added_ = nd;
  90     }
  91
  92   ++this->size_;
  93   return 0;
  94 }
  95
  96 TAO_END_VERSIONED_NAMESPACE_DECL