TAO/tests/BiDirectional/client.cpp

   1 #include "ace/Get_Opt.h"
   2 #include "test_i.h"
   3 #include "tao/BiDir_GIOP/BiDirGIOP.h"
   4 #include "tao/AnyTypeCode/Any.h"
   5
   6 const ACE_TCHAR *ior = ACE_TEXT("file://test.ior");
   7
   8 void do_nothing ()
   9 {
  10 }
  11
  12 int
  13 parse_args (int argc, ACE_TCHAR *argv[])
  14 {
  15   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:"));
  16   int c;
  17
  18   while ((c = get_opts ()) != -1)
  19     switch (c)
  20       {
  21       case 'k':
  22         ior = get_opts.opt_arg ();
  23         break;
  24
  25       case '?':
  26       default:
  27         ACE_ERROR_RETURN ((LM_ERROR,
  28                            "usage:  %s "
  29                            "-k <ior> "
  30                            "\n",
  31                            argv [0]),
  32                           -1);
  33       }
  34   // Indicates successful parsing of the command line
  35   return 0;
  36 }
  37
  38 int
  39 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  40 {
  41   try
  42     {
  43       CORBA::ORB_var orb =
  44         CORBA::ORB_init (argc, argv);
  45
  46       CORBA::Object_var poa_object =
  47         orb->resolve_initial_references ("RootPOA");
  48
  49       if (CORBA::is_nil (poa_object.in ()))
  50         ACE_ERROR_RETURN ((LM_ERROR,
  51                            " (%P|%t) Unable to initialize the POA.\n"),
  52                           1);
  53
  54       PortableServer::POA_var root_poa =
  55         PortableServer::POA::_narrow (poa_object.in ());
  56
  57       PortableServer::POAManager_var poa_manager =
  58         root_poa->the_POAManager ();
  59
  60       // Policies for the childPOA to be created.
  61       CORBA::PolicyList policies (1);
  62       policies.length (1);
  63
  64       CORBA::Any pol;
  65       pol <<= BiDirPolicy::BOTH;
  66       policies[0] =
  67         orb->create_policy (BiDirPolicy::BIDIRECTIONAL_POLICY_TYPE,
  68                             pol);
  69
  70       // Create POA as child of RootPOA with the above policies.  This POA
  71       // will receive request in the same connection in which it sent
  72       // the request
  73       PortableServer::POA_var child_poa =
  74         root_poa->create_POA ("childPOA",
  75                               poa_manager.in (),
  76                               policies);
  77
  78       // Creation of childPOA is over. Destroy the Policy objects.
  79       for (CORBA::ULong i = 0;
  80            i < policies.length ();
  81            ++i)
  82         {
  83           policies[i]->destroy ();
  84         }
  85
  86       poa_manager->activate ();
  87
  88       if (parse_args (argc, argv) != 0)
  89         return 1;
  90
  91       CORBA::Object_var object =
  92         orb->string_to_object (ior);
  93
  94       Simple_Server_var server =
  95         Simple_Server::_narrow (object.in ());
  96
  97       if (CORBA::is_nil (server.in ()))
  98         {
  99           ACE_ERROR_RETURN ((LM_ERROR,
 100                              "Object reference <%s> is nil.\n",
 101                              ior),
 102                             1);
 103         }
 104
 105       Callback_i callback_impl (orb.in ());
 106
 107       PortableServer::ObjectId_var id =
 108         root_poa->activate_object (&callback_impl);
 109
 110       CORBA::Object_var object_act = root_poa->id_to_reference (id.in ());
 111
 112       Callback_var callback =
 113         Callback::_narrow (object_act.in ());
 114
 115       // Send the callback object to the server
 116       server->callback_object (callback.in ());
 117
 118       // A method to kickstart callbacks from the server
 119       CORBA::Long r =
 120         server->test_method (1);
 121
 122       if (r != 0)
 123         {
 124           ACE_DEBUG ((LM_DEBUG,
 125                       "(%P|%t) unexpected result = %d ",
 126                       r));
 127         }
 128
 129       orb->run ();
 130
 131       root_poa->destroy (true, true);
 132     }
 133   catch (const CORBA::Exception& ex)
 134     {
 135       ex._tao_print_exception ("Caught exception:");
 136       return 1;
 137     }
 138
 139   return 0;
 140 }