TAO/tests/BiDirectional/test_i.cpp

   1 #include "test_i.h"
   2
   3 #include "tao/ORB_Core.h"
   4 #include "tao/debug.h"
   5 #include "tao/Transport_Cache_Manager.h"
   6 #include "tao/Thread_Lane_Resources.h"
   7
   8 #if !defined(__ACE_INLINE__)
   9 #include "test_i.inl"
  10 #endif /* __ACE_INLINE__ */
  11
  12 void
  13 Callback_i::shutdown ()
  14 {
  15   ACE_DEBUG ((LM_DEBUG, "Performing clean shutdown\n"));
  16   this->orb_->shutdown (false);
  17 }
  18
  19 void
  20 Callback_i::callback_method (/**/)
  21 {
  22   if (TAO_debug_level > 0)
  23     ACE_DEBUG ((LM_DEBUG, "Callback method called\n"));
  24 }
  25
  26
  27 // ****************************************************************
  28
  29 CORBA::Long
  30 Simple_Server_i::test_method (CORBA::Boolean do_callback
  31  )
  32 {
  33   if (do_callback)
  34     {
  35       this->flag_ = 1;
  36     }
  37
  38   return 0;
  39 }
  40
  41 void
  42 Simple_Server_i::callback_object (Callback_ptr callback
  43  )
  44 {
  45   // Store the callback object
  46   this->callback_ = Callback::_duplicate (callback);
  47 }
  48
  49 int
  50 Simple_Server_i::call_client ()
  51 {
  52   if (this->flag_)
  53     {
  54       for (int times = 0; times < this->no_iterations_; ++times)
  55         {
  56           this->callback_->callback_method ();
  57
  58           // If the cache size has gotten larger this indicates that
  59           // the connection isn't being shared properly, i.e., a new
  60           // connection was created, so we'll abort.
  61           if (this->orb_->orb_core ()->lane_resources ().transport_cache ().current_size () > 1)
  62             {
  63               ACE_ERROR ((LM_ERROR,
  64                           "(%P|%t) The cache has grown, aborting ..\n"));
  65
  66               ACE_OS::abort ();
  67             }
  68         }
  69
  70       this->callback_->shutdown ();
  71       this->flag_ = 0;
  72
  73       return 1;
  74     }
  75
  76   return 0;
  77 }
  78
  79
  80 void
  81 Simple_Server_i::shutdown ()
  82 {
  83   this->orb_->shutdown (false);
  84 }