TAO/tests/Collocation_Oneway_Tests/Hello.cpp

   1 #include "Hello.h"
   2 #include "tao/ORB_Core.h"
   3 #include "tao/ORB_Table.h"
   4 #include "tao/ORB_Core_Auto_Ptr.h"
   5
   6 Hello::Hello (CORBA::ORB_ptr orb,
   7               ACE_thread_t thrid)
   8   : orb_ (CORBA::ORB::_duplicate (orb))
   9     , thr_id_ (thrid)
  10 {
  11 }
  12
  13 void
  14 Hello::onewayTest (void)
  15 {
  16   ACE_DEBUG ((LM_DEBUG,
  17               "(%P|%t) onewayTest() Upcall in process ..\n"));
  18   return;
  19 }
  20
  21
  22 char *
  23 Hello::get_string (void)
  24 {
  25   ACE_DEBUG ((LM_DEBUG,
  26               "(%P|%t) Upcall in process ..\n"));
  27
  28   // Use portable thread IDs
  29   ACE_Thread_ID self_ID;
  30   ACE_Thread_ID this_ID;
  31   this_ID.id(this->thr_id_);
  32
  33   if (self_ID == this_ID)
  34     {
  35       if (this->orb_->orb_core ()->optimize_collocation_objects () &&
  36           this->orb_->orb_core ()->use_global_collocation ())
  37         {
  38           ACE_ERROR ((LM_ERROR,
  39                       "(%P|%t) ERROR: A remote call has been made "
  40                       " exiting ..\n"));
  41           ACE_OS::abort ();
  42         }
  43       else if (this->orb_->orb_core ()->optimize_collocation_objects () &&
  44                this->orb_->orb_core ()->use_global_collocation () == 0)
  45         {
  46           TAO::ORB_Table * const orb_table =
  47             TAO::ORB_Table::instance ();
  48
  49           TAO_ORB_Core_Auto_Ptr tmp (orb_table->find ("server_orb"));
  50           if (tmp.get () == 0)
  51             {
  52               // We are running on a single ORB and this is an error.
  53               ACE_ERROR ((LM_ERROR,
  54                           "(%P|%t) ERROR: A remote call has been made "
  55                           " with a single ORB "
  56                           " exiting ..\n"));
  57               ACE_OS::abort ();
  58             }
  59         }
  60     }
  61
  62   return CORBA::string_dup ("Hello there!");
  63 }
  64
  65 void
  66 Hello::shutdown (void)
  67 {
  68   this->orb_->shutdown (0);
  69 }