Fri Jan 4 15:48:20 UTC 2013 Simon Massey <simon dot massey at prismtech dot com>

orbsvcs/orbsvcs/PortableGroup/UIPMC_Mcast_Transport.cpp: Correction to the placement of the notify.

1 files changed, 9 insertions, 9 deletions

diff --git a/TAO/orbsvcs/orbsvcs/PortableGroup/UIPMC_Mcast_Transport.cpp b/TAO/orbsvcs/orbsvcs/PortableGroup/UIPMC_Mcast_Transport.cpp
index cc950284b42..80524a295c0 100644
--- a/TAO/orbsvcs/orbsvcs/PortableGroup/UIPMC_Mcast_Transport.cpp
+++ b/TAO/orbsvcs/orbsvcs/PortableGroup/UIPMC_Mcast_Transport.cpp
@@ -423,15 +423,6 @@ TAO_UIPMC_Mcast_Transport::handle_input (
       }
       ACE_Auto_Ptr<TAO_PG::UIPMC_Recv_Packet> owner (complete);
 
-      // Create a data block.
-      ACE_Data_Block db (complete->data_length () + ACE_CDR::MAX_ALIGNMENT,
-                         ACE_Message_Block::MB_DATA,
-                         0,
-                         this->orb_core_->input_cdr_buffer_allocator (),
-                         this->orb_core_->locking_strategy (),
-                         0,
-                         this->orb_core_->input_cdr_dblock_allocator ());
-
       // If there is another message waiting to be processed (in addition
       // to the one we have just taken off to be processed), notify another
       // thread (if available) so this can also be processed in parrellel.
@@ -455,6 +446,15 @@ TAO_UIPMC_Mcast_Transport::handle_input (
         }
 
       // Create a data block from our dequeued completed message.
+      ACE_Data_Block db (complete->data_length () + ACE_CDR::MAX_ALIGNMENT,
+                         ACE_Message_Block::MB_DATA,
+                         0,
+                         this->orb_core_->input_cdr_buffer_allocator (),
+                         this->orb_core_->locking_strategy (),
+                         0,
+                         this->orb_core_->input_cdr_dblock_allocator ());
+
+      // Create a message block
       ACE_Message_Block message_block (
         &db,
         ACE_Message_Block::DONT_DELETE,