summaryrefslogtreecommitdiff
path: root/TAO/tests/Bug_2084_Regression/Collocated_Test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tests/Bug_2084_Regression/Collocated_Test.cpp')
-rw-r--r--TAO/tests/Bug_2084_Regression/Collocated_Test.cpp127
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;
-}