summaryrefslogtreecommitdiff
path: root/TAO/performance-tests/Callback/client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/performance-tests/Callback/client.cpp')
-rw-r--r--TAO/performance-tests/Callback/client.cpp58
1 files changed, 29 insertions, 29 deletions
diff --git a/TAO/performance-tests/Callback/client.cpp b/TAO/performance-tests/Callback/client.cpp
index 586838059e6..3b51bd5e2a7 100644
--- a/TAO/performance-tests/Callback/client.cpp
+++ b/TAO/performance-tests/Callback/client.cpp
@@ -73,17 +73,17 @@ main (int argc, char *argv [])
ACE_TRY_NEW_ENV
{
CORBA::ORB_var orb =
- CORBA::ORB_init (argc, argv, "", ACE_TRY_ENV);
+ CORBA::ORB_init (argc, argv, "" TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::Object_var manager_object =
- orb->resolve_initial_references ("ORBPolicyManager",
- ACE_TRY_ENV);
+ orb->resolve_initial_references ("ORBPolicyManager"
+ TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::PolicyManager_var policy_manager =
- CORBA::PolicyManager::_narrow (manager_object.in (),
- ACE_TRY_ENV);
+ CORBA::PolicyManager::_narrow (manager_object.in ()
+ TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::Any sync_scope;
@@ -93,16 +93,16 @@ main (int argc, char *argv [])
policy_list.length (1);
policy_list[0] =
orb->create_policy (Messaging::SYNC_SCOPE_POLICY_TYPE,
- sync_scope,
- ACE_TRY_ENV);
+ sync_scope
+ TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
policy_manager->set_policy_overrides (policy_list,
- CORBA::SET_OVERRIDE,
- ACE_TRY_ENV);
+ CORBA::SET_OVERRIDE
+ TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::Object_var poa_object =
- orb->resolve_initial_references("RootPOA", ACE_TRY_ENV);
+ orb->resolve_initial_references("RootPOA" TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (CORBA::is_nil (poa_object.in ()))
@@ -111,14 +111,14 @@ main (int argc, char *argv [])
1);
PortableServer::POA_var root_poa =
- PortableServer::POA::_narrow (poa_object.in (), ACE_TRY_ENV);
+ PortableServer::POA::_narrow (poa_object.in () TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
PortableServer::POAManager_var poa_manager =
- root_poa->the_POAManager (ACE_TRY_ENV);
+ root_poa->the_POAManager (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
- poa_manager->activate (ACE_TRY_ENV);
+ poa_manager->activate (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
if (parse_args (argc, argv) != 0)
@@ -126,11 +126,11 @@ main (int argc, char *argv [])
// Get the event channel object reference
CORBA::Object_var object =
- orb->string_to_object (ior, ACE_TRY_ENV);
+ orb->string_to_object (ior TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
Test::Server_var server =
- Test::Server::_narrow (object.in (), ACE_TRY_ENV);
+ Test::Server::_narrow (object.in () TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
if (CORBA::is_nil (server.in ()))
{
@@ -143,10 +143,10 @@ main (int argc, char *argv [])
Callback_i callback_i (iterations);
- Test::Callback_var callback = callback_i._this (ACE_TRY_ENV);
+ Test::Callback_var callback = callback_i._this (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
- server->set_callback (callback.in (), ACE_TRY_ENV);
+ server->set_callback (callback.in () TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_DEBUG ((LM_DEBUG, "Connected callback\n"));
@@ -158,7 +158,7 @@ main (int argc, char *argv [])
while (!callback_i.done () || !task.done ())
{
ACE_Time_Value tv (1, 0);
- orb->run (tv, ACE_TRY_ENV);
+ orb->run (tv TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_hrtime_t end = ACE_OS::gethrtime ();
@@ -188,15 +188,15 @@ main (int argc, char *argv [])
end - start,
stats.samples_count ());
- server->shutdown (ACE_TRY_ENV);
+ server->shutdown (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
PortableServer::ObjectId_var id =
- root_poa->servant_to_id (&callback_i, ACE_TRY_ENV);
+ root_poa->servant_to_id (&callback_i TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
- root_poa->deactivate_object (id.in (), ACE_TRY_ENV);
+ root_poa->deactivate_object (id.in () TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
- orb->destroy (ACE_TRY_ENV);
+ orb->destroy (TAO_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
ACE_CATCH (CORBA::Exception, ex)
@@ -223,20 +223,20 @@ parse_args (int argc, char *argv[])
break;
case 'i':
- iterations = ACE_OS::atoi (get_opts.optarg);
- break;
+ iterations = ACE_OS::atoi (get_opts.optarg);
+ break;
case 'k':
- ior = get_opts.optarg;
- break;
+ ior = get_opts.optarg;
+ break;
case '?':
default:
ACE_ERROR_RETURN ((LM_ERROR,
"usage: %s "
"-h (dump full sample history) "
- "-i <iterations> "
- "-k <IOR> "
+ "-i <iterations> "
+ "-k <IOR> "
"\n",
argv [0]),
-1);
@@ -270,7 +270,7 @@ Task::svc (void)
for (;;)
{
Test::TimeStamp creation = ACE_OS::gethrtime ();
- this->server_->request (creation, payload, ACE_TRY_ENV);
+ this->server_->request (creation, payload TAO_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
// ACE_Time_Value tv (0, 5000);