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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
|
#include "tao/PortableServer/IORInfo.h"
#include "tao/PortableServer/POA.h"
#include "tao/PolicyC.h"
#include "tao/IOPC.h"
#include "tao/ORB_Constants.h"
ACE_RCSID (PortableServer,
IORInfo,
"$Id$")
#if !defined (__ACE_INLINE__)
# include "IORInfo.inl"
#endif /* __ACE_INLINE__ */
TAO_IORInfo::TAO_IORInfo (TAO_POA *poa)
: poa_ (poa),
components_established_ (0)
{
}
TAO_IORInfo::~TAO_IORInfo (void)
{
}
CORBA::Policy_ptr
TAO_IORInfo::get_effective_policy (CORBA::PolicyType type
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (CORBA::Policy::_nil ());
TAO_POA_Policy_Set &policies =
this->poa_->policies ();
// @@ This brain damaged implementation exists due to the fact
// neither TAO_POA nor TAO_POA_Policy_Set exposes any methods
// useful for retrieving a given Policy in the POA's PolicyList.
// So, I use the lame interfaces for now.
// -Ossama
const CORBA::ULong num_policies = policies.num_policies ();
for (CORBA::ULong i = 0; i < num_policies; ++i)
{
// @@ This incurs at least two locks per loop iteration due
// to the reference counting found within the policy
// object reference!!!
CORBA::Policy_var policy = policies.get_policy_by_index (i);
CORBA::PolicyType ptype =
policy->policy_type (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (CORBA::Policy::_nil ());
if (ptype == type)
return policy._retn ();
}
// TODO: Now check the global ORB policies.
// ........
// No policy matching the given PolicyType was found.
ACE_THROW_RETURN (CORBA::INV_POLICY (CORBA::OMGVMCID | 3,
CORBA::COMPLETED_NO),
CORBA::Policy::_nil ());
}
void
TAO_IORInfo::add_ior_component (const IOP::TaggedComponent &component
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
if (this->components_established_)
ACE_THROW (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14,
CORBA::COMPLETED_NO));
// Add the given tagged component to all profiles.
this->poa_->save_ior_component (component
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
void
TAO_IORInfo::add_ior_component_to_profile (
const IOP::TaggedComponent &component,
IOP::ProfileId profile_id
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
if (this->components_established_)
ACE_THROW (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14,
CORBA::COMPLETED_NO));
this->poa_->save_ior_component_and_profile_id (component,
profile_id
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
PortableInterceptor::AdapterManagerId
TAO_IORInfo::manager_id (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
return this->poa_->get_manager_id (ACE_ENV_SINGLE_ARG_PARAMETER);
}
PortableInterceptor::AdapterState
TAO_IORInfo::state (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (PortableInterceptor::NON_EXISTENT);
return this->poa_->get_adapter_state (ACE_ENV_SINGLE_ARG_PARAMETER);
}
PortableInterceptor::ObjectReferenceTemplate *
TAO_IORInfo::adapter_template (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
// Return the Object Reference Template whenever an IOR Interceptor
// is invoked. Its value is the template created for the adapter
// policies and the IOR Interceptor calls to add_ior_component and
// add_ior_component_to_profile. It's a const value and its value
// never changes.
PortableInterceptor::ObjectReferenceTemplate *adapter_template =
this->poa_->get_adapter_template ();
if (adapter_template == 0)
{
ACE_THROW_RETURN (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14,
CORBA::COMPLETED_NO),
0);
}
CORBA::add_ref (adapter_template);
return adapter_template;
}
PortableInterceptor::ObjectReferenceFactory *
TAO_IORInfo::current_factory (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (0);
// Return the current_factory that is used to create the object
// references by the adapter. Though initially, its value is the
// same as the adapter_template, unlike adapter_template, its value
// can be changed. The value of the current_factory can be changed
// only during the call to components_established method.
PortableInterceptor::ObjectReferenceFactory *adapter_factory =
this->poa_->get_obj_ref_factory ();
if (adapter_factory == 0)
{
ACE_THROW_RETURN (CORBA::BAD_INV_ORDER (CORBA::OMGVMCID | 14,
CORBA::COMPLETED_NO),
0);
}
CORBA::add_ref (adapter_factory);
return adapter_factory;
}
void
TAO_IORInfo::current_factory (
PortableInterceptor::ObjectReferenceFactory * current_factory
ACE_ENV_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->check_validity (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
this->poa_->set_obj_ref_factory (current_factory
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
void
TAO_IORInfo::check_validity (ACE_ENV_SINGLE_ARG_DECL)
{
if (this->poa_ == 0)
{
// Although not defined by the spec, duplicate the behavior used
// by the ORBInitInfo object once CORBA::ORB_init() has been
// called. Specifically, the IORInfo object is no longer valid
// once the POA has invoked all IORInterceptor interception
// points. This also prevents memory access violations from
// occuring if the POA is destroyed before this IORInfo object.
ACE_THROW (CORBA::OBJECT_NOT_EXIST (TAO_DEFAULT_MINOR_CODE,
CORBA::COMPLETED_NO));
}
}
|
