diff options
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.cpp | 80 |
1 files changed, 26 insertions, 54 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.cpp b/TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.cpp index a83a5b623da..38d2967bd3e 100644 --- a/TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.cpp +++ b/TAO/orbsvcs/tests/AVStreams/Multicast_Full_Profile/server.cpp @@ -9,19 +9,15 @@ FTP_Server_FlowEndPoint::FTP_Server_FlowEndPoint (void) protocols.length (2); protocols [0] = CORBA::string_dup ("TCP"); protocols [1] = CORBA::string_dup ("UDP"); - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY + try { - this->set_protocol_restriction (protocols - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + this->set_protocol_restriction (protocols); } - ACE_CATCHANY + catch (const CORBA::Exception& ex) { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,"FTP_Server_FlowEndPoint::FTP_Server_FlowEndPoint"); + ex._tao_print_exception ( + "FTP_Server_FlowEndPoint::FTP_Server_FlowEndPoint"); } - ACE_ENDTRY; - ACE_CHECK; } int @@ -82,15 +78,14 @@ FTP_Server_Callback::handle_end_stream (void) // AVStreams::QoS & the_qos, // CORBA::Boolean_out met_qos, // char *& named_fdev, -// ACE_ENV_SINGLE_ARG_DECL) +//) // { // ACE_DEBUG ((LM_DEBUG,"FTP_Server_FDev::make_consumer")); // FTP_Server_FlowEndPoint *endpoint; // ACE_NEW_RETURN (endpoint, // FTP_Server_FlowEndPoint, // 0); -// return endpoint->_this (ACE_ENV_SINGLE_ARG_PARAMETER); -// ACE_CHECK_RETURN (0); +// return endpoint->_this (); // } Server::Server (void) @@ -119,8 +114,7 @@ int Server::init (int argc, char **argv) { - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY + try { PortableServer::POAManager_var mgr @@ -148,63 +142,47 @@ Server::init (int argc, FTP_Server_FDev, -1); this->fdev_->flowname ("Data"); - AVStreams::MMDevice_var mmdevice = this->mmdevice_->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - AVStreams::FDev_var fdev = this->fdev_->_this (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; - mmdevice->add_fdev (fdev.in () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + AVStreams::MMDevice_var mmdevice = this->mmdevice_->_this (); + AVStreams::FDev_var fdev = this->fdev_->_this (); + mmdevice->add_fdev (fdev.in ()); // Register the mmdevice with the naming service. CosNaming::Name server_mmdevice_name (1); server_mmdevice_name.length (1); server_mmdevice_name [0].id = CORBA::string_dup ("Server_MMDevice1"); - ACE_TRY_EX (bind) + try { // Register the video control object with the naming server. this->my_naming_client_->bind (server_mmdevice_name, - mmdevice.in () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK_EX (bind); + mmdevice.in ()); } - ACE_CATCH (CosNaming::NamingContext::AlreadyBound,al_ex) + catch (const CosNaming::NamingContext::AlreadyBound&) { server_mmdevice_name [0].id = CORBA::string_dup ("Server_MMDevice2"); this->my_naming_client_->bind (server_mmdevice_name, - mmdevice.in () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + mmdevice.in ()); } - ACE_ENDTRY; - ACE_CHECK_RETURN (-1); } - ACE_CATCHANY + catch (const CORBA::Exception& ex) { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,"server::init"); + ex._tao_print_exception ("server::init"); return -1; } - ACE_ENDTRY; - ACE_CHECK_RETURN (-1); return 0; } int Server::run (void) { - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY + try { - TAO_AV_CORE::instance ()->orb ()->run (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_TRY_CHECK; + TAO_AV_CORE::instance ()->orb ()->run (); } - ACE_CATCHANY + catch (const CORBA::Exception& ex) { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,"server::init"); + ex._tao_print_exception ("server::init"); return -1; } - ACE_ENDTRY; - ACE_CHECK_RETURN (-1); return 0; } @@ -249,29 +227,23 @@ main (int argc, CORBA::ORB_var orb = CORBA::ORB_init (argc, argv); - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY + try { CORBA::Object_var obj - = orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + = orb->resolve_initial_references ("RootPOA"); PortableServer::POA_var poa = PortableServer::POA::_narrow (obj.in ()); TAO_AV_CORE::instance ()->init (orb.in (), - poa.in () - ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + poa.in ()); } - ACE_CATCHANY + catch (const CORBA::Exception& ex) { - ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,"server::init"); + ex._tao_print_exception ("server::init"); return -1; } - ACE_ENDTRY; - ACE_CHECK_RETURN (-1); int result = 0; result = FTP_SERVER::instance ()->init (argc,argv); |