TAO/tests/AMI_Buffering/Client_Task.cpp

   1
   2 #include "Client_Task.h"
   3
   4 Client_Task::Client_Task (CORBA::ORB_ptr orb)
   5   : orb_ (CORBA::ORB::_duplicate (orb))
   6   , terminate_loop_ (0)
   7 {
   8 }
   9
  10 void
  11 Client_Task::terminate_loop ()
  12 {
  13   ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->mutex_);
  14   this->terminate_loop_ = 1;
  15 }
  16
  17 int
  18 Client_Task::svc ()
  19 {
  20   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Starting client task\n"));
  21   try
  22     {
  23       while (1)
  24         {
  25           // run the even loop for 1 second...
  26           ACE_Time_Value tv (1, 0);
  27           this->orb_->run (tv);
  28
  29           ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->mutex_, -1);
  30           if (this->terminate_loop_ != 0)
  31             break;
  32         }
  33     }
  34   catch (const CORBA::Exception&)
  35     {
  36       return -1;
  37     }
  38   ACE_DEBUG ((LM_DEBUG, "(%P|%t) Client task finished\n"));
  39   return 0;
  40 }