diff options
author | bala <balanatarajan@users.noreply.github.com> | 2001-01-02 04:18:13 +0000 |
---|---|---|
committer | bala <balanatarajan@users.noreply.github.com> | 2001-01-02 04:18:13 +0000 |
commit | 8e46ca6a9e352331dabb0669c746d9671a582171 (patch) | |
tree | 8a5b08095644a1388bfa0ed1595a6a68681b9da8 | |
parent | 6bf140acf44f4f95f82aa3b5582ffd4910c5457c (diff) | |
download | ATCD-8e46ca6a9e352331dabb0669c746d9671a582171.tar.gz |
*** empty log message ***
-rw-r--r-- | TAO/tao/GIOP_Message_Base.cpp | 1 | ||||
-rw-r--r-- | TAO/tao/GIOP_Message_Handler.cpp | 14 |
2 files changed, 6 insertions, 9 deletions
diff --git a/TAO/tao/GIOP_Message_Base.cpp b/TAO/tao/GIOP_Message_Base.cpp index a99e8b4c2b9..52ab792d0a4 100644 --- a/TAO/tao/GIOP_Message_Base.cpp +++ b/TAO/tao/GIOP_Message_Base.cpp @@ -529,6 +529,7 @@ TAO_GIOP_Message_Base::process_request (TAO_Transport *transport, CORBA::COMPLETED_NO)); request_id = request.request_id (); + cout << "Processing request id " << request_id <<endl; response_required = request.response_expected (); CORBA::Object_var forward_to; diff --git a/TAO/tao/GIOP_Message_Handler.cpp b/TAO/tao/GIOP_Message_Handler.cpp index faa0fd28361..25e616627e5 100644 --- a/TAO/tao/GIOP_Message_Handler.cpp +++ b/TAO/tao/GIOP_Message_Handler.cpp @@ -32,11 +32,13 @@ TAO_GIOP_Message_Handler::TAO_GIOP_Message_Handler (TAO_ORB_Core * orb_core) int TAO_GIOP_Message_Handler::read_parse_message (TAO_Transport *transport) { - // Read the message from the transport + // Read the message from the transport. The size of the message read + // is the maximum size of the buffer that we have less the amount of + // data that has already been read in to the buffer. + size_t sp = this->current_buffer_.space (); ssize_t n = transport->read (this->current_buffer_.wr_ptr (), - this->message_size_ - this->current_buffer_.length ()); + this->current_buffer_.space ()); - cout << "The value of n is " << n <<endl; if (n == -1) { if (errno == EWOULDBLOCK) @@ -273,12 +275,9 @@ TAO_GIOP_Message_Handler::is_message_ready (void) { size_t len = this->current_buffer_.length (); - cout << "The length is " << len <<endl; - if (len == this->message_state_.message_size) { - cout << "Amba 1" <<endl; // If the buffer length is equal to the size of the payload we // have exactly one message. Check whether we have received // only the first part of the fragment. @@ -287,7 +286,6 @@ TAO_GIOP_Message_Handler::is_message_ready (void) } else if (len > this->message_state_.message_size) { - cout << "Amba 2" <<endl; // If the length is greater we have received some X messages // and a part of X + 1 messages (probably) with X varying // from 1 to N. @@ -306,8 +304,6 @@ TAO_GIOP_Message_Handler::is_message_ready (void) } } - cout << "Amba 3" <<endl; - // Just return allowing the reactor to call us back to get the rest // of the info return 0; |