diff options
Diffstat (limited to 'TAO/tao/DynamicInterface/DII_Invocation_Adapter.cpp')
| -rw-r--r-- | TAO/tao/DynamicInterface/DII_Invocation_Adapter.cpp | 216 |
1 files changed, 216 insertions, 0 deletions
diff --git a/TAO/tao/DynamicInterface/DII_Invocation_Adapter.cpp b/TAO/tao/DynamicInterface/DII_Invocation_Adapter.cpp new file mode 100644 index 00000000000..76922e3d88d --- /dev/null +++ b/TAO/tao/DynamicInterface/DII_Invocation_Adapter.cpp @@ -0,0 +1,216 @@ +//$Id$ +#include "tao/DynamicInterface/DII_Invocation_Adapter.h" +#include "tao/DynamicInterface/DII_Invocation.h" +#include "tao/DynamicInterface/DII_Reply_Dispatcher.h" + +#include "tao/Exception.h" +#include "tao/ORB_Constants.h" +#include "tao/Profile_Transport_Resolver.h" +#include "tao/Transport.h" +#include "tao/Transport.h" +#include "tao/Pluggable_Messaging.h" +#include "tao/SystemException.h" +#include "tao/DynamicInterface/Request.h" + +#include "ace/os_include/os_errno.h" + +ACE_RCSID (tao, + Invocation_Adapter, + "$Id$") + + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +namespace TAO +{ + DII_Invocation_Adapter::DII_Invocation_Adapter (CORBA::Object *target, + Argument **args, + int arg_number, + const char *operation, + size_t op_len, + CORBA::ExceptionList *excp, + CORBA::Request *r, + Invocation_Mode mode) + + : Invocation_Adapter (target, + args, + arg_number, + operation, + op_len, + 0, // Collocation Proxy broker pointer + TAO_TWOWAY_INVOCATION, + mode, + true) // is a dii request + , exception_list_ (excp) + , request_ (r) + { + } + + DII_Invocation_Adapter::~DII_Invocation_Adapter (void) + { + } + + Invocation_Status + DII_Invocation_Adapter::invoke_twoway ( + TAO_Operation_Details &op, + CORBA::Object_var &effective_target, + Profile_Transport_Resolver &r, + ACE_Time_Value *&max_wait_time + ) + { + // Simple sanity check + if (this->mode_ != TAO_DII_INVOCATION || + this->type_ != TAO_TWOWAY_INVOCATION) + { + throw ::CORBA::INTERNAL ( + CORBA::SystemException::_tao_minor_code ( + TAO::VMCID, + EINVAL), + CORBA::COMPLETED_NO); + } + + r.transport ()->messaging_object ()->out_stream ().reset_byte_order (request_->_tao_byte_order ()); + + TAO::DII_Invocation synch (this->target_, + r, + op, + this->exception_list_, + this->request_); + + + Invocation_Status status = synch.remote_invocation (max_wait_time); + + if (status == TAO_INVOKE_RESTART && synch.is_forwarded ()) + { + effective_target = synch.steal_forwarded_reference (); + +#if TAO_HAS_INTERCEPTORS == 1 + const CORBA::Boolean permanent_forward = + (synch.reply_status() == TAO_PLUGGABLE_MESSAGE_LOCATION_FORWARD_PERM); +#else + const CORBA::Boolean permanent_forward = false; +#endif + this->object_forwarded (effective_target, + r.stub (), + permanent_forward); + } + return status; + } + + //================================================================ + DII_Deferred_Invocation_Adapter::DII_Deferred_Invocation_Adapter ( + CORBA::Object *target, + Argument **args, + int arg_number, + const char *operation, + size_t op_len, + Collocation_Proxy_Broker *b, + TAO_ORB_Core *oc, + CORBA::Request *req, + Invocation_Mode mode) + : Invocation_Adapter (target, + args, + arg_number, + operation, + op_len, + b, + TAO_TWOWAY_INVOCATION, + mode, + true) // is a dii request + , request_ (req) + , rd_ (0) + , orb_core_ (oc) + { + } + + void + DII_Deferred_Invocation_Adapter::invoke ( + TAO::Exception_Data *ex, + unsigned long ex_count) + { + // New reply dispatcher on the heap, because we will go out of + // scope and hand over the reply dispatcher to the ORB. + // So this->rd_ is 0, because we do not need to + // hold a pointer to it. + ACE_NEW_THROW_EX (this->rd_, + TAO_DII_Deferred_Reply_Dispatcher (this->request_, + this->orb_core_), + CORBA::NO_MEMORY ()); + + Invocation_Adapter::invoke (ex, ex_count); + } + + Invocation_Status + DII_Deferred_Invocation_Adapter::invoke_twoway ( + TAO_Operation_Details &op, + CORBA::Object_var &effective_target, + Profile_Transport_Resolver &r, + ACE_Time_Value *&max_wait_time) + { + // Simple sanity check + if (this->mode_ != TAO_DII_DEFERRED_INVOCATION || + this->type_ != TAO_TWOWAY_INVOCATION) + { + throw ::CORBA::INTERNAL ( + CORBA::SystemException::_tao_minor_code ( + TAO::VMCID, + EINVAL), + CORBA::COMPLETED_NO); + } + + r.transport ()->messaging_object ()->out_stream ().reset_byte_order (request_->_tao_byte_order ()); + TAO::DII_Deferred_Invocation synch ( + this->target_, + r, + op, + this->rd_, + this->request_); + + r.transport ()->messaging_object ()->out_stream ().reset_byte_order (request_->_tao_byte_order ()); + + Invocation_Status status = synch.remote_invocation (max_wait_time); + + if (status == TAO_INVOKE_RESTART) + { + effective_target = synch.steal_forwarded_reference (); + } + + return status; + } + + DII_Asynch_Invocation_Adapter::DII_Asynch_Invocation_Adapter ( + CORBA::Object *target, + Argument **args, + int arg_count, + const char *operation, + int op_len, + CORBA::Request *req, + TAO::Invocation_Mode mode) + : DII_Invocation_Adapter (target, + args, + arg_count, + operation, + op_len, + 0, + req, + mode) + { + } + + void + DII_Asynch_Invocation_Adapter::invoke_reply_handler (Messaging::ReplyHandler_ptr) + { + } + + Invocation_Status + DII_Asynch_Invocation_Adapter::invoke_twoway ( + TAO_Operation_Details &, + CORBA::Object_var &, + Profile_Transport_Resolver &, + ACE_Time_Value *&) + { + return TAO_INVOKE_FAILURE; + } + +} // End namespace TAO +TAO_END_VERSIONED_NAMESPACE_DECL |