TAO_DynamicImplementation Class Reference

Base class for DSI. More...

#include <Dynamic_Implementation.h>

List of all members.

Public Member Functions
virtual void	invoke (CORBA::ServerRequest_ptr request)=0
virtual CORBA::RepositoryId	_primary_interface (const PortableServer::ObjectId &oid, PortableServer::POA_ptr poa)=0
virtual CORBA::Boolean	_is_a (const char *logical_type_id)
	Local implementation of the CORBA::Object::_is_a method.
CORBA::Object_ptr	_this (void)
	Returns a CORBA::Object_ptr for the target object.
virtual CORBA::InterfaceDef_ptr	_get_interface (void)
	Query the Interface Repository for the interface definition.
Protected Member Functions
virtual const char *	_interface_repository_id (void) const
	Return 0. Should never be used.
virtual void *	_downcast (const char *repository_id)
	Simply returns "this".
virtual TAO_Stub *	_create_stub (void)
	This is an auxiliary method for _this() and _narrow().
virtual void	_dispatch (TAO_ServerRequest &request, void *context)
	Turns around and calls invoke.
Private Member Functions
CORBA::RepositoryId	get_id_from_primary_interface (void)
	Encapsulates code common to _is_a(), _get_interface() and _create_stub().

---

Detailed Description

Base class for DSI.

It is expected that the <invoke> and <_primary_interface> methods will be only invoked by the POA in the context of serving a CORBA request. Invoking this method in other circumstances may lead to unpredictable results.

Definition at line 51 of file Dynamic_Implementation.h.

---

Member Function Documentation

TAO_Stub * TAO_DynamicImplementation::_create_stub

(

void

)

[protected, virtual]

This is an auxiliary method for _this() and _narrow().

Definition at line 85 of file Dynamic_Implementation.cpp.

References _primary_interface(), TAO_TSS_Resources::instance(), and TAO_TSS_Resources::poa_current_impl_.

Referenced by _this().

{
  // If DynamicImplementation::_this() is invoked outside of the
  // context of a request invocation on a target object being served
  // by the DSI servant, it raises the PortableServer::WrongPolicy
  // exception. See the CORBA C++ mapping, section 1.38.3.
  TAO::Portable_Server::POA_Current_Impl *poa_current_impl =
    static_cast <TAO::Portable_Server::POA_Current_Impl *>
                     (TAO_TSS_Resources::instance ()->poa_current_impl_);

  if (poa_current_impl == 0
      || this != poa_current_impl->servant ())
    {
      throw PortableServer::POA::WrongPolicy ();
    }

  PortableServer::POA_var poa =
    poa_current_impl->get_POA ();

  CORBA::PolicyList_var client_exposed_policies =
    poa_current_impl->poa ()->client_exposed_policies (
        poa_current_impl->priority ());

  CORBA::RepositoryId_var pinterface =
    this->_primary_interface (poa_current_impl->object_id (), poa.in ());

  return
    poa_current_impl->poa ()->key_to_stub (poa_current_impl->object_key (),
                                           pinterface.in (),
                                           poa_current_impl->priority ());
}

void TAO_DynamicImplementation::_dispatch	(	TAO_ServerRequest &	request,
		void *	context
	)			[protected, virtual]

Turns around and calls invoke.

Definition at line 118 of file Dynamic_Implementation.cpp.

References ACE_NEW, CORBA::ServerRequest::dsi_marshal(), TAO_ServerRequest::init_reply(), invoke(), TAO_ServerRequest::is_forwarded(), release(), TAO_ServerRequest::response_expected(), TAO_ServerRequest::send_no_exception_reply(), TAO_ServerRequest::sync_with_server(), and TAO_ServerRequest::tao_send_reply().

{
  // No need to do any of this if the client isn't waiting.
  if (request.response_expected ())
    {
      if (request.is_forwarded ())
        {
          request.init_reply ();
          request.tao_send_reply ();

          // No need to invoke in this case.
          return;
        }
      else if (request.sync_with_server ())
        {
          // The last line before the call to this function
          // was an ACE_CHECK_RETURN, so if we're here, we
          // know there is no exception so far, and that's all
          // a SYNC_WITH_SERVER client request cares about.
          request.send_no_exception_reply ();
        }
    }

  // Create DSI request object.
  CORBA::ServerRequest *dsi_request = 0;
  ACE_NEW (dsi_request,
           CORBA::ServerRequest (request));

  try
    {
      // Delegate to user.
      this->invoke (dsi_request);

      // Only if the client is waiting.
      if (request.response_expected () && !request.sync_with_server ())
        {
          dsi_request->dsi_marshal ();
        }
    }
  catch (::CORBA::Exception& ex)
    {
      // Only if the client is waiting.
      if (request.response_expected () && !request.sync_with_server ())
        {
          if (request.collocated ()
               && request.operation_details ()->cac () != 0)
            {
              // If we have a cac it will handle the exception and no
              // need to do any further processing
              request.operation_details ()->cac ()->handle_corba_exception (
                request, &ex);
              return;
            }
          else
            request.tao_send_reply_exception (ex);
        }
    }

  ::CORBA::release (dsi_request);
}

