1 files changed, 83 insertions, 0 deletions
diff --git a/TAO/tests/Big_Twoways/Coordinator.cpp b/TAO/tests/Big_Twoways/Coordinator.cpp
new file mode 100644
index 00000000000..bde4ea74848
--- /dev/null
+++ b/TAO/tests/Big_Twoways/Coordinator.cpp
@@ -0,0 +1,83 @@
+//
+// $Id$
+//
+#include "Coordinator.h"
+
+ACE_RCSID(Big_Oneways, Coordinator, "$Id$")
+
+Coordinator::Coordinator (CORBA::ULong peer_count)
+  : peers_ (0)
+  , peer_count_ (0)
+  , peer_max_ (peer_count)
+{
+  ACE_NEW (this->peers_, Test::Peer_var[this->peer_max_]);
+}
+
+Coordinator::~Coordinator (void)
+{
+  delete[] this->peers_;
+}
+
+int
+Coordinator::has_all_peers (void) const
+{
+  return this->peer_count_ == this->peer_max_;
+}
+
+void
+Coordinator::create_session_list (Test::Session_Control_ptr session_control,
+                                  CORBA::ULong payload_size,
+                                  CORBA::ULong thread_count,
+                                  CORBA::ULong message_count,
+                                  Test::Session_List &session_list,
+                                  CORBA::Environment &ACE_TRY_ENV)
+{
+  session_list.length (this->peer_count_);
+  CORBA::ULong count = 0;
+  for (Test::Peer_var *i = this->peers_;
+       i != this->peers_ + this->peer_count_;
+       ++i)
+    {
+      session_list[count++] =
+        (*i)->create_session (session_control,
+                              payload_size,
+                              thread_count,
+                              message_count,
+                              this->peer_count_,
+                              ACE_TRY_ENV);
+      ACE_TRY_CHECK;
+    }
+}
+
+void
+Coordinator::shutdown_all_peers (CORBA::Environment &ACE_TRY_ENV)
+{
+  for (Test::Peer_var *i = this->peers_;
+       i != this->peers_ + this->peer_count_;
+       ++i)
+    {
+      ACE_TRY
+        {
+          (*i)->shutdown (ACE_TRY_ENV);
+          ACE_TRY_CHECK;
+        }
+      ACE_CATCHANY
+        {
+          ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+                               "Coordinator::shutdown, ignored");
+        }
+      ACE_ENDTRY;
+    }
+}
+
+void
+Coordinator::add_peer (Test::Peer_ptr peer,
+                       CORBA::Environment &)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  if (this->peer_count_ >= this->peer_max_)
+    return;
+
+  this->peers_[this->peer_count_++] =
+    Test::Peer::_duplicate (peer);
+}