TAO/orbsvcs/tests/Notify/Bug_3252_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 ()
   8  : ma_barrier_(),
   9    mv_orb_ (),
  10    mv_rootPOA_ ()
  11 {
  12 }
  13
  14 DllOrb::~DllOrb ()
  15 {
  16 }
  17
  18 int
  19 DllOrb::init (int argc, ACE_TCHAR *argv[])
  20 {
  21   int threadCnt = 1;
  22
  23   try
  24   {
  25     ACE_Arg_Shifter as (argc, argv);
  26     const ACE_TCHAR *currentArg = 0;
  27     while (as.is_anything_left ())
  28     {
  29       if (0 != (currentArg = as.get_the_parameter (ACE_TEXT ("-NumThreads"))))
  30       {
  31         int num = ACE_OS::atoi (currentArg);
  32         if (num >= 1)
  33           threadCnt = num;
  34         as.consume_arg ();
  35       }
  36       else
  37         as.ignore_arg ();
  38     }
  39
  40     // Initialize the ORB
  41     mv_orb_ = CORBA::ORB_init (argc, argv);
  42     if (CORBA::is_nil (mv_orb_.in ()))
  43     {
  44       ACE_DEBUG ((LM_ERROR, ACE_TEXT ("nil ORB\n")));
  45       return -1;
  46     }
  47
  48     CORBA::Object_var v_poa =
  49       mv_orb_->resolve_initial_references ("RootPOA");
  50
  51     mv_rootPOA_ = PortableServer::POA::_narrow (v_poa.in ());
  52     if (CORBA::is_nil (mv_rootPOA_.in ()))
  53     {
  54       ACE_DEBUG ((LM_ERROR, ACE_TEXT ("nil RootPOA\n")));
  55       return -1;
  56     }
  57
  58     mv_poaManager_ = mv_rootPOA_->the_POAManager ();
  59     if (CORBA::is_nil (mv_poaManager_.in ()))
  60     {
  61       ACE_DEBUG ((LM_ERROR, ACE_TEXT ("nil POAManager\n")));
  62       return -1;
  63     }
  64
  65     mv_poaManager_->activate ();
  66   }
  67   catch (...)
  68   {
  69     ACE_DEBUG ((LM_ERROR, ACE_TEXT ("ERROR: exception\n")));
  70     return -1;
  71   }
  72
  73   ma_barrier_.reset (new ACE_Thread_Barrier (threadCnt + 1));
  74
  75   this->activate(
  76     THR_NEW_LWP|THR_JOINABLE|THR_INHERIT_SCHED,
  77     threadCnt);
  78   ACE_DEBUG ((LM_INFO, ACE_TEXT ("init mp_barrier->wait() ...\n")));
  79   ma_barrier_->wait();
  80   ACE_DEBUG ((LM_INFO, ACE_TEXT ("init mp_barrier->wait() done\n")));
  81
  82   return 0;
  83 }
  84
  85 int
  86 DllOrb::fini ()
  87 {
  88   try
  89   {
  90     mv_poaManager_->deactivate (1, 1);
  91     mv_poaManager_ = PortableServer::POAManager::_nil ();
  92
  93     // attempt to protect against sporadic BAD_INV_ORDER exceptions
  94     ACE_OS::sleep (ACE_Time_Value (0, 500));
  95
  96       mv_rootPOA_->destroy (1, 1);
  97
  98       mv_rootPOA_ = PortableServer::POA::_nil ();
  99     mv_orb_->shutdown (true);
 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     ma_barrier_.reset ();
 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 int DllOrb::svc ()
 129 {
 130   ACE_DEBUG ((LM_INFO, ACE_TEXT ("svc mp_barrier->wait() ...\n")));
 131   ma_barrier_->wait();
 132   ACE_DEBUG ((LM_INFO, ACE_TEXT ("svc mp_barrier->wait() done\n")));
 133
 134   try
 135   {
 136     ACE_DEBUG ((LM_INFO, ACE_TEXT ("mv_orb->run ...\n")));
 137     try
 138     {
 139       mv_orb_->run();
 140       ACE_DEBUG ((LM_INFO, ACE_TEXT ("mv_orb->run returned\n")));
 141     }
 142     catch(CORBA::BAD_INV_ORDER const & rc_ex)
 143     {
 144       const CORBA::ULong VMCID = rc_ex.minor() & 0xFFFFF000U;
 145       const CORBA::ULong minorCode = rc_ex.minor() & 0xFFFU;
 146       if (VMCID == CORBA::OMGVMCID && minorCode == 4)
 147       {
 148         ACE_DEBUG ((LM_INFO, ACE_TEXT ("ignored 'CORBA::BAD_INV_ORDER: ORB has shutdown.'\n")));
 149       }
 150       else
 151       {
 152         throw;
 153       }
 154     }
 155     ACE_DEBUG ((LM_INFO, ACE_TEXT ("mv_orb->run done\n")));
 156   }
 157   catch(...)
 158   {
 159     ACE_DEBUG ((LM_INFO, ACE_TEXT ("Exception\n")));
 160     return -1;
 161   }
 162
 163   return 0;
 164 } /* end of DllOrb::svc () */
 165
 166
 167 ACE_FACTORY_DEFINE (bug_3252, DllOrb)