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
|
// -*- C++ -*-
// $Id$
#include "tao/EndpointPolicy/Endpoint_Acceptor_Filter.h"
#include "tao/EndpointPolicy/EndpointPolicyC.h"
#include "tao/EndpointPolicy/Endpoint_Value_Impl.h"
#include "tao/Transport_Acceptor.h"
#include "tao/MProfile.h"
#include "tao/Profile.h"
#include "tao/Endpoint.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO_Endpoint_Acceptor_Filter::TAO_Endpoint_Acceptor_Filter (const EndpointPolicy::EndpointList & eps)
: endpoints_(eps)
{
}
int
TAO_Endpoint_Acceptor_Filter::fill_profile (const TAO::ObjectKey &object_key,
TAO_MProfile &mprofile,
TAO_Acceptor **acceptors_begin,
TAO_Acceptor **acceptors_end,
CORBA::Short priority)
{
CORBA::ULong const num_endpoints = endpoints_.length ();
for (TAO_Acceptor** acceptor = acceptors_begin;
acceptor != acceptors_end;
++acceptor)
{
bool tagfound = false;
for (CORBA::ULong epx = 0; !tagfound && epx < num_endpoints; epx++)
{
tagfound = (*acceptor)->tag () == endpoints_[epx]->protocol_tag();
}
if (!tagfound)
continue;
if ((*acceptor)->create_profile (object_key,
mprofile,
priority) == -1)
return -1;
}
if (TAO_debug_level > 2)
TAOLIB_DEBUG ((LM_DEBUG,
ACE_TEXT("(%P|%t) EndpointPolicy filtering acceptors")
ACE_TEXT(" - mprofile has %d profiles,")
ACE_TEXT(" endpoint list has %d entries\n"),
mprofile.profile_count(), num_endpoints));
for (TAO_PHandle pfile_ndx = 0;
pfile_ndx < mprofile.profile_count ();
++pfile_ndx)
{
TAO_Profile * const pfile = mprofile.get_profile (pfile_ndx);
TAO_Endpoint * ep_in_pfile = pfile->base_endpoint ();
if (TAO_debug_level > 2)
TAOLIB_DEBUG ((LM_DEBUG,
ACE_TEXT("(%P|%t) Testing profile %d - ")
ACE_TEXT("it contains %d endpoints\n"),
pfile_ndx, pfile->endpoint_count()));
bool first_endpoint = true;
// Iterate the endpoints in the profile.
while (ep_in_pfile != 0 && pfile->endpoint_count() > 0)
{
// Iterate the endpoints in the endpoint policy to see if the endpoint
// in the profile matches.
CORBA::ULong ep_ndx = 0;
bool epmatch = false;
for (ep_ndx = 0; !epmatch && ep_ndx < num_endpoints; ++ep_ndx)
{
if (endpoints_[ep_ndx]->protocol_tag() != pfile->tag())
continue;
const EndpointPolicy::EndpointValueBase_ptr evb =
endpoints_[ep_ndx];
const TAO_Endpoint_Value_Impl *evi =
dynamic_cast <const TAO_Endpoint_Value_Impl*>(evb);
epmatch = evi->is_equivalent(ep_in_pfile);
}
// The endpoint in profile does not match the endpoint specified in
// Endpoint policy, now remove the endpoint from the profile.
if (!epmatch)
{
//Get next endpoint before removing current one.
TAO_Endpoint * next = ep_in_pfile->next ();
if (TAO_debug_level > 2)
TAOLIB_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) EndpointPolicy filter ")
ACE_TEXT ("removing endpoint\n")));
pfile->remove_generic_endpoint (ep_in_pfile);
ep_in_pfile = first_endpoint ? pfile->endpoint() : next;
}
else
{
if (TAO_debug_level > 2)
TAOLIB_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) EndpointPolicy filter ")
ACE_TEXT ("Endpoint matched policy value\n")));
ep_in_pfile = ep_in_pfile->next();
first_endpoint = false;
}
}
CORBA::ULong const ep_count = pfile->endpoint_count ();
// Remove the profiles that have no endpoints match the endpoints in
// endpoint policy.
if (ep_count == 0
&& mprofile.remove_profile (pfile) != -1)
{
--pfile_ndx; // Step back one. We've just shifted the profile list.
if (TAO_debug_level > 2)
TAOLIB_DEBUG ((LM_DEBUG,
ACE_TEXT("(%P|%t) EndpointPolicy filter ")
ACE_TEXT("removing profile\n")));
}
else if (ep_count != 0)
{
if (TAO_debug_level > 2)
TAOLIB_DEBUG ((LM_DEBUG,
ACE_TEXT("(%P|%t) EndpointPolicy filter ")
ACE_TEXT("profile retained with %d endpoints\n"),
ep_count));
}
}
if (mprofile.profile_count () == 0) {
if (TAO_debug_level > 0)
TAOLIB_DEBUG ((LM_DEBUG,
ACE_TEXT("(%P|%t) EndpointPolicy filter ")
ACE_TEXT("eliminated all profiles\n")));
return -1;
}
if (TAO_debug_level > 2)
TAOLIB_DEBUG ((LM_DEBUG,
ACE_TEXT("(%P|%t) EndpointPolicy filter returning mprofile ")
ACE_TEXT("with %d profiles\n"),
mprofile.profile_count()));
return 0;
}
TAO_END_VERSIONED_NAMESPACE_DECL
|
