TAO/tests/BiDirectional_NestedUpcall/test_i.cpp

   1 #include "test_i.h"
   2 #include "tao/ORB_Core.h"
   3 #include "tao/debug.h"
   4 #include "tao/Transport_Cache_Manager.h"
   5 #include "tao/Thread_Lane_Resources.h"
   6
   7 #if !defined(__ACE_INLINE__)
   8 #include "test_i.inl"
   9 #endif /* __ACE_INLINE__ */
  10
  11 void
  12 Callback_i::shutdown ()
  13 {
  14   ACE_DEBUG ((LM_DEBUG, "Performing clean shutdown\n"));
  15   this->orb_->shutdown (false);
  16 }
  17
  18 void
  19 Callback_i::callback_method (/**/)
  20 {
  21   if (TAO_debug_level > 0)
  22     ACE_DEBUG ((LM_DEBUG, "Callback method called\n"));
  23 }
  24
  25
  26 // ****************************************************************
  27
  28 CORBA::Long
  29 Simple_Server_i::test_method (CORBA::Boolean do_callback)
  30 {
  31   if (do_callback)
  32     {
  33       if (TAO_debug_level > 0)
  34       ACE_DEBUG ((LM_DEBUG,
  35                   ACE_TEXT ("About to make a remote call in the Upcall\n")));
  36
  37       for (int times = 0;
  38            times < this->no_iterations_;
  39            ++times)
  40         {
  41           this->callback_->callback_method ();
  42
  43           if (this->orb_->orb_core ()->lane_resources ().transport_cache ().current_size () > 1)
  44             {
  45               ACE_ERROR ((LM_ERROR,
  46                           "(%P|%t) The cache has grown, aborting ..\n"));
  47
  48               ACE_OS::abort ();
  49             }
  50         }
  51     }
  52
  53   return 0;
  54 }
  55
  56 void
  57 Simple_Server_i::callback_object (Callback_ptr callback
  58  )
  59 {
  60   // Store the callback object
  61   this->callback_ = Callback::_duplicate (callback);
  62 }
  63
  64
  65 void
  66 Simple_Server_i::shutdown ()
  67 {
  68   this->orb_->shutdown (false);
  69 }