Repo restructuring

1 files changed, 0 insertions, 240 deletions

diff --git a/TAO/orbsvcs/tests/Bug_2285_Regression/ServerRequest_Interceptor2.cpp b/TAO/orbsvcs/tests/Bug_2285_Regression/ServerRequest_Interceptor2.cpp
deleted file mode 100644
index cc63dbf287e..00000000000
--- a/TAO/orbsvcs/tests/Bug_2285_Regression/ServerRequest_Interceptor2.cpp
+++ /dev/null
@@ -1,240 +0,0 @@
-// -*- C++ -*-
-
-#include "ServerRequest_Interceptor2.h"
-#include "orbsvcs/FT_CORBA_ORBC.h"
-#include "tao/IOP_IORC.h"
-#include "tao/ORB_Constants.h"
-#include "tao/AnyTypeCode/DynamicC.h"
-#include "tao/AnyTypeCode/TypeCode.h"
-#include "tao/CDR.h"
-#include "ace/Log_Msg.h"
-#include "ace/OS_NS_string.h"
-#include "ace/OS_NS_stdio.h"
-#include "ace/OS_NS_unistd.h"
-#include "Hello.h"
-#include "ace/OS_NS_sys_time.h"
-
-ACE_RCSID (FaultTolerance,
-           TAO249_ServerRequest_Interceptor2,
-           "$Id$")
-
-TAO249_ServerRequest_Interceptor2::TAO249_ServerRequest_Interceptor2 (void)
-: orb_ (0),
-  client_id_ (0)
-{
-}
-
-TAO249_ServerRequest_Interceptor2::~TAO249_ServerRequest_Interceptor2 (void)
-{
-}
-
-
-char *
-TAO249_ServerRequest_Interceptor2::name (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
-ACE_THROW_SPEC ((CORBA::SystemException))
-{
-  return CORBA::string_dup ("TAO_TAO249_ServerRequest_Interceptor2");
-}
-
-void
-TAO249_ServerRequest_Interceptor2::destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
-ACE_THROW_SPEC ((CORBA::SystemException))
-{
-}
-
-void
-TAO249_ServerRequest_Interceptor2::receive_request_service_contexts (
-  PortableInterceptor::ServerRequestInfo_ptr
-  ACE_ENV_ARG_DECL)
-ACE_THROW_SPEC ((CORBA::SystemException,
-                 PortableInterceptor::ForwardRequest))
-{
-}
-
-void
-TAO249_ServerRequest_Interceptor2::receive_request (
-  PortableInterceptor::ServerRequestInfo_ptr ri
-  ACE_ENV_ARG_DECL_NOT_USED)
-ACE_THROW_SPEC ((CORBA::SystemException,
-                 PortableInterceptor::ForwardRequest))
-{
-  CORBA::String_var op = ri->operation (ACE_ENV_SINGLE_ARG_PARAMETER);
-
-  if (ACE_OS::strcmp (op.in (), "drop_down_dead"))
-  {
-    // bail if not the op we are interested in - 
-    // avoid excess spurious error clutter when client calls ::shutdown
-    return;
-  }
-
-  ACE_CHECK;
-  ACE_TRY
-  {
-    IOP::ServiceContext_var sc =
-      ri->get_request_service_context (IOP::FT_REQUEST
-                                       ACE_ENV_ARG_PARAMETER);
-    ACE_TRY_CHECK;
-
-    TAO_InputCDR cdr (reinterpret_cast <const char*>
-                                       (sc->context_data.get_buffer ()
-                                        ),
-                                       sc->context_data.length ());
-
-    CORBA::Boolean byte_order;
-
-    if ((cdr >> ACE_InputCDR::to_boolean (byte_order)) == 0)
-      {
-        ACE_THROW (CORBA::BAD_PARAM (CORBA::OMGVMCID | 28,
-                               CORBA::COMPLETED_NO));
-      }
-    ACE_TRY_CHECK;
-
-    cdr.reset_byte_order (static_cast <int>(byte_order));
-
-    FT::FTRequestServiceContext ftrsc;
-
-    if ((cdr >> ftrsc) == 0)
-      ACE_THROW (CORBA::BAD_PARAM (CORBA::OMGVMCID | 28,
-                               CORBA::COMPLETED_NO));
-    ACE_TRY_CHECK;
-
-    FILE* last_exp_time_file = ACE_OS::fopen ("last_expiration_time", "r+");
-    TimeBase::TimeT last_exp_time = 0;
-    
-    if (!last_exp_time_file)
-      {
-        // file does not exist ... we're the first server
-        // create new file for the expiration time
-        last_exp_time_file = ACE_OS::fopen ("last_expiration_time", "w+");
-        last_exp_time = ftrsc.expiration_time;
-      }
-    else
-      {
-        // We're a subsequent server... read in the previous server's expiration time
-        ACE_OS::fread (&last_exp_time,
-                       1,
-                       sizeof (TimeBase::TimeT),
-                       last_exp_time_file);
-        ACE_OS::sleep (1);
-      }
-
-    if (last_exp_time != ftrsc.expiration_time)
-      {
-        ACE_DEBUG ((LM_DEBUG, "Test Failed - REGRESSION !!! Different expiration times used on consecutive retries of the same op!!\n"));
-        ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Previous expiration: %Q\n"), last_exp_time));
-        ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Current expiration : %Q\n"), ftrsc.expiration_time));
-        return;
-      }
-
-    
-    // This is the offset from UTC to posix - a value less than than this will
-    // indicate posix is (mistakenly) being used
-    TimeBase::TimeT the_seventies = ACE_UINT64_LITERAL (0x1B21DD213814000);
-    
-    // @warning - this test is fragile. It will break in 2358 A.D. :-)
-    if (last_exp_time <= the_seventies)
-      {  
-        ACE_DEBUG ((LM_ERROR, "Test Failed - REGRESSION !!! Expiration time is in wrong format - it is before 1970 A.D. !!\n"));
-        ACE_DEBUG ((LM_DEBUG, "Expiration time: %Q\n", last_exp_time));
-        ACE_DEBUG ((LM_DEBUG, "1970 A.D.      : %Q\n", the_seventies));
-        return;
-      }
-    else if ( last_exp_time > (the_seventies * 2))
-      {
-        ACE_DEBUG ((LM_ERROR, "Test Failed - REGRESSION !!! Expiration time is garbage - it is after 2358 A.D. !!\n"));
-        ACE_DEBUG ((LM_DEBUG, "Expiration time: %Q\n", last_exp_time));
-        ACE_DEBUG ((LM_DEBUG, "2358 A.D.      : %Q\n", (the_seventies * 2)));
-        return;
-      }
-
-    TimeBase::TimeT now = get_now ();
-    
-    if (now > last_exp_time)
-      {
-        // We have passed the exp time... there should be no more retries received after this point...
-        FILE* no_more_retries = ACE_OS::fopen ("no_more_retries", "r+");
-        if (no_more_retries)
-          {
-            TimeBase::TimeT last_expired_attempt = 0;
-            ACE_OS::fread (&last_expired_attempt, 1, sizeof (TimeBase::TimeT), no_more_retries);
-            ACE_OS::fclose (no_more_retries);
-            
-            // There has already been an attempt after the last server passed the expiration time
-            ACE_DEBUG ((LM_ERROR, "Test Failed - REGRESSION !!! Client ORB is still retrying after the expiration time!!\n"));
-            ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Expiration time  : %Q\n"), last_exp_time));
-            ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Previous attempt : %Q\n"), last_expired_attempt));
-            ACE_DEBUG ((LM_DEBUG, ACE_TEXT("Time now         : %Q\n"), now));
-            return;
-          }
-        else
-          {
-            // Tell the next server we've passed the point of no return
-            no_more_retries = ACE_OS::fopen ("no_more_retries", "w+");
-            ACE_OS::fwrite (&now, 1, sizeof (TimeBase::TimeT), no_more_retries);
-            ACE_OS::fflush (no_more_retries);
-            ACE_OS::fclose (no_more_retries);
-          }
-      }
-          
-    // Everthing is fine so far. Write out the expiration time for the next server to check
-    ACE_OS::fwrite (&ftrsc.expiration_time, 1, sizeof (TimeBase::TimeT), last_exp_time_file);
-    ACE_OS::fflush (last_exp_time_file);
-    ACE_OS::fclose (last_exp_time_file);
-
-    // Goodbye cruel world !!
-    ACE_OS::abort ();
-  }
-ACE_CATCHANY
-  {
-    ACE_DEBUG ((LM_ERROR, "Unexpected (non regression problem) error - test failed\n"));
-    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
-                         "Exception in TAO249_ServerRequest_Interceptor2::receive_request \n");
-    ACE_RE_THROW;
-  }
-ACE_ENDTRY;
-ACE_CHECK;
-
-}
-
-TimeBase::TimeT
-TAO249_ServerRequest_Interceptor2::get_now (void)
-{
-  // 1582...
-  const TimeBase::TimeT timeOffset = ACE_UINT64_LITERAL (0x1B21DD213814000);
-
-  // Now in posix
-  ACE_Time_Value time_value = ACE_OS::gettimeofday ();
-  
-  TimeBase::TimeT sec_part  = time_value.sec ();
-  sec_part = sec_part  * 10000000;
-  TimeBase::TimeT usec_part = time_value.usec ();
-  usec_part = usec_part * 10;
-  return (sec_part + usec_part + timeOffset);
-}
-
-void
-TAO249_ServerRequest_Interceptor2::send_reply (
-  PortableInterceptor::ServerRequestInfo_ptr
-  ACE_ENV_ARG_DECL_NOT_USED)
-ACE_THROW_SPEC ((CORBA::SystemException))
-{
-}
-
-void
-TAO249_ServerRequest_Interceptor2::send_exception (
-  PortableInterceptor::ServerRequestInfo_ptr
-  ACE_ENV_ARG_DECL_NOT_USED)
-ACE_THROW_SPEC ((CORBA::SystemException,
-                 PortableInterceptor::ForwardRequest))
-{
-}
-
-void
-TAO249_ServerRequest_Interceptor2::send_other (
-  PortableInterceptor::ServerRequestInfo_ptr
-  ACE_ENV_ARG_DECL_NOT_USED)
-ACE_THROW_SPEC ((CORBA::SystemException,
-                 PortableInterceptor::ForwardRequest))
-{
-}
-