summaryrefslogtreecommitdiff
path: root/performance-tests/Synch-Benchmarks/synch_driver.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'performance-tests/Synch-Benchmarks/synch_driver.cpp')
-rw-r--r--performance-tests/Synch-Benchmarks/synch_driver.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/performance-tests/Synch-Benchmarks/synch_driver.cpp b/performance-tests/Synch-Benchmarks/synch_driver.cpp
index 738eb5acf6c..f921edb19fe 100644
--- a/performance-tests/Synch-Benchmarks/synch_driver.cpp
+++ b/performance-tests/Synch-Benchmarks/synch_driver.cpp
@@ -29,9 +29,9 @@ Benchmark_Test::Benchmark_Test (void)
: ACE_Service_Config (1), // Do not load default services
n_lwps_ (0),
orig_n_lwps_ (0),
- done_ (ACE_Sig_Handler_Ex (ACE_Service_Config::end_reactor_event_loop))
+ done_ (ACE_Sig_Handler_Ex (ACE_Reactor::end_event_loop))
{
- ACE_Service_Config::reactor ()->register_handler (SIGINT, &this->done_);
+ ACE_Reactor::instance ()->register_handler (SIGINT, &this->done_);
}
void
@@ -41,7 +41,7 @@ Benchmark_Test::run_test (void)
Benchmark::done (0);
// Allow thread(s) to make progress.
- ACE_Service_Config::thr_mgr ()->resume_all ();
+ ACE_Thread_Manager::instance ()->resume_all ();
ACE_Time_Value timeout (options.sleep_time ());
@@ -49,13 +49,13 @@ Benchmark_Test::run_test (void)
options.start_timer ();
// Use Reactor as a timer (which can be interrupted by a signal).
- ACE_Service_Config::run_reactor_event_loop (timeout);
+ ACE_Reactor::run_event_loop (timeout);
options.stop_timer ();
ACE_DEBUG ((LM_DEBUG, "\nstopping timer\n"));
// Stop thread(s) from making any further progress.
- ACE_Service_Config::thr_mgr ()->suspend_all ();
+ ACE_Thread_Manager::instance ()->suspend_all ();
// Tell the threads that we are finished.
Benchmark::done (1);
@@ -77,10 +77,10 @@ Benchmark_Test::run_test (void)
options.print_results ();
// Allow thread(s) to finish up.
- ACE_Service_Config::thr_mgr ()->resume_all ();
+ ACE_Thread_Manager::instance ()->resume_all ();
// Wait for all the threads to exit.
- ACE_Service_Config::thr_mgr ()->wait ();
+ ACE_Thread_Manager::instance ()->wait ();
options.init ();
}
@@ -97,7 +97,7 @@ Benchmark_Test::init (int argc, char **argv)
if (this->open (argv[0]) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "ACE_Service_Config::open failed\n%a", 1), -1);
- ACE_Service_Repository_Iterator sri (*this->ACE_Service_Config::svc_rep ());
+ ACE_Service_Repository_Iterator sri (*ACE_Service_Repository::instance ());
// Iteratively execute each service loaded in from the svc.conf
// file.
@@ -123,7 +123,7 @@ Benchmark_Test::init (int argc, char **argv)
// We should probably use a "barrier" here rather than
// THR_SUSPENDED since many OS platforms lack the ability to
// create suspended threads...
- if (ACE_Service_Config::thr_mgr ()->spawn_n
+ if (ACE_Thread_Manager::instance ()->spawn_n
(options.thr_count (), ACE_THR_FUNC (bp->svc_run),
(void *) bp, options.t_flags () | THR_SUSPENDED) == -1)
ACE_ERROR ((LM_ERROR, "%p\n%a", "couldn't spawn threads", 1));