TAO/orbsvcs/tests/Bug_4080_Regression/test_impl.cpp

   1
   2 #include "test_impl.h"
   3
   4 UIPMC_Object_Impl::UIPMC_Object_Impl (CORBA::ORB_ptr orb,
   5                                       CORBA::ULong num_threads)
   6   : orb_ (CORBA::ORB::_duplicate (orb))
   7   , barrier_ ((unsigned int) num_threads)
   8   , lock_ ()
   9 {
  10 }
  11
  12 UIPMC_Object_Impl::~UIPMC_Object_Impl (void)
  13 {
  14 }
  15
  16 void
  17 UIPMC_Object_Impl::process ()
  18 {
  19   ACE_DEBUG ((LM_DEBUG, "Server %t received a message\n"));
  20   this->barrier_.wait ();
  21   static bool shutdown=false;
  22   if (!shutdown)
  23     {
  24       ACE_GUARD (TAO_SYNCH_MUTEX, guard, this->lock_);
  25       if (!shutdown)
  26         {
  27           shutdown=true;
  28           ACE_DEBUG ((LM_DEBUG, "Server %t Shutting down\n"));
  29           try
  30             {
  31               this->orb_->shutdown (0);
  32             }
  33           catch (const CORBA::Exception& ex)
  34             {
  35               ex._tao_print_exception (
  36                 "Server %t, Exception caught in shutdown():");
  37             }
  38         }
  39     }
  40 }