1 files changed, 75 insertions, 0 deletions
diff --git a/TAO/performance-tests/AMI_Latency/Roundtrip_Handler.cpp b/TAO/performance-tests/AMI_Latency/Roundtrip_Handler.cpp
new file mode 100644
index 00000000000..5f0061601e4
--- /dev/null
+++ b/TAO/performance-tests/AMI_Latency/Roundtrip_Handler.cpp
@@ -0,0 +1,75 @@
+//
+// $Id$
+//
+#include "Roundtrip_Handler.h"
+
+ACE_RCSID(AMI_Latency, Roundtrip, "$Id$")
+
+Roundtrip_Handler::Roundtrip_Handler (int expected_callbacks)
+  : pending_callbacks_ (expected_callbacks)
+{
+}
+
+int
+Roundtrip_Handler::pending_callbacks (void) const
+{
+  return this->pending_callbacks_;
+}
+
+void
+Roundtrip_Handler::dump_results (ACE_UINT32 gsf)
+{
+  this->latency_stats_.dump_results ("AMI Latency", gsf);
+}
+
+void
+Roundtrip_Handler::test_method (Test::Timestamp send_time
+                                ACE_ENV_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  this->pending_callbacks_--;
+
+  ACE_hrtime_t now = ACE_OS::gethrtime ();
+  this->latency_stats_.sample (now - send_time);
+}
+
+void
+Roundtrip_Handler::test_method_excep (Test::AMI_RoundtripExceptionHolder *holder
+                                      ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  ACE_TRY
+    {
+      this->pending_callbacks_--;
+      holder->raise_test_method (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+    }
+  ACE_CATCHANY
+    {
+      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "test_method:");
+    }
+  ACE_ENDTRY;
+}
+
+void
+Roundtrip_Handler::shutdown (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+}
+
+void
+Roundtrip_Handler::shutdown_excep (Test::AMI_RoundtripExceptionHolder *holder
+                                   ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  ACE_TRY
+    {
+      holder->raise_shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+    }
+  ACE_CATCHANY
+    {
+      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "shutdown:");
+    }
+  ACE_ENDTRY;
+}