diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp | 27 |
1 files changed, 6 insertions, 21 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp b/TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp index 34239319d22..3f868652ea3 100644 --- a/TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp +++ b/TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp @@ -183,8 +183,7 @@ Distributer::init (int argc, this->distributer_sender_mmdevice_; AVStreams::MMDevice_var distributer_sender_mmdevice = - this->distributer_sender_mmdevice_->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); + this->distributer_sender_mmdevice_->_this (); ACE_NEW_RETURN (this->distributer_receiver_mmdevice_, TAO_MMDevice (&this->receiver_endpoint_strategy_), @@ -192,30 +191,25 @@ Distributer::init (int argc, AVStreams::MMDevice_var distributer_receiver_mmdevice = - this->distributer_receiver_mmdevice_->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); + this->distributer_receiver_mmdevice_->_this (); // Bind to receivers. this->connection_manager_.bind_to_receivers (this->distributer_name_, distributer_sender_mmdevice.in () ACE_ENV_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); // Connect to receivers this->connection_manager_.connect_to_receivers (distributer_sender_mmdevice.in () ACE_ENV_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); // Bind to sender. this->connection_manager_.bind_to_sender (this->sender_name_, this->distributer_name_, distributer_receiver_mmdevice.in () ACE_ENV_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); // Connect to sender. - this->connection_manager_.connect_to_sender (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); + this->connection_manager_.connect_to_sender (); return 0; } @@ -245,46 +239,38 @@ main (int argc, argv, 0 ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; CORBA::Object_var obj = orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; // Get the POA_var object from Object_var. PortableServer::POA_var root_poa = PortableServer::POA::_narrow (obj.in () ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; PortableServer::POAManager_var mgr - = root_poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + = root_poa->the_POAManager (); - mgr->activate (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + mgr->activate (); // Initialize the AVStreams components. TAO_AV_CORE::instance ()->init (orb.in (), root_poa.in () ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; // Initialize the Distributer int result = DISTRIBUTER::instance ()->init (argc, argv ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; if (result != 0) return result; while (!DISTRIBUTER::instance ()->done ()) { - orb->perform_work (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + orb->perform_work (); } // Hack for now.... @@ -296,7 +282,6 @@ main (int argc, return -1; } ACE_ENDTRY; - ACE_CHECK_RETURN (-1); DISTRIBUTER::close (); // Explicitly finalize the Unmanaged_Singleton. |