TAO/orbsvcs/tests/HTIOP/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
  13 void
  14 Callback_i::shutdown ()
  15 {
  16   ACE_DEBUG ((LM_DEBUG, "Performing clean shutdown\n"));
  17   this->orb_->shutdown (false);
  18 }
  19
  20 void
  21 Callback_i::callback_method ()
  22 {
  23   if (TAO_debug_level > 0)
  24     ACE_DEBUG ((LM_DEBUG, "Callback method called\n"));
  25 }
  26
  27
  28 // ****************************************************************
  29
  30 CORBA::Long
  31 Simple_Server_i::test_method (CORBA::Boolean do_callback
  32  )
  33 {
  34   if (do_callback)
  35     {
  36       this->flag_ = 1;
  37     }
  38
  39   return 0;
  40 }
  41
  42 void
  43 Simple_Server_i::callback_object (Callback_ptr callback
  44  )
  45 {
  46   // Store the callback object
  47   this->callback_ = Callback::_duplicate (callback);
  48 }
  49
  50 int
  51 Simple_Server_i::call_client ()
  52 {
  53   if (this->flag_)
  54     {
  55       ACE_DEBUG ((LM_DEBUG,"calling client\n"));
  56
  57       for (int times = 0; times < this->no_iterations_; ++times)
  58         {
  59           this->callback_->callback_method ();
  60
  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 }