diff options
Diffstat (limited to 'TAO/tao/Asynch_Invocation.cpp')
-rw-r--r-- | TAO/tao/Asynch_Invocation.cpp | 173 |
1 files changed, 0 insertions, 173 deletions
diff --git a/TAO/tao/Asynch_Invocation.cpp b/TAO/tao/Asynch_Invocation.cpp deleted file mode 100644 index f1a3eff31aa..00000000000 --- a/TAO/tao/Asynch_Invocation.cpp +++ /dev/null @@ -1,173 +0,0 @@ -// $Id$ - -#include "tao/Asynch_Invocation.h" - -#include "tao/Timeprobe.h" -#include "tao/Stub.h" -#include "tao/Principal.h" -#include "tao/Object_KeyC.h" -#include "tao/Transport_Mux_Strategy.h" -#include "tao/debug.h" - -#if !defined (__ACE_INLINE__) -# include "tao/Asynch_Invocation.i" -#endif /* ! __ACE_INLINE__ */ - -ACE_RCSID(tao, Asynch_Invocation, "$Id$") - -#if defined (ACE_ENABLE_TIMEPROBES) - -static const char *TAO_Asynch_Invocation_Timeprobe_Description[] = - { - "GIOP_Asynch_Invocation::invoke - start", - "GIOP_Asynch_Invocation::invoke - end", - - "GIOP_Asynch_Invocation::start - enter", - "GIOP_Asynch_Invocation::start - leave", - "GIOP_Asynch_Invocation::start - connect", - "GIOP_Asynch_Invocation::start - start_msg", - "GIOP_Asynch_Invocation::start - request_hdr" - }; - -enum - { - TAO_GIOP_ASYNCH_INVOCATION_INVOKE_START = 1100, - TAO_GIOP_ASYNCH_INVOCATION_INVOKE_END, - - TAO_GIOP_ASYNCH_INVOCATION_START_ENTER, - TAO_GIOP_ASYNCH_INVOCATION_START_LEAVE, - TAO_GIOP_ASYNCH_INVOCATION_START_CONNECT, - TAO_GIOP_ASYNCH_INVOCATION_START_START_MSG, - TAO_GIOP_ASYNCH_INVOCATION_START_REQUEST_HDR - }; - - -// Setup Timeprobes -ACE_TIMEPROBE_EVENT_DESCRIPTIONS (TAO_Asynch_Invocation_Timeprobe_Description, - TAO_GIOP_ASYNCH_INVOCATION_INVOKE_START); - -#endif /* ACE_ENABLE_TIMEPROBES */ - -#if defined (TAO_HAS_CORBA_MESSAGING) -#if defined (TAO_HAS_AMI_CALLBACK) || defined (TAO_HAS_AMI_POLLER) - -void -TAO_GIOP_Twoway_Asynch_Invocation::start (CORBA::Environment &ACE_TRY_ENV) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - this->TAO_GIOP_Invocation::start (ACE_TRY_ENV); - ACE_CHECK; - - this->transport_->start_request (this->orb_core_, - this->profile_, - this->out_stream_, - ACE_TRY_ENV); -} - -int -TAO_GIOP_Twoway_Asynch_Invocation::invoke (CORBA::Environment &ACE_TRY_ENV) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - TAO_FUNCTION_PP_TIMEPROBE (TAO_GIOP_ASYNCH_INVOCATION_INVOKE_START); - - return this->invoke_i (ACE_TRY_ENV); -} - - -int -TAO_GIOP_Twoway_Asynch_Invocation::invoke_i (CORBA::Environment &ACE_TRY_ENV) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - // Register a reply dispatcher for this Asynch_Invocation. Use the - // heap allocated reply dispatcher. - - int retval = - this->transport_->tms ()->bind_dispatcher (this->request_id_, - this->rd_); - if (retval == -1) - { - // @@ What is the right way to handle this error? - this->close_connection (); - ACE_THROW_RETURN (CORBA::INTERNAL (TAO_DEFAULT_MINOR_CODE, - CORBA::COMPLETED_NO), - TAO_INVOKE_EXCEPTION); - } - - // Just send the request, without trying to wait for the reply. - retval = TAO_GIOP_Invocation::invoke (1, - ACE_TRY_ENV); - ACE_CHECK_RETURN (retval); - - if (retval != TAO_INVOKE_OK) - return retval; - - // We do not wait for the reply. Let us return. - - return TAO_INVOKE_OK; -} - -#endif /* TAO_HAS_AMI_CALLBACK || TAO_HAS_AMI_POLLER */ -#endif /* TAO_HAS_CORBA_MESSAGING */ - -//************************************************************************** - -#if !defined (TAO_HAS_MINIMUM_CORBA) - -void -TAO_GIOP_DII_Deferred_Invocation::start (CORBA::Environment &ACE_TRY_ENV) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - this->TAO_GIOP_Invocation::start (ACE_TRY_ENV); - ACE_CHECK; - - this->transport_->start_request (this->orb_core_, - this->profile_, - this->out_stream_, - ACE_TRY_ENV); - ACE_CHECK; -} - -int -TAO_GIOP_DII_Deferred_Invocation::invoke (CORBA::Environment &ACE_TRY_ENV) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - TAO_FUNCTION_PP_TIMEPROBE (TAO_GIOP_ASYNCH_INVOCATION_INVOKE_START); - - return this->invoke_i (ACE_TRY_ENV); -} - - -int -TAO_GIOP_DII_Deferred_Invocation::invoke_i (CORBA::Environment &ACE_TRY_ENV) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - // Register a reply dispatcher for this Asynch_Invocation. Use the - // heap allocated reply dispatcher. - - int retval = - this->transport_->tms ()->bind_dispatcher (this->request_id_, - this->rd_); - if (retval == -1) - { - // @@ What is the right way to handle this error? - this->close_connection (); - ACE_THROW_RETURN (CORBA::INTERNAL (TAO_DEFAULT_MINOR_CODE, - CORBA::COMPLETED_NO), - TAO_INVOKE_EXCEPTION); - } - - // Just send the request, without trying to wait for the reply. - retval = TAO_GIOP_Invocation::invoke (1, - ACE_TRY_ENV); - ACE_CHECK_RETURN (retval); - - if (retval != TAO_INVOKE_OK) - return retval; - - // We do not wait for the reply. Let us return. - - return TAO_INVOKE_OK; -} - -#endif /* TAO_HAS_MINIMUM_CORBA */ - |