diff options
Diffstat (limited to 'TAO/examples/POA/On_Demand_Loading/server.cpp')
-rw-r--r-- | TAO/examples/POA/On_Demand_Loading/server.cpp | 321 |
1 files changed, 0 insertions, 321 deletions
diff --git a/TAO/examples/POA/On_Demand_Loading/server.cpp b/TAO/examples/POA/On_Demand_Loading/server.cpp deleted file mode 100644 index 7a0cb24ed35..00000000000 --- a/TAO/examples/POA/On_Demand_Loading/server.cpp +++ /dev/null @@ -1,321 +0,0 @@ -// $Id$ - -//============================================================================ -// -// = FILENAME -// server.cpp -// -// = DESCRIPTION -// Server to test the Servant Activator and Servant Locator for a POA. -// -// = AUTHOR -// Kirthika Parameswaran <kirthika@cs.wustl.edu> -// -//============================================================================= - -#include "ace/streams.h" -#include "Servant_Activator.h" -#include "Servant_Locator.h" - -ACE_RCSID(On_Demand_Loading, server, "$Id$") - -static char *ior_output_file = 0; - -static int -parse_args (int argc, char **argv) -{ - ACE_Get_Opt get_opts (argc, argv, "f:"); - int c; - - while ((c = get_opts ()) != -1) - switch (c) - { - case 'f': - ior_output_file = get_opts.optarg; - break; - - case '?': - default: - ACE_ERROR_RETURN ((LM_ERROR, - "usage: %s " - "[-f ior_output_file] " - "\n", - argv [0]), - -1); - } - - // Indicates successful parsing of command line. - return 0; -} - -static int -write_iors_to_file (const char *first_ior, - const char *second_ior) -{ - if (ior_output_file == 0) - // No filename was specified; simply return - return 0; - - char ior_output_file_1[BUFSIZ]; - char ior_output_file_2[BUFSIZ]; - - ACE_OS::sprintf (ior_output_file_1, "%s_1", ior_output_file); - ACE_OS::sprintf (ior_output_file_2, "%s_2", ior_output_file); - - FILE *output_file_1 = ACE_OS::fopen (ior_output_file_1, "w"); - FILE *output_file_2 = ACE_OS::fopen (ior_output_file_2, "w"); - - if (output_file_1 == 0 || - output_file_2 == 0) - ACE_ERROR_RETURN ((LM_ERROR, "Cannot open output files for writing IORs: %s, %s\n", - ior_output_file_1, - ior_output_file_2), - -1); - - int result = ACE_OS::fprintf (output_file_1, - "%s", - first_ior); - if (result <= 0 - || ACE_static_cast (size_t,result) != ACE_OS::strlen (first_ior)) - ACE_ERROR_RETURN ((LM_ERROR, - "ACE_OS::fprintf failed while writing %s to %s\n", - first_ior, - ior_output_file_1), - -1); - - result = ACE_OS::fprintf (output_file_2, - "%s", - second_ior); - if (result <= 0 - || ACE_static_cast (size_t,result) != ACE_OS::strlen (second_ior)) - ACE_ERROR_RETURN ((LM_ERROR, - "ACE_OS::fprintf failed while writing %s to %s\n", - second_ior, - ior_output_file_2), - -1); - ACE_OS::fclose (output_file_1); - ACE_OS::fclose (output_file_2); - return 0; -} - -int -main (int argc, char **argv) -{ - CORBA::Environment TAO_TRY_ENV; - - TAO_TRY - { - // Initialize the ORB. - CORBA::ORB_var orb = - CORBA::ORB_init (argc, argv, 0, TAO_TRY_ENV); - TAO_CHECK_ENV; - - int result = parse_args (argc, argv); - if (result != 0) - return result; - - // Get an Object reference to RootPOA. - CORBA::Object_var obj = - orb->resolve_initial_references ("RootPOA"); - - // Narrow the Object reference to a POA reference - PortableServer::POA_var root_poa = - PortableServer::POA::_narrow (obj.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Get the POAManager of RootPOA - - PortableServer::POAManager_var poa_manager = - root_poa->the_POAManager (TAO_TRY_ENV); - - TAO_CHECK_ENV; - - CORBA::PolicyList policies (4); - policies.length (4); - - // ID Assignment Policy - policies[0] = - root_poa->create_id_assignment_policy (PortableServer::USER_ID, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Lifespan Policy - policies[1] = - root_poa->create_lifespan_policy (PortableServer::PERSISTENT, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Request Processing Policy - policies[2] = - root_poa->create_request_processing_policy (PortableServer::USE_SERVANT_MANAGER, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // @@ Kirthika, can you please break this giant function up into - // several smaller functions, e.g., put the initialization - // methods first in their own function, then put the POA - // creation methods next, perhaps in their own functions, - // followed finally by the other initialization. - PortableServer::POA_var first_poa; - { - // Servant Retention Policy - policies[3] = - root_poa->create_servant_retention_policy (PortableServer::RETAIN, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Create firstPOA as the child of RootPOA with the above - // policies firstPOA will use SERVANT_ACTIVATOR because of - // RETAIN policy. - first_poa = root_poa->create_POA ("firstPOA", - poa_manager.in (), - policies, - TAO_TRY_ENV); - TAO_CHECK_ENV; - } - - PortableServer::POA_var second_poa; - { - // Servant Retention Policy - policies[3] = - root_poa->create_servant_retention_policy (PortableServer::NON_RETAIN, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Create secondPOA as child of RootPOA with the above policies - // secondPOA will use a SERVANT_LOCATOR because of NON_RETAIN - // policy. - second_poa = root_poa->create_POA ("secondPOA", - poa_manager.in (), - policies, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Destroy the policy objects as they have been passed to - // create_POA and no longer needed. - for (CORBA::ULong i = 0; - i < policies.length () && TAO_TRY_ENV.exception () == 0; - ++i) - { - CORBA::Policy_ptr policy = policies[i]; - policy->destroy (TAO_TRY_ENV); - } - - TAO_CHECK_ENV; - - // @@ *done*Kirthika, please add a comment here. - // An Servant Activator object is created which will activate - // the servant on demand. - ServantActivator_i servant_activator_impl (orb.in ()); - - PortableServer::ServantActivator_var servant_activator = - servant_activator_impl._this (TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Set ServantActivator_i object as the servant_manager of - // firstPOA. - first_poa->set_servant_manager (servant_activator.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Create a reference with user created ID in firstPOA which - // uses the MyFooServantActivator. The servant dll name as - // well as the factory function in the dll are used in - // creating the objectId. - - ACE_DEBUG ((LM_DEBUG, - "create object id to be done\n")); - PortableServer::ObjectId_var first_foo_oid = - servant_activator_impl.create_dll_object_id ("MyFoo", - "create_MyFoo"); - - ACE_DEBUG ((LM_DEBUG, - "create object id done\n")); - CORBA::Object_var first_foo = - first_poa->create_reference_with_id (first_foo_oid.in (), - "IDL:Foo:1.0", - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // @@*done* Kirthika, please add a comment here. - // An Servant Locator object is created which will activate - // the servant on demand. - ServantLocator_i servant_locator_impl (orb.in ()); - - PortableServer::ServantLocator_var servant_locator = - servant_locator_impl._this (TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Set ServantLocator_i object as the servant Manager of - // secondPOA. - - second_poa->set_servant_manager (servant_locator.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Try to create a reference with user created ID in - // second_poa which uses MyFooServantLocator. The servant dll - // name as well as the factory function in the dll are used in - // creating the objectId. - PortableServer::ObjectId_var second_foo_oid = - servant_locator_impl.create_dll_object_id ("MyFoo", - "create_MyFoo"); - CORBA::Object_var second_foo = - second_poa->create_reference_with_id (second_foo_oid.in (), - "IDL:Foo:1.0", - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Invoke object_to_string on the references created in - // firstPOA and secondPOA. - - CORBA::String_var first_foo_ior = - orb->object_to_string (first_foo.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV; - - CORBA::String_var second_foo_ior = - orb->object_to_string (second_foo.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Print the ior's of first_foo and second_foo. - - ACE_DEBUG ((LM_DEBUG,"%s\n%s\n", - first_foo_ior.in (), - second_foo_ior.in ())); - - int write_result = write_iors_to_file (first_foo_ior.in (), - second_foo_ior.in ()); - if (write_result != 0) - return write_result; - - // Set the poa_manager state to active, ready to process - // requests. - poa_manager->activate (TAO_TRY_ENV); - - TAO_CHECK_ENV; - - // Run the ORB. - if (orb->run () == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "CORBA::ORB::run"), - -1); - // Destroy the root_poa and also first_poa and second_poa. - root_poa->destroy (1, - 1, - TAO_TRY_ENV); - TAO_CHECK_ENV; - } - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("server:main ()"); - return 1; - } - TAO_ENDTRY; - - return 0; -} |