TAO/tests/Bug_1482_Regression/Client_Task.cpp

   1
   2 #include "Client_Task.h"
   3 #include "tao/Stub.h"
   4
   5 Client_Task::Client_Task (Test::Hello_ptr receiver,
   6                           CORBA::ORB_ptr o,
   7                           ACE_Thread_Manager *thr_mgr)
   8   : ACE_Task_Base (thr_mgr)
   9     , receiver_ (Test::Hello::_duplicate (receiver))
  10     , handler_ (o)
  11     , handler_var_ ()
  12     , orb_ (CORBA::ORB::_duplicate (o))
  13 {
  14   this->handler_var_ = this->handler_._this ();
  15 }
  16
  17 int
  18 Client_Task::svc ()
  19 {
  20   // ACE_DEBUG ((LM_DEBUG, "(%P|%t) Starting client task\n"));
  21
  22   try
  23     {
  24       for (CORBA::Long j = 0;
  25            j != 1000;
  26            ++j)
  27         {
  28           // Send 25 messages in every loop..
  29           for (CORBA::Short i = 0; i != 25; ++i)
  30             {
  31               this->receiver_->sendc_next_prime (this->handler_var_.in ());
  32             }
  33
  34           CORBA::Short repl = 0;
  35           while (repl != 25)
  36             {
  37               CORBA::Boolean pending =
  38                 this->orb_->work_pending ();
  39
  40               if (pending)
  41                 {
  42                   this->orb_->perform_work ();
  43
  44                   ++repl;
  45                 }
  46             }
  47         }
  48     }
  49   catch (const CORBA::Exception&)
  50     {
  51       return -1;
  52     }
  53   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Client task finished\n"));
  54   return 0;
  55 }