diff options
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.cpp | 226 |
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; -} |