diff options
Diffstat (limited to 'TAO/tests/Exposed_Policies/Policy_Verifier.cpp')
| -rw-r--r-- | TAO/tests/Exposed_Policies/Policy_Verifier.cpp | 267 |
1 files changed, 267 insertions, 0 deletions
diff --git a/TAO/tests/Exposed_Policies/Policy_Verifier.cpp b/TAO/tests/Exposed_Policies/Policy_Verifier.cpp new file mode 100644 index 00000000000..4541f43613c --- /dev/null +++ b/TAO/tests/Exposed_Policies/Policy_Verifier.cpp @@ -0,0 +1,267 @@ +#include "Policy_Verifier.h" +#include "ace/OS_NS_string.h" + +ACE_RCSID (tao, Policy_Verifier, "$Id$") + +Policy_Verifier::Policy_Verifier (void) + : priority_bands_ (0) +{ + ACE_OS::strcpy (this->base_object_ref_, + "file://default.ior"); + ACE_OS::strcpy (this->overridden_object_ref_, + "file://overridden.ior"); +} + +Policy_Verifier::~Policy_Verifier (void) +{ + // No Op. +} + +bool +Policy_Verifier::init (int argc, + char *argv[] + ACE_ENV_ARG_DECL) +{ + this->orb_ = + CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (false); + + ACE_Arg_Shifter arg_shifter (argc, argv); + + while (arg_shifter.is_anything_left ()) + { + const char *arg = 0; + // IOR File Name Option. + if ((arg = arg_shifter.get_the_parameter ("-POAConfigFile"))) + { + this->rt_poa_properties_ = + RT_Properties::read_from (arg ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (false); + this->priority_bands_ = + this->rt_poa_properties_->priority_bands ().length (); + } + else if ((arg = arg_shifter.get_the_parameter ("-ObjectConfigFile"))) + { + this->rt_object_properties_ = + RT_Properties::read_from (arg ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (false); + } + else if ((arg = arg_shifter.get_the_parameter ("-BaseObjectIOR"))) + { + if (this->rt_poa_properties_ == 0) + { + ACE_NEW_THROW_EX (this->rt_poa_properties_, + RT_Properties, + CORBA::NO_MEMORY (TAO::VMCID, + CORBA::COMPLETED_NO)); + ACE_CHECK_RETURN (false); + } + this->rt_poa_properties_->ior_source (arg); + ACE_OS::strcpy (this->base_object_ref_, "file://"); + ACE_OS::strcat (this->base_object_ref_, + this->rt_poa_properties_->ior_source ()); + } + else if ((arg = arg_shifter.get_the_parameter ("-OverriddenIOR"))) + { + if (this->rt_object_properties_ == 0) + { + ACE_NEW_THROW_EX (this->rt_object_properties_, + RT_Properties, + CORBA::NO_MEMORY (TAO::VMCID, + CORBA::COMPLETED_NO)); + ACE_CHECK_RETURN (false); + } + this->rt_object_properties_->ior_source (arg); + ACE_OS::strcpy (this->overridden_object_ref_, "file://"); + ACE_OS::strcat (this->overridden_object_ref_, + this->rt_object_properties_->ior_source ()); + } + else + { + arg_shifter.consume_arg (); + } + } + + if ((this->rt_poa_properties_ == 0) || (this->rt_object_properties_ == 0)) + { + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Configuration file missing!\n"))); + return false; + } + + // Get the Object references. + CORBA::Object_var object = this->orb_->string_to_object (this->base_object_ref_ + ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (false); + + if (!Policy_Verifier::check_reference (object.in (), "Invalid IOR file!\n")) + return false; + + this->base_object_ = Counter::_narrow (object.in () ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (false); + + if (!Policy_Verifier::check_reference (this->base_object_.in (), + "Unable to convert the IOR to the proper object reference.\n")) + return false; + + object = this->orb_->string_to_object (this->overridden_object_ref_ ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (false); + + if (!Policy_Verifier::check_reference (object.in (), "Invalid IOR file!\n")) + return false; + + this->overridden_object_ = Counter::_narrow (object.in () ACE_ENV_ARG_PARAMETER); + ACE_CHECK_RETURN (false); + + if (!Policy_Verifier::check_reference (this->overridden_object_.in (), + "Unable to convert the IOR to the proper object reference.\n")) + return false; + + return true; +} + +void +Policy_Verifier::run (ACE_ENV_SINGLE_ARG_DECL ) +{ + this->verify_reference (this->base_object_.in (), + this->rt_poa_properties_ + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + this->verify_reference (this->overridden_object_.in (), + this->rt_object_properties_ + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} + +void +Policy_Verifier::verify_reference (Counter_ptr object, + RT_Properties *rt_properties + ACE_ENV_ARG_DECL) +{ + + ACE_TRY + { + CORBA::Policy_var policy_var = + object->_get_policy (RTCORBA::PRIORITY_MODEL_POLICY_TYPE + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (Policy_Verifier::check_reference (policy_var.in (), "Unable to get Priority Policy.\n")) + { + RTCORBA::PriorityModelPolicy_var priority_policy = + RTCORBA::PriorityModelPolicy::_narrow (policy_var.in ()); + + RTCORBA::PriorityModel priority_model = + priority_policy->priority_model (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + RTCORBA::Priority priority = + priority_policy->server_priority (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (priority_model == RTCORBA::SERVER_DECLARED) + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("\n\nPriority Model: RTCORBA::SERVER_DECLARED\n") + )); + + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Priority Model: %d\nCORBA Priority: %d\n\n"), + priority_model, + priority + )); + + + if (priority != rt_properties->priority ()) + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Priority Value Mismatch.\n"))); + } + + policy_var = object->_get_policy (RTCORBA::PRIORITY_BANDED_CONNECTION_POLICY_TYPE + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (Policy_Verifier::check_reference (policy_var.in (), + "Unable to get Priority Banded Policy\n")) + { + + RTCORBA::PriorityBandedConnectionPolicy_var priority_banded_policy = + RTCORBA::PriorityBandedConnectionPolicy::_narrow (policy_var.in () + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + + if (Policy_Verifier::check_reference (priority_banded_policy.in (), + "Unable to get Priority Banded Policy\n")) + { + + // Here we have a priority banded connection policy. + + RTCORBA::PriorityBands_var pb = + priority_banded_policy->priority_bands (); + unsigned int band_num = pb->length (); + if (band_num != this->priority_bands_) + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Mismatching Number of Priority Bands!\n"))); + + for (unsigned int i = 0; i < band_num; ++i) + { + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Priority Band <%d>: (%d, %d)\n"), + i, + pb[i].low, + pb[i].high + )); + + + if ((band_num == rt_properties->priority_bands ().length ()) && + ((pb[i].low != rt_properties->priority_bands ()[i].low) || + (pb[i].high != rt_properties->priority_bands ()[i].high))) + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Mismatching Priority Band Range!\n"))); + + } + } + } + policy_var = object->_get_policy (RTCORBA::CLIENT_PROTOCOL_POLICY_TYPE + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + if (Policy_Verifier::check_reference (policy_var.in (), + "Unable to get Client Protocol Policy\n")) + { + RTCORBA::ClientProtocolPolicy_var client_protocol_policy = + RTCORBA::ClientProtocolPolicy::_narrow (policy_var.in () ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + RTCORBA::ProtocolList_var protocol_list = + client_protocol_policy->protocols (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + for (unsigned int i = 0; i < protocol_list->length (); i++) + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("\nThe Client Protocol Type: %d\n"), + protocol_list[i].protocol_type)); + + } + + } + ACE_CATCHANY + { + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "CORBA Exception Raised"); + } + + ACE_ENDTRY; +} + +CORBA::Boolean +Policy_Verifier::check_reference (CORBA::Object_ptr object, + const char *msg) +{ + if (CORBA::is_nil (object)) + { + ACE_DEBUG ((LM_DEBUG, ACE_TEXT (msg))); + return 0; + } + return 1; +} |