diff options
author | bala <balanatarajan@users.noreply.github.com> | 2000-12-27 23:48:57 +0000 |
---|---|---|
committer | bala <balanatarajan@users.noreply.github.com> | 2000-12-27 23:48:57 +0000 |
commit | 7bf978f43718c2b0f718f78d05d7586b8d13270f (patch) | |
tree | 0414b680b0d16716ee57175d60d0c85e323b77aa | |
parent | 3625c1a5afb21b5284fa74d9108595a528e1fdf8 (diff) | |
download | ATCD-7bf978f43718c2b0f718f78d05d7586b8d13270f.tar.gz |
*** empty log message ***
-rw-r--r-- | TAO/tao/GIOP_Message_Handler.cpp | 1 | ||||
-rw-r--r-- | TAO/tao/GIOP_Message_Handler.h | 5 | ||||
-rw-r--r-- | TAO/tao/GIOP_Message_Handler.inl | 10 |
3 files changed, 15 insertions, 1 deletions
diff --git a/TAO/tao/GIOP_Message_Handler.cpp b/TAO/tao/GIOP_Message_Handler.cpp index 232c0744e4b..a8f1267bb4c 100644 --- a/TAO/tao/GIOP_Message_Handler.cpp +++ b/TAO/tao/GIOP_Message_Handler.cpp @@ -28,7 +28,6 @@ TAO_GIOP_Message_Handler:: int TAO_GIOP_Message_Handler::read_parse_message (TAO_Transport *transport) { - cout << "The wr_ptr is " << this->current_buffer_.wr_ptr () <<endl; // Read the message from the transport ssize_t n = transport->read (this->current_buffer_.wr_ptr (), this->message_size_); diff --git a/TAO/tao/GIOP_Message_Handler.h b/TAO/tao/GIOP_Message_Handler.h index a7be9bc60c3..47c266f9b86 100644 --- a/TAO/tao/GIOP_Message_Handler.h +++ b/TAO/tao/GIOP_Message_Handler.h @@ -61,6 +61,11 @@ public: /// processing. int is_message_ready (void); + /// Reset the contents of the <current_buffer_> if no more requests + /// need to be processed. We reset the contents of the + /// <message_state_> to parse and process the next request. + void reset (int reset_flag); + /// Return the underlying message state TAO_GIOP_Message_State &message_state (void); diff --git a/TAO/tao/GIOP_Message_Handler.inl b/TAO/tao/GIOP_Message_Handler.inl index 1a692bc6fe3..eae2ebe2312 100644 --- a/TAO/tao/GIOP_Message_Handler.inl +++ b/TAO/tao/GIOP_Message_Handler.inl @@ -13,3 +13,13 @@ TAO_GIOP_Message_Handler::message_block (void) // The read pointer should be after the GIOP header return &this->current_buffer_; } + +ACE_INLINE void +TAO_GIOP_Message_Handler::reset (int /*reset_flag*/) +{ + // Reset the contents of the message state + this->message_state_.reset (0); + + // Reset the current buffer + this->current_buffer_.reset (); +} |