summaryrefslogtreecommitdiff
path: root/TAO/tao/Queued_Message.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Queued_Message.cpp')
-rw-r--r--TAO/tao/Queued_Message.cpp43
1 files changed, 5 insertions, 38 deletions
diff --git a/TAO/tao/Queued_Message.cpp b/TAO/tao/Queued_Message.cpp
index 94ad78e1662..2d0e91b0388 100644
--- a/TAO/tao/Queued_Message.cpp
+++ b/TAO/tao/Queued_Message.cpp
@@ -10,13 +10,10 @@
ACE_RCSID(tao, Queued_Message, "$Id$")
-TAO_Queued_Message::TAO_Queued_Message (ACE_Message_Block *contents,
- int own_contents,
- TAO_Message_Sent_Callback *callback)
- : contents_ (contents)
- , own_contents_ (own_contents)
+TAO_Queued_Message::TAO_Queued_Message (TAO_Message_Sent_Callback *callback)
+ : data_sent_successfully_ (0)
+ , connection_closed_ (0)
, callback_ (callback)
- , current_block_ (contents)
, next_ (0)
, prev_ (0)
{
@@ -24,21 +21,13 @@ TAO_Queued_Message::TAO_Queued_Message (ACE_Message_Block *contents,
TAO_Queued_Message::~TAO_Queued_Message (void)
{
- if (this->own_contents_)
- {
- ACE_Message_Block *i = this->contents_;
- while (i != 0)
- {
- ACE_Message_Block *cont = i->cont (); i->cont (0);
- ACE_Message_Block::release (i);
- i = cont;
- }
- }
}
void
TAO_Queued_Message::connection_closed (void)
{
+ this->connection_closed_ = 1;
+
if (this->callback_ != 0)
{
if (this->done ())
@@ -53,28 +42,6 @@ TAO_Queued_Message::connection_closed (void)
}
void
-TAO_Queued_Message::destroy (void)
-{
- delete this;
-}
-
-void
-TAO_Queued_Message::bytes_transferred (size_t byte_count)
-{
- while (!this->done () && byte_count > 0)
- {
- size_t l = this->current_block_->length ();
- if (byte_count < l)
- {
- this->current_block_->rd_ptr (byte_count);
- return;
- }
- byte_count -= l;
- this->current_block_ = this->current_block_->cont ();
- }
-}
-
-void
TAO_Queued_Message::remove_from_list (TAO_Queued_Message *&head,
TAO_Queued_Message *&tail)
{