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
|
#include "Offer_Importer.h"
#include "orbsvcs/Trader/Policy_Manager.h"
TAO_Offer_Importer::TAO_Offer_Importer (CosTrading::Lookup_ptr lookup_if)
: lookup_ (lookup_if)
{
}
void
TAO_Offer_Importer::perform_queries (CORBA::Environment& _env)
TAO_THROW_SPEC ((CORBA::SystemException,
CosTrading::IllegalServiceType,
CosTrading::UnknownServiceType,
CosTrading::IllegalConstraint,
CosTrading::Lookup::IllegalPreference,
CosTrading::Lookup::IllegalPolicyName,
CosTrading::Lookup::PolicyTypeMismatch,
CosTrading::Lookup::InvalidPolicyValue,
CosTrading::IllegalPropertyName,
CosTrading::DuplicatePropertyName,
CosTrading::DuplicatePolicyName))
{
TAO_TRY
{
TAO_Policy_Manager policies;
CosTrading::Lookup::SpecifiedProps desired_props;
for (int i = 0; i < TT_Info::NUM_QUERIES; i++)
{
ACE_DEBUG ((LM_DEBUG, "Performing query for %s.\n", TT_Info::QUERIES[i][0]));
ACE_DEBUG ((LM_DEBUG, "Query: %s\n", TT_Info::QUERIES[i][1]));
ACE_DEBUG ((LM_DEBUG, "Preferences: %s\n", TT_Info::QUERIES[i][2]));
CosTrading::OfferSeq_ptr offer_seq_out = 0;
CosTrading::OfferIterator_ptr offer_iterator_out = 0;
CosTrading::PolicyNameSeq_ptr limits_applied_out = 0;
this->lookup_->query (TT_Info::QUERIES[i][0],
TT_Info::QUERIES[i][1],
TT_Info::QUERIES[i][2],
policies.policy_seq (),
desired_props,
8,
CosTrading::OfferSeq_out (offer_seq_out),
CosTrading::OfferIterator_out (offer_iterator_out),
CosTrading::PolicyNameSeq_out (limits_applied_out),
TAO_TRY_ENV);
TAO_CHECK_ENV;
CosTrading::OfferSeq_var offer_seq (offer_seq_out);
CosTrading::OfferIterator_var offer_iterator (offer_iterator_out);
CosTrading::PolicyNameSeq_var limits_applied (limits_applied_out);
ACE_DEBUG ((LM_DEBUG, "Results:\n\n"));
this->display_results (offer_seq.in (),
offer_iterator.in (),
TAO_TRY_ENV);
TAO_CHECK_ENV;
}
}
TAO_CATCHANY
{
TAO_TRY_ENV.print_exception ("TAO_Offer_Importer::perform_queries");
TAO_RETHROW;
}
TAO_ENDTRY;
}
void
TAO_Offer_Importer::perform_federated_queries (CORBA::Environment& _env)
TAO_THROW_SPEC ((CORBA::SystemException,
CosTrading::IllegalServiceType,
CosTrading::UnknownServiceType,
CosTrading::IllegalConstraint,
CosTrading::Lookup::IllegalPreference,
CosTrading::Lookup::IllegalPolicyName,
CosTrading::Lookup::PolicyTypeMismatch,
CosTrading::Lookup::InvalidPolicyValue,
CosTrading::IllegalPropertyName,
CosTrading::DuplicatePropertyName,
CosTrading::DuplicatePolicyName))
{
}
void
TAO_Offer_Importer::display_results (const CosTrading::OfferSeq& offer_seq,
CosTrading::OfferIterator_ptr offer_iterator,
CORBA::Environment& _env) const
TAO_THROW_SPEC ((CORBA::SystemException))
{
for (int length = offer_seq.length (), i = 0; i < length; i++)
TT_Info::dump_properties (offer_seq[i].properties);
TAO_TRY
{
if (! CORBA::is_nil (offer_iterator))
{
CORBA::Boolean any_left = CORBA::B_FALSE;
do
{
CosTrading::OfferSeq_ptr iter_offers_out;
any_left =
offer_iterator->next_n (length,
CosTrading::OfferSeq_out (iter_offers_out),
TAO_TRY_ENV);
TAO_CHECK_ENV;
CosTrading::OfferSeq_var iter_offers (iter_offers_out);
CosTrading::PropertySeq& props = iter_offers[i].properties;
for (length = iter_offers->length (), i = 0; i < length; i++)
TT_Info::dump_properties (props);
} while (any_left);
}
}
TAO_CATCHANY
{
TAO_TRY_ENV.print_exception ("TAO_Offer_Importer::display_results");
TAO_RETHROW;
}
TAO_ENDTRY;
}
|
