TAO/tests/AMI_Timeouts/client.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file    client.cpp
   5  *
   6  *  A client, which uses the AMI callback model and timeouts.
   7  *
   8  *  @author Michael Kircher <Michael.Kircher@mchp.siemens.de>
   9  */
  10 //=============================================================================
  11
  12
  13 #include "timeout_client.h"
  14
  15 #include "tao/debug.h"
  16
  17 #include "ace/Get_Opt.h"
  18
  19 const ACE_TCHAR *ior = ACE_TEXT("file://test.ior");
  20 unsigned int msec = 50;
  21
  22 int
  23 parse_args (int argc, ACE_TCHAR *argv[])
  24 {
  25   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("dk:t:"));
  26   int c;
  27
  28   while ((c = get_opts ()) != -1)
  29     switch (c)
  30       {
  31       case 'd':
  32         TAO_debug_level++;
  33         break;
  34       case 'k':
  35         ior = get_opts.opt_arg ();
  36         break;
  37       case 't':
  38         msec = ACE_OS::atoi (get_opts.opt_arg ());
  39         break;
  40       case '?':
  41       default:
  42         ACE_ERROR_RETURN ((LM_ERROR,
  43                            "usage:  %s "
  44                            "-d "
  45                            "-k <ior> "
  46                            "-t <timeout in ms> "
  47                            "\n",
  48                            argv [0]),
  49                           -1);
  50       }
  51   // Indicates successful parsing of the command line
  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 object =
  67         orb->string_to_object (ior);
  68
  69       TimeoutObj_var timeout_var =
  70         TimeoutObj::_narrow (object.in ());
  71
  72       if (CORBA::is_nil (timeout_var.in ()))
  73         {
  74           ACE_ERROR_RETURN ((LM_ERROR,
  75                              "Object reference <%s> is nil.\n",
  76                              ior),
  77                             1);
  78         }
  79
  80       // Activate POA to handle the call back.
  81
  82       CORBA::Object_var poa_object =
  83         orb->resolve_initial_references ("RootPOA");
  84
  85       if (CORBA::is_nil (poa_object.in ()))
  86         ACE_ERROR_RETURN ((LM_ERROR,
  87                            " (%P|%t) Unable to initialize the POA.\n"),
  88                           1);
  89
  90       PortableServer::POA_var root_poa =
  91         PortableServer::POA::_narrow (poa_object.in ());
  92
  93       PortableServer::POAManager_var poa_manager =
  94         root_poa->the_POAManager ();
  95
  96       poa_manager->activate ();
  97
  98       // Instantiate reply handler
  99       TimeoutHandler_i timeoutHandler_i;
 100
 101       PortableServer::ObjectId_var id =
 102         root_poa->activate_object (&timeoutHandler_i);
 103
 104       CORBA::Object_var object_act = root_poa->id_to_reference (id.in ());
 105
 106       AMI_TimeoutObjHandler_var timeoutHandler_var =
 107         AMI_TimeoutObjHandler::_narrow (object_act.in ());
 108
 109       // Instantiate client
 110       TimeoutClient client (orb.in (),
 111                             timeout_var.in (),
 112                             timeoutHandler_var.in (),
 113                             &timeoutHandler_i,
 114                             msec);
 115
 116       client.activate ();
 117
 118       // ORB loop.
 119       orb->run ();  // Fetch responses
 120
 121       root_poa->destroy (1,  // ethernalize objects
 122                          0  // wait for completion
 123                         );
 124
 125       // Wait for all the threads to finish before destroying the
 126       // ORB.
 127       (void) client.thr_mgr ()->wait ();
 128
 129       orb->destroy ();
 130
 131       ACE_DEBUG ((LM_DEBUG, "ORB finished\n"));
 132
 133     }
 134   catch (const CORBA::Exception& ex)
 135     {
 136       ex._tao_print_exception ("Caught exception:");
 137       return 1;
 138     }
 139
 140   return 0;
 141 }