diff options
Diffstat (limited to 'trunk/TAO/tao/Remote_Invocation.cpp')
| -rw-r--r-- | trunk/TAO/tao/Remote_Invocation.cpp | 209 |
1 files changed, 209 insertions, 0 deletions
diff --git a/trunk/TAO/tao/Remote_Invocation.cpp b/trunk/TAO/tao/Remote_Invocation.cpp new file mode 100644 index 00000000000..417722db92b --- /dev/null +++ b/trunk/TAO/tao/Remote_Invocation.cpp @@ -0,0 +1,209 @@ +//$Id$ + +#include "tao/Remote_Invocation.h" +#include "tao/Profile.h" +#include "tao/Profile_Transport_Resolver.h" +#include "tao/Stub.h" +#include "tao/Transport.h" +#include "tao/Connection_Handler.h" +#include "tao/operation_details.h" +#include "tao/ORB_Core.h" +#include "tao/Protocols_Hooks.h" +#include "tao/debug.h" + +ACE_RCSID (tao, + Remote_Invocation, + "$Id$") + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +namespace TAO +{ + Remote_Invocation::Remote_Invocation ( + CORBA::Object_ptr otarget, + Profile_Transport_Resolver &resolver, + TAO_Operation_Details &detail, + bool response_expected) + : Invocation_Base (otarget, + resolver.object (), + resolver.stub (), + detail, + response_expected, + true /* request_is_remote */ ) + , resolver_ (resolver) + { + } + + void + Remote_Invocation::init_target_spec (TAO_Target_Specification &target_spec + ACE_ENV_ARG_DECL) + { + /** + * Mega hack for RTCORBA start. I don't think that + * PortableInterceptor would work here esp. for RTCORBA. PI needs + * to be improved to help our cause. + */ + this->resolver_.stub ()->orb_core ()->service_context_list ( + this->resolver_.stub (), + this->details_.request_service_context (), + 0 + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + /** + * Mega hack for RTCORBA END + */ + + TAO_Profile *pfile = this->resolver_.profile (); + + // Set the target specification mode + switch (pfile->addressing_mode ()) + { + case TAO_Target_Specification::Key_Addr: + target_spec.target_specifier (pfile->object_key ()); + break; + case TAO_Target_Specification::Profile_Addr: + { + IOP::TaggedProfile *tp = + pfile->create_tagged_profile (); + + if (tp) + { + target_spec.target_specifier (*tp); + } + } + break; + + case TAO_Target_Specification::Reference_Addr: + // We need to call the method seperately. If there is no + // IOP::IOR info, the call would create the info and return the + // index that we need. + CORBA::ULong index = 0; + IOP::IOR *ior_info = 0; + int const retval = + this->resolver_.stub ()->create_ior_info (ior_info, + index + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + if (retval == -1) + { + if (TAO_debug_level > 0) + { + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("TAO (%P|%t) - ") + ACE_TEXT ("Remote_Invocation::init_target_spec, ") + ACE_TEXT ("Error in finding index for ") + ACE_TEXT ("IOP::IOR \n"))); + } + + return; + } + + target_spec.target_specifier (*ior_info, + index); + break; + } + + + } + + void + Remote_Invocation::write_header (TAO_Target_Specification &spec, + TAO_OutputCDR &out_stream + ACE_ENV_ARG_DECL) + { + this->resolver_.transport ()->clear_translators (0, + &out_stream); + + // Send the request for the header + if (this->resolver_.transport ()->generate_request_header (this->details_, + spec, + out_stream) + == -1) + { + ACE_THROW (CORBA::MARSHAL ()); + } + + this->resolver_.transport ()->assign_translators (0, + &out_stream); + } + + void + Remote_Invocation::marshal_data (TAO_OutputCDR &out_stream + ACE_ENV_ARG_DECL) + { + if (this->details_.marshal_args (out_stream) == false) + { + ACE_THROW (CORBA::MARSHAL ()); + } + + return; + } + + Invocation_Status + Remote_Invocation::send_message (TAO_OutputCDR &cdr, + short message_semantics, + ACE_Time_Value *max_wait_time + ACE_ENV_ARG_DECL) + { + TAO_Protocols_Hooks *tph = + this->resolver_.stub ()->orb_core ()->get_protocols_hooks (); + + CORBA::Boolean set_client_network_priority = + tph->set_client_network_priority (this->resolver_.transport ()->tag (), + this->resolver_.stub () + ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (TAO_INVOKE_FAILURE); + + TAO_Connection_Handler *connection_handler = + this->resolver_.transport ()->connection_handler (); + + connection_handler->set_dscp_codepoint (set_client_network_priority); + + int const retval = + this->resolver_.transport ()->send_request ( + this->resolver_.stub (), + this->resolver_.stub ()->orb_core (), + cdr, + message_semantics, + max_wait_time); + + if (retval == -1) + { + if (errno == ETIME) + { + // We sent a message already and we haven't gotten a + // reply. Just throw TIMEOUT with *COMPLETED_MAYBE*. + ACE_THROW_RETURN ( + CORBA::TIMEOUT ( + CORBA::SystemException::_tao_minor_code ( + TAO_TIMEOUT_SEND_MINOR_CODE, + errno + ), + CORBA::COMPLETED_MAYBE + ), + TAO_INVOKE_FAILURE + ); + } + + if (TAO_debug_level > 2) + { + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("TAO (%P|%t) - ") + ACE_TEXT ("Remote_Invocation::send_message, ") + ACE_TEXT ("failure while sending message \n"))); + } + + // Close the transport and all the associated stuff along with + // it. + this->resolver_.transport ()->close_connection (); + this->resolver_.stub ()->reset_profiles (); + return TAO_INVOKE_RESTART; + } + + this->resolver_.stub ()->set_valid_profile (); + return TAO_INVOKE_SUCCESS; + } +} + +TAO_END_VERSIONED_NAMESPACE_DECL |