1 files changed, 74 insertions, 0 deletions
diff --git a/ACE/TAO/tests/Bug_1551_Regression/Client_Task.cpp b/ACE/TAO/tests/Bug_1551_Regression/Client_Task.cpp
new file mode 100644
index 00000000000..a2eda92853d
--- /dev/null
+++ b/ACE/TAO/tests/Bug_1551_Regression/Client_Task.cpp
@@ -0,0 +1,74 @@
+//
+// $Id$
+//
+
+#include "Client_Task.h"
+
+ACE_RCSID(Bug_1XXX_Regression, Client_Task, "$Id$")
+
+Client_Task::Client_Task (Test::Hello_ptr receiver,
+                          CORBA::ORB_ptr orb,
+                          ACE_Thread_Manager *thr_mgr)
+  : ACE_Task_Base (thr_mgr)
+  , receiver_ (Test::Hello::_duplicate (receiver))
+  , handler_ (new Reply_Handler(receiver, orb))
+  , handler_var_ (handler_->_this())
+  , orb_ (CORBA::ORB::_duplicate (orb))
+{
+}
+
+Client_Task::~Client_Task (void)
+{
+}
+
+int
+Client_Task::svc (void)
+{
+  //  ACE_DEBUG ((LM_DEBUG, "(%P|%t) Starting client task\n"));
+
+  try
+    {
+      CORBA::Object_var object =
+        this->orb_->resolve_initial_references ("PolicyCurrent");
+
+      CORBA::PolicyCurrent_var policy_current =
+        CORBA::PolicyCurrent::_narrow (object.in ());
+
+      TimeBase::TimeT timeout_period = 20 * 1000;
+
+      CORBA::Any timeout_as_any;
+      timeout_as_any <<= timeout_period;
+
+      CORBA::PolicyList policy_list (1);
+      policy_list.length (1);
+      policy_list[0] =
+        this->orb_->create_policy (Messaging::RELATIVE_RT_TIMEOUT_POLICY_TYPE,
+                                   timeout_as_any);
+
+      policy_current->set_policy_overrides (policy_list,
+                                            CORBA::ADD_OVERRIDE);
+
+      policy_list[0]->destroy();
+
+      // Start 25 separate concurrent request streams
+      for (CORBA::Short i = 0; i != 25; ++i)
+      {
+        this->receiver_->sendc_short_sleep (this->handler_var_.in ());
+      }
+
+      ACE_Time_Value tv(10, 0);
+      orb_->run(tv);
+    }
+  catch (const CORBA::TIMEOUT&)
+    {
+      ACE_DEBUG ((LM_DEBUG,
+                  "Client received an expected CORBA::TIMEOUT exception.\n"));
+    }
+  catch (const CORBA::Exception& ex)
+    {
+      ex._tao_print_exception ("(%P|%t) Client_Task - caught exception:");
+      return -1;
+    }
+
+  return 0;
+}