diff options
| author | bala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2005-10-03 11:34:20 +0000 |
|---|---|---|
| committer | bala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2005-10-03 11:34:20 +0000 |
| commit | b3868151be3d8bd6acdf6a909217a2827320a7f8 (patch) | |
| tree | a57de040c70ec715b1005a5db1c163baa48ba470 /TAO/tao/Synch_Queued_Message.cpp | |
| parent | a155e1d1520902a8476a480c561c1dcdd66322af (diff) | |
| download | ATCD-b3868151be3d8bd6acdf6a909217a2827320a7f8.tar.gz | |
ChangeLogTag:Mon Oct 3 06:33:20 2005 Bala Natarajan <bala_natarajan at symantec dot com>
Diffstat (limited to 'TAO/tao/Synch_Queued_Message.cpp')
| -rw-r--r-- | TAO/tao/Synch_Queued_Message.cpp | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/TAO/tao/Synch_Queued_Message.cpp b/TAO/tao/Synch_Queued_Message.cpp index b024fffc314..58cbf2afb3e 100644 --- a/TAO/tao/Synch_Queued_Message.cpp +++ b/TAO/tao/Synch_Queued_Message.cpp @@ -2,6 +2,7 @@ #include "Synch_Queued_Message.h" #include "debug.h" +#include "ORB_Core.h" #include "ace/Malloc_T.h" #include "ace/Message_Block.h" @@ -12,9 +13,10 @@ ACE_RCSID (tao, TAO_Synch_Queued_Message:: TAO_Synch_Queued_Message (const ACE_Message_Block *contents, + TAO_ORB_Core *oc, ACE_Allocator *alloc, int is_heap_allocated) - : TAO_Queued_Message (alloc, is_heap_allocated) + : TAO_Queued_Message (oc, alloc, is_heap_allocated) , contents_ (const_cast<ACE_Message_Block*> (contents)) , current_block_ (contents_) { @@ -102,9 +104,8 @@ TAO_Synch_Queued_Message::bytes_transferred (size_t &byte_count) } if (this->current_block_ == 0) - { - this->state_changed (TAO_LF_Event::LFS_SUCCESS); - } + this->state_changed (TAO_LF_Event::LFS_SUCCESS, + this->orb_core_->leader_follower ()); } TAO_Queued_Message * @@ -125,6 +126,7 @@ TAO_Synch_Queued_Message::clone (ACE_Allocator *alloc) static_cast<TAO_Synch_Queued_Message *> ( alloc->malloc (sizeof (TAO_Synch_Queued_Message))), TAO_Synch_Queued_Message (mb, + this->orb_core_, alloc), 0); } @@ -140,7 +142,7 @@ TAO_Synch_Queued_Message::clone (ACE_Allocator *alloc) } ACE_NEW_RETURN (qm, - TAO_Synch_Queued_Message (mb), + TAO_Synch_Queued_Message (mb, this->orb_core_), 0); } |