diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/performance-tests/Filter/Structured_Consumer.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/Notify/performance-tests/Filter/Structured_Consumer.cpp | 41 |
1 files changed, 18 insertions, 23 deletions
diff --git a/TAO/orbsvcs/tests/Notify/performance-tests/Filter/Structured_Consumer.cpp b/TAO/orbsvcs/tests/Notify/performance-tests/Filter/Structured_Consumer.cpp index 404a51ced9f..2e08e1570fa 100644 --- a/TAO/orbsvcs/tests/Notify/performance-tests/Filter/Structured_Consumer.cpp +++ b/TAO/orbsvcs/tests/Notify/performance-tests/Filter/Structured_Consumer.cpp @@ -78,14 +78,12 @@ Consumer_Client::parse_args (int argc, char *argv[]) static CosNotifyChannelAdmin::ConsumerAdmin_ptr -create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec - ACE_ENV_ARG_DECL) +create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec) { CosNotifyChannelAdmin::AdminID adminid = 0; CosNotifyChannelAdmin::ConsumerAdmin_var admin = ec->new_for_consumers (CosNotifyChannelAdmin::AND_OP, - adminid - ACE_ENV_ARG_PARAMETER); + adminid); if (filter) @@ -96,7 +94,7 @@ create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec // One Filter CosNotifyFilter::Filter_var filter = - ffact->create_filter (GRAMMAR ACE_ENV_ARG_PARAMETER); + ffact->create_filter (GRAMMAR); CosNotifyFilter::ConstraintExpSeq constraint_list (1); constraint_list.length (1); @@ -105,9 +103,9 @@ create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec constraint_list[0].constraint_expr = CORBA::string_dup ("type == 'even'"); - filter->add_constraints (constraint_list ACE_ENV_ARG_PARAMETER); + filter->add_constraints (constraint_list); - admin->add_filter (filter.in () ACE_ENV_ARG_PARAMETER); + admin->add_filter (filter.in ()); // End One Filter } @@ -117,8 +115,7 @@ create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec static void create_consumers (CosNotifyChannelAdmin::ConsumerAdmin_ptr admin, - Notify_Test_Client* client - ACE_ENV_ARG_DECL) + Notify_Test_Client* client) { for(unsigned int i = 0; i < consumers; i++) { @@ -133,9 +130,9 @@ create_consumers (CosNotifyChannelAdmin::ConsumerAdmin_ptr admin, *client), CORBA::NO_MEMORY ()); - consumer->init (client->root_poa () ACE_ENV_ARG_PARAMETER); + consumer->init (client->root_poa ()); - consumer->_connect (admin ACE_ENV_ARG_PARAMETER); + consumer->_connect (admin); } } @@ -146,11 +143,11 @@ create_consumers (CosNotifyChannelAdmin::ConsumerAdmin_ptr admin, int main (int argc, char* argv[]) { int status = 0; - ACE_TRY_NEW_ENV + try { Consumer_Client client; - status = client.init (argc, argv ACE_ENV_ARG_PARAMETER); + status = client.init (argc, argv); if (status == 0) { @@ -162,14 +159,13 @@ int main (int argc, char* argv[]) } CosNotifyChannelAdmin::EventChannel_var ec = - client.create_event_channel ("MyEventChannel", 1 - ACE_ENV_ARG_PARAMETER); + client.create_event_channel ("MyEventChannel", 1); CORBA::ORB_ptr orb = client.orb (); CORBA::Object_var object = - orb->string_to_object (ior ACE_ENV_ARG_PARAMETER); + orb->string_to_object (ior); - sig_var sig = sig::_narrow (object.in () ACE_ENV_ARG_PARAMETER); + sig_var sig = sig::_narrow (object.in ()); if (CORBA::is_nil (sig.in ())) { @@ -180,28 +176,27 @@ int main (int argc, char* argv[]) } CosNotifyChannelAdmin::ConsumerAdmin_var admin = - create_consumeradmin (ec.in () ACE_ENV_ARG_PARAMETER); + create_consumeradmin (ec.in ()); if (!CORBA::is_nil (admin.in ())) { - create_consumers(admin.in (), &client ACE_ENV_ARG_PARAMETER); + create_consumers(admin.in (), &client); // Tell the supplier to go sig->go (); - client.ORB_run( ACE_ENV_SINGLE_ARG_PARAMETER ); + client.ORB_run( ); ACE_DEBUG((LM_DEBUG, "Consumer done.\n")); sig->done (); } } } - ACE_CATCH (CORBA::Exception, e) + catch (const CORBA::Exception& e) { - ACE_PRINT_EXCEPTION (e, "Error: Consumer exception: "); + e._tao_print_exception ("Error: Consumer exception: "); status = 1; } - ACE_ENDTRY; return status; } |