diff options
Diffstat (limited to 'TAO/tao/Incoming_Message_Queue.inl')
| -rw-r--r-- | TAO/tao/Incoming_Message_Queue.inl | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/TAO/tao/Incoming_Message_Queue.inl b/TAO/tao/Incoming_Message_Queue.inl index d67bd485383..d04512d81b0 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->queued_data_->missing_data_ == 0) + this->queued_data_->missing_data_bytes_ == 0) return 1; return 0; @@ -31,7 +31,7 @@ TAO_Incoming_Message_Queue::is_head_complete (void) return -1; if (this->size_ && - this->queued_data_->next_->missing_data_ == 0 && + this->queued_data_->next_->missing_data_bytes_ == 0 && this->queued_data_->next_->more_fragments_ == 0) return 1; @@ -55,23 +55,30 @@ ACE_INLINE size_t TAO_Incoming_Message_Queue::missing_data_tail (void) const { if (this->size_ != 0) - return this->queued_data_->missing_data_; + return this->queued_data_->missing_data_bytes_; return 0; } - +#if 0 ACE_INLINE TAO_Queued_Data * TAO_Incoming_Message_Queue::get_node (void) { return TAO_Queued_Data::get_queued_data (); } +#endif /************************************************************************/ // Methods for TAO_Queued_Data /************************************************************************/ +ACE_INLINE void +TAO_Queued_Data::release (void) +{ + TAO_Queued_Data::release (this); +} + /*static*/ ACE_INLINE void TAO_Queued_Data::replace_data_block (ACE_Message_Block &mb) |