TAO/tests/Bug_1551_Regression/client.cpp

   1
   2 #include "TestS.h"
   3 #include "Client_Task.h"
   4 #include "ace/Get_Opt.h"
   5 #include "tao/AnyTypeCode/Any.h"
   6
   7 const ACE_TCHAR *ior = ACE_TEXT("file://test.ior");
   8
   9 int nthreads = 1;
  10
  11 int
  12 parse_args (int argc, ACE_TCHAR *argv[])
  13 {
  14   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("n:k:"));
  15   int c;
  16
  17   while ((c = get_opts ()) != -1)
  18     switch (c)
  19       {
  20       case 'k':
  21         ior = get_opts.opt_arg ();
  22         break;
  23
  24       case 'n':
  25         nthreads = ACE_OS::atoi(get_opts.opt_arg());
  26         break;
  27
  28       case '?':
  29       default:
  30         ACE_ERROR_RETURN ((LM_ERROR,
  31                            "usage:  %s "
  32                            "-k <ior> "
  33                            "\n",
  34                            argv [0]),
  35                           -1);
  36       }
  37   // Indicates successful parsing of the command line
  38   return 0;
  39 }
  40
  41 int
  42 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  43 {
  44   int retval = 0;
  45
  46   try
  47     {
  48       CORBA::ORB_var orb =
  49         CORBA::ORB_init (argc, argv);
  50
  51       if (parse_args (argc, argv) != 0)
  52         return 1;
  53
  54       CORBA::Object_var tmp =
  55         orb->string_to_object(ior);
  56
  57       Test::Hello_var hello =
  58         Test::Hello::_narrow(tmp.in ());
  59
  60       if (CORBA::is_nil (hello.in ()))
  61         {
  62           ACE_ERROR_RETURN ((LM_DEBUG,
  63                              "Nil Test::Hello reference <%s>\n",
  64                              ior),
  65                             1);
  66         }
  67
  68       CORBA::Object_var poa_object =
  69         orb->resolve_initial_references("RootPOA");
  70
  71       PortableServer::POA_var root_poa =
  72         PortableServer::POA::_narrow (poa_object.in ());
  73
  74       PortableServer::POAManager_var poa_manager =
  75         root_poa->the_POAManager ();
  76
  77       poa_manager->activate ();
  78
  79
  80       // Let the client perform the test in a separate thread
  81
  82
  83       Client_Task client (hello.in (),
  84                           orb.in (),
  85                           ACE_Thread_Manager::instance ());
  86
  87       if (client.activate (THR_NEW_LWP | THR_JOINABLE, nthreads) != 0)
  88       {
  89         ACE_ERROR_RETURN ((LM_ERROR,
  90                               "ERROR - Cannot activate client threads\n"),
  91             1);
  92       }
  93
  94
  95       ACE_Time_Value thread_deadline = ACE_OS::gettimeofday();
  96       thread_deadline += 30;
  97
  98       if(client.thr_mgr ()->wait (&thread_deadline) == -1)
  99       {
 100         ACE_ERROR((LM_ERROR,
 101                              "ERROR - Timeout waiting for client threads\n"));
 102
 103         retval = 1;
 104       }
 105
 106       root_poa->destroy (true,  // ethernalize objects
 107                          false); // wait for completion
 108
 109       orb->destroy ();
 110     }
 111   catch (const CORBA::Exception& ex)
 112     {
 113       ex._tao_print_exception ("Exception caught:");
 114       return 1;
 115     }
 116
 117   return retval;
 118 }