diff options
Diffstat (limited to 'TAO/tao/Transport.cpp')
| -rw-r--r-- | TAO/tao/Transport.cpp | 35 |
1 files changed, 33 insertions, 2 deletions
diff --git a/TAO/tao/Transport.cpp b/TAO/tao/Transport.cpp index 194072dc587..b42243d6a09 100644 --- a/TAO/tao/Transport.cpp +++ b/TAO/tao/Transport.cpp @@ -1662,11 +1662,30 @@ TAO_Transport::consolidate_message_queue (ACE_Message_Block &incoming, // If the queue did not have a complete message put this piece of // message in the queue. We kow it did not have a complete // message. That is why we are here. - size_t n = this->incoming_message_queue_.copy_tail (incoming); + size_t n = + this->incoming_message_queue_.copy_tail (incoming); + + if (TAO_debug_level > 6) + { + ACE_DEBUG ((LM_DEBUG, + "(%P|%t) TAO_Transport[%d]::consolidate_message_queue", + "copied [%d] bytes to the tail \n", + this->id (), + n)); + } // Update the missing data... - missing_data = this->incoming_message_queue_.missing_data_tail (); + missing_data = + this->incoming_message_queue_.missing_data_tail (); + if (TAO_debug_level > 6) + { + ACE_DEBUG ((LM_DEBUG, + "(%P|%t) TAO_Transport[%d]::consolidate_message_queue", + "missing [%d] bytes in the tail messahe \n", + this->id (), + missing_data)); + } // Move the read pointer of the <incoming> message block to the end // of the copied message and process the remaining portion... @@ -1737,12 +1756,24 @@ TAO_Transport::consolidate_message_queue (ACE_Message_Block &incoming, TAO_Queued_Data *qd = this->incoming_message_queue_.dequeue_tail (); + if (TAO_debug_level > 5) + ACE_DEBUG ((LM_DEBUG, + "(%P|%t) TAO_Transport[%d]::consolidate_message_queue", + " trying recv, again \n", + this->id ())); + // Try to do a read again. If we have some luck it would be // great.. ssize_t n = this->recv (qd->msg_block_->wr_ptr (), missing_data, max_wait_time); + if (TAO_debug_level > 5) + ACE_DEBUG ((LM_DEBUG, + "(%P|%t) TAO_Transport[%d]::consolidate_message_queue", + " recv retval [%d] \n", + this->id (), + n)); // Error... if (n < 0) return n; |