diff options
Diffstat (limited to 'TAO/tests/Big_Oneways/Coordinator.cpp')
-rw-r--r-- | TAO/tests/Big_Oneways/Coordinator.cpp | 83 |
1 files changed, 0 insertions, 83 deletions
diff --git a/TAO/tests/Big_Oneways/Coordinator.cpp b/TAO/tests/Big_Oneways/Coordinator.cpp deleted file mode 100644 index 6b6b332a9cc..00000000000 --- a/TAO/tests/Big_Oneways/Coordinator.cpp +++ /dev/null @@ -1,83 +0,0 @@ -// -// $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 - ACE_ENV_ARG_DECL) -{ - 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_ENV_ARG_PARAMETER); - ACE_CHECK; - } -} - -void -Coordinator::shutdown_all_peers (ACE_ENV_SINGLE_ARG_DECL) -{ - for (Test::Peer_var *i = this->peers_; - i != this->peers_ + this->peer_count_; - ++i) - { - ACE_TRY - { - (*i)->shutdown (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, - "Coordinator::shutdown, ignored"); - } - ACE_ENDTRY; - } -} - -void -Coordinator::add_peer (Test::Peer_ptr peer - ACE_ENV_ARG_DECL_NOT_USED) - ACE_THROW_SPEC ((CORBA::SystemException)) -{ - if (this->peer_count_ >= this->peer_max_) - return; - - this->peers_[this->peer_count_++] = - Test::Peer::_duplicate (peer); -} |