TAO/tests/Portable_Interceptors/Bug_2510_Regression/client.cpp

   1 #include "ace/Get_Opt.h"
   2 #include "ace/Synch.h"
   3 #include "ace/Thread.h"
   4 #include "testC.h"
   5 #include "Client_ORBInitializer.h"
   6 #include "tao/ORBInitializer_Registry.h"
   7
   8 const ACE_TCHAR *ior = ACE_TEXT("file://test.ior");
   9
  10 int
  11 parse_args (int argc, ACE_TCHAR *argv[])
  12 {
  13   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("ef:"));
  14   int c;
  15
  16   while ((c = get_opts ()) != -1)
  17     switch (c)
  18       {
  19       case 'e':
  20       break;
  21       case 'f':
  22         ior = get_opts.opt_arg ();
  23         break;
  24       case '?':
  25       default:
  26         ACE_ERROR_RETURN ((LM_ERROR,
  27                            "usage:  %s "
  28                            "-v "
  29                            "\n",
  30                            argv [0]),
  31                           -1);
  32       }
  33   return 0;
  34 }
  35
  36 static ACE_THR_FUNC_RETURN run_test(void* pData)
  37 {
  38     Test_Interceptors::Visual_ptr server = static_cast<Test_Interceptors::Visual_ptr>(pData);
  39
  40     try
  41     {
  42         server->normal (10);
  43     }
  44     catch (const CORBA::Exception& ex)
  45     {
  46         ex._tao_print_exception ("Exception thrown in run_test()\n");
  47     }
  48
  49     return (ACE_THR_FUNC_RETURN)0;
  50 }
  51
  52 int
  53 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  54 {
  55     try
  56     {
  57         PortableInterceptor::ORBInitializer_ptr temp_initializer;
  58
  59         ACE_NEW_RETURN (temp_initializer,
  60                       Client_ORBInitializer,
  61                       -1);  // No exceptions yet!
  62         PortableInterceptor::ORBInitializer_var initializer =
  63         temp_initializer;
  64
  65         PortableInterceptor::register_orb_initializer (initializer.in ());
  66
  67         CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  68
  69         if (parse_args (argc, argv) != 0)
  70           return 1;
  71
  72         CORBA::Object_var object =
  73         orb->string_to_object (ior);
  74
  75         Test_Interceptors::Visual_var server =
  76         Test_Interceptors::Visual::_narrow (object.in ());
  77
  78         if (CORBA::is_nil (server.in ()))
  79         {
  80             ACE_ERROR_RETURN ((LM_ERROR,
  81                              "Object reference <%s> is nil.\n",
  82                              ior),
  83                             1);
  84         }
  85
  86         ACE_hthread_t threadHandle;
  87         if ( ACE_Thread::spawn(run_test,
  88                                static_cast<void*>(server.in()),
  89                                THR_NEW_LWP | THR_JOINABLE ,
  90                                0,
  91                                & threadHandle) == -1 )
  92         {
  93            ACE_ERROR_RETURN ((LM_ERROR,"Cannot start thread"), 1);
  94         }
  95
  96         ACE_Thread::join (threadHandle);
  97
  98         server->shutdown ();
  99
 100         orb->destroy ();
 101     }
 102
 103     catch (const CORBA::Exception& ex)
 104     {
 105         ex._tao_print_exception ("Caught exception in client:");
 106         return 1;
 107     }
 108
 109
 110     return 0;
 111 }