TAO/tests/Nested_Event_Loop/test_i.cpp

   1 #include "test_i.h"
   2 #include "ace/OS_NS_string.h"
   3
   4 server_i::server_i (CORBA::ORB_ptr orb)
   5   : orb_ (CORBA::ORB::_duplicate (orb))
   6 {
   7 }
   8
   9 void
  10 server_i::loop (client_ptr remote_partner,
  11                 CORBA::ULong event_loop_depth,
  12                 CORBA::ULong event_loop_iterations)
  13 {
  14   ACE_DEBUG ((LM_DEBUG,
  15               "server_i::loop: event_loop_depth = %2.2d; event_loop_iterations = %2.2d\n",
  16               event_loop_depth,
  17               event_loop_iterations));
  18
  19   this->run_no_ops (remote_partner,
  20                     event_loop_iterations / 2);
  21
  22   if (--event_loop_depth != 0)
  23     {
  24       remote_partner->loop (event_loop_depth,
  25                             event_loop_iterations);
  26     }
  27
  28   this->run_no_ops (remote_partner,
  29                     event_loop_iterations / 2);
  30 }
  31
  32 void
  33 server_i::run_no_ops (client_ptr remote_partner,
  34                       CORBA::ULong iterations)
  35 {
  36   while (iterations != 0)
  37     {
  38       CORBA::ULong *pointer_to_iterations = &iterations;
  39       size_t sizeof_pointer_to_iterations = sizeof (pointer_to_iterations);
  40
  41       act act_for_iterations (sizeof_pointer_to_iterations);
  42       act_for_iterations.length (sizeof_pointer_to_iterations);
  43
  44       ACE_OS::memcpy (act_for_iterations.get_buffer (),
  45                       &pointer_to_iterations,
  46                       sizeof_pointer_to_iterations);
  47
  48       CORBA::ULong got_reply = 0;
  49
  50       CORBA::ULong *pointer_to_flag = &got_reply;
  51       size_t sizeof_pointer_to_flag = sizeof (pointer_to_flag);
  52
  53       act act_for_flag (sizeof_pointer_to_flag);
  54       act_for_flag.length (sizeof_pointer_to_flag);
  55
  56       ACE_OS::memcpy (act_for_flag.get_buffer (),
  57                       &pointer_to_flag,
  58                       sizeof_pointer_to_flag);
  59
  60       remote_partner->oneway_no_op (act_for_iterations,
  61                                     act_for_flag);
  62
  63       while (!got_reply)
  64         {
  65           this->orb_->perform_work ();
  66         }
  67     }
  68 }
  69
  70 void
  71 server_i::no_op (client_ptr remote_partner,
  72                  const act &act_for_iterations,
  73                  const act &act_for_flag)
  74 {
  75   CORBA::ULong *pointer_to_iterations = 0;
  76
  77   ACE_OS::memcpy (&pointer_to_iterations,
  78                   act_for_iterations.get_buffer (),
  79                   act_for_iterations.length ());
  80
  81   CORBA::ULong *pointer_to_flag = 0;
  82
  83   ACE_OS::memcpy (&pointer_to_flag,
  84                   act_for_flag.get_buffer (),
  85                   act_for_flag.length ());
  86
  87   ACE_DEBUG ((LM_DEBUG,
  88               "server_i::no_op: iterations = %d\n",
  89               *pointer_to_iterations));
  90
  91   --(*pointer_to_iterations);
  92
  93   *pointer_to_flag = 1;
  94
  95   remote_partner->twoway_no_op ();
  96 }
  97
  98 void
  99 server_i::shutdown (void)
 100 {
 101   this->orb_->shutdown (0);
 102 }
 103
 104 client_i::client_i (server_ptr remote_partner)
 105   : remote_partner_ (server::_duplicate (remote_partner))
 106 {
 107 #if defined (CORBA_E_COMPACT) || defined (CORBA_E_MICRO)
 108   PortableServer::POA_var poa = this->_default_POA ();
 109   PortableServer::ObjectId_var id = poa->activate_object (this);
 110   CORBA::Object_var object = poa->id_to_reference (id.in ());
 111   self_ = client::_unchecked_narrow (object.in ());
 112 #else
 113   self_ = this->_this ();
 114 #endif /* CORBA_E_COMPACT || CORBA_E_MICRO */
 115 }
 116
 117 void
 118 client_i::loop (CORBA::ULong event_loop_depth,
 119                 CORBA::ULong event_loop_iterations)
 120 {
 121   ACE_DEBUG ((LM_DEBUG,
 122               "client_i::loop: event_loop_depth = %2.2d; event_loop_iterations = %2.2d\n",
 123               event_loop_depth,
 124               event_loop_iterations));
 125
 126
 127   try
 128     {
 129       this->remote_partner_->loop (self_.in (),
 130                                    event_loop_depth,
 131                                    event_loop_iterations);
 132     }
 133   catch (const CORBA::Exception& ex)
 134     {
 135       ex._tao_print_exception ("Exception caught in client_i::loop:");
 136     }
 137 }
 138
 139 void
 140 client_i::oneway_no_op (const act &act_for_iterations,
 141                         const act &act_for_flag)
 142 {
 143
 144   try
 145     {
 146       this->remote_partner_->no_op (self_.in (),
 147                                     act_for_iterations,
 148                                     act_for_flag);
 149     }
 150   catch (const CORBA::Exception& ex)
 151     {
 152       ex._tao_print_exception ("Exception caught in client_i::oneway_no_op:");
 153     }
 154 }
 155
 156 void
 157 client_i::twoway_no_op (void)
 158 {
 159   ACE_DEBUG ((LM_DEBUG,
 160               "client_i::twoway_no_op\n"));
 161 }