TAO/tests/Bug_3333_Regression/client.cpp

   1 #include "TestC.h"
   2 #include "ace/Get_Opt.h"
   3 #include "tao/Messaging/Messaging.h"
   4
   5 const ACE_TCHAR *ior = ACE_TEXT ("file://test.ior");
   6 const ACE_TCHAR *loop_forever_ior = ACE_TEXT ("file://forward_forever.ior");
   7 bool shutdown_only = false;
   8
   9
  10 int
  11 parse_args (int argc, ACE_TCHAR *argv[])
  12 {
  13   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:l:s"));
  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       case 'l':
  23         loop_forever_ior = get_opts.opt_arg ();
  24         break;
  25       case 's':
  26         shutdown_only = true;
  27         break;
  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   try
  45     {
  46       ACE_DEBUG ((LM_DEBUG, "(%P|%t) client - ORB_init()\n"));
  47       CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  48
  49       if (parse_args (argc, argv) != 0)
  50         return 1;
  51
  52       CORBA::Object_var tmp;
  53       Test::Hello_var hello;
  54
  55       if (!shutdown_only)
  56         {
  57           tmp = orb->string_to_object (loop_forever_ior);
  58
  59           if (CORBA::is_nil (tmp.in ()))
  60             {
  61               ACE_ERROR_RETURN ((LM_DEBUG,
  62                                 "ERROR: Nil object from string_to_object of <%s>\n",
  63                                 loop_forever_ior),
  64                                 1);
  65             }
  66
  67           ACE_DEBUG ((LM_DEBUG, "(%P|%t) client - create timeout policy\n"));
  68           // Three second relative roundtrip timeout.
  69           TimeBase::TimeT timeout_period = 30000000u;
  70
  71           CORBA::Any timeout_as_any;
  72           timeout_as_any <<= timeout_period;
  73
  74           CORBA::PolicyList policy_list (1);
  75           policy_list.length (1);
  76           policy_list[0] =
  77             orb->create_policy (Messaging::RELATIVE_RT_TIMEOUT_POLICY_TYPE,
  78                                       timeout_as_any);
  79           tmp = tmp->_set_policy_overrides (policy_list,
  80                                             CORBA::SET_OVERRIDE);
  81
  82           for (CORBA::ULong i = 0;
  83               i < policy_list.length ();
  84               ++i)
  85             {
  86               policy_list[i]->destroy ();
  87             }
  88
  89           try
  90             {
  91               ACE_DEBUG ((LM_DEBUG, "(%P|%t) client - loop_forever narrow\n"));
  92
  93               // This should LOCATION_FORWARD loop until the timeout
  94               hello = Test::Hello::_narrow(tmp.in ());
  95
  96               if (CORBA::is_nil (hello.in ()))
  97                 {
  98                   ACE_ERROR_RETURN ((LM_DEBUG,
  99                                 "ERROR: Nil hello from <%s>\n",
 100                                 loop_forever_ior),
 101                                 1);
 102                 }
 103
 104               ACE_DEBUG ((LM_DEBUG, "(%P|%t) client - loop_forever call\n"));
 105               CORBA::String_var the_string = hello->get_string ();
 106
 107               ACE_ERROR_RETURN ((LM_ERROR,
 108                                   "ERROR - We have managed to invoke a server method. \n"),
 109                                 1);
 110             }
 111           catch (const CORBA::TIMEOUT &)
 112             {
 113               // Hooray - all OK
 114               ACE_DEBUG ((LM_DEBUG, "Test OK - RELATIVE_RT_TIMEOUT ends location forward loop.\n"));
 115             }
 116         }
 117
 118       ACE_DEBUG ((LM_DEBUG, "(%P|%t) client - shutdown server\n"));
 119       tmp = orb->string_to_object (ior);
 120
 121       hello = Test::Hello::_narrow(tmp.in ());
 122
 123       if (CORBA::is_nil (hello.in ()))
 124         {
 125           ACE_ERROR_RETURN ((LM_DEBUG,
 126                         "ERROR: Nil hello from <%s>\n",
 127                         ior),
 128                         1);
 129         }
 130
 131       hello->shutdown ();
 132
 133       ACE_DEBUG ((LM_DEBUG, "(%P|%t) client - End\n"));
 134       orb->destroy ();
 135     }
 136   catch (const CORBA::Exception& ex)
 137     {
 138       ex._tao_print_exception ("ERROR: Exception caught:");
 139       return 1;
 140     }
 141
 142   ACE_DEBUG ((LM_DEBUG, "(%P|%t) client - Test SUCCESSFULL!\n"));
 143   return 0;
 144 }