diff options
Diffstat (limited to 'TAO/tests/Portable_Interceptors/Bug_1559/client_interceptor.cpp')
| -rw-r--r-- | TAO/tests/Portable_Interceptors/Bug_1559/client_interceptor.cpp | 386 |
1 files changed, 386 insertions, 0 deletions
diff --git a/TAO/tests/Portable_Interceptors/Bug_1559/client_interceptor.cpp b/TAO/tests/Portable_Interceptors/Bug_1559/client_interceptor.cpp new file mode 100644 index 00000000000..a9ea659b832 --- /dev/null +++ b/TAO/tests/Portable_Interceptors/Bug_1559/client_interceptor.cpp @@ -0,0 +1,386 @@ +// $Id$ + +#include "client_interceptor.h" +#include "tao/OctetSeqC.h" +#include "ace/Log_Msg.h" +#include "tao/ORB_Constants.h" +#include "ace/OS_NS_string.h" + +ACE_RCSID (Bug_1559, + client_interceptor, + "$Id$") + +const IOP::ServiceId service_id = 0xdeadbeef; +const char *request_msg = "REQUEST message"; +const char *reply_msg = "REPLY message"; +const char *forward_msg = "FORWARD message"; +int send_request_count = 0; +int exception_count = 0; + +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\" on object: %s\n", + this->myname_, + operation.in (), + ior.in ())); + + send_request_count++; + + ACE_TRY_NEW_ENV + { + ri->get_request_service_context (::service_id ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + } + ACE_CATCH (CORBA::BAD_PARAM, error) + { + // This is supposed to happen + exception_count++; + } + ACE_ENDTRY; + + if (send_request_count == 1) + { + if (exception_count != 1) + { + ACE_ERROR ((LM_ERROR, + "ERROR: Expected exception_count is <1>\n")); + } + ACE_ASSERT (exception_count == 1); + // 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 ()); + + 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)); + } + } + else if (send_request_count == 2) + { + ACE_DEBUG ((LM_DEBUG, "Exception count: %i\n", exception_count)); + if (exception_count != 2) + { + ACE_ERROR ((LM_ERROR, + "ERROR: Expected exception_count is <2>\n")); + } + ACE_ASSERT (exception_count == 2); + // 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 (forward_msg) + 1; + CORBA::Octet *buf = CORBA::OctetSeq::allocbuf (string_len); + ACE_OS::strcpy (reinterpret_cast<char *> (buf), forward_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 ()); + + if (ACE_OS::strcmp (buf2, forward_msg) != 0) + { + ACE_ERROR ((LM_ERROR, + "ERROR: Expected request service context to be: %s.\n" + " Got: %s\n", + forward_msg, + buf2)); + } + } + else + { + // Something's wrong + } + +} + +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\" on object: %s\n", + this->myname_, + operation.in (), + ior.in ())); + + // 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_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_CHECK; + + const char *buf2 = + reinterpret_cast<const char *> (sc2->context_data.get_buffer ()); + + if (ACE_OS::strcmp (buf2, forward_msg) != 0) + { + ACE_ERROR ((LM_ERROR, + "ERROR: Expected request service context to be: %s.\n" + " Got: %s\n", + forward_msg, + buf2)); + } + send_request_count = 0; + exception_count = 0; +} + +void +Echo_Client_Request_Interceptor::receive_other ( + 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 ()); + } + + 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_other from " + "\"%s\" on object: %s\n", + this->myname_, + operation.in (), + ior.in ())); + + // Check that no one has messed with the request service context. + IOP::ServiceContext_var sc = + ri->get_request_service_context (::service_id ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + const char *buf = + reinterpret_cast<const char *> (sc->context_data.get_buffer ()); + + if (ACE_OS::strcmp (buf, request_msg) != 0) + { + ACE_ERROR ((LM_ERROR, + "ERROR: Expected request service context to be: %s.\n" + " Got: %s\n", + request_msg, + buf)); + } +} + +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\" on object: %s\n", + this->myname_, + operation.in (), + ior.in ())); + + // 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_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_CHECK; + + const char *buf2 = + reinterpret_cast<const char *> (sc2->context_data.get_buffer ()); + + if (ACE_OS::strcmp (buf2, forward_msg) != 0) + { + ACE_ERROR ((LM_ERROR, + "ERROR: Expected request service context to be: %s.\n" + " Got: %s\n", + forward_msg, + buf2)); + } + send_request_count = 0; + exception_count = 0; +} + |