summaryrefslogtreecommitdiff
path: root/TAO/performance-tests/RTCorba/Thread_Pool/client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/performance-tests/RTCorba/Thread_Pool/client.cpp')
-rw-r--r--TAO/performance-tests/RTCorba/Thread_Pool/client.cpp54
1 files changed, 27 insertions, 27 deletions
diff --git a/TAO/performance-tests/RTCorba/Thread_Pool/client.cpp b/TAO/performance-tests/RTCorba/Thread_Pool/client.cpp
index a45471a31a4..1c565863857 100644
--- a/TAO/performance-tests/RTCorba/Thread_Pool/client.cpp
+++ b/TAO/performance-tests/RTCorba/Thread_Pool/client.cpp
@@ -249,7 +249,7 @@ start_synchronization (test_ptr test,
{
test->method (work,
prime_number
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
}
}
@@ -358,7 +358,7 @@ max_throughput (test_ptr test,
ACE_TRY_NEW_ENV
{
CORBA_priority =
- current->the_priority (TAO_ENV_SINGLE_ARG_PARAMETER);
+ current->the_priority (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
CORBA::Boolean result =
@@ -387,7 +387,7 @@ max_throughput (test_ptr test,
test->method (work,
prime_number
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
++calls_made;
@@ -430,9 +430,9 @@ public:
int svc (void);
ACE_hrtime_t deadline_for_current_call (CORBA::ULong i);
- void reset_priority (TAO_ENV_SINGLE_ARG_DECL);
+ void reset_priority (ACE_ENV_SINGLE_ARG_DECL);
void print_stats (ACE_hrtime_t test_end);
- int setup (TAO_ENV_SINGLE_ARG_DECL);
+ int setup (ACE_ENV_SINGLE_ARG_DECL);
void missed_start_deadline (CORBA::ULong invocation);
void missed_end_deadline (CORBA::ULong invocation);
@@ -483,18 +483,18 @@ Paced_Worker::Paced_Worker (ACE_Thread_Manager &thread_manager,
}
void
-Paced_Worker::reset_priority (TAO_ENV_SINGLE_ARG_DECL)
+Paced_Worker::reset_priority (ACE_ENV_SINGLE_ARG_DECL)
{
if (set_priority)
{
this->current_->the_priority (this->priority_
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
else
{
this->current_->the_priority (continuous_worker_priority
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
}
@@ -600,16 +600,16 @@ Paced_Worker::print_stats (ACE_hrtime_t test_end)
}
int
-Paced_Worker::setup (TAO_ENV_SINGLE_ARG_DECL)
+Paced_Worker::setup (ACE_ENV_SINGLE_ARG_DECL)
{
if (priority_setting == AFTER_THREAD_CREATION)
{
- this->reset_priority (TAO_ENV_SINGLE_ARG_PARAMETER);
+ this->reset_priority (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
}
this->CORBA_priority_ =
- this->current_->the_priority (TAO_ENV_SINGLE_ARG_PARAMETER);
+ this->current_->the_priority (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
CORBA::Boolean result =
@@ -647,7 +647,7 @@ Paced_Worker::svc (void)
ACE_TRY_NEW_ENV
{
int result =
- this->setup (TAO_ENV_SINGLE_ARG_PARAMETER);
+ this->setup (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
if (result != 0)
@@ -671,7 +671,7 @@ Paced_Worker::svc (void)
this->test_->method (work,
prime_number
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_hrtime_t time_after_call =
@@ -725,7 +725,7 @@ public:
int svc (void);
void print_stats (ACE_Sample_History &history,
ACE_hrtime_t test_end);
- int setup (TAO_ENV_SINGLE_ARG_DECL);
+ int setup (ACE_ENV_SINGLE_ARG_DECL);
void print_collective_stats (void);
test_var test_;
@@ -827,17 +827,17 @@ Continuous_Worker::print_collective_stats (void)
}
int
-Continuous_Worker::setup (TAO_ENV_SINGLE_ARG_DECL)
+Continuous_Worker::setup (ACE_ENV_SINGLE_ARG_DECL)
{
if (priority_setting == AFTER_THREAD_CREATION)
{
this->current_->the_priority (continuous_worker_priority
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
}
this->CORBA_priority_ =
- this->current_->the_priority (TAO_ENV_SINGLE_ARG_PARAMETER);
+ this->current_->the_priority (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK_RETURN (-1);
CORBA::Boolean result =
@@ -862,7 +862,7 @@ Continuous_Worker::svc (void)
ACE_Sample_History history (this->iterations_);
int result =
- this->setup (TAO_ENV_SINGLE_ARG_PARAMETER);
+ this->setup (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
if (result != 0)
@@ -876,7 +876,7 @@ Continuous_Worker::svc (void)
this->test_->method (work,
prime_number
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
ACE_hrtime_t end = ACE_OS::gethrtime ();
@@ -911,7 +911,7 @@ main (int argc, char *argv[])
ACE_TRY_NEW_ENV
{
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;
int result =
@@ -922,31 +922,31 @@ main (int argc, char *argv[])
fudge_priorities (orb.in ());
CORBA::Object_var object =
- orb->string_to_object (ior TAO_ENV_ARG_PARAMETER);
+ orb->string_to_object (ior ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
test_var test =
- test::_narrow (object.in () TAO_ENV_ARG_PARAMETER);
+ test::_narrow (object.in () ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
object =
orb->resolve_initial_references ("RTCurrent"
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
RTCORBA::Current_var current =
RTCORBA::Current::_narrow (object.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
object =
orb->resolve_initial_references ("PriorityMappingManager"
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
RTCORBA::PriorityMappingManager_var mapping_manager =
RTCORBA::PriorityMappingManager::_narrow (object.in ()
- TAO_ENV_ARG_PARAMETER);
+ ACE_ENV_ARG_PARAMETER);
ACE_TRY_CHECK;
RTCORBA::PriorityMapping &priority_mapping =
@@ -1145,7 +1145,7 @@ main (int argc, char *argv[])
if (shutdown_server)
{
- test->shutdown (TAO_ENV_SINGLE_ARG_PARAMETER);
+ test->shutdown (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_TRY_CHECK;
}
}