diff options
author | okellogg <okellogg@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2002-01-29 20:21:11 +0000 |
---|---|---|
committer | okellogg <okellogg@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2002-01-29 20:21:11 +0000 |
commit | 15f9b16afed320b4e581b8f61fee7d7fbf1aa9a8 (patch) | |
tree | fd798ba5478a08b4b6f842cb8515ed9776861f5f /TAO/orbsvcs/tests/CosEvent/Basic | |
parent | 5e12d6686388ccadee1714b94ddee0cce6587bfd (diff) | |
download | ATCD-15f9b16afed320b4e581b8f61fee7d7fbf1aa9a8.tar.gz |
ChangeLogTag:Tue Jan 29 21:09:12 2002 Oliver Kellogg <oliver.kellogg@sysde.eads.net>
Diffstat (limited to 'TAO/orbsvcs/tests/CosEvent/Basic')
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Basic/Disconnect.cpp | 68 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.cpp | 68 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.h | 2 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Basic/Pull_Push_Event.cpp | 54 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Basic/Push_Event.cpp | 50 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Basic/Random.cpp | 112 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Basic/Random.h | 24 | ||||
-rw-r--r-- | TAO/orbsvcs/tests/CosEvent/Basic/Shutdown.cpp | 52 |
8 files changed, 215 insertions, 215 deletions
diff --git a/TAO/orbsvcs/tests/CosEvent/Basic/Disconnect.cpp b/TAO/orbsvcs/tests/CosEvent/Basic/Disconnect.cpp index a2e9d894079..14bff5925b2 100644 --- a/TAO/orbsvcs/tests/CosEvent/Basic/Disconnect.cpp +++ b/TAO/orbsvcs/tests/CosEvent/Basic/Disconnect.cpp @@ -11,47 +11,47 @@ ACE_RCSID(CEC_Tests, Disconnect, "$Id$") static void run_test (PortableServer::POA_ptr poa, int use_callbacks - TAO_ENV_ARG_DECL); + ACE_ENV_ARG_DECL); int main (int argc, char* argv[]) { TAO_CEC_Default_Factory::init_svcs (); - TAO_ENV_DECLARE_NEW_ENV; + ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { // ORB initialization boiler plate... CORBA::ORB_var orb = - CORBA::ORB_init (argc, argv, "" TAO_ENV_ARG_PARAMETER); + CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; CORBA::Object_var object = - orb->resolve_initial_references ("RootPOA" TAO_ENV_ARG_PARAMETER); + orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POA_var poa = - PortableServer::POA::_narrow (object.in () TAO_ENV_ARG_PARAMETER); + PortableServer::POA::_narrow (object.in () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POAManager_var poa_manager = - poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER); + poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - poa_manager->activate (TAO_ENV_SINGLE_ARG_PARAMETER); + poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - run_test (poa.in (), 0 TAO_ENV_ARG_PARAMETER); + run_test (poa.in (), 0 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - run_test (poa.in (), 1 TAO_ENV_ARG_PARAMETER); + run_test (poa.in (), 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - poa->destroy (1, 1 TAO_ENV_ARG_PARAMETER); + poa->destroy (1, 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - orb->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } @@ -68,44 +68,44 @@ main (int argc, char* argv[]) void deactivate_servant (PortableServer::Servant servant - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { PortableServer::POA_var poa = - servant->_default_POA (TAO_ENV_SINGLE_ARG_PARAMETER); + servant->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; PortableServer::ObjectId_var id = - poa->servant_to_id (servant TAO_ENV_ARG_PARAMETER); + poa->servant_to_id (servant ACE_ENV_ARG_PARAMETER); ACE_CHECK; - poa->deactivate_object (id.in () TAO_ENV_ARG_PARAMETER); + poa->deactivate_object (id.in () ACE_ENV_ARG_PARAMETER); ACE_CHECK; } void run_test (PortableServer::POA_ptr poa, int use_callbacks - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { TAO_CEC_EventChannel_Attributes attributes (poa, poa); attributes.disconnect_callbacks = use_callbacks; TAO_CEC_EventChannel ec_impl (attributes); - ec_impl.activate (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; CosEventChannelAdmin::EventChannel_var event_channel = - ec_impl._this (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl._this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // **************************************************************** // Obtain the consumer admin.. CosEventChannelAdmin::ConsumerAdmin_var consumer_admin = - event_channel->for_consumers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_consumers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // and the supplier admin.. CosEventChannelAdmin::SupplierAdmin_var supplier_admin = - event_channel->for_suppliers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_suppliers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // **************************************************************** @@ -120,50 +120,50 @@ run_test (PortableServer::POA_ptr poa, for (int i = 0; i != iterations; ++i) { supplier_0.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; consumer_0.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; if (i % 2 == 1) { supplier_1.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; consumer_1.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; } - supplier_0.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_0.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - consumer_0.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_0.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; if (i % 2 == 1) { - consumer_1.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_1.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - supplier_1.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_1.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; } } supplier_0.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; consumer_0.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; - event_channel->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - deactivate_servant (&supplier_0 TAO_ENV_ARG_PARAMETER); + deactivate_servant (&supplier_0 ACE_ENV_ARG_PARAMETER); ACE_CHECK; - deactivate_servant (&consumer_0 TAO_ENV_ARG_PARAMETER); + deactivate_servant (&consumer_0 ACE_ENV_ARG_PARAMETER); ACE_CHECK; - deactivate_servant (&ec_impl TAO_ENV_ARG_PARAMETER); + deactivate_servant (&ec_impl ACE_ENV_ARG_PARAMETER); ACE_CHECK; CORBA::ULong count_0 = 1; diff --git a/TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.cpp b/TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.cpp index 2f661daad58..5587b6584fd 100644 --- a/TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.cpp +++ b/TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.cpp @@ -11,47 +11,47 @@ ACE_RCSID(CEC_Tests, MT_Disconnect, "$Id$") static void run_test (PortableServer::POA_ptr poa, int use_callbacks - TAO_ENV_ARG_DECL); + ACE_ENV_ARG_DECL); int main (int argc, char* argv[]) { TAO_CEC_Default_Factory::init_svcs (); - TAO_ENV_DECLARE_NEW_ENV; + ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { // ORB initialization boiler plate... CORBA::ORB_var orb = - CORBA::ORB_init (argc, argv, "" TAO_ENV_ARG_PARAMETER); + CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; CORBA::Object_var object = - orb->resolve_initial_references ("RootPOA" TAO_ENV_ARG_PARAMETER); + orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POA_var poa = - PortableServer::POA::_narrow (object.in () TAO_ENV_ARG_PARAMETER); + PortableServer::POA::_narrow (object.in () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POAManager_var poa_manager = - poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER); + poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - poa_manager->activate (TAO_ENV_SINGLE_ARG_PARAMETER); + poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - run_test (poa.in (), 0 TAO_ENV_ARG_PARAMETER); + run_test (poa.in (), 0 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - run_test (poa.in (), 1 TAO_ENV_ARG_PARAMETER); + run_test (poa.in (), 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - poa->destroy (1, 1 TAO_ENV_ARG_PARAMETER); + poa->destroy (1, 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - orb->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } @@ -68,32 +68,32 @@ main (int argc, char* argv[]) void deactivate_servant (PortableServer::Servant servant - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { PortableServer::POA_var poa = - servant->_default_POA (TAO_ENV_SINGLE_ARG_PARAMETER); + servant->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; PortableServer::ObjectId_var id = - poa->servant_to_id (servant TAO_ENV_ARG_PARAMETER); + poa->servant_to_id (servant ACE_ENV_ARG_PARAMETER); ACE_CHECK; - poa->deactivate_object (id.in () TAO_ENV_ARG_PARAMETER); + poa->deactivate_object (id.in () ACE_ENV_ARG_PARAMETER); ACE_CHECK; } void run_test (PortableServer::POA_ptr poa, int use_callbacks - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { TAO_CEC_EventChannel_Attributes attributes (poa, poa); attributes.disconnect_callbacks = use_callbacks; TAO_CEC_EventChannel ec_impl (attributes); - ec_impl.activate (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; CosEventChannelAdmin::EventChannel_var event_channel = - ec_impl._this (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl._this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; Task task (event_channel.in (), use_callbacks); @@ -106,10 +106,10 @@ run_test (PortableServer::POA_ptr poa, // Wait for all the threads to complete and the return ACE_Thread_Manager::instance ()->wait (); - event_channel->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - deactivate_servant (&ec_impl TAO_ENV_ARG_PARAMETER); + deactivate_servant (&ec_impl ACE_ENV_ARG_PARAMETER); ACE_CHECK; } @@ -128,7 +128,7 @@ Task::svc () { ACE_TRY_NEW_ENV { - this->run_iteration (TAO_ENV_SINGLE_ARG_PARAMETER); + this->run_iteration (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } ACE_CATCHANY @@ -141,16 +141,16 @@ Task::svc () } void -Task::run_iteration (TAO_ENV_SINGLE_ARG_DECL) +Task::run_iteration (ACE_ENV_SINGLE_ARG_DECL) { // Obtain the consumer admin.. CosEventChannelAdmin::ConsumerAdmin_var consumer_admin = - this->event_channel->for_consumers (TAO_ENV_SINGLE_ARG_PARAMETER); + this->event_channel->for_consumers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // and the supplier admin.. CosEventChannelAdmin::SupplierAdmin_var supplier_admin = - this->event_channel->for_suppliers (TAO_ENV_SINGLE_ARG_PARAMETER); + this->event_channel->for_suppliers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // **************************************************************** @@ -165,37 +165,37 @@ Task::run_iteration (TAO_ENV_SINGLE_ARG_DECL) for (int i = 0; i != iterations; ++i) { supplier_0.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; consumer_0.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; if (i % 2 == 1) { supplier_1.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; consumer_1.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; } - supplier_0.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_0.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - consumer_0.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_0.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; if (i % 2 == 1) { - consumer_1.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_1.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - supplier_1.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_1.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; } } - deactivate_servant (&supplier_0 TAO_ENV_ARG_PARAMETER); + deactivate_servant (&supplier_0 ACE_ENV_ARG_PARAMETER); ACE_CHECK; - deactivate_servant (&consumer_0 TAO_ENV_ARG_PARAMETER); + deactivate_servant (&consumer_0 ACE_ENV_ARG_PARAMETER); ACE_CHECK; CORBA::ULong count_0 = 0; diff --git a/TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.h b/TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.h index 10ad1725717..06a263e9178 100644 --- a/TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.h +++ b/TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.h @@ -34,7 +34,7 @@ public: // = Check the ACE_Task_Base documentation. int svc (void); - void run_iteration (TAO_ENV_SINGLE_ARG_DECL); + void run_iteration (ACE_ENV_SINGLE_ARG_DECL); // Run a single iteration of the test private: diff --git a/TAO/orbsvcs/tests/CosEvent/Basic/Pull_Push_Event.cpp b/TAO/orbsvcs/tests/CosEvent/Basic/Pull_Push_Event.cpp index bce8e4efbc6..9f117d025b3 100644 --- a/TAO/orbsvcs/tests/CosEvent/Basic/Pull_Push_Event.cpp +++ b/TAO/orbsvcs/tests/CosEvent/Basic/Pull_Push_Event.cpp @@ -12,24 +12,24 @@ main (int argc, char* argv[]) { TAO_CEC_Default_Factory::init_svcs (); - TAO_ENV_DECLARE_NEW_ENV; + ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { // ORB initialization boiler plate... CORBA::ORB_var orb = - CORBA::ORB_init (argc, argv, "" TAO_ENV_ARG_PARAMETER); + CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; CORBA::Object_var object = - orb->resolve_initial_references ("RootPOA" TAO_ENV_ARG_PARAMETER); + orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POA_var poa = - PortableServer::POA::_narrow (object.in () TAO_ENV_ARG_PARAMETER); + PortableServer::POA::_narrow (object.in () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POAManager_var poa_manager = - poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER); + poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - poa_manager->activate (TAO_ENV_SINGLE_ARG_PARAMETER); + poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -38,23 +38,23 @@ main (int argc, char* argv[]) poa.in ()); TAO_CEC_EventChannel ec_impl (attributes); - ec_impl.activate (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; CosEventChannelAdmin::EventChannel_var event_channel = - ec_impl._this (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl._this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** // Obtain the consumer admin.. CosEventChannelAdmin::ConsumerAdmin_var consumer_admin = - event_channel->for_consumers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_consumers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // Obtain the supplier admin.. CosEventChannelAdmin::SupplierAdmin_var supplier_admin = - event_channel->for_suppliers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_suppliers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -64,7 +64,7 @@ main (int argc, char* argv[]) CEC_Counting_Supplier supplier_00; supplier_00.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -72,7 +72,7 @@ main (int argc, char* argv[]) CEC_Counting_Supplier supplier_01; supplier_01.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -80,7 +80,7 @@ main (int argc, char* argv[]) CEC_Pull_Counting_Supplier supplier_10; supplier_10.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -88,7 +88,7 @@ main (int argc, char* argv[]) CEC_Pull_Counting_Supplier supplier_11; supplier_11.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -97,21 +97,21 @@ main (int argc, char* argv[]) // connnect to the event channel.... CEC_Counting_Consumer consumer_00 ("Consumer/00"); consumer_00.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** CEC_Pull_Counting_Consumer consumer_01 ("Consumer/01"); consumer_01.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** CEC_Pull_Counting_Consumer consumer_10 ("Consumer/10"); consumer_10.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -171,35 +171,35 @@ main (int argc, char* argv[]) // **************************************************************** - consumer_10.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_10.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - consumer_01.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_01.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - consumer_00.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_00.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - supplier_11.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_11.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - supplier_10.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_10.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - supplier_01.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_01.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - supplier_00.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_00.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - event_channel->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - poa->destroy (1, 1 TAO_ENV_ARG_PARAMETER); + poa->destroy (1, 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - orb->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** diff --git a/TAO/orbsvcs/tests/CosEvent/Basic/Push_Event.cpp b/TAO/orbsvcs/tests/CosEvent/Basic/Push_Event.cpp index cb46f224cc6..f4fffebd1ad 100644 --- a/TAO/orbsvcs/tests/CosEvent/Basic/Push_Event.cpp +++ b/TAO/orbsvcs/tests/CosEvent/Basic/Push_Event.cpp @@ -12,24 +12,24 @@ main (int argc, char* argv[]) { TAO_CEC_Default_Factory::init_svcs (); - TAO_ENV_DECLARE_NEW_ENV; + ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { // ORB initialization boiler plate... CORBA::ORB_var orb = - CORBA::ORB_init (argc, argv, "" TAO_ENV_ARG_PARAMETER); + CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; CORBA::Object_var object = - orb->resolve_initial_references ("RootPOA" TAO_ENV_ARG_PARAMETER); + orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POA_var poa = - PortableServer::POA::_narrow (object.in () TAO_ENV_ARG_PARAMETER); + PortableServer::POA::_narrow (object.in () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POAManager_var poa_manager = - poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER); + poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - poa_manager->activate (TAO_ENV_SINGLE_ARG_PARAMETER); + poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -38,23 +38,23 @@ main (int argc, char* argv[]) poa.in ()); TAO_CEC_EventChannel ec_impl (attributes); - ec_impl.activate (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; CosEventChannelAdmin::EventChannel_var event_channel = - ec_impl._this (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl._this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** // Obtain the consumer admin.. CosEventChannelAdmin::ConsumerAdmin_var consumer_admin = - event_channel->for_consumers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_consumers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // Obtain the supplier admin.. CosEventChannelAdmin::SupplierAdmin_var supplier_admin = - event_channel->for_suppliers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_suppliers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -64,7 +64,7 @@ main (int argc, char* argv[]) CEC_Counting_Supplier supplier_00; supplier_00.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -72,7 +72,7 @@ main (int argc, char* argv[]) CEC_Counting_Supplier supplier_01; supplier_01.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -80,7 +80,7 @@ main (int argc, char* argv[]) CEC_Counting_Supplier supplier_10; supplier_10.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -88,7 +88,7 @@ main (int argc, char* argv[]) CEC_Counting_Supplier supplier_11; supplier_11.connect (supplier_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -97,14 +97,14 @@ main (int argc, char* argv[]) // connnect to the event channel.... CEC_Counting_Consumer consumer_00 ("Consumer/00"); consumer_00.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** CEC_Counting_Consumer consumer_01 ("Consumer/01"); consumer_01.connect (consumer_admin.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -144,32 +144,32 @@ main (int argc, char* argv[]) // **************************************************************** - consumer_01.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_01.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - consumer_00.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + consumer_00.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - supplier_11.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_11.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - supplier_10.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_10.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - supplier_01.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_01.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - supplier_00.disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + supplier_00.disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - event_channel->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - poa->destroy (1, 1 TAO_ENV_ARG_PARAMETER); + poa->destroy (1, 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - orb->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** diff --git a/TAO/orbsvcs/tests/CosEvent/Basic/Random.cpp b/TAO/orbsvcs/tests/CosEvent/Basic/Random.cpp index 7c3f444bf1d..ec6ffd9effb 100644 --- a/TAO/orbsvcs/tests/CosEvent/Basic/Random.cpp +++ b/TAO/orbsvcs/tests/CosEvent/Basic/Random.cpp @@ -18,15 +18,15 @@ main (int argc, char* argv[]) void deactivate_servant (PortableServer::Servant servant - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { PortableServer::POA_var poa = - servant->_default_POA (TAO_ENV_SINGLE_ARG_PARAMETER); + servant->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; PortableServer::ObjectId_var oid = - poa->servant_to_id (servant TAO_ENV_ARG_PARAMETER); + poa->servant_to_id (servant ACE_ENV_ARG_PARAMETER); ACE_CHECK; - poa->deactivate_object (oid.in () TAO_ENV_ARG_PARAMETER); + poa->deactivate_object (oid.in () ACE_ENV_ARG_PARAMETER); ACE_CHECK; } @@ -42,11 +42,11 @@ RND_Driver::RND_Driver (void) int RND_Driver::run (int argc, char *argv[]) { - TAO_ENV_DECLARE_NEW_ENV; + ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { CORBA::ORB_var orb = - CORBA::ORB_init (argc, argv, "" TAO_ENV_ARG_PARAMETER); + CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -103,15 +103,15 @@ RND_Driver::run (int argc, char *argv[]) // **************************************************************** CORBA::Object_var object = - orb->resolve_initial_references ("RootPOA" TAO_ENV_ARG_PARAMETER); + orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POA_var poa = - PortableServer::POA::_narrow (object.in () TAO_ENV_ARG_PARAMETER); + PortableServer::POA::_narrow (object.in () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POAManager_var poa_manager = - poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER); + poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - poa_manager->activate (TAO_ENV_SINGLE_ARG_PARAMETER); + poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -122,29 +122,29 @@ RND_Driver::run (int argc, char *argv[]) attributes.supplier_reconnect = 1; TAO_CEC_EventChannel ec_impl (attributes); - ec_impl.activate (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; CosEventChannelAdmin::EventChannel_var event_channel = - ec_impl._this (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl._this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** // Obtain the consumer admin.. this->consumer_admin_ = - event_channel->for_consumers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_consumers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // Obtain the supplier admin.. this->supplier_admin_ = - event_channel->for_suppliers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_suppliers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** this->supplier_.connect (this->supplier_admin_.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -159,7 +159,7 @@ RND_Driver::run (int argc, char *argv[]) 1); CORBA::Object_var obj = - this->consumers_[i]->_this (TAO_ENV_SINGLE_ARG_PARAMETER); + this->consumers_[i]->_this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } @@ -176,7 +176,7 @@ RND_Driver::run (int argc, char *argv[]) this->suppliers_[j]->activate (); CORBA::Object_var obj = - this->suppliers_[j]->_this (TAO_ENV_SINGLE_ARG_PARAMETER); + this->suppliers_[j]->_this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } @@ -186,7 +186,7 @@ RND_Driver::run (int argc, char *argv[]) { ACE_Time_Value tv (0, 50000); orb->run (tv); - this->supplier_.push_new_event (TAO_ENV_SINGLE_ARG_PARAMETER); + this->supplier_.push_new_event (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } @@ -198,9 +198,9 @@ RND_Driver::run (int argc, char *argv[]) for (int k = 0; k != this->nsuppliers_; ++k) { deactivate_servant (this->suppliers_[k] - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - this->suppliers_[k]->_remove_ref (TAO_ENV_SINGLE_ARG_PARAMETER); + this->suppliers_[k]->_remove_ref (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } delete[] this->suppliers_; @@ -211,7 +211,7 @@ RND_Driver::run (int argc, char *argv[]) // We destroy now to verify that the callbacks work and do not // produce any problems. - event_channel->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** @@ -220,9 +220,9 @@ RND_Driver::run (int argc, char *argv[]) for (int k = 0; k != this->nconsumers_; ++k) { deactivate_servant (this->consumers_[k] - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - this->consumers_[k]->_remove_ref (TAO_ENV_SINGLE_ARG_PARAMETER); + this->consumers_[k]->_remove_ref (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } delete[] this->consumers_; @@ -232,17 +232,17 @@ RND_Driver::run (int argc, char *argv[]) // **************************************************************** deactivate_servant (&ec_impl - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - poa->destroy (1, 1 TAO_ENV_ARG_PARAMETER); + poa->destroy (1, 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - orb->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } ACE_CATCHANY @@ -256,7 +256,7 @@ RND_Driver::run (int argc, char *argv[]) void RND_Driver::timer (const CORBA::Any &e - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { int r = ACE_OS::rand (); if (r < 0) @@ -277,7 +277,7 @@ RND_Driver::timer (const CORBA::Any &e CORBA::Any new_event; recursion++; new_event <<= recursion; - this->supplier_.push (new_event TAO_ENV_ARG_PARAMETER); + this->supplier_.push (new_event ACE_ENV_ARG_PARAMETER); ACE_CHECK; } } @@ -298,7 +298,7 @@ RND_Driver::timer (const CORBA::Any &e // ACE_DEBUG ((LM_DEBUG, "Connecting supplier %d\n", n)); this->suppliers_[n]->connect (this->supplier_admin_.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; } break; @@ -310,7 +310,7 @@ RND_Driver::timer (const CORBA::Any &e // ACE_DEBUG ((LM_DEBUG, "Connecting consumer %d\n", n)); this->consumers_[n]->connect (this->consumer_admin_.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; } break; @@ -321,7 +321,7 @@ RND_Driver::timer (const CORBA::Any &e // ACE_DEBUG ((LM_DEBUG, "Disconnecting supplier %d\n", n)); - this->suppliers_[n]->disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + this->suppliers_[n]->disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; } break; @@ -332,7 +332,7 @@ RND_Driver::timer (const CORBA::Any &e // ACE_DEBUG ((LM_DEBUG, "Disconnecting consumer %d\n", n)); - this->consumers_[n]->disconnect (TAO_ENV_SINGLE_ARG_PARAMETER); + this->consumers_[n]->disconnect (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; } break; @@ -341,16 +341,16 @@ RND_Driver::timer (const CORBA::Any &e void RND_Driver::event (const CORBA::Any &e - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { - this->timer (e TAO_ENV_ARG_PARAMETER); + this->timer (e ACE_ENV_ARG_PARAMETER); } // **************************************************************** void RND_Consumer::connect (CosEventChannelAdmin::ConsumerAdmin_ptr admin - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { CosEventChannelAdmin::ProxyPushSupplier_var proxy; { @@ -358,28 +358,28 @@ RND_Consumer::connect (CosEventChannelAdmin::ConsumerAdmin_ptr admin if (CORBA::is_nil (this->proxy_.in ())) { - this->proxy_ = admin->obtain_push_supplier (TAO_ENV_SINGLE_ARG_PARAMETER); + this->proxy_ = admin->obtain_push_supplier (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; } proxy = CosEventChannelAdmin::ProxyPushSupplier::_duplicate(this->proxy_.in ()); } CosEventComm::PushConsumer_var me = - this->_this (TAO_ENV_SINGLE_ARG_PARAMETER); + this->_this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; proxy->connect_push_consumer (me.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; } void -RND_Consumer::disconnect (TAO_ENV_SINGLE_ARG_DECL) +RND_Consumer::disconnect (ACE_ENV_SINGLE_ARG_DECL) { ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->lock_); if (CORBA::is_nil (this->proxy_.in ())) return; - this->proxy_->disconnect_push_supplier (TAO_ENV_SINGLE_ARG_PARAMETER); + this->proxy_->disconnect_push_supplier (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; this->proxy_ = CosEventChannelAdmin::ProxyPushSupplier::_nil (); @@ -387,14 +387,14 @@ RND_Consumer::disconnect (TAO_ENV_SINGLE_ARG_DECL) void RND_Consumer::push (const CORBA::Any &event - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) ACE_THROW_SPEC ((CORBA::SystemException)) { - this->driver_->event (event TAO_ENV_ARG_PARAMETER); + this->driver_->event (event ACE_ENV_ARG_PARAMETER); } void -RND_Consumer::disconnect_push_consumer (TAO_ENV_SINGLE_ARG_DECL_NOT_USED) +RND_Consumer::disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) ACE_THROW_SPEC ((CORBA::SystemException)) { } @@ -403,7 +403,7 @@ RND_Consumer::disconnect_push_consumer (TAO_ENV_SINGLE_ARG_DECL_NOT_USED) void RND_Supplier::connect (CosEventChannelAdmin::SupplierAdmin_ptr admin - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { CosEventChannelAdmin::ProxyPushConsumer_var proxy; { @@ -411,7 +411,7 @@ RND_Supplier::connect (CosEventChannelAdmin::SupplierAdmin_ptr admin if (CORBA::is_nil (this->proxy_.in ())) { - this->proxy_ = admin->obtain_push_consumer (TAO_ENV_SINGLE_ARG_PARAMETER); + this->proxy_ = admin->obtain_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; } @@ -423,40 +423,40 @@ RND_Supplier::connect (CosEventChannelAdmin::SupplierAdmin_ptr admin int r = ACE_OS::rand () % 2; if (r == 0) { - me = this->_this (TAO_ENV_SINGLE_ARG_PARAMETER); + me = this->_this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; } proxy->connect_push_supplier (me.in () - TAO_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; } void -RND_Supplier::disconnect (TAO_ENV_SINGLE_ARG_DECL) +RND_Supplier::disconnect (ACE_ENV_SINGLE_ARG_DECL) { ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->lock_); if (CORBA::is_nil (this->proxy_.in ())) return; - this->proxy_->disconnect_push_consumer (TAO_ENV_SINGLE_ARG_PARAMETER); + this->proxy_->disconnect_push_consumer (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; this->proxy_ = CosEventChannelAdmin::ProxyPushConsumer::_nil (); } void -RND_Supplier::push_new_event (TAO_ENV_SINGLE_ARG_DECL) +RND_Supplier::push_new_event (ACE_ENV_SINGLE_ARG_DECL) { CORBA::Any event; CORBA::Long recursion = 0; event <<= recursion; - this->push (event TAO_ENV_ARG_PARAMETER); + this->push (event ACE_ENV_ARG_PARAMETER); } void RND_Supplier::push (CORBA::Any &event - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { CosEventChannelAdmin::ProxyPushConsumer_var proxy; { @@ -469,11 +469,11 @@ RND_Supplier::push (CORBA::Any &event CosEventChannelAdmin::ProxyPushConsumer::_duplicate(this->proxy_.in ()); } - proxy->push (event TAO_ENV_ARG_PARAMETER); + proxy->push (event ACE_ENV_ARG_PARAMETER); } void -RND_Supplier::disconnect_push_supplier (TAO_ENV_SINGLE_ARG_DECL_NOT_USED) +RND_Supplier::disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) ACE_THROW_SPEC ((CORBA::SystemException)) { } @@ -486,13 +486,13 @@ RND_Supplier::svc (void) int niterations = 5000; for (int i = 0; i != niterations; ++i) { - TAO_ENV_DECLARE_NEW_ENV; + ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { ACE_Time_Value tv (0, 10000); ACE_OS::sleep (tv); - this->push_new_event (TAO_ENV_SINGLE_ARG_PARAMETER); + this->push_new_event (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } ACE_CATCHANY diff --git a/TAO/orbsvcs/tests/CosEvent/Basic/Random.h b/TAO/orbsvcs/tests/CosEvent/Basic/Random.h index d2ee42666bb..450fe418668 100644 --- a/TAO/orbsvcs/tests/CosEvent/Basic/Random.h +++ b/TAO/orbsvcs/tests/CosEvent/Basic/Random.h @@ -48,14 +48,14 @@ public: // Constructor void push (const CORBA::Any &event - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) ACE_THROW_SPEC ((CORBA::SystemException)); - void disconnect_push_consumer (TAO_ENV_SINGLE_ARG_DECL) + void disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL) ACE_THROW_SPEC ((CORBA::SystemException)); void connect (CosEventChannelAdmin::ConsumerAdmin_ptr admin - TAO_ENV_ARG_DECL); - void disconnect (TAO_ENV_SINGLE_ARG_DECL); + ACE_ENV_ARG_DECL); + void disconnect (ACE_ENV_SINGLE_ARG_DECL); protected: RND_Driver *driver_; @@ -82,7 +82,7 @@ public: RND_Timer (RND_Driver *driver); void push (const CORBA::Any &event - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) ACE_THROW_SPEC ((CORBA::SystemException)); }; @@ -109,15 +109,15 @@ public: // Constructor void connect (CosEventChannelAdmin::SupplierAdmin_ptr admin - TAO_ENV_ARG_DECL); - void disconnect (TAO_ENV_SINGLE_ARG_DECL); + ACE_ENV_ARG_DECL); + void disconnect (ACE_ENV_SINGLE_ARG_DECL); - void push_new_event (TAO_ENV_SINGLE_ARG_DECL); + void push_new_event (ACE_ENV_SINGLE_ARG_DECL); void push (CORBA::Any &event - TAO_ENV_ARG_DECL); + ACE_ENV_ARG_DECL); // Push a single event... - virtual void disconnect_push_supplier (TAO_ENV_SINGLE_ARG_DECL) + virtual void disconnect_push_supplier (ACE_ENV_SINGLE_ARG_DECL) ACE_THROW_SPEC ((CORBA::SystemException)); virtual int svc (void); @@ -147,11 +147,11 @@ public: // Run the test void timer (const CORBA::Any &e - TAO_ENV_ARG_DECL); + ACE_ENV_ARG_DECL); // The main timer has expired void event (const CORBA::Any &e - TAO_ENV_ARG_DECL); + ACE_ENV_ARG_DECL); // One of the consumers has received an event private: diff --git a/TAO/orbsvcs/tests/CosEvent/Basic/Shutdown.cpp b/TAO/orbsvcs/tests/CosEvent/Basic/Shutdown.cpp index fa56d3cc978..b69af879380 100644 --- a/TAO/orbsvcs/tests/CosEvent/Basic/Shutdown.cpp +++ b/TAO/orbsvcs/tests/CosEvent/Basic/Shutdown.cpp @@ -9,47 +9,47 @@ ACE_RCSID(CEC_Tests_Basic, Shutdown, "$Id$") static void run_test (PortableServer::POA_ptr poa, int with_callbacks - TAO_ENV_ARG_DECL); + ACE_ENV_ARG_DECL); int main (int argc, char* argv[]) { TAO_CEC_Default_Factory::init_svcs (); - TAO_ENV_DECLARE_NEW_ENV; + ACE_DECLARE_NEW_CORBA_ENV; ACE_TRY { // ORB initialization boiler plate... CORBA::ORB_var orb = - CORBA::ORB_init (argc, argv, "" TAO_ENV_ARG_PARAMETER); + CORBA::ORB_init (argc, argv, "" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; CORBA::Object_var object = - orb->resolve_initial_references ("RootPOA" TAO_ENV_ARG_PARAMETER); + orb->resolve_initial_references ("RootPOA" ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POA_var poa = - PortableServer::POA::_narrow (object.in () TAO_ENV_ARG_PARAMETER); + PortableServer::POA::_narrow (object.in () ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; PortableServer::POAManager_var poa_manager = - poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER); + poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; - poa_manager->activate (TAO_ENV_SINGLE_ARG_PARAMETER); + poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - run_test (poa.in (), 0 TAO_ENV_ARG_PARAMETER); + run_test (poa.in (), 0 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - run_test (poa.in (), 1 TAO_ENV_ARG_PARAMETER); + run_test (poa.in (), 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; // **************************************************************** - poa->destroy (1, 1 TAO_ENV_ARG_PARAMETER); + poa->destroy (1, 1 ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - orb->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_TRY_CHECK; } ACE_CATCHANY @@ -63,45 +63,45 @@ main (int argc, char* argv[]) void deactivate_servant (PortableServer::Servant servant - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { PortableServer::POA_var poa = - servant->_default_POA (TAO_ENV_SINGLE_ARG_PARAMETER); + servant->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; PortableServer::ObjectId_var id = - poa->servant_to_id (servant TAO_ENV_ARG_PARAMETER); + poa->servant_to_id (servant ACE_ENV_ARG_PARAMETER); ACE_CHECK; - poa->deactivate_object (id.in () TAO_ENV_ARG_PARAMETER); + poa->deactivate_object (id.in () ACE_ENV_ARG_PARAMETER); ACE_CHECK; } static void run_test (PortableServer::POA_ptr poa, int with_callbacks - TAO_ENV_ARG_DECL) + ACE_ENV_ARG_DECL) { TAO_CEC_EventChannel_Attributes attributes (poa, poa); attributes.disconnect_callbacks = with_callbacks; TAO_CEC_EventChannel ec_impl (attributes); - ec_impl.activate (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl.activate (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; CosEventChannelAdmin::EventChannel_var event_channel = - ec_impl._this (TAO_ENV_SINGLE_ARG_PARAMETER); + ec_impl._this (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // **************************************************************** // Obtain the consumer admin.. CosEventChannelAdmin::ConsumerAdmin_var consumer_admin = - event_channel->for_consumers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_consumers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // Obtain the supplier admin.. CosEventChannelAdmin::SupplierAdmin_var supplier_admin = - event_channel->for_suppliers (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->for_suppliers (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // **************************************************************** @@ -126,10 +126,10 @@ run_test (PortableServer::POA_ptr poa, for (i = 0; i != n; ++i) { - consumer[i]->connect (consumer_admin.in () TAO_ENV_ARG_PARAMETER); + consumer[i]->connect (consumer_admin.in () ACE_ENV_ARG_PARAMETER); ACE_CHECK; - supplier[i]->connect (supplier_admin.in () TAO_ENV_ARG_PARAMETER); + supplier[i]->connect (supplier_admin.in () ACE_ENV_ARG_PARAMETER); ACE_CHECK; } @@ -137,7 +137,7 @@ run_test (PortableServer::POA_ptr poa, // Destroy the event channel, *before* disconnecting the // clients. - event_channel->destroy (TAO_ENV_SINGLE_ARG_PARAMETER); + event_channel->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; // **************************************************************** @@ -163,18 +163,18 @@ run_test (PortableServer::POA_ptr poa, for (i = 0; i != n; ++i) { - deactivate_servant (supplier[i] TAO_ENV_ARG_PARAMETER); + deactivate_servant (supplier[i] ACE_ENV_ARG_PARAMETER); ACE_CHECK; delete supplier[i]; - deactivate_servant (consumer[i] TAO_ENV_ARG_PARAMETER); + deactivate_servant (consumer[i] ACE_ENV_ARG_PARAMETER); ACE_CHECK; delete consumer[i]; } delete[] supplier; delete[] consumer; - deactivate_servant (&ec_impl TAO_ENV_ARG_PARAMETER); + deactivate_servant (&ec_impl ACE_ENV_ARG_PARAMETER); ACE_CHECK; } |