TAO/tests/Dynamic_TP/ORB_ThreadPool/Client.cpp

   1 #include "TestC.h"
   2 #include "ace/Get_Opt.h"
   3 #include "ace/Task.h"
   4
   5 class MT_Requestor : public virtual ACE_Task_Base
   6 {
   7 public:
   8   MT_Requestor (Test::Middle_ptr m, CORBA::Short sec);
   9
  10   virtual int svc ();
  11 private:
  12   Test::Middle_var middle_;
  13   CORBA::Short seconds_;
  14 };
  15
  16 MT_Requestor::MT_Requestor (Test::Middle_ptr m, CORBA::Short sec)
  17   : middle_ (Test::Middle::_duplicate (m)),
  18     seconds_ (sec)
  19
  20 {
  21 }
  22
  23 int
  24 MT_Requestor::svc ()
  25 {
  26   int retries = 5;
  27   while (retries-- > 0)
  28     {
  29       ACE_DEBUG ((LM_DEBUG,
  30                   ACE_TEXT ("Client thread %t calling delay with %d retries\n"),
  31                   retries));
  32       try
  33         {
  34           this->middle_->call_delay(seconds_);
  35           ACE_DEBUG ((LM_DEBUG,
  36                       ACE_TEXT ("Client thread %t delay succeeded\n")));
  37           break;
  38         }
  39       catch (const CORBA::Exception &ex)
  40         {
  41           ACE_DEBUG ((LM_DEBUG,
  42                       ACE_TEXT ("Client thread %t caught %s\n"),
  43                       ex._name()));
  44         }
  45     }
  46   ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Client thread %t done\n")));
  47   return 0;
  48 }
  49
  50 const ACE_TCHAR *ior = ACE_TEXT("file://middle.ior");
  51 bool do_shutdown = false;
  52 CORBA::Short sec = 2;
  53 int num_threads = 1;
  54
  55 int
  56 parse_args (int argc, ACE_TCHAR *argv[])
  57 {
  58   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:n:s:x"));
  59   int c;
  60
  61   while ((c = get_opts ()) != -1)
  62     switch (c)
  63       {
  64       case 'k':
  65         ior = get_opts.opt_arg ();
  66         break;
  67       case 'n':
  68         num_threads = ACE_OS::atoi (get_opts.opt_arg ());
  69         break;
  70       case 's':
  71         sec = ACE_OS::atoi (get_opts.opt_arg ());
  72         break;
  73       case 'x':
  74         do_shutdown = true;
  75         break;
  76       case '?':
  77       default:
  78         ACE_ERROR_RETURN ((LM_ERROR,
  79                            "usage:  %s "
  80                            "-k <ior> "
  81                            "-n <threads> "
  82                            "-x "
  83                            "\n",
  84                            argv [0]),
  85                           -1);
  86       }
  87   // Indicates successful parsing of the command line
  88   return 0;
  89 }
  90
  91 int
  92 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  93 {
  94   try
  95     {
  96       CORBA::ORB_var orb =
  97         CORBA::ORB_init (argc, argv);
  98
  99       if (parse_args (argc, argv) != 0)
 100         return 1;
 101
 102       CORBA::Object_var tmp =
 103         orb->string_to_object(ior);
 104
 105       Test::Middle_var middle =
 106         Test::Middle::_narrow(tmp.in ());
 107
 108       if (CORBA::is_nil (middle.in ()))
 109         {
 110           ACE_ERROR_RETURN ((LM_DEBUG,
 111                              "Nil Test::Middle reference <%s>\n",
 112                              ior),
 113                             1);
 114         }
 115
 116       MT_Requestor requestor (middle.in(), sec);
 117       requestor.activate (THR_NEW_LWP | THR_JOINABLE, num_threads);
 118       requestor.wait ();
 119
 120       if (do_shutdown)
 121       {
 122         middle->shutdown();
 123       }
 124
 125       orb->destroy ();
 126     }
 127   catch (const CORBA::Exception& ex)
 128     {
 129       ex._tao_print_exception ("Client main exception caught:");
 130       return 1;
 131     }
 132
 133   return 0;
 134 }