TAO/tests/Muxing/Client_Task.cpp

   1
   2 #include "Client_Task.h"
   3
   4 Client_Task::Client_Task (Test::Receiver_ptr receiver,
   5                           CORBA::Long event_count,
   6                           CORBA::ULong event_size,
   7                           ACE_Thread_Manager *thr_mgr)
   8   : ACE_Task_Base (thr_mgr)
   9   , receiver_ (Test::Receiver::_duplicate (receiver))
  10   , event_count_ (event_count)
  11   , event_size_ (event_size)
  12 {
  13 }
  14
  15 int
  16 Client_Task::svc ()
  17 {
  18   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Starting client task\n"));
  19   Test::Payload payload (this->event_size_);
  20   payload.length (this->event_size_);
  21
  22   for (CORBA::ULong j = 0; j != payload.length (); ++j)
  23     payload[j] = (j % 256);
  24
  25   try
  26     {
  27       for (int i = 0; i != this->event_count_; ++i)
  28         {
  29           this->receiver_->receive_data (payload);
  30         }
  31     }
  32   catch (const CORBA::Exception&)
  33     {
  34       return -1;
  35     }
  36   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Client task finished\n"));
  37   return 0;
  38 }