TAO/tests/Bug_3542_Regression/DllOrb.cpp

   1 #include "DllOrb.h"
   2 #include "ace/Arg_Shifter.h"
   3 #include "ace/Argv_Type_Converter.h"
   4 #include "ace/OS_NS_unistd.h"
   5 #include "tao/TAO_Singleton_Manager.h"
   6
   7 DllOrb::DllOrb (void)
   8  :
   9    ma_barrier_(),
  10    mv_orb_ (),
  11    mv_rootPOA_ ()
  12 {
  13 }
  14
  15 DllOrb::~DllOrb (void)
  16 {
  17 }
  18
  19 int
  20 DllOrb::init (int argc, ACE_TCHAR *argv[])
  21 {
  22   int threadCnt = 1;
  23
  24   try
  25   {
  26     ACE_Arg_Shifter as (argc, argv);
  27     const ACE_TCHAR *currentArg = 0;
  28     while (as.is_anything_left ())
  29     {
  30       if (0 != (currentArg = as.get_the_parameter (ACE_TEXT ("-NumThreads"))))
  31       {
  32         int num = ACE_OS::atoi (currentArg);
  33         if (num >= 1)
  34           threadCnt = num;
  35         as.consume_arg ();
  36       }
  37       else
  38         as.ignore_arg ();
  39     }
  40
  41     // Initialize the ORB
  42     mv_orb_ = CORBA::ORB_init (argc, argv);
  43     if (CORBA::is_nil (mv_orb_.in ()))
  44     {
  45       ACE_DEBUG ((LM_ERROR, ACE_TEXT ("nil ORB\n")));
  46       return -1;
  47     }
  48
  49     CORBA::Object_var v_poa =
  50       mv_orb_->resolve_initial_references ("RootPOA");
  51
  52     mv_rootPOA_ = PortableServer::POA::_narrow (v_poa.in ());
  53     if (CORBA::is_nil (mv_rootPOA_.in ()))
  54     {
  55       ACE_DEBUG ((LM_ERROR, ACE_TEXT ("nil RootPOA\n")));
  56       return -1;
  57     }
  58
  59     mv_poaManager_ = mv_rootPOA_->the_POAManager ();
  60     if (CORBA::is_nil (mv_poaManager_.in ()))
  61     {
  62       ACE_DEBUG ((LM_ERROR, ACE_TEXT ("nil POAManager\n")));
  63       return -1;
  64     }
  65
  66     mv_poaManager_->activate ();
  67   }
  68   catch (...)
  69   {
  70     ACE_DEBUG ((LM_ERROR, ACE_TEXT ("ERROR: exception\n")));
  71     return -1;
  72   }
  73
  74   ACE_auto_ptr_reset (ma_barrier_, new ACE_Thread_Barrier (threadCnt + 1));
  75
  76   this->activate(
  77     THR_NEW_LWP|THR_JOINABLE|THR_INHERIT_SCHED,
  78     threadCnt
  79   );
  80   ACE_DEBUG ((LM_INFO, ACE_TEXT ("init mp_barrier->wait() ...\n")));
  81   ma_barrier_->wait();
  82   ACE_DEBUG ((LM_INFO, ACE_TEXT ("init mp_barrier->wait() done\n")));
  83
  84   return 0;
  85 }
  86
  87
  88 int
  89 DllOrb::fini (void)
  90 {
  91   try
  92   {
  93     mv_poaManager_->deactivate (1, 1);
  94     mv_poaManager_ = PortableServer::POAManager::_nil ();
  95
  96     // attempt to protect against sporadic BAD_INV_ORDER exceptions
  97     ACE_OS::sleep (ACE_Time_Value (0, 500));
  98
  99     mv_orb_->shutdown (1);
 100
 101     ACE_DEBUG ((LM_ERROR, ACE_TEXT ("wait() ...\n")));
 102     // wait for our threads to finish
 103     wait();
 104     ACE_DEBUG ((LM_ERROR, ACE_TEXT ("wait() done\n")));
 105
 106     ACE_auto_ptr_reset (ma_barrier_, static_cast<ACE_Thread_Barrier *> (0));
 107   }
 108   catch (...)
 109   {
 110     ACE_DEBUG ((LM_ERROR, ACE_TEXT ("ERROR: exception\n")));
 111     return -1;
 112   }
 113
 114   try
 115   {
 116     mv_orb_->destroy ();
 117     mv_orb_ = CORBA::ORB::_nil ();
 118   }
 119   catch (const CORBA::Exception& ex)
 120   {
 121     ex._tao_print_exception ("Exception caught:");
 122     return -1;
 123   }
 124
 125   return 0;
 126 }
 127
 128
 129 int DllOrb::svc (void)
 130 {
 131   ACE_DEBUG ((LM_INFO, ACE_TEXT ("svc mp_barrier->wait() ...\n")));
 132   ma_barrier_->wait();
 133   ACE_DEBUG ((LM_INFO, ACE_TEXT ("svc mp_barrier->wait() done\n")));
 134
 135   try
 136   {
 137     ACE_DEBUG ((LM_INFO, ACE_TEXT ("mv_orb->run ...\n")));
 138     try
 139     {
 140       mv_orb_->run();
 141       ACE_DEBUG ((LM_INFO, ACE_TEXT ("mv_orb->run returned\n")));
 142     }
 143     catch(CORBA::BAD_INV_ORDER const & rc_ex)
 144     {
 145       const CORBA::ULong VMCID = rc_ex.minor() & 0xFFFFF000U;
 146       const CORBA::ULong minorCode = rc_ex.minor() & 0xFFFU;
 147       if (VMCID == CORBA::OMGVMCID && minorCode == 4)
 148       {
 149         ACE_DEBUG ((LM_INFO, ACE_TEXT ("ignored 'CORBA::BAD_INV_ORDER: ORB has shutdown.'\n")));
 150       }
 151       else
 152       {
 153         throw;
 154       }
 155     }
 156     ACE_DEBUG ((LM_INFO, ACE_TEXT ("mv_orb->run done\n")));
 157   }
 158   catch(...)
 159   {
 160     ACE_DEBUG ((LM_INFO, ACE_TEXT ("Exception\n")));
 161     return -1;
 162   }
 163
 164   return 0;
 165 } /* end of DllOrb::svc ( ) */
 166
 167
 168 ACE_FACTORY_DEFINE (bug_3542, DllOrb)