blob: 841c73bc6dc345dc1f4b5e3893efbb4cd74460ef (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
#include "tao/RTCORBA/RT_Endpoint_Utils.h"
#include "tao/Profile_Transport_Resolver.h"
#if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
#include "tao/RTCORBA/RT_Endpoint_Selector_Factory.h"
#include "tao/RTCORBA/RT_Invocation_Endpoint_Selectors.h"
#include "tao/RTCORBA/RT_Stub.h"
ACE_RCSID (RTCORBA,
RT_Endpoint_Utils,
"$Id$")
// ****************************************************************
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
CORBA::Policy *
TAO_RT_Endpoint_Utils::policy (TAO_Cached_Policy_Type type,
TAO::Profile_Transport_Resolver &r
ACE_ENV_ARG_DECL)
{
CORBA::Policy *policy = CORBA::Policy::_nil ();
TAO_RT_Stub *rt_stub = dynamic_cast<TAO_RT_Stub *> (r.stub ());
ACE_TRY
{
policy =
rt_stub->get_cached_policy (type
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCH (CORBA::INV_POLICY, ex)
{
if (r.inconsistent_policies ())
{
CORBA::PolicyList *p = r.inconsistent_policies ();
p->length (1);
(*p)[0u] = rt_stub->TAO_Stub::get_cached_policy (type
ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_RE_THROW;
}
ACE_ENDTRY;
ACE_CHECK_RETURN (CORBA::Policy::_nil ());
return policy;
}
TAO_END_VERSIONED_NAMESPACE_DECL
#endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */
|
