TAO/tests/Bug_2966_Regression/client.cpp

   1 // -*- C++ -*-
   2 #include "tao/DynamicInterface/Request.h"
   3 #include "tao/DynamicInterface/DII_CORBA_methods.h"
   4 #include "TestC.h"
   5 #include "ace/Get_Opt.h"
   6 #include "ace/OS_NS_unistd.h"
   7
   8 const ACE_TCHAR *ior = ACE_TEXT("file://test.ior");
   9
  10 int
  11 parse_args (int argc, ACE_TCHAR *argv[])
  12 {
  13   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:"));
  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
  23       case '?':
  24       default:
  25         ACE_ERROR_RETURN ((LM_ERROR,
  26                            "usage:  %s "
  27                            "-k <ior> "
  28                            "\n",
  29                            argv [0]),
  30                           -1);
  31       }
  32   // Indicates successful parsing of the command line
  33   return 0;
  34 }
  35
  36 int
  37 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  38 {
  39   try
  40     {
  41       CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  42
  43       if (parse_args (argc, argv) != 0)
  44         return 1;
  45
  46       CORBA::Object_var obj = orb->string_to_object(ior);
  47
  48       const char* the_string = 0;
  49
  50       ACE_DEBUG ((LM_INFO, "(%P|%t) - #### Synchronous twoway DII\n"));
  51
  52       CORBA::Request_var req = obj->_request ("get_string");
  53       req->set_return_type (CORBA::_tc_string);
  54
  55       req->invoke ();
  56       req->return_value () >>= the_string;
  57
  58       ACE_DEBUG ((LM_DEBUG, "(%P|%t) - string returned <%C>\n",
  59                   the_string));
  60
  61       ACE_DEBUG ((LM_INFO, "(%P|%t) - #### Deferred twoway DII (using get_response())\n"));
  62
  63       req = obj->_request ("get_string");
  64       req->set_return_type (CORBA::_tc_string);
  65
  66       req->send_deferred ();
  67       ACE_DEBUG ((LM_INFO, "(%P|%t) - Get response...\n"));
  68       req->get_response ();
  69       req->return_value () >>= the_string;
  70
  71       ACE_DEBUG ((LM_DEBUG, "(%P|%t) - string returned <%C>\n",
  72                   the_string));
  73
  74       ACE_DEBUG ((LM_INFO, "(%P|%t) - #### Deferred twoway DII (using poll_response())\n"));
  75
  76       req = obj->_request ("get_string");
  77       req->set_return_type (CORBA::_tc_string);
  78
  79       req->send_deferred ();
  80       do {
  81         ACE_OS::sleep(1);
  82         ACE_DEBUG ((LM_INFO, "(%P|%t) - Polling...\n"));
  83       } while (!req->poll_response ());
  84       req->return_value () >>= the_string;
  85
  86       ACE_DEBUG ((LM_DEBUG, "(%P|%t) - string returned <%C>\n",
  87                   the_string));
  88
  89       ACE_DEBUG ((LM_INFO, "(%P|%t) - #### Oneway shutdown DII\n"));
  90
  91       req = obj->_request ("shutdown");
  92       req->send_oneway ();
  93
  94       orb->destroy ();
  95     }
  96   catch (const CORBA::Exception& ex)
  97     {
  98       ex._tao_print_exception ("Exception caught:");
  99       return 1;
 100     }
 101
 102   return 0;
 103 }