*** empty log message ***

3 files changed, 47 insertions, 11 deletions

diff --git a/TAO/tao/Collocated_Invocation.cpp b/TAO/tao/Collocated_Invocation.cpp
index 1e6941a408e..6c3f17b6f1b 100644
--- a/TAO/tao/Collocated_Invocation.cpp
+++ b/TAO/tao/Collocated_Invocation.cpp
@@ -59,7 +59,7 @@ namespace TAO
 
             dispatcher->dispatch (orb_core,
                                   request,
-                                  this->forwarded_to_.out ());
+                                  this->forwarded_to_.out ()
                                   ACE_ENV_ARG_PARAMETER);
             ACE_TRY_CHECK;
           }
diff --git a/TAO/tao/TAO_Server_Request.cpp b/TAO/tao/TAO_Server_Request.cpp
index 879a332ccfc..472a07245b7 100644
--- a/TAO/tao/TAO_Server_Request.cpp
+++ b/TAO/tao/TAO_Server_Request.cpp
@@ -51,16 +51,16 @@ TAO_ServerRequest::TAO_ServerRequest (TAO_Pluggable_Messaging *mesg_base,
     // transport already duplicated in
     // TAO_Transport::process_parsed_messages ()
     transport_(transport),
-    response_expected_ (0),
-    deferred_reply_ (0),
-    sync_with_server_ (0),
+    response_expected_ (false),
+    deferred_reply_ (false),
+    sync_with_server_ (false),
     // @@ We shouldn't be using GIOP specific types here. Need to be revisited.
     exception_type_ (TAO_GIOP_NO_EXCEPTION),
     orb_core_ (orb_core),
     request_id_ (0),
     profile_ (orb_core),
     requesting_principal_ (0),
-    is_dsi_ (0),
+    is_dsi_ (false),
     dsi_nvlist_align_ (0),
     argument_flag_ (1)
 #if TAO_HAS_INTERCEPTORS == 1
@@ -94,15 +94,15 @@ TAO_ServerRequest::TAO_ServerRequest (TAO_Pluggable_Messaging *mesg_base,
     transport_ (transport),
     response_expected_ (response_expected),
     deferred_reply_ (deferred_reply),
-    sync_with_server_ (0),
+    sync_with_server_ (false),
     exception_type_ (TAO_GIOP_NO_EXCEPTION),
     orb_core_ (orb_core),
     request_id_ (request_id),
     profile_ (orb_core),
     requesting_principal_ (0),
-    is_dsi_ (0),
+    is_dsi_ (false),
     dsi_nvlist_align_ (0),
-    argument_flag_ (1)
+    argument_flag_ (true)
 #if TAO_HAS_INTERCEPTORS == 1
   , interceptor_count_ (0)
   , rs_pi_current_ ()
@@ -113,6 +113,37 @@ TAO_ServerRequest::TAO_ServerRequest (TAO_Pluggable_Messaging *mesg_base,
   parse_error = 0;
 }
 
+// Constructor used Thru-POA collocation code.
+TAO_ServerRequest::TAO_ServerRequest (TAO_ORB_Core * orb_core,
+                                      TAO_Operation_Details const & details,
+                                      CORBA::Object_ptr target)
+  : mesg_base_ (0),
+    operation_ (details->opname ()),
+    incoming_ (0),
+    outgoing_ (0),
+    transport_ (0),
+    response_expected_ (details.response_flags () == TAO_TWOWAY_RESPONSE_FLAG
+                        || details.response_flags () == static_cast<CORBA::Octet> (Messaging::SYNC_WITH_SERVER)
+                        || details.response_flags () == static_cast<CORBA::Octet> (Messaging::SYNC_WITH_TARGET)),
+    deferred_reply_ (false),
+    sync_with_server_ (details.response_flags () == static_cast<CORBA::Octet> (Messaging::SYNC_WITH_SERVER)),
+    exception_type_ (TAO_GIOP_NO_EXCEPTION),
+    orb_core_ (orb_core),
+    request_id_ (0),
+    profile_ (orb_core),
+    requesting_principal_ (0),
+    is_dsi_ (false),
+    dsi_nvlist_align_ (0),
+    argument_flag_ (false)
+#if TAO_HAS_INTERCEPTORS == 1
+  , interceptor_count_ (0)
+  , rs_pi_current_ ()
+  , result_seq_ (0)
+#endif  /* TAO_HAS_INTERCEPTORS == 1 */
+{
+  this->profile_.object_key (target->_stubobj ()->object_key ());
+}
+
 TAO_ServerRequest::~TAO_ServerRequest (void)
 {
 }
@@ -134,9 +165,9 @@ TAO_ServerRequest::init_reply (void)
   // pluggable_messaging_interface. One point to be noted however is
   // that, it was the pluggable_messaging classes who created us and
   // delegated us to do work on its behalf. But we would be calling
-  // back. As we dont have a LOCK or any such things we can call
+  // back. As we don't have a LOCK or any such things we can call
   // pluggable_messaging guys again. We would be on the same thread of
-  // invocation. So *theoratically* there should not be a problem.
+  // invocation. So *theoretically* there should not be a problem.
   reply_params.request_id_ = this->request_id_;
   reply_params.is_dsi_ = this->is_dsi_;
   reply_params.dsi_nvlist_align_ = this->dsi_nvlist_align_;
@@ -180,7 +211,7 @@ TAO_ServerRequest::init_reply (void)
                       ACE_TEXT ("marshal encoding forwarded objref failed\n")));
         }
     }
-  this->transport_->assign_translators (0,this->outgoing_);
+  this->transport_->assign_translators (0, this->outgoing_);
 }
 
 void
diff --git a/TAO/tao/TAO_Server_Request.h b/TAO/tao/TAO_Server_Request.h
index 8796f78d207..9a7b7f1c0b6 100644
--- a/TAO/tao/TAO_Server_Request.h
+++ b/TAO/tao/TAO_Server_Request.h
@@ -88,6 +88,11 @@ public:
                      TAO_ORB_Core *orb_core,
                      int &parse_error);
 
+  /// Constructor used by thru-POA collocated invocation path.
+  TAO_ServerRequest (TAO_ORB_Core * orb_core,
+                     TAO_Operation_Details const & details,
+                     CORBA::Object_ptr target);
+
   /// Destructor.
   virtual ~TAO_ServerRequest (void);