1 files changed, 128 insertions, 0 deletions
diff --git a/ACE/TAO/tests/Portable_Interceptors/AMI/Client_Interceptor.cpp b/ACE/TAO/tests/Portable_Interceptors/AMI/Client_Interceptor.cpp
new file mode 100644
index 00000000000..61d0ffc5046
--- /dev/null
+++ b/ACE/TAO/tests/Portable_Interceptors/AMI/Client_Interceptor.cpp
@@ -0,0 +1,128 @@
+/**
+ * @file Client_Interceptor.cpp
+ *
+ * $Id$
+ *
+ * @author Carlos O'Ryan <coryan@atdesk.com>
+ */
+
+#include "Client_Interceptor.h"
+#include "Shared_Interceptor.h"
+#include "tao/OctetSeqC.h"
+
+#include "ace/Log_Msg.h"
+#include "ace/OS_NS_string.h"
+
+
+ACE_RCSID (AMI,
+           Client_Interceptor,
+           "$Id$")
+
+
+unsigned long Echo_Client_Request_Interceptor::request_count = 0;
+unsigned long Echo_Client_Request_Interceptor::reply_count = 0;
+unsigned long Echo_Client_Request_Interceptor::other_count = 0;
+unsigned long Echo_Client_Request_Interceptor::exception_count = 0;
+
+Echo_Client_Request_Interceptor::
+Echo_Client_Request_Interceptor (void)
+{
+}
+
+char *
+Echo_Client_Request_Interceptor::name (void)
+{
+  return CORBA::string_dup ("Echo_Client_Interceptor");
+}
+
+void
+Echo_Client_Request_Interceptor::destroy (void)
+{
+}
+
+void
+Echo_Client_Request_Interceptor::send_poll (
+    PortableInterceptor::ClientRequestInfo_ptr)
+{
+  ACE_ERROR((LM_ERROR,
+             "ERROR, unexpected interception point called send_poll()\n"));
+  throw CORBA::BAD_PARAM ();
+}
+
+void
+Echo_Client_Request_Interceptor::send_request (
+    PortableInterceptor::ClientRequestInfo_ptr ri)
+{
+  IOP::ServiceContext sc;
+  sc.context_id = ::service_id;
+
+  CORBA::Octet *buf = CORBA::OctetSeq::allocbuf(magic_cookie_len);
+  ACE_OS::memcpy(buf, magic_cookie, magic_cookie_len);
+  sc.context_data.replace (magic_cookie_len, magic_cookie_len, buf, 1);
+
+  // Add this context to the service context list.
+  ri->add_request_service_context (sc,
+                                   0);
+
+  // Check that the request service context can be retrieved.
+  IOP::ServiceContext_var rc =
+    ri->get_request_service_context (::service_id);
+
+  if (rc->context_data.length() != magic_cookie_len
+      || ACE_OS::memcmp(
+             magic_cookie, rc->context_data.get_buffer(),
+             magic_cookie_len) != 0
+      )
+    {
+      throw CORBA::BAD_PARAM();
+    }
+
+  Echo_Client_Request_Interceptor::request_count++;
+}
+
+void
+Echo_Client_Request_Interceptor::receive_reply (
+    PortableInterceptor::ClientRequestInfo_ptr ri)
+{
+  // Check that the request service context can be retrieved.
+  IOP::ServiceContext_var rc =
+    ri->get_request_service_context (::service_id);
+
+  if (rc->context_data.length() != magic_cookie_len
+      || ACE_OS::memcmp(
+             magic_cookie, rc->context_data.get_buffer(),
+             magic_cookie_len) != 0
+      )
+    {
+      throw CORBA::BAD_PARAM();
+    }
+
+  ++Echo_Client_Request_Interceptor::reply_count;
+}
+
+void
+Echo_Client_Request_Interceptor::receive_other (
+    PortableInterceptor::ClientRequestInfo_ptr ri)
+{
+  // Check that the request service context can be retrieved.
+  IOP::ServiceContext_var rc =
+    ri->get_request_service_context (::service_id);
+
+  if (rc->context_data.length() != magic_cookie_len
+      || ACE_OS::memcmp(
+             magic_cookie, rc->context_data.get_buffer(),
+             magic_cookie_len) != 0
+      )
+    {
+      throw CORBA::BAD_PARAM ();
+    }
+
+  Echo_Client_Request_Interceptor::other_count++;
+}
+
+void
+Echo_Client_Request_Interceptor::receive_exception (
+    PortableInterceptor::ClientRequestInfo_ptr)
+{
+  Echo_Client_Request_Interceptor::exception_count++;
+}