TAO/tests/Bug_1551_Regression/Client_Task.cpp

   1 #include "Client_Task.h"
   2
   3 Client_Task::Client_Task (Test::Hello_ptr receiver,
   4                           CORBA::ORB_ptr orb,
   5                           ACE_Thread_Manager *thr_mgr)
   6   : ACE_Task_Base (thr_mgr)
   7   , receiver_ (Test::Hello::_duplicate (receiver))
   8   , handler_ (new Reply_Handler(receiver, orb))
   9   , handler_var_ (handler_->_this())
  10   , orb_ (CORBA::ORB::_duplicate (orb))
  11 {
  12 }
  13
  14 Client_Task::~Client_Task (void)
  15 {
  16 }
  17
  18 int
  19 Client_Task::svc (void)
  20 {
  21   //  ACE_DEBUG ((LM_DEBUG, "(%P|%t) Starting client task\n"));
  22
  23   try
  24     {
  25       CORBA::Object_var object =
  26         this->orb_->resolve_initial_references ("PolicyCurrent");
  27
  28       CORBA::PolicyCurrent_var policy_current =
  29         CORBA::PolicyCurrent::_narrow (object.in ());
  30
  31       TimeBase::TimeT timeout_period = 20 * 1000;
  32
  33       CORBA::Any timeout_as_any;
  34       timeout_as_any <<= timeout_period;
  35
  36       CORBA::PolicyList policy_list (1);
  37       policy_list.length (1);
  38       policy_list[0] =
  39         this->orb_->create_policy (Messaging::RELATIVE_RT_TIMEOUT_POLICY_TYPE,
  40                                    timeout_as_any);
  41
  42       policy_current->set_policy_overrides (policy_list,
  43                                             CORBA::ADD_OVERRIDE);
  44
  45       policy_list[0]->destroy();
  46
  47       // Start 25 separate concurrent request streams
  48       for (CORBA::Short i = 0; i != 25; ++i)
  49       {
  50         this->receiver_->sendc_short_sleep (this->handler_var_.in ());
  51       }
  52
  53       ACE_Time_Value tv(10, 0);
  54       orb_->run(tv);
  55     }
  56   catch (const CORBA::TIMEOUT&)
  57     {
  58       ACE_DEBUG ((LM_DEBUG,
  59                   "Client received an expected CORBA::TIMEOUT exception.\n"));
  60     }
  61   catch (const CORBA::Exception& ex)
  62     {
  63       ex._tao_print_exception ("(%P|%t) Client_Task - caught exception:");
  64       return -1;
  65     }
  66
  67   return 0;
  68 }