diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Trading/Offer_Importer.cpp')
| -rw-r--r-- | TAO/orbsvcs/tests/Trading/Offer_Importer.cpp | 311 |
1 files changed, 0 insertions, 311 deletions
diff --git a/TAO/orbsvcs/tests/Trading/Offer_Importer.cpp b/TAO/orbsvcs/tests/Trading/Offer_Importer.cpp deleted file mode 100644 index dec7312c051..00000000000 --- a/TAO/orbsvcs/tests/Trading/Offer_Importer.cpp +++ /dev/null @@ -1,311 +0,0 @@ -// $Id$ - -#include "Offer_Importer.h" - -ACE_RCSID(Trading, Offer_Importer, "$Id$") - -TAO_Offer_Importer::TAO_Offer_Importer (CosTrading::Lookup_ptr lookup_if, - CORBA::Boolean verbose) - : verbose_ (verbose), - lookup_ (lookup_if) -{ -} - -void -TAO_Offer_Importer::perform_queries (CORBA::Environment& TAO_IN_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)) -{ - ACE_DEBUG ((LM_DEBUG, "*** TAO_Offer_Importer::Federated Query.\n")); - - TAO_Policy_Manager policies; - policies.exact_type_match (0); - policies.search_card (16*NUM_OFFERS); - policies.match_card (16*NUM_OFFERS); - policies.return_card (16*NUM_OFFERS); - policies.link_follow_rule (CosTrading::always); - - this->perform_queries_with_policies (policies, TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); -} - -void -TAO_Offer_Importer::perform_directed_queries (CORBA::Environment& TAO_IN_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)) -{ - ACE_DEBUG ((LM_DEBUG, "*** TAO_Offer_Importer::Directed Query.\n")); - - TAO_Policy_Manager policies; - policies.exact_type_match (0); - policies.search_card (16*NUM_OFFERS); - policies.match_card (16*NUM_OFFERS); - policies.return_card (16*NUM_OFFERS); - policies.link_follow_rule (CosTrading::local_only); - - if (this->verbose_) - ACE_DEBUG ((LM_DEBUG, "Obtaining link interface.\n")); - CosTrading::Link_var link_if = this->lookup_->link_if (TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); - - if (this->verbose_) - { - ACE_DEBUG ((LM_DEBUG, "Obtaining references to traders directly" - " linked to the root trader.\n")); - } - CosTrading::LinkNameSeq_var link_name_seq = link_if->list_links (TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); - - if (link_name_seq->length () > 0) - { - if (this->verbose_) - { - ACE_DEBUG ((LM_DEBUG, "Getting link information for %s\n", - ACE_static_cast (const char*, link_name_seq[0]))); - } - - CosTrading::Link::LinkInfo_var link_info = - link_if->describe_link (link_name_seq[0], TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); - - CosTrading::Lookup_var lookup_if; -#ifdef TAO_HAS_OBJECT_IN_STRUCT_MARSHAL_BUG - CORBA::ORB_ptr orb = TAO_ORB_Core_instance ()-> orb (); - CORBA::Object_var obj = orb->string_to_object (link_info->target, TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); - lookup_if = CosTrading::Lookup::_narrow (obj.in (), TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); -#else - lookup_if = CosTrading::Lookup::_duplicate (link_info->target.in ()); -#endif /* TAO_HAS_OBJECT_IN_STRUCT_MARSHAL_BUG */ - - CosTrading::Link_var link_if2 = lookup_if->link_if (TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); - - CosTrading::LinkNameSeq_var link_name_seq2 = link_if2->list_links (TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); - - if (link_name_seq2->length () > 0) - { - CORBA::ULong i = 0; - CORBA::ULong length = link_name_seq2->length (); - for (i = 0; i < length; i++) - { - if (ACE_OS::strcmp (link_name_seq2[i], "Bootstrap") != 0) - break; - } - - if (i < length) - { - CosTrading::LinkName* trader_name = - CosTrading::TraderName::allocbuf (2); - - ACE_DEBUG ((LM_DEBUG, "*** Query through %s to destination %s.\n", - ACE_static_cast (const char*, link_name_seq[0]), - ACE_static_cast (const char*, link_name_seq2[i]))); - - trader_name[0] = CORBA::string_dup (link_name_seq[0]); - trader_name[1] = CORBA::string_dup (link_name_seq2[i]); - policies.starting_trader (new CosTrading::TraderName - (2, 2, trader_name, 1)); - - this->perform_queries_with_policies (policies, TAO_IN_ENV); - TAO_CHECK_ENV_RETURN_VOID (TAO_IN_ENV); - } - } - else - { - ACE_DEBUG ((LM_DEBUG, "This test requires a complete" - " graph of three traders.\n")); - } - } - else - { - ACE_DEBUG ((LM_DEBUG, "This test requires a complete" - " graph of three traders.\n")); - } -} - - -void -TAO_Offer_Importer:: -perform_queries_with_policies (const TAO_Policy_Manager& policies, - CORBA::Environment& TAO_IN_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 - { - CosTrading::Lookup::SpecifiedProps desired_props; - - char* props[] = - { - (char*) TT_Info::REMOTE_IO_PROPERTY_NAMES[TT_Info::NAME], - (char*) TT_Info::REMOTE_IO_PROPERTY_NAMES[TT_Info::DESCRIPTION], - (char*) TT_Info::REMOTE_IO_PROPERTY_NAMES[TT_Info::LOCATION], - (char*) TT_Info::REMOTE_IO_PROPERTY_NAMES[TT_Info::HOST_NAME] - }; - - CosTrading::PropertyNameSeq prop_name_seq (4, 4, props, 0); - //desired_props.prop_names (prop_name_seq); - desired_props.all_ (1); - - for (int i = 0; i < TT_Info::NUM_QUERIES; i++) - { - ACE_DEBUG ((LM_DEBUG, "\n")); - 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_ptr = 0; - CosTrading::OfferIterator_ptr offer_iterator_ptr = 0; - CosTrading::PolicyNameSeq_ptr limits_applied_ptr = 0; - - CosTrading::OfferSeq_out offer_seq_out (offer_seq_ptr); - CosTrading::OfferIterator_out offer_iterator_out (offer_iterator_ptr); - CosTrading::PolicyNameSeq_out limits_applied_out (limits_applied_ptr); - - this->lookup_->query (TT_Info::QUERIES[i][0], - TT_Info::QUERIES[i][1], - TT_Info::QUERIES[i][2], - policies.policy_seq (), - desired_props, - 8, - offer_seq_out, - offer_iterator_out, - limits_applied_out, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - CosTrading::OfferSeq_var offer_seq (offer_seq_ptr); - CosTrading::OfferIterator_var offer_iterator (offer_iterator_ptr); - CosTrading::PolicyNameSeq_var limits_applied (limits_applied_ptr); - - if (this->verbose_) - { - ACE_DEBUG ((LM_DEBUG, "*** Results:\n\n")); - this->display_results (*offer_seq_ptr, - offer_iterator_ptr, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - if (limits_applied_out->length () > 0) - ACE_DEBUG ((LM_DEBUG, "*** Limits Applied:\n\n")); - - for (int length = limits_applied_out->length (), j = 0; j < length; j++) - { - const char *policy_name = (*limits_applied_ptr)[j]; - ACE_DEBUG ((LM_DEBUG, "%s\n", - ACE_static_cast (const char*, policy_name))); - } - } - } - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("TAO_Offer_Importer::perform_queries"); - TAO_RETHROW; - } - TAO_ENDTRY; -} - -void -TAO_Offer_Importer::display_results (const CosTrading::OfferSeq& offer_seq, - CosTrading::OfferIterator_ptr offer_iterator, - CORBA::Environment& TAO_IN_ENV) const - TAO_THROW_SPEC ((CORBA::SystemException)) -{ - TAO_TRY - { - CORBA::ULong length = 0, i = 0; - ACE_DEBUG ((LM_DEBUG, "------------------------------\n")); - ACE_DEBUG ((LM_DEBUG, "Offers in the sequence:\n")); - ACE_DEBUG ((LM_DEBUG, "------------------------------\n")); - for (length = offer_seq.length (), i = 0; i < length; i++) - { - // Call back to the exported object. - TAO_Trader_Test::Remote_Output_var remote_output = - TAO_Trader_Test::Remote_Output::_narrow (offer_seq[i].reference.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV; - - remote_output->confirm (TAO_TRY_ENV); - TAO_CHECK_ENV; - - TT_Info::dump_properties (offer_seq[i].properties); - ACE_DEBUG ((LM_DEBUG, "------------------------------\n")); - } - - ACE_DEBUG ((LM_DEBUG, " Offers in the iterator:\n")); - ACE_DEBUG ((LM_DEBUG, "------------------------------\n")); - if (! CORBA::is_nil (offer_iterator)) - { - length = offer_seq.length (); - CORBA::Boolean any_left = 0; - - do - { - CosTrading::OfferSeq_ptr iter_offers_ptr; - CosTrading::OfferSeq_out iter_offers_out (iter_offers_ptr); - - any_left = offer_iterator->next_n (length, - iter_offers_out, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - CosTrading::OfferSeq_var iter_offers (iter_offers_ptr); - for (length = iter_offers->length (), i = 0; i < length; i++) - { - // Call back to the exported object. - TAO_Trader_Test::Remote_Output_var remote_output = - TAO_Trader_Test::Remote_Output::_narrow (offer_seq[i].reference.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV; - - remote_output->confirm (TAO_TRY_ENV); - TAO_CHECK_ENV; - - CosTrading::PropertySeq& props = iter_offers[i].properties; - TT_Info::dump_properties (props); - ACE_DEBUG ((LM_DEBUG, "------------------------------\n")); - } - - } while (any_left); - - offer_iterator->destroy (TAO_TRY_ENV); - TAO_CHECK_ENV; - } - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("TAO_Offer_Importer::display_results"); - TAO_RETHROW; - } - TAO_ENDTRY; -} |