TAO/tests/Crash_On_Write/client.cpp

   1 #include "TestC.h"
   2 #include "ace/Get_Opt.h"
   3 #include "ace/OS_NS_unistd.h"
   4
   5 const ACE_TCHAR *ior = ACE_TEXT("file://test.ior");
   6 int iterations = 2000;
   7
   8 int
   9 parse_args (int argc, ACE_TCHAR *argv[])
  10 {
  11   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:i:"));
  12   int c;
  13
  14   while ((c = get_opts ()) != -1)
  15     switch (c)
  16       {
  17       case 'k':
  18         ior = get_opts.opt_arg ();
  19         break;
  20
  21       case 'i':
  22         iterations = ACE_OS::atoi (get_opts.opt_arg ());
  23         break;
  24
  25       case '?':
  26       default:
  27         ACE_ERROR_RETURN ((LM_ERROR,
  28                            "usage:  %s "
  29                            "-k <ior> "
  30                            "-i iterations "
  31                            "\n",
  32                            argv [0]),
  33                           -1);
  34       }
  35   // Indicates successful parsing of the command line
  36   return 0;
  37 }
  38
  39 int
  40 single_iteration (Test::Oneway_Receiver_ptr oneway_receiver)
  41 {
  42   try
  43     {
  44       oneway_receiver->receive_oneway ();
  45       ACE_Time_Value tv (0, 40000);
  46       ACE_OS::sleep (tv);
  47     }
  48   catch (const CORBA::Exception&)
  49     {
  50       return 1;
  51     }
  52   return 0;
  53 }
  54
  55 int
  56 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  57 {
  58   try
  59     {
  60       CORBA::ORB_var orb =
  61         CORBA::ORB_init (argc, argv);
  62
  63       if (parse_args (argc, argv) != 0)
  64         return 1;
  65
  66       CORBA::Object_var tmp =
  67         orb->string_to_object(ior);
  68
  69       Test::Oneway_Receiver_var oneway_receiver =
  70         Test::Oneway_Receiver::_narrow(tmp.in ());
  71
  72       if (CORBA::is_nil (oneway_receiver.in ()))
  73         {
  74           ACE_ERROR_RETURN ((LM_DEBUG,
  75                              "Nil process reference <%s>\n",
  76                              ior),
  77                             1);
  78         }
  79
  80       int normal_count = 0;
  81       int exception_count = 0;
  82       for (int i = 0; i != iterations; ++i)
  83         {
  84           int result = single_iteration (oneway_receiver.in ());
  85           if (result)
  86             exception_count++;
  87           else
  88             normal_count++;
  89
  90           if (i % 100 == 0)
  91             ACE_DEBUG ((LM_DEBUG, "Finished iteration %d\n", i));
  92
  93           // Lets not waste any more time than we have to
  94           if (exception_count > 10 && normal_count > 0)
  95             break;
  96         }
  97
  98       if (exception_count == 0)
  99         ACE_ERROR ((LM_ERROR, "ERROR: no exceptions detected\n"));
 100
 101       if (normal_count == 0)
 102         ACE_ERROR ((LM_ERROR, "ERROR: no request was succesful\n"));
 103
 104       orb->destroy ();
 105     }
 106   catch (const CORBA::Exception& ex)
 107     {
 108       ex._tao_print_exception ("Exception caught:");
 109       return 1;
 110     }
 111
 112   return 0;
 113 }