summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorbala <balanatarajan@users.noreply.github.com>2000-12-27 23:48:57 +0000
committerbala <balanatarajan@users.noreply.github.com>2000-12-27 23:48:57 +0000
commit7bf978f43718c2b0f718f78d05d7586b8d13270f (patch)
tree0414b680b0d16716ee57175d60d0c85e323b77aa
parent3625c1a5afb21b5284fa74d9108595a528e1fdf8 (diff)
downloadATCD-7bf978f43718c2b0f718f78d05d7586b8d13270f.tar.gz
*** empty log message ***
-rw-r--r--TAO/tao/GIOP_Message_Handler.cpp1
-rw-r--r--TAO/tao/GIOP_Message_Handler.h5
-rw-r--r--TAO/tao/GIOP_Message_Handler.inl10
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 ();
+}