summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorbala <balanatarajan@users.noreply.github.com>2001-01-02 04:18:13 +0000
committerbala <balanatarajan@users.noreply.github.com>2001-01-02 04:18:13 +0000
commit8e46ca6a9e352331dabb0669c746d9671a582171 (patch)
tree8a5b08095644a1388bfa0ed1595a6a68681b9da8
parent6bf140acf44f4f95f82aa3b5582ffd4910c5457c (diff)
downloadATCD-8e46ca6a9e352331dabb0669c746d9671a582171.tar.gz
*** empty log message ***
-rw-r--r--TAO/tao/GIOP_Message_Base.cpp1
-rw-r--r--TAO/tao/GIOP_Message_Handler.cpp14
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;