diff options
author | bala <balanatarajan@users.noreply.github.com> | 2001-02-16 21:09:51 +0000 |
---|---|---|
committer | bala <balanatarajan@users.noreply.github.com> | 2001-02-16 21:09:51 +0000 |
commit | a3f7bbea432d336361784424e8d35682991c981c (patch) | |
tree | 6ac6d23aa1a8a8e7fb77c03327ab40978d35bcfc /TAO | |
parent | 43fcd758a895b36db8fb51723e534b2a9b46ff2c (diff) | |
download | ATCD-a3f7bbea432d336361784424e8d35682991c981c.tar.gz |
ChangeLogTag: Fri Feb 16 15:06:17 2001 Balachandran Natarajan <bala@cs.wustl.edu>
Diffstat (limited to 'TAO')
-rw-r--r-- | TAO/ChangeLogs/ChangeLog-02a | 8 | ||||
-rw-r--r-- | TAO/tao/GIOP_Message_Handler.cpp | 10 |
2 files changed, 17 insertions, 1 deletions
diff --git a/TAO/ChangeLogs/ChangeLog-02a b/TAO/ChangeLogs/ChangeLog-02a index 2a03fea5efa..42e7d441dd2 100644 --- a/TAO/ChangeLogs/ChangeLog-02a +++ b/TAO/ChangeLogs/ChangeLog-02a @@ -1,3 +1,11 @@ +Fri Feb 16 15:06:17 2001 Balachandran Natarajan <bala@cs.wustl.edu> + + * tao/GIOP_Message_Handler.cpp: Fixed a problem in the case when + multiple one way messages were read from the socket. All the + complete calls got processed correctly. One of the incomplete + calls at the boundary was not processed properly. This should + fix the reliable one way test failures. + Fri Feb 16 11:09:41 2001 Jeff Parsons <parsons@cs.wustl.edu> * tao/Makefile: diff --git a/TAO/tao/GIOP_Message_Handler.cpp b/TAO/tao/GIOP_Message_Handler.cpp index ba2fe76784c..c6263cb9bfd 100644 --- a/TAO/tao/GIOP_Message_Handler.cpp +++ b/TAO/tao/GIOP_Message_Handler.cpp @@ -375,7 +375,6 @@ TAO_GIOP_Message_Handler::more_messages (void) return this->get_message (); } - } return TAO_MESSAGE_BLOCK_COMPLETE; @@ -438,6 +437,15 @@ TAO_GIOP_Message_Handler::get_message (void) this->supp_buffer_.rd_ptr (this->message_state_.message_size); return this->message_state_.is_complete (this->current_buffer_); } + else + { + // The remaining message in the supp buffer + this->current_buffer_.copy (this->supp_buffer_.rd_ptr (), + this->supp_buffer_.length ()); + + // Reset the supp buffer now + this->supp_buffer_.reset (); + } } return TAO_MESSAGE_BLOCK_INCOMPLETE; |