TAO/tests/TransportCurrent/IIOP/Current_Test_Impl.cpp

   1 // -*- C++ -*-
   2 #include "tao/TransportCurrent/TC_IIOPC.h"
   3 #include "tao/TransportCurrent/TCC.h"
   4
   5 #include "Current_Test_Impl.h"
   6
   7 Current_Test_Impl::Current_Test_Impl (CORBA::ORB_ptr orb,
   8                                       PortableServer::POA_ptr poa,
   9                                       int do_collocated_calls)
  10     : orb_ (CORBA::ORB::_duplicate (orb))
  11     , poa_ (PortableServer::POA::_duplicate (poa))
  12     , do_collocated_calls_ (do_collocated_calls)
  13 {
  14 }
  15
  16 Current_Test_Impl::~Current_Test_Impl (void)
  17 {
  18 }
  19
  20 ::CORBA::Long
  21 Current_Test_Impl::self_test (void)
  22 {
  23   return 0;
  24 }
  25
  26 void
  27 Current_Test_Impl::test_transport_current (void)
  28 {
  29   if (TAO_debug_level > 2) {
  30     ACE_DEBUG ((LM_DEBUG,
  31                 ACE_TEXT ("(%P|%t) server - Testing access to IIOP Transport Current ...\n")));
  32   }
  33
  34   CORBA::Object_var tcobject =
  35     this->orb_->resolve_initial_references ("TAO::Transport::IIOP::Current");
  36
  37   TAO::Transport::IIOP::Current_var tc =
  38     TAO::Transport::IIOP::Current::_narrow (tcobject.in ());
  39
  40   if (CORBA::is_nil (tc.in()))
  41     {
  42       ACE_ERROR ((LM_ERROR,
  43                   ACE_TEXT ("Unable to narrow down to TAO::Transport::IIOP::Current\n")));
  44       throw CORBA::INTERNAL ();
  45     }
  46
  47   CORBA::String_var rhost (tc->remote_host ());
  48   CORBA::String_var lhost (tc->local_host ());
  49   ACE_DEBUG ((LM_DEBUG,
  50               ACE_TEXT ("(%P|%t) server - [%s:%d] -> [%s:%d]\n"),
  51               rhost.in (), tc->remote_port (),
  52               lhost.in (), tc->local_port ()));
  53
  54   if (TAO_debug_level > 2) {
  55     ACE_DEBUG ((LM_DEBUG,
  56                 ACE_TEXT ("(%P|%t) server - Successfully accessed IIOP Transport Current\n")));
  57   }
  58 }
  59
  60
  61
  62 void
  63 Current_Test_Impl::invoked_by_client (void)
  64 {
  65   if (TAO_debug_level >= 1) {
  66     ACE_DEBUG ((LM_DEBUG,
  67                 ACE_TEXT ("(%P|%t) server - Test method invoked by client.\n")));
  68   }
  69
  70   this->test_transport_current ();
  71
  72   if (this->do_collocated_calls_)
  73     {
  74       CORBA::Object_var selfobject =
  75         poa_->servant_to_reference (this);
  76
  77       Test::Transport::CurrentTest_var self =
  78         Test::Transport::CurrentTest::_narrow (selfobject.in ());
  79
  80       if (TAO_debug_level >= 1) {
  81         ACE_DEBUG ((LM_DEBUG,
  82                     ACE_TEXT ("(%P|%t) server - Making a collocated invocation to invoked_during_upcall().\n")));
  83       }
  84       self->invoked_during_upcall ();
  85     }
  86   else
  87     {
  88       if (TAO_debug_level >= 1)
  89         {
  90           ACE_DEBUG ((LM_DEBUG,
  91                       ACE_TEXT ("(%P|%t) server - skipping collocated calls\n")));
  92         }
  93
  94     }
  95
  96 }
  97
  98 void
  99 Current_Test_Impl::invoked_during_upcall (void)
 100 {
 101   if (TAO_debug_level > 2) {
 102     ACE_DEBUG ((LM_DEBUG,
 103                 ACE_TEXT ("(%P|%t) server - Test method invoked ")
 104                 ACE_TEXT ("by the server during upcall.\n")));
 105   }
 106 }
 107
 108 void
 109 Current_Test_Impl::shutdown (void)
 110 {
 111   if (TAO_debug_level > 2) {
 112     ACE_DEBUG ((LM_DEBUG,
 113                 ACE_TEXT ("(%P|%t) server - shutting down.\n")));
 114   }
 115
 116   this->orb_->shutdown (0);
 117 }