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