summaryrefslogtreecommitdiff
path: root/TAO/tests/Timed_Buffered_Oneways
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/tests/Timed_Buffered_Oneways
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/tests/Timed_Buffered_Oneways')
-rw-r--r--TAO/tests/Timed_Buffered_Oneways/client.cpp48
-rw-r--r--TAO/tests/Timed_Buffered_Oneways/server.cpp18
-rw-r--r--TAO/tests/Timed_Buffered_Oneways/test_i.cpp6
-rw-r--r--TAO/tests/Timed_Buffered_Oneways/test_i.h4
4 files changed, 38 insertions, 38 deletions
diff --git a/TAO/tests/Timed_Buffered_Oneways/client.cpp b/TAO/tests/Timed_Buffered_Oneways/client.cpp
index 11765552378..a3d05a6c5c5 100644
--- a/TAO/tests/Timed_Buffered_Oneways/client.cpp
+++ b/TAO/tests/Timed_Buffered_Oneways/client.cpp
@@ -116,7 +116,7 @@ parse_args (int argc, char **argv)
void
setup_timeouts (CORBA::ORB_ptr orb
- TAO_ENV_ARG_DECL)
+ ACE_ENV_ARG_DECL)
{
// Escape value.
if (timeout == -1)
@@ -124,13 +124,13 @@ setup_timeouts (CORBA::ORB_ptr orb
// Obtain PolicyCurrent.
CORBA::Object_var object = orb->resolve_initial_references ("PolicyCurrent"
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// Narrow down to correct type.
CORBA::PolicyCurrent_var policy_current =
CORBA::PolicyCurrent::_narrow (object.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
TimeBase::TimeT rt_timeout = 10000 * timeout;
@@ -144,31 +144,31 @@ setup_timeouts (CORBA::ORB_ptr orb
rt_timeout_policy_list[0] =
orb->create_policy (Messaging::RELATIVE_RT_TIMEOUT_POLICY_TYPE,
rt_timeout_any
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
policy_current->set_policy_overrides (rt_timeout_policy_list,
CORBA::ADD_OVERRIDE
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
- rt_timeout_policy_list[0]->destroy (TAO_ENV_SINGLE_ARG_PARAMETER);
+ rt_timeout_policy_list[0]->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
}
void
setup_buffering_constraints (CORBA::ORB_ptr orb
- TAO_ENV_ARG_DECL)
+ ACE_ENV_ARG_DECL)
{
// Obtain PolicyCurrent.
CORBA::Object_var object = orb->resolve_initial_references ("PolicyCurrent"
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// Narrow down to correct type.
CORBA::PolicyCurrent_var policy_current =
CORBA::PolicyCurrent::_narrow (object.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// Setup the sync scope policy, i.e., the ORB will buffer oneways.
@@ -187,17 +187,17 @@ setup_buffering_constraints (CORBA::ORB_ptr orb
sync_policy_list[0] =
orb->create_policy (Messaging::SYNC_SCOPE_POLICY_TYPE,
sync_any
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// Setup the sync scope.
policy_current->set_policy_overrides (sync_policy_list,
CORBA::ADD_OVERRIDE
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// We are now done with this policy.
- sync_policy_list[0]->destroy (TAO_ENV_SINGLE_ARG_PARAMETER);
+ sync_policy_list[0]->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
// Flush buffers.
@@ -219,24 +219,24 @@ setup_buffering_constraints (CORBA::ORB_ptr orb
buffering_constraint_policy_list[0] =
orb->create_policy (TAO::BUFFERING_CONSTRAINT_POLICY_TYPE,
buffering_constraint_any
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// Setup the constraints.
policy_current->set_policy_overrides (buffering_constraint_policy_list,
CORBA::ADD_OVERRIDE
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
// We are done with the policy.
- buffering_constraint_policy_list[0]->destroy (TAO_ENV_SINGLE_ARG_PARAMETER);
+ buffering_constraint_policy_list[0]->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
}
int
main (int argc, char **argv)
{
- TAO_ENV_DECLARE_NEW_ENV;
+ ACE_DECLARE_NEW_CORBA_ENV;
ACE_TRY
{
@@ -245,7 +245,7 @@ main (int argc, char **argv)
CORBA::ORB_init (argc,
argv,
0
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Initialize options based on command-line arguments.
@@ -256,22 +256,22 @@ main (int argc, char **argv)
// Get an object reference from the argument string.
CORBA::Object_var object =
orb->string_to_object (IOR
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Try to narrow the object reference to a <test> reference.
test_var test_object = test::_narrow (object.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Setup buffering.
setup_buffering_constraints (orb.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Setup timeout.
setup_timeouts (orb.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
test::data the_data (data_bytes);
@@ -287,7 +287,7 @@ main (int argc, char **argv)
test_object->method (i,
the_data,
work
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// Interval between successive calls.
@@ -300,7 +300,7 @@ main (int argc, char **argv)
// Shutdown server.
if (shutdown_server)
{
- test_object->shutdown (TAO_ENV_SINGLE_ARG_PARAMETER);
+ test_object->shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
@@ -310,7 +310,7 @@ main (int argc, char **argv)
// static destructors to flush the queues, it will be too late.
// Therefore, we use explicit destruction here and flush the
// queues before main() ends.
- orb->destroy (TAO_ENV_SINGLE_ARG_PARAMETER);
+ orb->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
diff --git a/TAO/tests/Timed_Buffered_Oneways/server.cpp b/TAO/tests/Timed_Buffered_Oneways/server.cpp
index 6f82d84ac69..13f7c855cfd 100644
--- a/TAO/tests/Timed_Buffered_Oneways/server.cpp
+++ b/TAO/tests/Timed_Buffered_Oneways/server.cpp
@@ -42,21 +42,21 @@ main (int argc, char *argv[])
CORBA::ORB_init (argc,
argv,
""
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::Object_var poa_object =
orb->resolve_initial_references ("RootPOA"
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
PortableServer::POA_var root_poa =
PortableServer::POA::_narrow (poa_object.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
PortableServer::POAManager_var poa_manager =
- root_poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER);
+ root_poa->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
if (parse_args (argc, argv) != 0)
@@ -65,12 +65,12 @@ main (int argc, char *argv[])
test_i servant (orb.in ());
test_var server =
- servant._this (TAO_ENV_SINGLE_ARG_PARAMETER);
+ servant._this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::String_var ior =
orb->object_to_string (server.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "Activated as <%s>\n", ior.in ()));
@@ -84,17 +84,17 @@ main (int argc, char *argv[])
ACE_OS::fprintf (output_file, "%s", ior.in ());
ACE_OS::fclose (output_file);
- poa_manager->activate (TAO_ENV_SINGLE_ARG_PARAMETER);
+ poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
- orb->run (TAO_ENV_SINGLE_ARG_PARAMETER);
+ orb->run (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "event loop finished\n"));
root_poa->destroy (1,
1
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCHANY
diff --git a/TAO/tests/Timed_Buffered_Oneways/test_i.cpp b/TAO/tests/Timed_Buffered_Oneways/test_i.cpp
index ae78c1de3e6..9fbd1859f2a 100644
--- a/TAO/tests/Timed_Buffered_Oneways/test_i.cpp
+++ b/TAO/tests/Timed_Buffered_Oneways/test_i.cpp
@@ -13,7 +13,7 @@ void
test_i::method (CORBA::ULong request_number,
const test::data &,
CORBA::ULong work
- TAO_ENV_ARG_DECL_NOT_USED)
+ ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException))
{
ACE_DEBUG ((LM_DEBUG,
@@ -29,9 +29,9 @@ test_i::method (CORBA::ULong request_number,
}
void
-test_i::shutdown (TAO_ENV_SINGLE_ARG_DECL)
+test_i::shutdown (ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->orb_->shutdown (0
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
}
diff --git a/TAO/tests/Timed_Buffered_Oneways/test_i.h b/TAO/tests/Timed_Buffered_Oneways/test_i.h
index 06723f6b263..48b20f4057f 100644
--- a/TAO/tests/Timed_Buffered_Oneways/test_i.h
+++ b/TAO/tests/Timed_Buffered_Oneways/test_i.h
@@ -31,10 +31,10 @@ public:
void method (CORBA::ULong request_number,
const test::data &,
CORBA::ULong work
- TAO_ENV_ARG_DECL_NOT_USED)
+ ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
- void shutdown (TAO_ENV_SINGLE_ARG_DECL_NOT_USED)
+ void shutdown (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException));
private: