TAO/orbsvcs/tests/Bug_4080_Regression/client.cpp

   1
   2 #include "ace/Get_Opt.h"
   3 #include "ace/OS_NS_unistd.h"
   4 #include "tao/Object_T.h"
   5 #include "testC.h"
   6
   7 ACE_TCHAR const *ior = ACE_TEXT ("file://test.ior");
   8 CORBA::ULong threads = 2u;
   9
  10 int
  11 parse_args (int argc, ACE_TCHAR *argv[])
  12 {
  13   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT ("k:t:"));
  14   int c;
  15
  16   while ((c = get_opts ()) != -1)
  17     switch (c)
  18       {
  19       case 'k':
  20         ior = get_opts.opt_arg ();
  21         break;
  22
  23       case 't':
  24         threads = ACE_OS::strtoul (get_opts.opt_arg (), 0, 10);
  25         break;
  26
  27       case '?':
  28       default:
  29         ACE_ERROR_RETURN ((LM_ERROR,
  30                            ACE_TEXT ("usage:  %s ")
  31                            ACE_TEXT ("-k <ior> ")
  32                            ACE_TEXT ("-t <number of threads server has> ")
  33                            ACE_TEXT ("\n"),
  34                            argv [0]),
  35                           -1);
  36       }
  37
  38   ACE_DEBUG ((LM_DEBUG,
  39               ACE_TEXT ("args to be used: -k '%s' -t %d\n"),
  40               ior,
  41               threads));
  42
  43   // Indicates sucessful parsing of the command line
  44   return 0;
  45 }
  46
  47 int
  48 ACE_TMAIN (int argc, ACE_TCHAR *argv[])
  49 {
  50   try
  51     {
  52       CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  53
  54       if (parse_args (argc, argv) != 0)
  55         ACE_ERROR_RETURN ((LM_ERROR,
  56                            ACE_TEXT ("ERROR: wrong arguments\n")),
  57                           -1);
  58
  59       CORBA::Object_var obj = orb->string_to_object (ior);
  60
  61       // Create Hello reference.
  62       Test::UIPMC_Object_var test =
  63         TAO::Narrow_Utils<Test::UIPMC_Object>::unchecked_narrow (obj.in ());
  64
  65       if (CORBA::is_nil (test.in ()))
  66         ACE_ERROR_RETURN ((LM_ERROR,
  67                            ACE_TEXT ("ERROR: IOR is not an UIPMC_Object\n")),
  68                           -1);
  69
  70       for (CORBA::ULong j = 0u; j < threads; ++j)
  71         {
  72           try
  73             {
  74               ACE_DEBUG ((LM_DEBUG, "Sending request %u\n", (unsigned) (j+1u)));
  75               test->process ();
  76             }
  77           catch (const CORBA::Exception& ex)
  78             {
  79               ex._tao_print_exception ("Exception caught during send\n");
  80             }
  81         }
  82
  83       // Give a chance to flush all OS buffers for client.
  84       while (orb->work_pending ())
  85         orb->perform_work ();
  86
  87       ACE_DEBUG ((LM_DEBUG, "Client shutting down\n"));
  88       orb->destroy ();
  89     }
  90   catch (const CORBA::Exception& ex)
  91     {
  92       ex._tao_print_exception ("Exception caught in client main ():");
  93       return -1;
  94     }
  95
  96   ACE_DEBUG ((LM_DEBUG,
  97               ACE_TEXT ("\nClient finished successfully\n")));
  98   return 0;
  99 }