1 files changed, 40 insertions, 0 deletions
diff --git a/TAO/orbsvcs/performance-tests/RTEvent/RTCORBA_Callback/Callback.cpp b/TAO/orbsvcs/performance-tests/RTEvent/RTCORBA_Callback/Callback.cpp
new file mode 100644
index 00000000000..8ac7e2263f2
--- /dev/null
+++ b/TAO/orbsvcs/performance-tests/RTEvent/RTCORBA_Callback/Callback.cpp
@@ -0,0 +1,40 @@
+//
+// $Id$
+//
+#include "Callback.h"
+#include "Implicit_Deactivator.h"
+#include "ace/OS_NS_time.h"
+
+ACE_RCSID (TAO_RTEC_Perf_RTCORBA_Callback,
+           Callback,
+           "$Id$")
+
+Callback::Callback (int iterations,
+                    PortableServer::POA_ptr poa)
+  : sample_history_ (iterations)
+  , poa_ (PortableServer::POA::_duplicate (poa))
+{
+}
+
+ACE_Sample_History &
+Callback::sample_history (void)
+{
+  return this->sample_history_;
+}
+
+void
+Callback::sample (Test::Timestamp the_timestamp)
+{
+  ACE_hrtime_t elapsed = ACE_OS::gethrtime () - the_timestamp;
+
+  ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->mutex_);
+  if (sample_history_.max_samples () == sample_history_.sample_count ())
+    return;
+  this->sample_history_.sample (elapsed);
+}
+
+PortableServer::POA_ptr
+Callback::_default_POA (void)
+{
+  return PortableServer::POA::_duplicate (this->poa_.in ());
+}