summaryrefslogtreecommitdiff
path: root/TAO/tests/Portable_Interceptors/Processing_Mode_Policy/Collocated/Collocated_Test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tests/Portable_Interceptors/Processing_Mode_Policy/Collocated/Collocated_Test.cpp')
-rw-r--r--TAO/tests/Portable_Interceptors/Processing_Mode_Policy/Collocated/Collocated_Test.cpp226
1 files changed, 0 insertions, 226 deletions
diff --git a/TAO/tests/Portable_Interceptors/Processing_Mode_Policy/Collocated/Collocated_Test.cpp b/TAO/tests/Portable_Interceptors/Processing_Mode_Policy/Collocated/Collocated_Test.cpp
deleted file mode 100644
index 41d8c39fec7..00000000000
--- a/TAO/tests/Portable_Interceptors/Processing_Mode_Policy/Collocated/Collocated_Test.cpp
+++ /dev/null
@@ -1,226 +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 "Echo_Collocated_ORBInitializer.h"
-#include "tao/ORBInitializer_Registry.h"
-#include "interceptors.h"
-
-const char *output = "test.ior";
-const char *input = "file://test.ior";
-
-ACE_CString server_proc_mode_str;
-ACE_CString client_proc_mode_str;
-ACE_CString server_orb;
-ACE_CString client_orb;
-
-int
-parse_args (int argc, char *argv[])
-{
- ACE_Get_Opt get_opts (argc, argv, "s:c:k:o");
- int c;
-
- server_proc_mode_str.set ("LOCAL_AND_REMOTE");
- client_proc_mode_str.set ("LOCAL_AND_REMOTE");
-
- while ((c = get_opts ()) != -1)
- {
- switch (c)
- {
- case 's':
- server_proc_mode_str.set (get_opts.opt_arg ());
- break;
- case 'c':
- client_proc_mode_str.set (get_opts.opt_arg ());
- break;
- case 'o':
- output = get_opts.opt_arg ();
- break;
- case 'k':
- input = get_opts.opt_arg ();
- break;
- case '?':
- default:
- 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;
-
- server_orb.set ("server_orb");
- client_orb.set ("client_orb");
-
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
- {
- PortableInterceptor::ORBInitializer_ptr temp_initializer =
- PortableInterceptor::ORBInitializer::_nil ();
-
- // Set up our default expectations.
- CORBA::ULong expected_server_interceptor_check = 10;
- CORBA::ULong expected_client_interceptor_check = 10;
-
- PortableInterceptor::ProcessingMode client_proc_mode =
- PortableInterceptor::LOCAL_AND_REMOTE;
-
- if (client_proc_mode_str == "LOCAL_ONLY")
- {
- client_proc_mode = PortableInterceptor::LOCAL_ONLY;
- ACE_DEBUG((LM_DEBUG,
- "Using LOCAL_ONLY for client-side ProcessingMode.\n"));
- }
- else if (client_proc_mode_str == "REMOTE_ONLY")
- {
- client_proc_mode = PortableInterceptor::REMOTE_ONLY;
- ACE_DEBUG((LM_DEBUG,
- "Using REMOTE_ONLY for client-side ProcessingMode.\n"));
-
- // Since all of the calls are collocated, setting the client-side
- // ProcessingMode to REMOTE_ONLY will cause the client request
- // interceptor to not fire. Thus, we expect 0 calls on the
- // client interceptor.
- expected_client_interceptor_check = 0;
- }
- else
- {
- ACE_DEBUG((LM_DEBUG,
- "Using LOCAL_AND_REMOTE for client-side ProcessingMode.\n"));
- }
-
- PortableInterceptor::ProcessingMode server_proc_mode =
- PortableInterceptor::LOCAL_AND_REMOTE;
-
- if (server_proc_mode_str == "LOCAL_ONLY")
- {
- server_proc_mode = PortableInterceptor::LOCAL_ONLY;
- ACE_DEBUG((LM_DEBUG,
- "Using LOCAL_ONLY for server-side ProcessingMode.\n"));
- }
- else if (server_proc_mode_str == "REMOTE_ONLY")
- {
- server_proc_mode = PortableInterceptor::REMOTE_ONLY;
- ACE_DEBUG((LM_DEBUG,
- "Using REMOTE_ONLY for server-side ProcessingMode.\n"));
-
- // Since all of the calls are collocated, setting the server-side
- // ProcessingMode to REMOTE_ONLY will cause the server request
- // interceptor to not fire. Thus, we expect 0 calls on the
- // server interceptor.
- expected_server_interceptor_check = 0;
- }
- else
- {
- ACE_DEBUG((LM_DEBUG,
- "Using LOCAL_AND_REMOTE for server-side ProcessingMode.\n"));
- }
-
- ACE_NEW_RETURN (temp_initializer,
- Echo_Collocated_ORBInitializer (server_proc_mode,
- client_proc_mode),
- -1); // No exceptions yet!
- PortableInterceptor::ORBInitializer_var orb_initializer =
- temp_initializer;
-
- PortableInterceptor::register_orb_initializer (orb_initializer.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- 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 ();
-
- 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"));
- }
-
- ACE_Thread_Manager::instance ()->wait ();
-
- sorb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- bool failed_check = false;
-
- CORBA::ULong number_called =
- Echo_Server_Request_Interceptor::server_interceptor_check_;
-
- if (number_called != expected_server_interceptor_check)
- {
- ACE_ERROR ((LM_ERROR,
- "(%P|%t) ERROR: Server-Side Interceptors not "
- "called properly, called %d times, expected %d.\n",
- number_called, expected_server_interceptor_check));
- failed_check = true;
- }
-
- number_called =
- Echo_Client_Request_Interceptor::client_interceptor_check_;
-
- if (number_called != expected_client_interceptor_check)
- {
- ACE_ERROR ((LM_ERROR,
- "(%P|%t) ERROR:Client-Side Interceptors not called "
- "properly, called %d times, expected %d.\n",
- number_called, expected_client_interceptor_check));
- failed_check = true;
- }
-
- if (failed_check)
- {
- return 1;
- }
- }
- ACE_CATCHANY
- {
- ACE_ERROR ((LM_ERROR,
- "(%P|%t) ERROR: Some exception was caught in main().\n"));
- return 1;
- }
- ACE_ENDTRY;
- return 0;
-}