diff options
Diffstat (limited to 'TAO/tao/Incoming_Message_Queue.inl')
| -rw-r--r-- | TAO/tao/Incoming_Message_Queue.inl | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/TAO/tao/Incoming_Message_Queue.inl b/TAO/tao/Incoming_Message_Queue.inl index f82267b5cea..d67bd485383 100644 --- a/TAO/tao/Incoming_Message_Queue.inl +++ b/TAO/tao/Incoming_Message_Queue.inl @@ -18,7 +18,7 @@ TAO_Incoming_Message_Queue::is_tail_complete (void) return -1; if (this->size_ && - this->last_added_->missing_data_bytes_ == 0) + this->queued_data_->missing_data_ == 0) return 1; return 0; @@ -31,8 +31,8 @@ TAO_Incoming_Message_Queue::is_head_complete (void) return -1; if (this->size_ && - this->last_added_->next_->missing_data_bytes_ == 0 && - this->last_added_->next_->more_fragments_ == 0) + this->queued_data_->next_->missing_data_ == 0 && + this->queued_data_->next_->more_fragments_ == 0) return 1; return 0; @@ -45,7 +45,7 @@ TAO_Incoming_Message_Queue::is_tail_fragmented (void) return 0; if (this->size_ && - this->last_added_->more_fragments_ == 1) + this->queued_data_->more_fragments_ == 1) return 1; return 0; @@ -55,22 +55,23 @@ ACE_INLINE size_t TAO_Incoming_Message_Queue::missing_data_tail (void) const { if (this->size_ != 0) - return this->last_added_->missing_data_bytes_; + return this->queued_data_->missing_data_; return 0; } -/************************************************************************/ -// Methods for TAO_Queued_Data -/************************************************************************/ -ACE_INLINE void -TAO_Queued_Data::release (void) +ACE_INLINE TAO_Queued_Data * +TAO_Incoming_Message_Queue::get_node (void) { - TAO_Queued_Data::release (this); + return TAO_Queued_Data::get_queued_data (); } +/************************************************************************/ +// Methods for TAO_Queued_Data +/************************************************************************/ + /*static*/ ACE_INLINE void TAO_Queued_Data::replace_data_block (ACE_Message_Block &mb) |