ChangeLogTag:Sat Aug 03 12:42:43 2002 Balachandran Natarajan <bala@cs.wustl.edu>

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;