1 files changed, 56 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/FtRtEvent/PushConsumer.cpp b/TAO/orbsvcs/tests/FtRtEvent/PushConsumer.cpp
new file mode 100644
index 00000000000..7a2f3049b87
--- /dev/null
+++ b/TAO/orbsvcs/tests/FtRtEvent/PushConsumer.cpp
@@ -0,0 +1,56 @@
+// $Id$
+
+#include "PushConsumer.h"
+#include "orbsvcs/FtRtEvent/Utils/resolve_init.h"
+#include <stdio.h>
+
+ACE_RCSID (FtRtEvent,
+           PushConsumer,
+           "$Id$")
+
+PushConsumer_impl::PushConsumer_impl(CORBA::ORB_ptr orb)
+: orb_(CORBA::ORB::_duplicate(orb))
+{
+}
+
+
+void
+PushConsumer_impl::push (const RtecEventComm::EventSet & event
+             ACE_ENV_ARG_DECL_WITH_DEFAULTS
+             )
+             ACE_THROW_SPEC ((
+             CORBA::SystemException
+             ))
+{
+  CORBA::ULong x;
+  ACE_Time_Value time_val = ACE_OS::gettimeofday ();
+
+  if (event.length() >0) {
+    TimeBase::TimeT elaps =
+      time_val.sec () * 10000000 + time_val.usec ()* 10 - event[0].header.ec_send_time;
+    event[0].data.any_value >>= x;
+    printf("Received data : %d,  single trip time = %d usec\n", x, static_cast<long>(elaps/10));
+  }
+}
+
+
+void
+PushConsumer_impl::disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
+                       )
+                       ACE_THROW_SPEC ((
+                       CORBA::SystemException
+                       ))
+{
+  PortableServer::Current_var current =
+    resolve_init<PortableServer::Current>(orb_.in(), "POACurrent" ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  PortableServer::POA_var poa = current->get_POA(ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  PortableServer::ObjectId_var oid = current->get_object_id(ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  poa->deactivate_object(oid ACE_ENV_ARG_PARAMETER);
+
+}