TAO/tests/DII_Deferred_Transient/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) - #### Deferred twoway DII (using get_response())\n"));
  51
  52       CORBA::Request_var req = obj->_request ("get_string");
  53       req->set_return_type (CORBA::_tc_string);
  54
  55       req->send_deferred ();
  56       ACE_DEBUG ((LM_INFO, "(%P|%t) - Get response...\n"));
  57       req->get_response ();
  58       req->return_value () >>= the_string;
  59
  60       ACE_DEBUG ((LM_DEBUG, "(%P|%t) - string returned <%C>\n",
  61                   the_string));
  62
  63       ACE_DEBUG ((LM_INFO, "(%P|%t) - #### Oneway DII to initiate crash\n"));
  64
  65       req = obj->_request ("crash");
  66
  67       req->send_oneway ();
  68
  69       ACE_OS::sleep(1); // give it some time
  70
  71       ACE_DEBUG ((LM_INFO, "(%P|%t) - #### Multiple deferred twoway DII (with discarded replies)\n"));
  72
  73       int iterations = 10;
  74       int exceptions = 0;
  75       for (int i=0; i<iterations ;++i)
  76       {
  77         try
  78         {
  79           ACE_DEBUG ((LM_INFO, "(%P|%t) - get_string iteration #%d\n", i));
  80
  81           req = obj->_request ("get_string");
  82           req->set_return_type (CORBA::_tc_string);
  83
  84           req->send_deferred ();
  85           // discard reply
  86
  87           ACE_DEBUG ((LM_INFO, "(%P|%t) - sent deferred\n"));
  88         }
  89         catch (const CORBA::Exception&)
  90         {
  91           ++exceptions;
  92         }
  93       }
  94
  95       if (exceptions == 0)
  96       {
  97         ACE_DEBUG ((LM_ERROR, "(%P|%t) - All requests unexpectedly succeeded\n"));
  98       }
  99       else
 100       {
 101         ACE_DEBUG ((LM_INFO, "(%P|%t) - Caught exceptions from requests as expected (%d)\n", exceptions));
 102       }
 103
 104       orb->destroy ();
 105     }
 106   catch (const CORBA::Exception& ex)
 107     {
 108       ex._tao_print_exception ("Exception caught:");
 109       return 1;
 110     }
 111
 112   return 0;
 113 }