blob: d2b0c9bcfa2a90549c9cc06774f533515d091c65 (
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
57
58
59
60
61
62
|
// $Id$
#include "RT_POA_Initializer.h"
#include "RT_Servant_Dispatcher.h"
#include "RT_Policy_Validator.h"
#include "tao/PortableServer/Object_Adapter.h"
#include "tao/ORB_Core.h"
ACE_RCSID(tao, RT_POA_Initializer, "$Id$")
TAO_RT_POA_Initializer::~TAO_RT_POA_Initializer (void)
{
}
void
TAO_RT_POA_Initializer::register_hooks_impl (TAO_Object_Adapter &object_adapter,
CORBA::Environment &ACE_TRY_ENV)
{
// Create and register the RT servant dispatcher.
TAO_RT_Servant_Dispatcher *rt_servant_dispatcher;
ACE_NEW (rt_servant_dispatcher,
TAO_RT_Servant_Dispatcher);
object_adapter.servant_dispatcher (rt_servant_dispatcher);
// Create and add the RT policy validator.
TAO_POA_RT_Policy_Validator *rt_validator;
ACE_NEW (rt_validator,
TAO_POA_RT_Policy_Validator (&object_adapter.orb_core ()));
object_adapter.validator ().add_validator (rt_validator);
// Add the default RT policies to the list of default POA policies.
this->init_rt_default_policies (object_adapter.default_poa_policies (),
object_adapter.orb_core (),
ACE_TRY_ENV);
}
void
TAO_RT_POA_Initializer::init_rt_default_policies (TAO_POA_Policy_Set &policies,
TAO_ORB_Core &orb_core,
CORBA::Environment &ACE_TRY_ENV)
{
CORBA::Policy_var policy =
orb_core.get_cached_policy (TAO_CACHED_POLICY_PRIORITY_MODEL);
if (!CORBA::is_nil (policy.in ()))
{
policies.merge_policy (policy.in (), ACE_TRY_ENV);
ACE_CHECK;
}
CORBA::Policy_var protocol =
orb_core.get_cached_policy (TAO_CACHED_POLICY_RT_SERVER_PROTOCOL);
if (!CORBA::is_nil (protocol.in ()))
{
policies.merge_policy (protocol.in (), ACE_TRY_ENV);
ACE_CHECK;
}
}
|
