diff options
Diffstat (limited to 'TAO/tests/Big_Oneways/Peer.cpp')
| -rw-r--r-- | TAO/tests/Big_Oneways/Peer.cpp | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/TAO/tests/Big_Oneways/Peer.cpp b/TAO/tests/Big_Oneways/Peer.cpp index fbb85bcea96..e5cf894acba 100644 --- a/TAO/tests/Big_Oneways/Peer.cpp +++ b/TAO/tests/Big_Oneways/Peer.cpp @@ -17,12 +17,20 @@ Peer::~Peer (void) Test::Session_ptr Peer::create_session (Test::Session_Control_ptr control, + CORBA::ULong payload_size, + CORBA::ULong thread_count, + CORBA::ULong message_count, + CORBA::ULong peer_count, CORBA::Environment &ACE_TRY_ENV) ACE_THROW_SPEC ((CORBA::SystemException)) { Session *session_impl; ACE_NEW_THROW_EX (session_impl, - Session (control), + Session (control, + payload_size, + thread_count, + message_count, + peer_count), CORBA::NO_MEMORY ()); ACE_CHECK_RETURN (Test::Session::_nil ()); PortableServer::ServantBase_var transfer_ownership (session_impl); @@ -37,9 +45,6 @@ Peer::shutdown (CORBA::Environment &ACE_TRY_ENV) ACE_DEBUG ((LM_DEBUG, "(%P|%t) Peer::shutdown, waiting for threads\n")); - // Wait for all the threads. - ACE_Thread_Manager::instance ()->wait (); - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Peer::shutdown, shutting down ORB\n")); this->orb_->shutdown (0, ACE_TRY_ENV); |