diff options
Diffstat (limited to 'trunk/TAO/tests/POA/Default_Servant/Default_Servant.cpp')
| -rw-r--r-- | trunk/TAO/tests/POA/Default_Servant/Default_Servant.cpp | 301 |
1 files changed, 301 insertions, 0 deletions
diff --git a/trunk/TAO/tests/POA/Default_Servant/Default_Servant.cpp b/trunk/TAO/tests/POA/Default_Servant/Default_Servant.cpp new file mode 100644 index 00000000000..d0de0aad007 --- /dev/null +++ b/trunk/TAO/tests/POA/Default_Servant/Default_Servant.cpp @@ -0,0 +1,301 @@ +// $Id$ + +//======================================================================== +// +// = LIBRARY +// TAO/tests/POA/Default_Servant +// +// = FILENAME +// Default_Servant.cpp +// +// = DESCRIPTION +// This program tests the behavior of POA::id_to_servant() and +// POA::reference_to_servant() with the use of default servants. +// +// = AUTHOR +// Irfan Pyarali +// +//========================================================================= + +#include "testS.h" +#include "ace/SString.h" +#include "tao/PortableServer/ServantManagerC.h" + +class test_i : public POA_test +{ +}; + +void +test_get_servant_manager (PortableServer::POA_ptr poa) +{ + bool succeed = false; + ACE_TRY_NEW_ENV + { + // Getting the servant manager should give a wrong policy exception + // exception + PortableServer::ServantManager_ptr servant_manager = + poa->get_servant_manager (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + ACE_UNUSED_ARG (servant_manager); + } + ACE_CATCH (PortableServer::POA::WrongPolicy, ex) + { + succeed = true; + } + ACE_CATCHANY + { + } + ACE_ENDTRY; + + if (!succeed) + { + ACE_ERROR ((LM_ERROR, + "(%t) ERROR, get servant manager failed, should give an exception\n")); + } +} + +void +test_set_servant_manager (PortableServer::POA_ptr poa) +{ + bool succeed = false; + ACE_TRY_NEW_ENV + { + // Setting the servant manager should give a wrong policy exception + // exception + poa->set_servant_manager (PortableServer::ServantManager::_nil() ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + } + ACE_CATCH (PortableServer::POA::WrongPolicy, ex) + { + succeed = true; + } + ACE_CATCHANY + { + } + ACE_ENDTRY; + + if (!succeed) + { + ACE_ERROR ((LM_ERROR, + "(%t) ERROR, set servant manager failed, should give an exception\n")); + } +} + +void +test_get_servant_with_no_set (PortableServer::POA_ptr poa) +{ + bool succeed = false; + ACE_TRY_NEW_ENV + { + // Getting the default servant without one set whould give a NoServant + // exception + PortableServer::Servant servant = + poa->get_servant (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + ACE_UNUSED_ARG (servant); + } + ACE_CATCH (PortableServer::POA::NoServant, ex) + { + succeed = true; + } + ACE_CATCHANY + { + } + ACE_ENDTRY; + + if (!succeed) + { + ACE_ERROR ((LM_ERROR, + "(%t) ERROR, get servant without one set failed\n")); + } +} + +void +test_reference_to_servant_active_object(PortableServer::POA_ptr root_poa + ACE_ENV_ARG_DECL) +{ + test_i test; + CORBA::ULong expected_refcount = 1; + + PortableServer::ObjectId* id = + root_poa->activate_object (&test ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + expected_refcount++; + + CORBA::Object_var object = + root_poa->id_to_reference (*id ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + PortableServer::ServantBase_var servant = + root_poa->reference_to_servant (object.in () ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + expected_refcount++; + + root_poa->deactivate_object (*id ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + expected_refcount--; + + CORBA::ULong refcount = + test._refcount_value (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + ACE_UNUSED_ARG (refcount); + ACE_UNUSED_ARG (expected_refcount); + ACE_ASSERT (expected_refcount == refcount); +} + + +int +main (int argc, char **argv) +{ + ACE_DECLARE_NEW_CORBA_ENV; + + ACE_TRY + { + // Initialize the ORB. + CORBA::ORB_var orb = CORBA::ORB_init (argc, + argv, + 0 + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Obtain the RootPOA. + CORBA::Object_var object = + orb->resolve_initial_references ("RootPOA" + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Narrow to POA. + PortableServer::POA_var root_poa = + PortableServer::POA::_narrow (object.in () + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Get the POAManager of the RootPOA. + PortableServer::POAManager_var poa_manager = + root_poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Policies for the new POA. + CORBA::PolicyList policies (3); + policies.length (3); + + // Request Processing Policy. + policies[0] = + root_poa->create_request_processing_policy (PortableServer::USE_DEFAULT_SERVANT + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Id Uniqueness Policy. + policies[1] = + root_poa->create_id_uniqueness_policy (PortableServer::MULTIPLE_ID + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Servant Retention Policy. + policies[2] = + root_poa->create_servant_retention_policy (PortableServer::NON_RETAIN + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Create POA to host default servant. + ACE_CString name = "Default Servant"; + PortableServer::POA_var default_servant_poa = + root_poa->create_POA (name.c_str (), + poa_manager.in (), + policies + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Destroy policies. + for (CORBA::ULong i = 0; + i < policies.length (); + ++i) + { + CORBA::Policy_ptr policy = policies[i]; + policy->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + } + + // Activate POA manager. + poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + test_reference_to_servant_active_object(root_poa.in () + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Test servant. + test_i test; + CORBA::ULong expected_refcount = 1; + + (void) test_get_servant_with_no_set (default_servant_poa.in()); + + (void) test_get_servant_manager (default_servant_poa.in()); + + (void) test_set_servant_manager (default_servant_poa.in()); + + // Register default servant. + default_servant_poa->set_servant (&test + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + expected_refcount++; + + // Create dummy id. + PortableServer::ObjectId_var id = + PortableServer::string_to_ObjectId ("id"); + + // Create dummy object. + object = + default_servant_poa->create_reference ("IDL:test:1.0" + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + + // Invoke id_to_servant(). Should retrieve default servant. + PortableServer::ServantBase_var servant = + default_servant_poa->id_to_servant (id.in () + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + expected_refcount++; + + // Assert correctness. + ACE_ASSERT (&test == servant.in()); + + // Invoke reference_to_servant(). Should retrieve default servant. + servant = + default_servant_poa->reference_to_servant (object.in () + ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + expected_refcount++; + + // Assert correctness. + ACE_ASSERT (&test == servant.in()); + + // Report success. + ACE_DEBUG ((LM_DEBUG, + "Default_Servant test successful\n")); + + CORBA::ULong refcount = + test._refcount_value (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + + ACE_UNUSED_ARG (refcount); + ACE_UNUSED_ARG (expected_refcount); + ACE_ASSERT (expected_refcount == refcount); + + // Destroy the ORB. + orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + } + ACE_CATCHANY + { + ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Exception caught"); + return -1; + } + ACE_ENDTRY; + ACE_CHECK_RETURN (-1); + + return 0; +} |