summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/CosEvent/Basic
diff options
context:
space:
mode:
authorokellogg <okellogg@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2002-01-29 20:21:11 +0000
committerokellogg <okellogg@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2002-01-29 20:21:11 +0000
commit15f9b16afed320b4e581b8f61fee7d7fbf1aa9a8 (patch)
treefd798ba5478a08b4b6f842cb8515ed9776861f5f /TAO/orbsvcs/tests/CosEvent/Basic
parent5e12d6686388ccadee1714b94ddee0cce6587bfd (diff)
downloadATCD-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.cpp68
-rw-r--r--TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.cpp68
-rw-r--r--TAO/orbsvcs/tests/CosEvent/Basic/MT_Disconnect.h2
-rw-r--r--TAO/orbsvcs/tests/CosEvent/Basic/Pull_Push_Event.cpp54
-rw-r--r--TAO/orbsvcs/tests/CosEvent/Basic/Push_Event.cpp50
-rw-r--r--TAO/orbsvcs/tests/CosEvent/Basic/Random.cpp112
-rw-r--r--TAO/orbsvcs/tests/CosEvent/Basic/Random.h24
-rw-r--r--TAO/orbsvcs/tests/CosEvent/Basic/Shutdown.cpp52
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;
}