1 files changed, 41 insertions, 0 deletions
diff --git a/TAO/tests/Bug_1270_Regression/Echo.cpp b/TAO/tests/Bug_1270_Regression/Echo.cpp
new file mode 100644
index 00000000000..d9c971f82e3
--- /dev/null
+++ b/TAO/tests/Bug_1270_Regression/Echo.cpp
@@ -0,0 +1,41 @@
+/**
+ * @file Echo.cpp
+ *
+ * $Id$
+ *
+ * @author Carlos O'Ryan <coryan@atdesk.com>
+ *
+ */
+#include "Echo.h"
+#include "ace/OS_NS_unistd.h"
+
+ACE_RCSID(Bug_1270_Regression, Echo, "$Id$")
+
+Echo::Echo(CORBA::ORB_ptr orb,
+           int abort_counter)
+  : orb_(CORBA::ORB::_duplicate(orb))
+  , abort_counter_(abort_counter)
+{
+}
+
+void
+Echo::echo_payload(Test::Payload const &)
+{
+  this->abort_counter_--;
+
+  if (this->abort_counter_ == 0)
+    {
+      ACE_DEBUG ((LM_DEBUG, "(%P|%t) Echo::echo_payload, sleeping\n"));
+      // Sleep for 15 seconds, forcing a flow control of some kind.
+      ACE_OS::sleep(15);
+
+      // Run the ORB for a while, to generate a short-lived release of
+      // the flow control.
+      ACE_Time_Value tv(0, 10000);
+      this->orb_->perform_work(tv);
+
+      ACE_DEBUG ((LM_DEBUG, "(%P|%t) Echo::echo_payload, aborting\n"));
+      // Kill the app
+      ACE_OS::abort();
+    }
+}