TAO/tests/Bug_2356_Regression/client.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file    client.cpp
   5  *
   6  *  A very simple client which uses the AMI callback model.
   7  *
   8  *  @author Johnny Willemsen  <jwillemsen@remedy.nl>
   9  */
  10 //=============================================================================
  11
  12
  13 #include "ace/Get_Opt.h"
  14 #include "ace/Task.h"
  15
  16 #include "ami_testS.h"
  17 #include "tao/Codeset/Codeset.h"
  18
  19 const ACE_TCHAR *ior = ACE_TEXT("file://test.ior");
  20 int niterations = 5;
  21 int shutdown_flag = 1;
  22 int debug = 0;
  23 int result = 0;
  24
  25 int
  26 parse_args (int argc, ACE_TCHAR *argv[])
  27 {
  28   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("dk:"));
  29   int c;
  30
  31   while ((c = get_opts ()) != -1)
  32     switch (c)
  33       {
  34       case 'd':
  35         debug = 1;
  36         break;
  37       case 'k':
  38         ior = get_opts.opt_arg ();
  39         break;
  40       case '?':
  41       default:
  42         ACE_ERROR_RETURN ((LM_ERROR,
  43                            "usage:  %s "
  44                            "-k <ior> "
  45                            "\n",
  46                            argv [0]),
  47                           -1);
  48       }
  49   // Indicates successful parsing of the command line
  50   return 0;
  51 }
  52
  53 class Handler : public POA_A::AMI_AMI_TestHandler
  54 {
  55 public:
  56   /// Constructor.
  57   Handler () = default;
  58
  59   /// Destructor.
  60   ~Handler () = default;
  61
  62   void foo ()
  63     {
  64     };
  65
  66   void foo_excep (::Messaging::ExceptionHolder * excep_holder)
  67     {
  68       ACE_DEBUG ((LM_DEBUG,
  69                   "Callback method <foo_excep> called:\n"
  70                   "Testing proper exception handling ...\n"));
  71       try
  72         {
  73           excep_holder->raise_exception ();
  74         }
  75       catch (const A::DidTheRightThing& ex)
  76         {
  77           ACE_DEBUG ((LM_DEBUG,
  78                       "... exception received successfully: <%d>\n",
  79                       ex.id));
  80 #if defined(ACE_HAS_WCHAR) || defined(ACE_HAS_XPG4_MULTIBYTE_CHAR)
  81           ACE_HEX_DUMP((LM_DEBUG,
  82                         reinterpret_cast<char const *>(ex.whatDidTheRightThing.in()),
  83                         ACE_OS::strlen(ex.whatDidTheRightThing.in()) * sizeof(CORBA::WChar)
  84                         ));
  85
  86           CORBA::WChar const* wstring = L"Hello world";
  87 #else
  88           CORBA::WChar const empty[] = { 0 };
  89           CORBA::WChar const* wstring = empty;
  90 #endif
  91           if (ACE_OS::strcmp (wstring, ex.whatDidTheRightThing.in()) != 0)
  92             {
  93               ex._tao_print_exception ("ERROR");
  94                  ACE_ERROR ((LM_ERROR,
  95                            "... caught the exception but got wrong wstring -> ERROR\n"));
  96               result = 1;
  97             }
  98         }
  99       catch (const CORBA::Exception& ex)
 100         {
 101           ex._tao_print_exception ("ERROR");
 102           ACE_ERROR ((LM_ERROR,
 103                       "... caught the wrong exception -> ERROR\n"));
 104           result = 1;
 105         }
 106     };
 107 };
 108
 109 int
 110 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
 111 {
 112   try
 113     {
 114       CORBA::ORB_var orb =
 115         CORBA::ORB_init (argc, argv);
 116
 117       CORBA::Object_var object_var =
 118         orb->resolve_initial_references ("RootPOA");
 119
 120       PortableServer::POA_var poa_var =
 121         PortableServer::POA::_narrow (object_var.in ());
 122
 123       PortableServer::POAManager_var poa_manager_var =
 124         poa_var->the_POAManager ();
 125
 126       poa_manager_var->activate ();
 127
 128       if (parse_args (argc, argv) != 0)
 129         return 1;
 130
 131       // We reuse the object_var smart pointer!
 132       object_var = orb->string_to_object (ior);
 133
 134       A::AMI_Test_var ami_test_var =
 135         A::AMI_Test::_narrow (object_var.in ());
 136
 137       if (CORBA::is_nil (ami_test_var.in ()))
 138         {
 139           ACE_ERROR_RETURN ((LM_ERROR,
 140                              "Object reference <%s> is nil.\n",
 141                              ior),
 142                             1);
 143         }
 144
 145       // Instantiate the ReplyHandler and register that with the POA.
 146       Handler handler;
 147       PortableServer::ObjectId_var id =
 148         poa_var->activate_object (&handler);
 149
 150       CORBA::Object_var object = poa_var->id_to_reference (id.in ());
 151
 152       A::AMI_AMI_TestHandler_var the_handler_var =
 153         A::AMI_AMI_TestHandler::_narrow (object.in ());
 154
 155       // Trigger the DidTheRightThing exception on the server side
 156       // by sending 0 to it.
 157       ACE_DEBUG ((LM_DEBUG,
 158                   "Sending asynch message\n"));
 159
 160       ami_test_var->sendc_foo (the_handler_var.in (), 0);
 161
 162       if (debug)
 163         {
 164           ACE_DEBUG ((LM_DEBUG,
 165                       "Issuing a synchronous method to collect the AMI replies\n"));
 166         }
 167
 168       ami_test_var->foo (1);
 169
 170       if (shutdown_flag)
 171         {
 172           ami_test_var->shutdown ();
 173         }
 174
 175       poa_var->destroy (1,  // ethernalize objects
 176                         0); // wait for completion
 177
 178       orb->destroy ();
 179     }
 180   catch (const CORBA::Exception& ex)
 181     {
 182       ex._tao_print_exception ("Caught exception:");
 183       return 1;
 184     }
 185
 186   return result;
 187 }