TAO/orbsvcs/tests/Bug_3215_Regression/ServerRequest_Interceptor2.cpp

   1 // -*- C++ -*-
   2 #include "ServerRequest_Interceptor2.h"
   3 #include "orbsvcs/FT_CORBA_ORBC.h"
   4 #include "tao/IOPC.h"
   5 #include "tao/ORB_Constants.h"
   6 #include "tao/AnyTypeCode/DynamicC.h"
   7 #include "tao/AnyTypeCode/TypeCode.h"
   8 #include "tao/CDR.h"
   9 #include "ace/Log_Msg.h"
  10 #include "ace/OS_NS_string.h"
  11 #include "ace/OS_NS_stdio.h"
  12 #include "ace/OS_NS_unistd.h"
  13 #include "Hello.h"
  14 #include "ace/OS_NS_sys_time.h"
  15 #include "tao/PI/PIForwardRequestC.h"
  16
  17 int invocation_count = 0;
  18
  19 TAO249_ServerRequest_Interceptor2::TAO249_ServerRequest_Interceptor2 ()
  20 : orb_ (0),
  21   expired_ (0)
  22 {
  23 }
  24
  25 TAO249_ServerRequest_Interceptor2::~TAO249_ServerRequest_Interceptor2 ()
  26 {
  27 }
  28
  29 char *
  30 TAO249_ServerRequest_Interceptor2::name ()
  31 {
  32   return CORBA::string_dup ("TAO_TAO249_ServerRequest_Interceptor2");
  33 }
  34
  35 void
  36 TAO249_ServerRequest_Interceptor2::destroy ()
  37 {
  38 }
  39
  40 void
  41 TAO249_ServerRequest_Interceptor2::receive_request_service_contexts (
  42   PortableInterceptor::ServerRequestInfo_ptr
  43   )
  44 {
  45 }
  46
  47 void
  48 TAO249_ServerRequest_Interceptor2::receive_request (
  49   PortableInterceptor::ServerRequestInfo_ptr ri
  50   )
  51 {
  52   CORBA::String_var op = ri->operation ();
  53
  54   if (ACE_OS::strcmp (op.in (), "throw_location_forward"))
  55   {
  56     // bail if not the op we are interested in -
  57     // avoid excess spurious error clutter when client calls ::shutdown
  58     return;
  59   }
  60
  61
  62   IOP::ServiceContext_var sc =
  63     ri->get_request_service_context (IOP::FT_REQUEST);
  64
  65
  66   TAO_InputCDR cdr (reinterpret_cast <const char*>
  67                                      (sc->context_data.get_buffer ()
  68                                       ),
  69                                      sc->context_data.length ());
  70
  71   CORBA::Boolean byte_order;
  72
  73   if ((cdr >> ACE_InputCDR::to_boolean (byte_order)) == 0)
  74     {
  75       throw CORBA::BAD_PARAM (CORBA::OMGVMCID | 28,
  76                            CORBA::COMPLETED_NO);
  77     }
  78
  79
  80   cdr.reset_byte_order (static_cast <int>(byte_order));
  81
  82   FT::FTRequestServiceContext ftrsc;
  83
  84   if ((cdr >> ftrsc) == 0)
  85     throw CORBA::BAD_PARAM (CORBA::OMGVMCID | 28,
  86                              CORBA::COMPLETED_NO);
  87
  88
  89   TimeBase::TimeT now = get_now ();
  90
  91   if (now > ftrsc.expiration_time)
  92     {
  93       // We have passed the exp time... there should be no more retries received after this point...
  94       if (expired_)
  95         {
  96           // The client has retried more than once after the expiration time. This is a regression
  97           ACE_DEBUG ((LM_ERROR, "Test Failed - REGRESSION !!! Client ORB is still retrying LOCATION_FORWARDs / TRANSIENTS after the expiration time on invocation # %d !!\n", invocation_count + 1));
  98           ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Expiration time  : %Q\n"), ftrsc.expiration_time));
  99           ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Time now         : %Q\n"), now));
 100
 101           // Let the request 'succeed' rather than throwing a forward exception.
 102           return;
 103         }
 104       else
 105         {
 106           // A request has been recioved after the expiration time.
 107           // This could legitimately happen - it is only definitely a problem if
 108           // the client keeps on retrying after now. We set a flag so we can check for this.
 109           expired_ = 1;
 110           ACE_DEBUG ((LM_DEBUG, "The expiration time has now passed !! The next exception must NOT prompt reinvocation.\n"));
 111           ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Expiration time  : %Q\n"), ftrsc.expiration_time));
 112           ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Time now         : %Q\n"), now));
 113         }
 114     }
 115
 116   if (invocation_count == 0)
 117     {
 118       ++invocation_count;
 119       if (expired_)
 120         {
 121           ACE_DEBUG ((LM_DEBUG, "On invocation #%d throwing a ForwardRequest back to the client\n", invocation_count));
 122         }
 123       // Throw a forward back to ourselves on the first try
 124       // This means that we are testing the exception handling after a forward perm...
 125       throw PortableInterceptor::ForwardRequest (server_iogr_.in ());
 126     }
 127   else
 128     {
 129       ++invocation_count;
 130       if (expired_)
 131         {
 132           ACE_DEBUG ((LM_DEBUG, "On invocation #%d throwing a TRANSIENT back to the client\n", invocation_count));
 133         }
 134       // Thaen throw a transient on all subsequent invocations
 135       throw CORBA::TRANSIENT (0, CORBA::COMPLETED_NO);
 136     }
 137 }
 138
 139 TimeBase::TimeT
 140 TAO249_ServerRequest_Interceptor2::get_now ()
 141 {
 142   // 1582...
 143   const TimeBase::TimeT timeOffset = ACE_UINT64_LITERAL (0x1B21DD213814000);
 144
 145   // Now in posix
 146   ACE_Time_Value time_value = ACE_OS::gettimeofday ();
 147
 148   TimeBase::TimeT sec_part  = time_value.sec ();
 149   sec_part = sec_part  * 10000000;
 150   TimeBase::TimeT usec_part = time_value.usec ();
 151   usec_part = usec_part * 10;
 152   return (sec_part + usec_part + timeOffset);
 153 }
 154
 155 void
 156 TAO249_ServerRequest_Interceptor2::send_reply (
 157   PortableInterceptor::ServerRequestInfo_ptr
 158   )
 159 {
 160 }
 161
 162 void
 163 TAO249_ServerRequest_Interceptor2::send_exception (
 164   PortableInterceptor::ServerRequestInfo_ptr
 165   )
 166 {
 167 }
 168
 169 void
 170 TAO249_ServerRequest_Interceptor2::send_other (
 171   PortableInterceptor::ServerRequestInfo_ptr
 172   )
 173 {
 174 }