diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/receiver.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/receiver.cpp | 26 |
1 files changed, 6 insertions, 20 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/receiver.cpp b/TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/receiver.cpp index 3683e3e7ba2..9756c58ad40 100644 --- a/TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/receiver.cpp +++ b/TAO/orbsvcs/tests/AVStreams/Bidirectional_Flows/receiver.cpp @@ -120,7 +120,6 @@ Receiver_Callback::handle_destroy (void) { TAO_AV_CORE::instance ()->orb ()->shutdown (0 ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; } ACE_CATCHANY { @@ -230,8 +229,7 @@ Receiver::init (int argc, this->mmdevice_; CORBA::Object_var mmdevice = - this->mmdevice_->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); + this->mmdevice_->_this (); // Register the mmdevice with the naming service. CosNaming::Name name (1); @@ -250,7 +248,6 @@ Receiver::init (int argc, this->naming_client_->rebind (name, mmdevice.in () ACE_ENV_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); return 0; } @@ -280,29 +277,23 @@ 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; // Make sure we have a valid <output_file> output_file = ACE_OS::fopen (output_file_name, @@ -321,23 +312,19 @@ main (int argc, RECEIVER::instance ()->init (argc, argv ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; // // Start sending data. - // result = SENDER::instance ()->pace_data (ACE_ENV_SINGLE_ARG_PARAMETER); - // ACE_TRY_CHECK; + // result = SENDER::instance ()->pace_data (); if (result != 0) return result; - orb->run (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + orb->run (); // Hack for now.... ACE_OS::sleep (1); - //orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + //orb->destroy (); } ACE_CATCHANY { @@ -345,7 +332,6 @@ main (int argc, return -1; } ACE_ENDTRY; - ACE_CHECK_RETURN (-1); ACE_OS::fclose (output_file); |