diff options
Diffstat (limited to 'TAO/tests/Bug_2084_Regression/Collocated_Test.cpp')
-rw-r--r-- | TAO/tests/Bug_2084_Regression/Collocated_Test.cpp | 127 |
1 files changed, 0 insertions, 127 deletions
diff --git a/TAO/tests/Bug_2084_Regression/Collocated_Test.cpp b/TAO/tests/Bug_2084_Regression/Collocated_Test.cpp deleted file mode 100644 index a16745c918a..00000000000 --- a/TAO/tests/Bug_2084_Regression/Collocated_Test.cpp +++ /dev/null @@ -1,127 +0,0 @@ -//$Id$ -#include "Server_Task.h" -#include "Client_Task.h" -#include "ace/Get_Opt.h" -#include "ace/Argv_Type_Converter.h" -#include "ace/SString.h" -#include "ace/Manual_Event.h" -#include <ace/ARGV.h> -#include <iostream> - -const char *output = "test.ior"; -const char *input = "file://test.ior"; -// static int named_orbs = 0; -ACE_CString server_orb; -ACE_CString client_orb; -int -parse_args (int argc, char *argv[]) -{ - ACE_Get_Opt get_opts (argc, argv, "k:o:n"); - int c; - - while ((c = get_opts ()) != -1) - switch (c) - { - case 'o': - output = get_opts.opt_arg (); - break; - case 'k': - input = get_opts.opt_arg (); - break; - case 'n': - // named_orbs = 1; - server_orb.set ("server_orb"); - client_orb.set ("client_orb"); - break; - case '?': - default: - // This is a hack but that is okay! - return 0; - } - // Indicates sucessful parsing of the command line - return 0; -} - -int -main (int argc, char *argv[]) -{ - if (parse_args (argc, - argv) == -1) - return -1; - - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY - { - - // Keep a copy of the ORB options args - ACE_ARGV orb_args; - for (int i = 1; i < argc; ++i) - { - if (orb_args.add (argv[i]) == -1) - return -1; - } - - ACE_Argv_Type_Converter satc (argc, argv); - - CORBA::ORB_var sorb = - CORBA::ORB_init (satc.get_argc (), - satc.get_TCHAR_argv (), - server_orb.c_str () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - - ACE_Manual_Event me; - Server_Task server_task (output, - sorb.in (), - me, - ACE_Thread_Manager::instance ()); - - if (server_task.activate (THR_NEW_LWP | THR_JOINABLE, - 1, - 1) == -1) - { - ACE_ERROR ((LM_ERROR, "Error activating server task\n")); - } - - // Wait for the server thread to do some processing - me.wait (); - - // This eats all orb-specific options! - ACE_Argv_Type_Converter catc (argc, argv); - CORBA::ORB_var corb = - CORBA::ORB_init (catc.get_argc(), - catc.get_TCHAR_argv(), - client_orb.c_str () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - - Client_Task client_task (input, - corb.in (), - ACE_Thread_Manager::instance ()); - - if (client_task.activate (THR_NEW_LWP | THR_JOINABLE, - 1, - 1) == -1) - { - ACE_ERROR ((LM_ERROR, "Error activating client task\n")); - } - - // Wait for the client and server to finish - ACE_Thread_Manager::instance ()->wait (); - - // Now that all threads have completed we can destroy the ORB - sorb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - if (server_orb != client_orb) - { - corb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - } - } - ACE_CATCHANY - { - // Ignore exceptions.. - } - ACE_ENDTRY; - return 0; -} |