summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/EC_Throughput/ECT_Supplier_Driver.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/EC_Throughput/ECT_Supplier_Driver.cpp')
-rw-r--r--TAO/orbsvcs/tests/EC_Throughput/ECT_Supplier_Driver.cpp46
1 files changed, 19 insertions, 27 deletions
diff --git a/TAO/orbsvcs/tests/EC_Throughput/ECT_Supplier_Driver.cpp b/TAO/orbsvcs/tests/EC_Throughput/ECT_Supplier_Driver.cpp
index 4cf395bd7c6..8a052c303a1 100644
--- a/TAO/orbsvcs/tests/EC_Throughput/ECT_Supplier_Driver.cpp
+++ b/TAO/orbsvcs/tests/EC_Throughput/ECT_Supplier_Driver.cpp
@@ -46,22 +46,20 @@ ECT_Supplier_Driver::~ECT_Supplier_Driver (void)
}
void
-ECT_Supplier_Driver::shutdown_consumer (void*
- ACE_ENV_ARG_DECL_NOT_USED)
+ECT_Supplier_Driver::shutdown_consumer (void*)
{
}
int
ECT_Supplier_Driver::run (int argc, char* argv[])
{
- ACE_DECLARE_NEW_CORBA_ENV;
- ACE_TRY
+ try
{
CORBA::ORB_var orb =
- CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER);
+ CORBA::ORB_init (argc, argv, "");
CORBA::Object_var poa_object =
- orb->resolve_initial_references("RootPOA" ACE_ENV_ARG_PARAMETER);
+ orb->resolve_initial_references("RootPOA");
if (CORBA::is_nil (poa_object.in ()))
ACE_ERROR_RETURN ((LM_ERROR,
@@ -69,7 +67,7 @@ ECT_Supplier_Driver::run (int argc, char* argv[])
1);
PortableServer::POA_var root_poa =
- PortableServer::POA::_narrow (poa_object.in () ACE_ENV_ARG_PARAMETER);
+ PortableServer::POA::_narrow (poa_object.in ());
PortableServer::POAManager_var poa_manager =
root_poa->the_POAManager ();
@@ -136,7 +134,7 @@ ECT_Supplier_Driver::run (int argc, char* argv[])
}
CORBA::Object_var naming_obj =
- orb->resolve_initial_references ("NameService" ACE_ENV_ARG_PARAMETER);
+ orb->resolve_initial_references ("NameService");
if (CORBA::is_nil (naming_obj.in ()))
ACE_ERROR_RETURN ((LM_ERROR,
@@ -144,38 +142,35 @@ ECT_Supplier_Driver::run (int argc, char* argv[])
1);
CosNaming::NamingContext_var naming_context =
- CosNaming::NamingContext::_narrow (naming_obj.in () ACE_ENV_ARG_PARAMETER);
+ CosNaming::NamingContext::_narrow (naming_obj.in ());
CosNaming::Name schedule_name (1);
schedule_name.length (1);
schedule_name[0].id = CORBA::string_dup ("ScheduleService");
CORBA::Object_var sched_obj =
- naming_context->resolve (schedule_name ACE_ENV_ARG_PARAMETER);
+ naming_context->resolve (schedule_name);
if (CORBA::is_nil (sched_obj.in ()))
return 1;
RtecScheduler::Scheduler_var scheduler =
- RtecScheduler::Scheduler::_narrow (sched_obj.in ()
- ACE_ENV_ARG_PARAMETER);
+ RtecScheduler::Scheduler::_narrow (sched_obj.in ());
CosNaming::Name name (1);
name.length (1);
name[0].id = CORBA::string_dup ("EventService");
CORBA::Object_var ec_obj =
- naming_context->resolve (name ACE_ENV_ARG_PARAMETER);
+ naming_context->resolve (name);
RtecEventChannelAdmin::EventChannel_var channel;
if (CORBA::is_nil (ec_obj.in ()))
channel = RtecEventChannelAdmin::EventChannel::_nil ();
else
- channel = RtecEventChannelAdmin::EventChannel::_narrow (ec_obj.in ()
- ACE_ENV_ARG_PARAMETER);
+ channel = RtecEventChannelAdmin::EventChannel::_narrow (ec_obj.in ());
poa_manager->activate ();
this->connect_suppliers (scheduler.in (),
- channel.in ()
- ACE_ENV_ARG_PARAMETER);
+ channel.in ());
ACE_DEBUG ((LM_DEBUG, "connected supplier(s)\n"));
@@ -200,29 +195,27 @@ ECT_Supplier_Driver::run (int argc, char* argv[])
// @@ Deactivate the suppliers (as CORBA Objects?)
- root_poa->destroy (1, 1 ACE_ENV_ARG_PARAMETER);
+ root_poa->destroy (1, 1);
orb->destroy ();
ACE_DEBUG ((LM_DEBUG, "orb and poa destroyed\n"));
}
- ACE_CATCH (CORBA::SystemException, sys_ex)
+ catch (const CORBA::SystemException& sys_ex)
{
- ACE_PRINT_EXCEPTION (sys_ex, "SYS_EX");
+ sys_ex._tao_print_exception ("SYS_EX");
}
- ACE_CATCHANY
+ catch (const CORBA::Exception& ex)
{
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "NON SYS EX");
+ ex._tao_print_exception ("NON SYS EX");
}
- ACE_ENDTRY;
return 0;
}
void
ECT_Supplier_Driver::connect_suppliers
(RtecScheduler::Scheduler_ptr scheduler,
- RtecEventChannelAdmin::EventChannel_ptr channel
- ACE_ENV_ARG_DECL)
+ RtecEventChannelAdmin::EventChannel_ptr channel)
{
for (int i = 0; i < this->n_suppliers_; ++i)
{
@@ -239,8 +232,7 @@ ECT_Supplier_Driver::connect_suppliers
this->burst_pause_,
this->type_start_,
this->type_count_,
- channel
- ACE_ENV_ARG_PARAMETER);
+ channel);
}
}