summaryrefslogtreecommitdiff
path: root/TAO/tests/Portable_Interceptors/Collocated/Service_Context_Manipulation/interceptors.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tests/Portable_Interceptors/Collocated/Service_Context_Manipulation/interceptors.cpp')
-rw-r--r--TAO/tests/Portable_Interceptors/Collocated/Service_Context_Manipulation/interceptors.cpp492
1 files changed, 0 insertions, 492 deletions
diff --git a/TAO/tests/Portable_Interceptors/Collocated/Service_Context_Manipulation/interceptors.cpp b/TAO/tests/Portable_Interceptors/Collocated/Service_Context_Manipulation/interceptors.cpp
deleted file mode 100644
index 58260168b5e..00000000000
--- a/TAO/tests/Portable_Interceptors/Collocated/Service_Context_Manipulation/interceptors.cpp
+++ /dev/null
@@ -1,492 +0,0 @@
-// $Id$
-
-#include "interceptors.h"
-#include "tao/OctetSeqC.h"
-#include "ace/Log_Msg.h"
-#include "ace/OS_NS_string.h"
-
-ACE_RCSID (Service_Context_Manipulation,
- interceptors,
- "$Id$")
-
-const IOP::ServiceId service_id = 0xdeadbeef;
-const char *request_msg = "The Echo_Request_Interceptor request message";
-const char *reply_msg = "The Echo_Request_Interceptor reply message";
-
-Echo_Client_Request_Interceptor::
-Echo_Client_Request_Interceptor (const char *id)
- : myname_ ("Echo_Client_Interceptor"),
- orb_id_ (CORBA::string_dup (id))
-{
-}
-
-Echo_Client_Request_Interceptor::~Echo_Client_Request_Interceptor (void)
-{
-}
-
-char *
-Echo_Client_Request_Interceptor::name (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- return CORBA::string_dup (this->myname_);
-}
-
-void
-Echo_Client_Request_Interceptor::destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
-}
-
-void
-Echo_Client_Request_Interceptor::send_poll (
- PortableInterceptor::ClientRequestInfo_ptr
- ACE_ENV_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- // Do Nothing
-}
-
-void
-Echo_Client_Request_Interceptor::send_request (
- PortableInterceptor::ClientRequestInfo_ptr ri
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException,
- PortableInterceptor::ForwardRequest))
-{
-
- if (CORBA::is_nil (this->orb_.in ()))
- {
- int argc = 0;
- this->orb_ = CORBA::ORB_init (argc, 0,
- this->orb_id_.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- }
-
- CORBA::String_var operation =
- ri->operation (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- CORBA::Object_var target = ri->target (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- CORBA::String_var ior =
- this->orb_->object_to_string (target.in () ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- ACE_DEBUG ((LM_DEBUG,
- "%s.send_request "
- "from \"%s\"\n",
- this->myname_,
- operation.in ()));
-
- // Populate target member of the ClientRequestInfo.
-
- // Make the context to send the context to the target
- IOP::ServiceContext sc;
- sc.context_id = ::service_id;
-
- CORBA::ULong string_len = ACE_OS::strlen (request_msg) + 1;
- CORBA::Octet *buf = CORBA::OctetSeq::allocbuf (string_len);
- ACE_OS::strcpy (reinterpret_cast<char *> (buf), request_msg);
-
- sc.context_data.replace (string_len, string_len, buf, 1);
-
- // Add this context to the service context list.
- ri->add_request_service_context (sc, 0 ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- // Check that the request service context can be retrieved.
- IOP::ServiceContext_var sc2 =
- ri->get_request_service_context (::service_id ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- const char *buf2 =
- reinterpret_cast<const char *> (sc2->context_data.get_buffer ());
-
- ACE_UNUSED_ARG (buf2);
-
- if (ACE_OS::strcmp (buf2, request_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Expected request service context to be: %s.\n"
- " Got: %s\n",
- request_msg,
- buf2));
- }
-}
-
-void
-Echo_Client_Request_Interceptor::receive_reply (
- PortableInterceptor::ClientRequestInfo_ptr ri
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
-
- if (CORBA::is_nil (this->orb_.in ()))
- {
- int argc = 0;
- this->orb_ = CORBA::ORB_init (argc, 0,
- this->orb_id_.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- }
-
- CORBA::String_var operation =
- ri->operation (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- CORBA::Object_var target =
- ri->target (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- CORBA::String_var ior =
- this->orb_->object_to_string (target.in () ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- ACE_DEBUG ((LM_DEBUG,
- "%s.receive_reply from "
- "\"%s\"\n",
- this->myname_,
- operation.in ()));
-
- ACE_TRY
- {
- // Check that the reply service context was received as
- // expected.
- IOP::ServiceContext_var sc =
- ri->get_reply_service_context (::service_id
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- const char *buf =
- reinterpret_cast<const char *> (sc->context_data.get_buffer ());
- ACE_DEBUG ((LM_DEBUG,
- "Received reply service context: %s\n",
- buf));
-
- if (ACE_OS::strcmp (buf, reply_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Expected reply service context to be: %s\n",
- reply_msg));
- }
-
- // Check that no one has messed with the request service context.
- IOP::ServiceContext_var sc2 =
- ri->get_request_service_context (::service_id
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- const char *buf2 =
- reinterpret_cast<const char *> (sc2->context_data.get_buffer ());
-
- if (ACE_OS::strcmp (buf2, request_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Expected request service context to be: %s.\n"
- " Got: %s\n",
- request_msg,
- buf2));
- }
- }
- ACE_CATCH (CORBA::BAD_PARAM, ex)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Service Context Error \n"));
- }
- ACE_ENDTRY;
- ACE_CHECK;
-}
-
-void
-Echo_Client_Request_Interceptor::receive_other (
- PortableInterceptor::ClientRequestInfo_ptr
- ACE_ENV_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException,
- PortableInterceptor::ForwardRequest))
-{
- ACE_DEBUG ((LM_DEBUG,
- "%s.receive_other\n",
- this->myname_));
-}
-
-void
-Echo_Client_Request_Interceptor::receive_exception (
- PortableInterceptor::ClientRequestInfo_ptr ri
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException,
- PortableInterceptor::ForwardRequest))
-{
- if (CORBA::is_nil (this->orb_.in ()))
- {
- int argc = 0;
- this->orb_ = CORBA::ORB_init (argc, 0,
- this->orb_id_.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- }
-
- CORBA::String_var operation = ri->operation (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- CORBA::Object_var target = ri->target (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- CORBA::String_var ior =
- this->orb_->object_to_string (target.in () ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- ACE_DEBUG ((LM_DEBUG,
- "%s.received_exception "
- "from \"%s\"\n",
- this->myname_,
- operation.in ()));
-
- ACE_TRY
- {
- // Check that the reply service context was received as
- // expected.
- IOP::ServiceContext_var sc =
- ri->get_reply_service_context (::service_id
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- const char *buf =
- reinterpret_cast<const char *> (sc->context_data.get_buffer ());
- ACE_DEBUG ((LM_DEBUG,
- "Received reply service context: %s\n",
- buf));
-
- if (ACE_OS::strcmp (buf, reply_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Expected reply service context to be: %s\n",
- reply_msg));
- }
-
- // Check that no one has messed with the request service context.
- IOP::ServiceContext_var sc2 =
- ri->get_request_service_context (::service_id
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
-
- const char *buf2 =
- reinterpret_cast<const char *> (sc2->context_data.get_buffer ());
-
- if (ACE_OS::strcmp (buf2, request_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Expected request service context to be: %s.\n"
- " Got: %s\n",
- request_msg,
- buf2));
- }
- }
- ACE_CATCH (CORBA::BAD_PARAM, ex)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Service Context Error \n"));
- }
- ACE_ENDTRY;
- ACE_CHECK;
-}
-
-Echo_Server_Request_Interceptor::Echo_Server_Request_Interceptor (void)
- : myname_ ("Echo_Server_Interceptor")
-{
-}
-
-Echo_Server_Request_Interceptor::~Echo_Server_Request_Interceptor (void)
-{
- ACE_DEBUG ((LM_DEBUG,"(%P|%t) ~Echo_Server_Request_Interceptor\n"));
-}
-
-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,
- "(%P|%t)%s.receive_request_service_contexts from "
- "\"%s\"\n",
- this->myname_,
- operation.in ()));
-
- 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,
- "(%P|%t) 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));
- }
-
- // Make the context to send the context to the client
- IOP::ServiceContext scc;
-
- scc.context_id = ::service_id;
-
- CORBA::ULong string_len = ACE_OS::strlen (reply_msg) + 1;
- CORBA::Octet *buff = CORBA::OctetSeq::allocbuf (string_len);
-
- ACE_OS::strcpy (reinterpret_cast<char *> (buff), reply_msg);
-
- scc.context_data.replace (string_len, string_len, buff, 1);
-
- // Add this context to the service context list.
- ri->add_reply_service_context (scc, 0 ACE_ENV_ARG_PARAMETER);
- 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 ri
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
-
- CORBA::String_var operation = ri->operation (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK;
-
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t)%s.send_reply from \"%s\"\n",
- this->myname_,
- operation.in ()));
-
- // Check that the reply service context is set as expected.
- IOP::ServiceContext_var sc =
- ri->get_reply_service_context (::service_id ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- const char *buf = reinterpret_cast<const char *> (sc->context_data.get_buffer ());
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t) Reply service context: %s\n",
- buf));
-
- if (ACE_OS::strcmp (buf, reply_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Echo_Server_Request_Interceptor::send_reply: "
- "Expected reply service context to be: %s\n",
- reply_msg));
- }
-
- // Check that the request service context hasn't been changed.
- IOP::ServiceContext_var sc2 =
- ri->get_request_service_context (::service_id ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- const char *buf2 = reinterpret_cast<const char *> (sc2->context_data.get_buffer ());
-
- if (ACE_OS::strcmp (buf2, request_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Echo_Server_Request_Interceptor::send_reply: "
- "Expected request service context to be: %s.\n"
- " Got: %s\n",
- request_msg,
- buf2));
- }
-}
-
-void
-Echo_Server_Request_Interceptor::send_exception (
- 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,
- "(%P|%t)%s.send_exception from \"%s\"\n",
- this->myname_,
- operation.in ()));
-
- // Check that the reply service context is set as expected.
- IOP::ServiceContext_var sc =
- ri->get_reply_service_context (::service_id ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- const char *buf = reinterpret_cast<const char *> (sc->context_data.get_buffer ());
- ACE_DEBUG ((LM_DEBUG,
- "(%P|%t) Reply service context: %s\n",
- buf));
-
- if (ACE_OS::strcmp (buf, reply_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Echo_Server_Request_Interceptor::send_exception: "
- "Expected reply service context to be: %s\n",
- reply_msg));
- }
-
- // Check that the request service context hasn't been changed.
- IOP::ServiceContext_var sc2 =
- ri->get_request_service_context (::service_id ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- const char *buf2 = reinterpret_cast<const char *> (sc2->context_data.get_buffer ());
-
- if (ACE_OS::strcmp (buf2, request_msg) != 0)
- {
- ACE_ERROR ((LM_ERROR,
- "ERROR: Echo_Server_Request_Interceptor::send_exception: "
- "Expected request service context to be: %s.\n"
- " Got: %s\n",
- request_msg,
- buf2));
- }
-}
-
-void
-Echo_Server_Request_Interceptor::send_other (
- PortableInterceptor::ServerRequestInfo_ptr
- ACE_ENV_ARG_DECL_NOT_USED)
- ACE_THROW_SPEC ((CORBA::SystemException,
- PortableInterceptor::ForwardRequest))
-{
- // Do Nothing
-}
View Lorry Controller Status