TAO/tests/Bug_3827_Regression/test.cpp

   1 #include "MessageC.h"
   2 #include "ace/Task.h"
   3 #include "ace/OS_NS_unistd.h"
   4
   5 int status = 0;
   6
   7 class ORB_Task : public ACE_Task_Base
   8 {
   9 public:
  10   ORB_Task (CORBA::ORB_ptr orb)
  11     : orb_ (CORBA::ORB::_duplicate (orb))
  12   {
  13   }
  14
  15   virtual int svc ()
  16   {
  17     try
  18       {
  19         ACE_DEBUG ((LM_DEBUG, "(%P|%t) Event loop started\n"));
  20         this->orb_->run ();
  21         ACE_DEBUG ((LM_DEBUG, "(%P|%t) Event loop finished\n"));
  22       }
  23     catch (const CORBA::Exception& )
  24       {
  25       }
  26     return 0;
  27   }
  28
  29 private:
  30   CORBA::ORB_var orb_;
  31 };
  32
  33 class Worker_Task : public ACE_Task_Base
  34 {
  35 public:
  36   Worker_Task (CORBA::ORB_ptr orb)
  37     : orb_ (CORBA::ORB::_duplicate (orb))
  38   {
  39   }
  40
  41   virtual int svc ()
  42   {
  43     try
  44       {
  45         Message_init *mi = new Message_init ();
  46         CORBA::ValueFactoryBase_var safe (mi);
  47
  48         while (1)
  49           {
  50             CORBA::ValueFactoryBase_var tmp1 =
  51               this->orb_->register_value_factory (mi->tao_repository_id (), mi);
  52
  53             CORBA::ValueFactoryBase_var tmp2 =
  54               this->orb_->lookup_value_factory (mi->tao_repository_id ());
  55
  56             this->orb_->unregister_value_factory (mi->tao_repository_id ());
  57           }
  58       }
  59     catch (const CORBA::BAD_INV_ORDER&)
  60       {
  61         // It's ok to ignore BAD_INV_ORDER which can be thrown after orb
  62         // is shutdown from other thread.
  63       }
  64     catch (const CORBA::Exception&)
  65       {
  66         ACE_ERROR ((LM_ERROR,
  67                     ACE_TEXT ("ERROR: Unexpected exception.\n")));
  68         status = 1;
  69       }
  70     return 0;
  71   }
  72
  73 private:
  74   CORBA::ORB_var orb_;
  75 };
  76
  77 int
  78 ACE_TMAIN (int argc, ACE_TCHAR *argv[])
  79 {
  80   try
  81     {
  82       CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  83
  84       ORB_Task orb_runner (orb.in ());
  85       if (orb_runner.activate (THR_NEW_LWP | THR_JOINABLE, 1) == -1)
  86         {
  87           ACE_ERROR_RETURN ((LM_ERROR,
  88                              "ERROR: Can not start ORB thread\n"),
  89                             -1);
  90         }
  91
  92       ACE_OS::sleep (1);
  93
  94       Worker_Task work_runner (orb.in ());
  95       if (work_runner.activate (THR_NEW_LWP | THR_JOINABLE, 10) == -1)
  96         {
  97           ACE_ERROR_RETURN ((LM_ERROR,
  98                              "ERROR: Can not start work threads\n"),
  99                             -1);
 100         }
 101
 102       ACE_OS::sleep (1);
 103
 104       ACE_DEBUG ((LM_DEBUG,
 105                   ACE_TEXT ("(%P|%t) Shutting down / destroying ORB\n")));
 106
 107       orb->shutdown (false);
 108
 109       ACE_Thread_Manager::instance ()->wait ();
 110
 111       orb->destroy ();
 112     }
 113   catch (const CORBA::Exception& ex)
 114     {
 115       ex._tao_print_exception ("Exception caught:");
 116       return 1;
 117     }
 118
 119   return status;
 120 }