1 files changed, 136 insertions, 0 deletions
diff --git a/TAO/tests/Portable_Interceptors/Bug_2510_Regression/server_interceptor.cpp b/TAO/tests/Portable_Interceptors/Bug_2510_Regression/server_interceptor.cpp
new file mode 100644
index 00000000000..60b8e2eb1d2
--- /dev/null
+++ b/TAO/tests/Portable_Interceptors/Bug_2510_Regression/server_interceptor.cpp
@@ -0,0 +1,136 @@
+// $Id$
+
+#include "server_interceptor.h"
+#include "tao/OctetSeqC.h"
+#include "ace/Log_Msg.h"
+#include "tao/ORB_Constants.h"
+#include "ace/OS_NS_string.h"
+
+const IOP::ServiceId service_id = 0x08154711;
+const char * const request_msg = "TEST 0123456789 TEST";
+PortableInterceptor::SlotId slotId = 0;
+
+Echo_Server_Request_Interceptor::Echo_Server_Request_Interceptor (void)
+  : myname_ ("Echo_Server_Interceptor")
+{
+}
+
+Echo_Server_Request_Interceptor::~Echo_Server_Request_Interceptor (void)
+{
+}
+
+char *
+Echo_Server_Request_Interceptor::name (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  return CORBA::string_dup (this->myname_);
+}
+
+void
+Echo_Server_Request_Interceptor::destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+}
+
+void
+Echo_Server_Request_Interceptor::receive_request_service_contexts (
+    PortableInterceptor::ServerRequestInfo_ptr ri
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException,
+                   PortableInterceptor::ForwardRequest))
+{
+
+  CORBA::String_var operation = ri->operation (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  ACE_DEBUG ((LM_DEBUG,
+              "%s.receive_request_service_contexts from "
+              "\"%s\"\n",
+              this->myname_,
+              operation.in ()));
+
+  // Ignore the shutdown operation.
+  if (ACE_OS_String::strcmp ("shutdown", operation.in ()) == 0)
+    return;
+
+  // retrieve the context
+  IOP::ServiceId id = ::service_id;
+  IOP::ServiceContext_var sc =
+    ri->get_request_service_context (id ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  const char *buf =
+    reinterpret_cast<const char *> (sc->context_data.get_buffer ());
+  ACE_DEBUG ((LM_DEBUG,
+              "  Received service context: %s\n",
+              buf));
+
+  if (ACE_OS::strcmp (buf, request_msg) != 0)
+  {
+    ACE_ERROR ((LM_ERROR,
+                "ERROR: Echo_Server_Request_Interceptor::receive_request_service_contexts: "
+                "Expected request service context to be: %s\n",
+                request_msg ));
+  }
+  else
+  {
+    // put the context into s slot
+    CORBA::Any data;
+    data <<= buf;
+
+    ACE_TRY
+    {
+        ri->set_slot (slotId, data);
+        ACE_DEBUG ((LM_DEBUG, "receive_request_service_contexts filled Slot %d\n",(int)slotId));
+        ACE_TRY_CHECK;
+    }
+    ACE_CATCHANY
+    {
+        ACE_PRINT_EXCEPTION (ex, "Exception thrown in receive_request_service_contexts()\n");
+        ACE_TRY_THROW (CORBA::INTERNAL ());
+    }
+    ACE_ENDTRY;
+    ACE_CHECK;
+
+  }
+}
+
+
+void
+Echo_Server_Request_Interceptor::receive_request (
+    PortableInterceptor::ServerRequestInfo_ptr
+    ACE_ENV_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException,
+                   PortableInterceptor::ForwardRequest))
+{
+  // Do nothing
+}
+
+void
+Echo_Server_Request_Interceptor::send_reply (
+    PortableInterceptor::ServerRequestInfo_ptr
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  // Do nothing
+}
+
+void
+Echo_Server_Request_Interceptor::send_exception (
+    PortableInterceptor::ServerRequestInfo_ptr
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException,
+                   PortableInterceptor::ForwardRequest))
+{
+  // Do nothing
+}
+
+void
+Echo_Server_Request_Interceptor::send_other (
+             PortableInterceptor::ServerRequestInfo_ptr
+             ACE_ENV_ARG_DECL)
+      ACE_THROW_SPEC ((CORBA::SystemException,
+                       PortableInterceptor::ForwardRequest))
+{
+  // Do nothing
+}