TAO/tests/POA/On_Demand_Act_Direct_Coll/Client_Task.cpp

   1 #include "Client_Task.h"
   2 #include "testC.h"
   3
   4 Client_Task::Client_Task (const ACE_TCHAR *ior,
   5                           CORBA::ORB_ptr corb,
   6                           ACE_Thread_Manager *thr_mgr,
   7                           CORBA::Boolean except)
   8   : ACE_Task_Base (thr_mgr)
   9     , input_ (ior)
  10     , corb_ (CORBA::ORB::_duplicate (corb))
  11     , except_ (except)
  12 {
  13 }
  14
  15 int
  16 Client_Task::svc ()
  17 {
  18   int status = 0;
  19   try
  20     {
  21       // Get an object reference from the argument string.
  22       CORBA::Object_var tmp =
  23         this->corb_->string_to_object (input_);
  24
  25       // Try to narrow the object reference to a test reference.
  26       test_var test = test::_narrow (tmp.in ());
  27       if (CORBA::is_nil (test.in ()))
  28         {
  29           ACE_ERROR_RETURN ((LM_DEBUG,
  30                                "Nil Test::Hello reference <%s>\n",
  31                                input_),
  32                                1);
  33          }
  34
  35       CORBA::String_var ior =
  36         this->corb_->object_to_string (test.in ());
  37
  38       ACE_DEBUG ((LM_DEBUG,
  39                    "\nConnecting to: %C\n\n",
  40                    ior.in ()));
  41       try
  42         {
  43            CORBA::String_var the_string = test->get_string ();
  44           if (ACE_OS::strcmp (the_string.in (), "Hello there!") != 0)
  45              {
  46                ACE_ERROR ((LM_ERROR, "(%P|%t) - Error, incorrect string returned <%C>\n",
  47                the_string.in ()));
  48              }
  49            else
  50              {
  51                ACE_DEBUG ((LM_DEBUG, "(%P|%t) - OK , correct string returned <%C>\n",
  52                  the_string.in ()));
  53                }
  54         }
  55       catch (const CORBA::INTERNAL&)
  56          {
  57            if (this->except_)
  58              {
  59                ACE_DEBUG ((LM_DEBUG,
  60                    "OK: Client_Task Expected excep with "
  61                    "direct collocation received\n"));
  62                   status = 0;
  63              }
  64            else
  65              {
  66                ACE_ERROR ((LM_ERROR,
  67                     "ERROR: Client_Task Unxpected exception with"
  68                     "thru_poa collocation received\n"));
  69                    status = 1;
  70              }
  71            corb_->destroy ();
  72            return 1;
  73          }
  74     }
  75   catch (const CORBA::Exception& ex)
  76     {
  77       ex._tao_print_exception ("Exception caught:");
  78       status = 1;
  79     }
  80   corb_->destroy ();
  81   return status;
  82 }