TAO/tao/RTCORBA/RT_Endpoint_Utils.cpp

   1 #include "tao/RTCORBA/RT_Endpoint_Utils.h"
   2 #include "tao/Profile_Transport_Resolver.h"
   3
   4 #if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
   5
   6 #include "tao/RTCORBA/RT_Endpoint_Selector_Factory.h"
   7 #include "tao/RTCORBA/RT_Invocation_Endpoint_Selectors.h"
   8
   9 #include "tao/RTCORBA/RT_Stub.h"
  10
  11 #include "tao/SystemException.h"
  12
  13 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  14
  15 CORBA::Policy_ptr
  16 TAO_RT_Endpoint_Utils::policy (TAO_Cached_Policy_Type type,
  17                                TAO::Profile_Transport_Resolver &r)
  18 {
  19   CORBA::Policy_ptr policy = CORBA::Policy::_nil ();
  20
  21   TAO_RT_Stub * const rt_stub =
  22     dynamic_cast<TAO_RT_Stub *> (r.stub ());
  23
  24   if (!rt_stub)
  25     throw CORBA::INTERNAL ();
  26
  27   try
  28     {
  29       policy = rt_stub->get_cached_policy (type);
  30     }
  31   catch (const ::CORBA::INV_POLICY&)
  32     {
  33       if (r.inconsistent_policies ())
  34         {
  35           CORBA::PolicyList *p = r.inconsistent_policies ();
  36           p->length (1);
  37           (*p)[0u] = rt_stub->TAO_Stub::get_cached_policy (type);
  38         }
  39
  40       throw;
  41     }
  42
  43   return policy;
  44 }
  45
  46 TAO_END_VERSIONED_NAMESPACE_DECL
  47
  48 #endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */