TAO/tests/Collocated_Forwarding/test_i.cpp

   1 // -*- C++ -*-
   2
   3 #include "test_i.h"
   4 #include "tao/PortableServer/ForwardRequestC.h"
   5
   6 test_i::test_i (CORBA::Short id,
   7                 CORBA::ORB_ptr orb)
   8   : id_ (id)
   9   , orb_ (CORBA::ORB::_duplicate (orb))
  10   , to_ (CORBA::Object::_nil ())
  11   , request_pass_count_ (0)
  12   , request_count_ (0)
  13 {
  14 }
  15
  16 void
  17 test_i::forward (CORBA::Object_ptr to,
  18                  CORBA::ULong request_pass_count)
  19 {
  20   this->to_ = CORBA::Object::_duplicate (to);
  21   this->request_pass_count_ = request_pass_count;
  22 }
  23
  24 CORBA::Short
  25 test_i::collocated_call ()
  26 {
  27   this->request_count_++;
  28
  29   ACE_DEBUG ((LM_DEBUG,
  30               "Collocated call is executed in object with id %d.\n",
  31               this->id_));
  32
  33   if (!CORBA::is_nil (this->to_.in ()))
  34     {
  35       if (this->request_count_ == this->request_pass_count_)
  36         {
  37           ACE_DEBUG ((LM_DEBUG,
  38                       "SERVER: Request %d will be forwarded "
  39                       "to object 'to'\nSERVER: via collocated_call().\n",
  40                       this->request_count_));
  41
  42           // Throw forward exception
  43           throw PortableServer::ForwardRequest (this->to_.in ());
  44         }
  45     }
  46
  47   return this->id_;
  48 }