summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp')
-rw-r--r--TAO/orbsvcs/tests/AVStreams/Asynch_Three_Stage/distributer.cpp27
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.