summaryrefslogtreecommitdiff
path: root/TAO/tests/Portable_Interceptors/AMI/client.cpp
diff options
context:
space:
mode:
authorWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:11 +0000
committerWilliam R. Otte <wotte@dre.vanderbilt.edu>2006-07-24 15:50:11 +0000
commit6b846cf03c0bcbd8c276cb0af61a181e5f98eaae (patch)
treeda50d054f9c761c3f6a5923f6979e93306c56d68 /TAO/tests/Portable_Interceptors/AMI/client.cpp
parent0e555b9150d38e3b3473ba325b56db2642e6352b (diff)
downloadATCD-6b846cf03c0bcbd8c276cb0af61a181e5f98eaae.tar.gz
Repo restructuring
Diffstat (limited to 'TAO/tests/Portable_Interceptors/AMI/client.cpp')
-rw-r--r--TAO/tests/Portable_Interceptors/AMI/client.cpp319
1 files changed, 0 insertions, 319 deletions
diff --git a/TAO/tests/Portable_Interceptors/AMI/client.cpp b/TAO/tests/Portable_Interceptors/AMI/client.cpp
deleted file mode 100644
index 571ccf476a0..00000000000
--- a/TAO/tests/Portable_Interceptors/AMI/client.cpp
+++ /dev/null
@@ -1,319 +0,0 @@
-#include "Echo_Handler.h"
-#include "Client_ORBInitializer.h"
-#include "Client_Interceptor.h"
-
-#include "tao/ORBInitializer_Registry.h"
-
-#include "ace/Get_Opt.h"
-#include "ace/Log_Msg.h"
-#include <iostream>
-
-ACE_RCSID (AMI,
- client,
- "$Id$")
-
-
-const char *ior = "file://test.ior";
-static int exit_status = 0;
-const unsigned long ITERATIONS = 100;
-
-int
-parse_args (int argc, char *argv[])
-{
- ACE_Get_Opt get_opts (argc, argv, "k:");
- int c;
-
- while ((c = get_opts ()) != -1)
- switch (c)
- {
- case 'k':
- ior = get_opts.opt_arg ();
- break;
-
- case '?':
- default:
- ACE_ERROR_RETURN ((LM_ERROR,
- "usage: %s "
- "-k <ior> "
- "\n",
- argv [0]),
- -1);
- }
- // Indicates sucessful parsing of the command line
- return 0;
-}
-
-static void test_synchronous (Test::Echo_ptr echo
- ACE_ENV_ARG_DECL);
-
-static void test_ami (CORBA::ORB_ptr orb,
- Test::Echo_ptr echo
- ACE_ENV_ARG_DECL);
-int
-main (int argc, char *argv[])
-{
- ACE_TRY_NEW_ENV
- {
- {
- PortableInterceptor::ORBInitializer_var initializer (
- new Client_ORBInitializer);
- PortableInterceptor::register_orb_initializer (initializer.in()
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
- }
-
- CORBA::ORB_var orb =
- CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- if (parse_args (argc, argv) != 0)
- return 1;
-
- CORBA::Object_var poa_object =
- orb->resolve_initial_references ("RootPOA"
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- PortableServer::POA_var root_poa =
- PortableServer::POA::_narrow (poa_object.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- if (CORBA::is_nil (root_poa.in ()))
- ACE_ERROR_RETURN ((LM_ERROR,
- " (%P|%t) Panic: nil RootPOA\n"),
- 1);
-
- PortableServer::POAManager_var poa_manager =
- root_poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- CORBA::Object_var tmp =
- orb->string_to_object (ior ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- Test::Echo_var echo =
- Test::Echo::_narrow (tmp.in () ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- if (CORBA::is_nil (echo.in ()))
- {
- ACE_ERROR_RETURN ((LM_DEBUG,
- "Nil Test::Echo reference <%s>\n",
- ior),
- 1);
- }
-
- test_synchronous (echo.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- test_ami (orb.in (),
- echo.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- echo->shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- unsigned long request_count =
- Echo_Client_Request_Interceptor::request_count;
- unsigned long response_count =
- Echo_Client_Request_Interceptor::reply_count
- + Echo_Client_Request_Interceptor::other_count
- + Echo_Client_Request_Interceptor::exception_count;
-
- if (request_count != response_count)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Mismatched count of requests and responses "
- " (request = %d, response = %d)\n",
- request_count, response_count));
- }
-
- if (request_count == 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: No requests handled "));
- }
-
- if (response_count == 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: No response handled "));
- }
- }
- ACE_CATCHANY
- {
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
- "Exception caught:");
- return 1;
- }
- ACE_ENDTRY;
-
- return exit_status;
-}
-
-static void
-test_synchronous (Test::Echo_ptr echo
- ACE_ENV_ARG_DECL)
-{
- unsigned long initial_request_count =
- Echo_Client_Request_Interceptor::request_count;
- unsigned long initial_reply_count =
- Echo_Client_Request_Interceptor::reply_count;
-
- for (unsigned long i = 0; i != ITERATIONS; ++i)
- {
- CORBA::String_var s =
- echo->echo_operation ("dummy message"
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- }
-
- unsigned long total_request_count =
- Echo_Client_Request_Interceptor::request_count - initial_request_count;
- unsigned long total_reply_count =
- Echo_Client_Request_Interceptor::reply_count - initial_reply_count;
-
- if (total_request_count != ITERATIONS
- || total_reply_count != ITERATIONS)
- {
- ACE_ERROR((LM_ERROR,
- "ERROR: Invalid or mismatched request/reply "
- "count (request = %d, reply = %d)\n",
- total_request_count, total_reply_count));
- exit_status = 1;
- }
-
- if (total_request_count == 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: No synchronouse requests handled "));
- }
-
- if (total_reply_count == 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: No synchronouse requests handled "));
- }
-}
-
-static void
-test_ami (CORBA::ORB_ptr orb,
- Test::Echo_ptr echo
- ACE_ENV_ARG_DECL)
-{
- Test::AMI_EchoHandler_var echo_handler;
- Echo_Handler * echo_handler_impl = new Echo_Handler;
-
- PortableServer::ServantBase_var safe_echo_handler = echo_handler_impl;
-
- echo_handler =
- echo_handler_impl->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- unsigned long initial_request_count =
- Echo_Client_Request_Interceptor::request_count;
- unsigned long initial_other_count =
- Echo_Client_Request_Interceptor::other_count;
-
- for (unsigned long i = 0; i != ITERATIONS; ++i)
- {
- echo->sendc_echo_operation (
- echo_handler.in (),
- "dummy message"
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- }
-
- unsigned long total_request_count =
- Echo_Client_Request_Interceptor::request_count - initial_request_count;
- unsigned long total_other_count =
- Echo_Client_Request_Interceptor::other_count - initial_other_count;
-
- if (total_request_count != ITERATIONS
- || total_other_count != ITERATIONS)
- {
- ACE_ERROR((LM_ERROR,
- "ERROR: In test_ami () unexpected request/other "
- "count (request = %d, other = %d)\n",
- total_request_count, total_other_count));
- exit_status = 1;
- }
-
- initial_request_count =
- Echo_Client_Request_Interceptor::request_count;
- unsigned long initial_reply_count =
- Echo_Client_Request_Interceptor::reply_count;
-
- while (echo_handler_impl->replies () != ITERATIONS)
- {
- CORBA::Boolean pending =
- orb->work_pending (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- if (pending)
- {
- orb->perform_work (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
- }
-
- }
-
- total_request_count =
- Echo_Client_Request_Interceptor::request_count - initial_request_count;
- unsigned long total_reply_count =
- Echo_Client_Request_Interceptor::reply_count - initial_reply_count;
-
- if (total_request_count != ITERATIONS
- || total_reply_count != ITERATIONS)
- {
- ACE_ERROR((LM_ERROR,
- "ERROR: In test_ami () unexpected request/reply "
- "count (request = %d, reply = %d)\n",
- total_request_count, total_reply_count));
- exit_status = 1;
- }
-}
-
-#if 0
-static void
-wait_for_exception (CORBA::ORB_ptr orb,
- Test::Echo_ptr echo
- ACE_ENV_ARG_DECL)
-{
- ACE_Time_Value tv (1, 0);
- orb->run (tv ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- bool exception_detected = false;
-
- while(!exception_detected)
- {
- ACE_TRY
- {
- CORBA::String_var dummy =
- echo->echo_operation ("foo"
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- exception_detected = true;
- }
- ACE_ENDTRY;
- }
-
- tv = ACE_Time_Value (1, 0);
- orb->run (tv ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-}
-
-#endif /*if 0*/