diff options
Diffstat (limited to 'TAO/orbsvcs/ImplRepo_Service/Forwarder.cpp')
| -rw-r--r-- | TAO/orbsvcs/ImplRepo_Service/Forwarder.cpp | 162 |
1 files changed, 162 insertions, 0 deletions
diff --git a/TAO/orbsvcs/ImplRepo_Service/Forwarder.cpp b/TAO/orbsvcs/ImplRepo_Service/Forwarder.cpp new file mode 100644 index 00000000000..7337af511e9 --- /dev/null +++ b/TAO/orbsvcs/ImplRepo_Service/Forwarder.cpp @@ -0,0 +1,162 @@ +//============================================================================= +/** +* @file Forwarder.cpp +* +* $Id$ +* +* @brief Definition of ImR_Forwarder +* +* @author Darrell Brunsch <brunsch@cs.wustl.edu> +* @author Priyanka Gontla <pgontla@doc.ece.uci.edu> +*/ +//============================================================================= + +#include "Forwarder.h" +#include "ImR_Locator_i.h" + +#include "tao/ORB.h" +#include "tao/Object_KeyC.h" +#include "tao/ORB_Constants.h" + +#include "tao/PortableServer/PortableServer.h" +#include "tao/PortableServer/POA_Current_Impl.h" +#include "tao/PortableServer/POA_Current.h" + +/** +* This constructor takes in orb and ImR_Locator_i pointers to store for later +* use. It also grabs a reference to the POACurrent object for use in +* preinvoke. +*/ +ImR_Forwarder::ImR_Forwarder (ImR_Locator_i& imr_impl) + : locator_ (imr_impl) +{ +} + +void +ImR_Forwarder::init (CORBA::ORB_ptr orb ACE_ENV_ARG_DECL) +{ + ACE_ASSERT (! CORBA::is_nil(orb)); + this->orb_ = orb; + ACE_TRY_NEW_ENV + { + CORBA::Object_var tmp = + orb->resolve_initial_references ("POACurrent" ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + this->poa_current_var_ = + PortableServer::Current::_narrow (tmp.in () ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + } + ACE_CATCHANY + { + ACE_DEBUG ((LM_DEBUG, "ImR_Forwarder::init() Exception ignored.\n")); + } + ACE_ENDTRY; + ACE_CHECK; + ACE_ASSERT (!CORBA::is_nil (this->poa_current_var_.in ())); +} + +/** +* We figure out the intended recipient from the POA name. After activating +* the server, we throw a forwarding exception to the correct server. +* +* The big complicated thing here is that we have to create the forwarding +* ior based on what we already have. So we combine the endpoint received +* from activate_server_i and append the objectid from the request to it. +*/ +PortableServer::Servant +ImR_Forwarder::preinvoke (const PortableServer::ObjectId &, + PortableServer::POA_ptr poa, + const char *, + PortableServer::ServantLocator::Cookie & + ACE_ENV_ARG_DECL) + ACE_THROW_SPEC ((CORBA::SystemException, PortableServer::ForwardRequest)) +{ + ACE_ASSERT (! CORBA::is_nil(poa)); + CORBA::Object_var forward_obj; + + ACE_TRY + { + CORBA::String_var server_name = poa->the_name(); + + if (locator_.debug() > 1) + ACE_DEBUG ((LM_DEBUG, "ImR: Activating server <%s>.\n", server_name.in())); + + // The activator stores a partial ior with each server. We can + // just tack on the current ObjectKey to get a valid ior for + // the desired server. + CORBA::String_var pior = locator_.activate_server_by_name (server_name.in (), false ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + ACE_CString ior = pior.in (); + + // Check that the returned ior is the expected partial ior with + // missing ObjectKey. + if (ior.find ("corbaloc:") != 0 || ior[ior.length () - 1] != '/') + { + ACE_ERROR ((LM_ERROR, "ImR_Forwarder::preinvoke () Invalid corbaloc ior.\n\t<%s>\n", ior.c_str())); + ACE_TRY_THROW (CORBA::OBJECT_NOT_EXIST ( + CORBA::SystemException::_tao_minor_code (TAO_IMPLREPO_MINOR_CODE, 0), + CORBA::COMPLETED_NO)); + } + + CORBA::String_var key_str; + // Unlike POA Current, this implementation cannot be cached. + TAO::Portable_Server::POA_Current* tao_current = + dynamic_cast <TAO::Portable_Server::POA_Current*> (this->poa_current_var_.in ()); + + ACE_ASSERT(tao_current != 0); + TAO::Portable_Server::POA_Current_Impl* impl = tao_current->implementation (); + TAO::ObjectKey::encode_sequence_to_string (key_str.out (), impl->object_key ()); + + ior += key_str.in(); + + if (locator_.debug() > 0) + ACE_DEBUG ((LM_DEBUG, "ImR: Forwarding invocation on <%s> to <%s>\n", server_name.in(), ior.c_str())); + + forward_obj = + this->orb_->string_to_object (ior.c_str () ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + } + ACE_CATCH (ImplementationRepository::CannotActivate, ex) + { + ACE_TRY_THROW (CORBA::TRANSIENT ( + CORBA::SystemException::_tao_minor_code (TAO_IMPLREPO_MINOR_CODE, 0), + CORBA::COMPLETED_NO)); + } + ACE_CATCH (ImplementationRepository::NotFound, ex) + { + ACE_TRY_THROW (CORBA::TRANSIENT ( + CORBA::SystemException::_tao_minor_code (TAO_IMPLREPO_MINOR_CODE, 0), + CORBA::COMPLETED_NO)); + } + ACE_CATCHANY + { + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Forwarder"); + ACE_TRY_THROW (CORBA::TRANSIENT ( + CORBA::SystemException::_tao_minor_code (TAO_IMPLREPO_MINOR_CODE, 0), + CORBA::COMPLETED_NO)); + } + ACE_ENDTRY; + ACE_CHECK_RETURN (0); + + if (!CORBA::is_nil (forward_obj.in ())) + ACE_THROW_RETURN (PortableServer::ForwardRequest (forward_obj.in ()), 0); + + ACE_ERROR ((LM_ERROR, "Error: Forward_to reference is nil.\n")); + ACE_THROW_RETURN (CORBA::OBJECT_NOT_EXIST ( + CORBA::SystemException::_tao_minor_code (TAO_IMPLREPO_MINOR_CODE, 0), + CORBA::COMPLETED_NO), 0); +} + +void +ImR_Forwarder::postinvoke (const PortableServer::ObjectId &, + PortableServer::POA_ptr, + const char *, + PortableServer::ServantLocator::Cookie, + PortableServer::Servant + ACE_ENV_ARG_DECL_NOT_USED + ) ACE_THROW_SPEC ((CORBA::SystemException)) +{ +} + |