void * TAO_DynamicImplementation::_downcast

(

const char *

repository_id

)

[protected, virtual]

Simply returns "this".

Definition at line 78 of file Dynamic_Implementation.cpp.

{
  // Don't know enough to do better.
  return this;
}

CORBA::InterfaceDef_ptr TAO_DynamicImplementation::_get_interface

(

void

)

[virtual]

Query the Interface Repository for the interface definition.

Definition at line 52 of file Dynamic_Implementation.cpp.

References get_id_from_primary_interface(), TAO_IFR_Client_Adapter::get_interface(), TAO_ORB_Core::ifr_client_adapter_name(), ACE_Dynamic_Service< TYPE >::instance(), and TAO_ORB_Core_instance().

{
  TAO_IFR_Client_Adapter *adapter =
    ACE_Dynamic_Service<TAO_IFR_Client_Adapter>::instance (
        TAO_ORB_Core::ifr_client_adapter_name ());

  if (adapter == 0)
    {
      throw ::CORBA::INTF_REPOS ();
    }

  CORBA::RepositoryId_var id = this->get_id_from_primary_interface ();

  // This doesn't take multiple ORBs into account, but it's being
  // used only to resolve the IFR, so we should be ok.
  return adapter->get_interface (TAO_ORB_Core_instance ()->orb (), id.in ());
}

const char * TAO_DynamicImplementation::_interface_repository_id

(

void

)

const [protected, virtual]

Return 0. Should never be used.

Definition at line 71 of file Dynamic_Implementation.cpp.

{
  // This should never be called.
  return 0;
}

TAO_BEGIN_VERSIONED_NAMESPACE_DECL CORBA::Boolean TAO_DynamicImplementation::_is_a

(

const char *

logical_type_id

)

[virtual]

Local implementation of the CORBA::Object::_is_a method.

Definition at line 24 of file Dynamic_Implementation.cpp.

References get_id_from_primary_interface(), and ACE_OS::strcmp().

{
  CORBA::RepositoryId_var id = this->get_id_from_primary_interface ();

  return ACE_OS::strcmp (logical_type_id, id.in ()) == 0;
}

virtual CORBA::RepositoryId TAO_DynamicImplementation::_primary_interface	(	const PortableServer::ObjectId &	oid,
		PortableServer::POA_ptr	poa
	)			[pure virtual]

The _primary_interface() method receives an ObjectId value and a POA_ptr as input parameters and returns a valid RepositoryId representing the most-derived interface for that oid.

Referenced by _create_stub(), and get_id_from_primary_interface().

CORBA::Object_ptr TAO_DynamicImplementation::_this

(

void

)

Returns a CORBA::Object_ptr for the target object.

Definition at line 32 of file Dynamic_Implementation.cpp.

References _create_stub(), CORBA::Object::_nil(), and ACE_NEW_RETURN.

{
  // The _this() function returns a CORBA::Object_ptr for the target
  // object. Unlike _this() for static skeletons, its return type is
  // not interface-specific because a DSI servant may very well
  // incarnate multiple CORBA objects of different types.
  TAO_Stub *stub = this->_create_stub ();

  // Create a object.
  CORBA::Object_ptr retval = CORBA::Object_ptr ();
  ACE_NEW_RETURN (retval,
                  CORBA::Object (stub,
                                 1,
                                 this),
                  CORBA::Object::_nil ());

  return retval;
}

CORBA::RepositoryId TAO_DynamicImplementation::get_id_from_primary_interface

(

void

)

[private]

Encapsulates code common to _is_a(), _get_interface() and _create_stub().

Definition at line 181 of file Dynamic_Implementation.cpp.

References _primary_interface(), TAO_TSS_Resources::instance(), and TAO_TSS_Resources::poa_current_impl_.

Referenced by _get_interface(), and _is_a().

{
  // If this method is called outside of the
  // context of a request invocation on a target object being served
  // by the DSI servant, it raises the PortableServer::WrongPolicy
  // exception. See the CORBA C++ mapping, section 1.38.3.
  TAO::Portable_Server::POA_Current_Impl *poa_current_impl =
    static_cast <TAO::Portable_Server::POA_Current_Impl *>
                     (TAO_TSS_Resources::instance ()->poa_current_impl_);

  if (poa_current_impl == 0
      || this != poa_current_impl->servant ())
    {
      throw PortableServer::POA::WrongPolicy ();
    }

  PortableServer::POA_var poa = poa_current_impl->get_POA ();

  return this->_primary_interface (poa_current_impl->object_id (), poa.in ());
}

virtual void TAO_DynamicImplementation::invoke

(

CORBA::ServerRequest_ptr

request

)

[pure virtual]

The invoke() method receives requests issued to any CORBA object incarnated by the DSI servant and performs the processing necessary to execute the request.

Referenced by _dispatch().

---

The documentation for this class was generated from the following files:

• Dynamic_Implementation.h
• Dynamic_Implementation.cpp

---