1 files changed, 191 insertions, 0 deletions
diff --git a/TAO/performance-tests/Sequence_Latency/Thread_Per_Connection/Client_Task.cpp b/TAO/performance-tests/Sequence_Latency/Thread_Per_Connection/Client_Task.cpp
new file mode 100644
index 00000000000..8e892fb74ec
--- /dev/null
+++ b/TAO/performance-tests/Sequence_Latency/Thread_Per_Connection/Client_Task.cpp
@@ -0,0 +1,191 @@
+//
+// $Id$
+//
+#include "Client_Task.h"
+#include "ace/OS_NS_time.h"
+
+ACE_RCSID(Thread_Per_Connection_Latency, Client_Task, "$Id$")
+
+Client_Task::Client_Task (const char *data_type,
+                          int size,
+                          Test::Roundtrip_ptr roundtrip,
+                          int niterations)
+  : data_type_ (CORBA::string_dup (data_type))
+  , size_ (size)
+  , roundtrip_ (Test::Roundtrip::_duplicate (roundtrip))
+  , niterations_ (niterations)
+{
+}
+
+int
+Client_Task::svc (void)
+{
+  try
+    {
+      this->validate_connection ();
+
+      if (ACE_OS::strcmp (this->data_type_.in (), "octet") == 0 )
+        {
+          this->test_octet_seq ();
+        }
+      if (ACE_OS::strcmp (this->data_type_.in (), "long") == 0 )
+        {
+          this->test_long_seq ();
+        }
+      if (ACE_OS::strcmp (this->data_type_.in (), "short") == 0 )
+        {
+          this->test_short_seq ();
+        }
+      if (ACE_OS::strcmp (this->data_type_.in (), "char") == 0 )
+        {
+          this->test_char_seq ();
+        }
+      if (ACE_OS::strcmp (this->data_type_.in (), "longlong") == 0 )
+        {
+          this->test_longlong_seq ();
+        }
+      if (ACE_OS::strcmp (this->data_type_.in (), "double") == 0 )
+        {
+          this->test_double_seq ();
+        }
+    }
+  catch (const CORBA::Exception&)
+    {
+      return 0;
+    }
+  return 0;
+}
+
+void
+Client_Task::accumulate_and_dump (ACE_Basic_Stats &totals,
+                                  const char *msg,
+                                  ACE_UINT32 gsf)
+{
+  totals.accumulate (this->latency_);
+  this->latency_.dump_results (msg, gsf);
+}
+
+void
+Client_Task::validate_connection (void)
+{
+  CORBA::ULongLong dummy = 0;
+  Test::octet_load oc;
+
+  for (int i = 0; i != 100; ++i)
+    {
+      try
+        {
+          (void) this->roundtrip_->test_octet_method (oc, dummy);
+        }
+      catch (const CORBA::Exception&){}
+    }
+}
+
+void
+Client_Task::test_octet_seq (void)
+{
+  Test::octet_load ol (this->size_);
+  ol.length (this->size_);
+
+  for (int i = 0; i != this->niterations_; ++i)
+    {
+      CORBA::ULongLong start = ACE_OS::gethrtime ();
+
+      (void) this->roundtrip_->test_octet_method (ol, start);
+
+      ACE_hrtime_t now = ACE_OS::gethrtime ();
+      this->latency_.sample (now - start);
+
+    }
+}
+
+void
+Client_Task::test_long_seq (void)
+{
+  Test::long_load ll (this->size_);
+  ll.length (this->size_);
+
+  for (int i = 0; i != this->niterations_; ++i)
+    {
+      CORBA::ULongLong start = ACE_OS::gethrtime ();
+
+      (void) this->roundtrip_->test_long_method (ll, start);
+
+      ACE_hrtime_t now = ACE_OS::gethrtime ();
+      this->latency_.sample (now - start);
+
+    }
+}
+
+
+void
+Client_Task::test_short_seq (void)
+{
+  Test::short_load sl (this->size_);
+  sl.length (this->size_);
+
+  for (int i = 0; i != this->niterations_; ++i)
+    {
+      CORBA::ULongLong start = ACE_OS::gethrtime ();
+
+      (void) this->roundtrip_->test_short_method (sl, start);
+
+      ACE_hrtime_t now = ACE_OS::gethrtime ();
+      this->latency_.sample (now - start);
+
+    }
+}
+
+void
+Client_Task::test_char_seq (void)
+{
+  Test::char_load cl (this->size_);
+  cl.length (this->size_);
+
+  for (int i = 0; i != this->niterations_; ++i)
+    {
+      CORBA::ULongLong start = ACE_OS::gethrtime ();
+
+      (void) this->roundtrip_->test_char_method (cl, start);
+
+      ACE_hrtime_t now = ACE_OS::gethrtime ();
+      this->latency_.sample (now - start);
+
+    }
+}
+
+void
+Client_Task::test_longlong_seq (void)
+{
+  Test::longlong_load ll (this->size_);
+  ll.length (this->size_);
+
+  for (int i = 0; i != this->niterations_; ++i)
+    {
+      CORBA::ULongLong start = ACE_OS::gethrtime ();
+
+      (void) this->roundtrip_->test_longlong_method (ll, start);
+
+      ACE_hrtime_t now = ACE_OS::gethrtime ();
+      this->latency_.sample (now - start);
+
+    }
+}
+
+void
+Client_Task::test_double_seq (void)
+{
+  Test::double_load dl (this->size_);
+  dl.length (this->size_);
+
+  for (int i = 0; i != this->niterations_; ++i)
+    {
+      CORBA::ULongLong start = ACE_OS::gethrtime ();
+
+      (void) this->roundtrip_->test_double_method (dl, start);
+
+      ACE_hrtime_t now = ACE_OS::gethrtime ();
+      this->latency_.sample (now - start);
+
+    }
+}