diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/performance-tests/Filter/Sequence_Consumer.cpp')
| -rw-r--r-- | TAO/orbsvcs/tests/Notify/performance-tests/Filter/Sequence_Consumer.cpp | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/TAO/orbsvcs/tests/Notify/performance-tests/Filter/Sequence_Consumer.cpp b/TAO/orbsvcs/tests/Notify/performance-tests/Filter/Sequence_Consumer.cpp index 0d70d2d31c0..24f12bf3d23 100644 --- a/TAO/orbsvcs/tests/Notify/performance-tests/Filter/Sequence_Consumer.cpp +++ b/TAO/orbsvcs/tests/Notify/performance-tests/Filter/Sequence_Consumer.cpp @@ -81,13 +81,13 @@ Consumer_Client::parse_args (int argc, char *argv[]) static CosNotifyChannelAdmin::ConsumerAdmin_ptr create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { CosNotifyChannelAdmin::AdminID adminid = 0; CosNotifyChannelAdmin::ConsumerAdmin_var admin = ec->new_for_consumers (CosNotifyChannelAdmin::OR_OP, adminid - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); @@ -95,12 +95,12 @@ create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec { // Filter Section CosNotifyFilter::FilterFactory_var ffact = - ec->default_filter_factory (TAO_ENV_SINGLE_ARG_PARAMETER); + ec->default_filter_factory (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK_RETURN (0); // One Filter CosNotifyFilter::Filter_var filter = - ffact->create_filter (GRAMMAR TAO_ENV_ARG_PARAMETER); + ffact->create_filter (GRAMMAR ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); CosNotifyFilter::ConstraintExpSeq constraint_list (1); @@ -110,10 +110,10 @@ create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec constraint_list[0].constraint_expr = CORBA::string_dup ("type == 'even'"); - filter->add_constraints (constraint_list TAO_ENV_ARG_PARAMETER); + filter->add_constraints (constraint_list ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); - admin->add_filter (filter.in () TAO_ENV_ARG_PARAMETER); + admin->add_filter (filter.in () ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); // End One Filter } @@ -127,7 +127,7 @@ create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec added[0].domain_name = CORBA::string_dup ("*"); added[0].type_name = CORBA::string_dup ("*"); - admin->subscription_change (added, removed TAO_ENV_ARG_PARAMETER); + admin->subscription_change (added, removed ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (0); return CosNotifyChannelAdmin::ConsumerAdmin::_duplicate (admin.in ()); @@ -137,7 +137,7 @@ create_consumeradmin (CosNotifyChannelAdmin::EventChannel_ptr ec static void create_consumers (CosNotifyChannelAdmin::ConsumerAdmin_ptr admin, Notify_Test_Client* client - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { for(unsigned int i = 0; i < consumers; i++) { @@ -152,10 +152,10 @@ create_consumers (CosNotifyChannelAdmin::ConsumerAdmin_ptr admin, (i + 1 == consumers ? done : dummy)), CORBA::NO_MEMORY ()); - consumer->init (client->root_poa () TAO_ENV_ARG_PARAMETER); + consumer->init (client->root_poa () ACE_ENV_ARG_PARAMETER); ACE_CHECK; - consumer->connect (admin TAO_ENV_ARG_PARAMETER); + consumer->connect (admin ACE_ENV_ARG_PARAMETER); ACE_CHECK; } } @@ -171,7 +171,7 @@ int main (int argc, char* argv[]) { Consumer_Client client; - status = client.init (argc, argv TAO_ENV_ARG_PARAMETER); + status = client.init (argc, argv ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; if (status == 0) @@ -185,15 +185,15 @@ int main (int argc, char* argv[]) CosNotifyChannelAdmin::EventChannel_var ec = client.create_event_channel ("MyEventChannel", 1 - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; CORBA::ORB_ptr orb = client.orb (); CORBA::Object_var object = - orb->string_to_object (ior TAO_ENV_ARG_PARAMETER); + orb->string_to_object (ior ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - sig_var sig = sig::_narrow (object.in () TAO_ENV_ARG_PARAMETER); + sig_var sig = sig::_narrow (object.in () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; if (CORBA::is_nil (sig.in ())) @@ -205,16 +205,16 @@ int main (int argc, char* argv[]) } CosNotifyChannelAdmin::ConsumerAdmin_var admin = - create_consumeradmin (ec.in () TAO_ENV_ARG_PARAMETER); + create_consumeradmin (ec.in () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; if (!CORBA::is_nil (admin.in ())) { - create_consumers(admin.in (), &client TAO_ENV_ARG_PARAMETER); + create_consumers(admin.in (), &client ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // Tell the supplier to go - sig->go (TAO_ENV_SINGLE_ARG_PARAMETER); + sig->go (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; ACE_Time_Value now = ACE_OS::gettimeofday (); |