diff options
Diffstat (limited to 'ACE/TAO/performance-tests/Sequence_Latency/DSI/Roundtrip.cpp')
| -rw-r--r-- | ACE/TAO/performance-tests/Sequence_Latency/DSI/Roundtrip.cpp | 219 |
1 files changed, 219 insertions, 0 deletions
diff --git a/ACE/TAO/performance-tests/Sequence_Latency/DSI/Roundtrip.cpp b/ACE/TAO/performance-tests/Sequence_Latency/DSI/Roundtrip.cpp new file mode 100644 index 00000000000..8404810a854 --- /dev/null +++ b/ACE/TAO/performance-tests/Sequence_Latency/DSI/Roundtrip.cpp @@ -0,0 +1,219 @@ +// +// $Id$ +// + +#include "TestC.h" +#include "tao/AnyTypeCode/TypeCode_Constants.h" +#include "tao/AnyTypeCode/NVList.h" +#include "tao/AnyTypeCode/SystemExceptionA.h" +#include "Roundtrip.h" +#include "tao/DynamicInterface/Server_Request.h" + +ACE_RCSID(DSI_Latency, Roundtrip, "$Id$") + +Roundtrip::Roundtrip (CORBA::ORB_ptr orb) + : orb_ (CORBA::ORB::_duplicate (orb)) +{ +} + +void +Roundtrip::invoke (CORBA::ServerRequest_ptr request) +{ + if (ACE_OS::strcmp ("shutdown", request->operation ()) == 0) + { + this->orb_->shutdown (0); + + return; + } + else if (ACE_OS::strcmp ("_is_a", request->operation ()) == 0) + { + CORBA::NVList_ptr list; + this->orb_->create_list (0, list); + + CORBA::Any type_id; + type_id._tao_set_typecode (CORBA::_tc_string); + list->add_value ("type_id", type_id, CORBA::ARG_IN); + + request->arguments (list); + + CORBA::NamedValue_ptr nv = list->item (0); + + const char *arg; + *(nv->value ()) >>= arg; + + CORBA::Boolean type_matches = 0; + if (ACE_OS::strcmp (arg, "IDL:Test/Roundtrip:1.0") == 0 + || ACE_OS::strcmp (arg, "IDL:omg.org/CORBA/Object:1.0") == 0 + || ACE_OS::strcmp (arg, "") == 0) + type_matches = 1; + + CORBA::Any result; + result <<= CORBA::Any::from_boolean (type_matches); + + request->set_result (result); + + return; + } + else if (ACE_OS::strcmp ("test_octet_method", request->operation ()) == 0) + { + CORBA::NVList_ptr list; + this->orb_->create_list (0, list); + + // Set up the argument list + + CORBA::Any octet_load; + octet_load._tao_set_typecode (Test::_tc_octet_load); + list->add_value ("octet_load", octet_load, CORBA::ARG_IN); + + CORBA::Any send_time; + send_time._tao_set_typecode (CORBA::_tc_ulonglong); + list->add_value ("send_time", send_time, CORBA::ARG_IN); + + request->arguments (list); + + // Set up the return value + + CORBA::NamedValue_ptr nv = list->item (1); + + request->set_result (*(nv->value ())); + + return; + } + else if (ACE_OS::strcmp ("test_long_method", request->operation ()) == 0) + { + CORBA::NVList_ptr list; + this->orb_->create_list (0, list); + + // Set up the argument list + + CORBA::Any long_load; + long_load._tao_set_typecode (Test::_tc_long_load); + list->add_value ("long_load", long_load, CORBA::ARG_IN); + + CORBA::Any send_time; + send_time._tao_set_typecode (CORBA::_tc_ulonglong); + list->add_value ("send_time", send_time, CORBA::ARG_IN); + + request->arguments (list); + + // Set up the return value + + CORBA::NamedValue_ptr nv = list->item (1); + + request->set_result (*(nv->value ())); + + return; + } + else if (ACE_OS::strcmp ("test_short_method", request->operation ()) == 0) + { + CORBA::NVList_ptr list; + this->orb_->create_list (0, list); + + // Set up the argument list + + CORBA::Any short_load; + short_load._tao_set_typecode (Test::_tc_short_load); + list->add_value ("short_load", short_load, CORBA::ARG_IN); + + CORBA::Any send_time; + send_time._tao_set_typecode (CORBA::_tc_ulonglong); + list->add_value ("send_time", send_time, CORBA::ARG_IN); + + request->arguments (list); + + // Set up the return value + + CORBA::NamedValue_ptr nv = list->item (1); + + request->set_result (*(nv->value ())); + + return; + } + else if (ACE_OS::strcmp ("test_char_method", request->operation ()) == 0) + { + CORBA::NVList_ptr list; + this->orb_->create_list (0, list); + + // Set up the argument list + + CORBA::Any char_load; + char_load._tao_set_typecode (Test::_tc_char_load); + list->add_value ("char_load", char_load, CORBA::ARG_IN); + + CORBA::Any send_time; + send_time._tao_set_typecode (CORBA::_tc_ulonglong); + list->add_value ("send_time", send_time, CORBA::ARG_IN); + + request->arguments (list); + + // Set up the return value + + CORBA::NamedValue_ptr nv = list->item (1); + + request->set_result (*(nv->value ())); + + return; + } + else if (ACE_OS::strcmp ("test_longlong_method", request->operation ()) == 0) + { + CORBA::NVList_ptr list; + this->orb_->create_list (0, list); + + // Set up the argument list + + CORBA::Any longlong_load; + longlong_load._tao_set_typecode (Test::_tc_longlong_load); + list->add_value ("longlong_load", longlong_load, CORBA::ARG_IN); + + CORBA::Any send_time; + send_time._tao_set_typecode (CORBA::_tc_ulonglong); + list->add_value ("send_time", send_time, CORBA::ARG_IN); + + request->arguments (list); + + // Set up the return value + + CORBA::NamedValue_ptr nv = list->item (1); + + request->set_result (*(nv->value ())); + + return; + } + else if (ACE_OS::strcmp ("test_double_method", request->operation ()) == 0) + { + CORBA::NVList_ptr list; + this->orb_->create_list (0, list); + + // Set up the argument list + + CORBA::Any double_load; + double_load._tao_set_typecode (Test::_tc_double_load); + list->add_value ("double_load", double_load, CORBA::ARG_IN); + + CORBA::Any send_time; + send_time._tao_set_typecode (CORBA::_tc_ulonglong); + list->add_value ("send_time", send_time, CORBA::ARG_IN); + + request->arguments (list); + + // Set up the return value + + CORBA::NamedValue_ptr nv = list->item (1); + + request->set_result (*(nv->value ())); + + return; + } + + CORBA::Any bad_operation; + CORBA::BAD_OPERATION exception; + bad_operation <<= exception; + request->set_exception (bad_operation); +} + +CORBA::RepositoryId +Roundtrip::_primary_interface (const PortableServer::ObjectId &, + PortableServer::POA_ptr) +{ + return CORBA::string_dup ("IDL:Test/Roundtrip:1.0"); +} |