TAO/examples/CSD_Strategy/ThreadPool/OrbShutdownTask.cpp

   1 //=============================================================================
   2 /**
   3  *  @file    OrbShutdownTask.cpp
   4  *
   5  *  @author  Tim Bradley <bradley_t@ociweb.com>
   6  */
   7 //=============================================================================
   8
   9 #include "OrbShutdownTask.h"
  10 #include "ace/CORBA_macros.h"
  11 #include "ace/OS_NS_unistd.h"
  12
  13 OrbShutdownTask::OrbShutdownTask()
  14 {
  15 }
  16
  17 void
  18 OrbShutdownTask::orb(CORBA::ORB_ptr orb)
  19 {
  20   this->orb_ = CORBA::ORB::_duplicate (orb);
  21 }
  22
  23 int
  24 OrbShutdownTask::open(void*)
  25 {
  26   if (this->activate(THR_NEW_LWP | THR_JOINABLE, 1) != 0)
  27     {
  28       //FUZZ: disable check_for_lack_ACE_OS
  29       // Assumes that when activate returns non-zero return code that
  30       // no threads were activated.
  31       ACE_ERROR_RETURN((LM_ERROR,
  32                         "(%P|%t) OrbShutdownTask failed to open().\n"),
  33                        -1);
  34       //FUZZ: enable check_for_lack_ACE_OS
  35     }
  36
  37   return 0;
  38 }
  39
  40 int
  41 OrbShutdownTask::svc()
  42 {
  43   ACE_OS::sleep (2);
  44   ACE_DEBUG ((LM_DEBUG, "(%P|%t)OrbShutdownTask::svc shutdown orb\n"));
  45   try
  46   {
  47     this->orb_->shutdown(0);
  48   }
  49   catch (...)
  50   {
  51     ACE_ERROR((LM_ERROR,
  52       "(%P|%t) Exception raised by ORB::shutdown() call "
  53       "in OrbShutdownTask::svc().\n"));
  54   }
  55
  56   return 0;
  57 }
  58
  59 int
  60 OrbShutdownTask::close(u_long)
  61 {
  62   return 0;
  63 }