summaryrefslogtreecommitdiff
path: root/examples/Timer_Queue
diff options
context:
space:
mode:
authorlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1997-11-04 16:12:04 +0000
committerlevine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1997-11-04 16:12:04 +0000
commit09074913aa2d110771e9e609a3656283af379158 (patch)
treeeaef7193ed9a88442b5e1d8c1e1cd432de17ca95 /examples/Timer_Queue
parent42f3a5308b093a40285c754bb5d97e44070ff979 (diff)
downloadATCD-09074913aa2d110771e9e609a3656283af379158.tar.gz
(dump): changed another lock () to mutex ()
Diffstat (limited to 'examples/Timer_Queue')
-rw-r--r--examples/Timer_Queue/Thread_Timer_Queue_Test.cpp32
1 files changed, 16 insertions, 16 deletions
diff --git a/examples/Timer_Queue/Thread_Timer_Queue_Test.cpp b/examples/Timer_Queue/Thread_Timer_Queue_Test.cpp
index b97c043be75..6ee3689b75a 100644
--- a/examples/Timer_Queue/Thread_Timer_Queue_Test.cpp
+++ b/examples/Timer_Queue/Thread_Timer_Queue_Test.cpp
@@ -44,18 +44,18 @@ Handler::set_id (int id)
int
Handler::handle_timeout (const ACE_Time_Value &current_time,
- const void *)
+ const void *)
{
ACE_Time_Value delay = current_time - this->expires_;
// No need to protect this printf is always called from a Async safe
// point.
ACE_OS::printf ("\nexpiring timer %d at %u.%07.7u secs\n"
- "\tthere was a %u.%07.7u secs delay\n",
- this->id_,
- current_time.sec (),
- current_time.usec (),
- delay.sec (), delay.usec ());
+ "\tthere was a %u.%07.7u secs delay\n",
+ this->id_,
+ current_time.sec (),
+ current_time.usec (),
+ delay.sec (), delay.usec ());
// Notice this delete is protected.
delete this;
@@ -72,7 +72,7 @@ Handler::cancelled (void)
}
Input_Task::Input_Task (Thread_Timer_Queue *queue,
- Thread_Timer_Queue_Test_Driver &timer_queue_driver)
+ Thread_Timer_Queue_Test_Driver &timer_queue_driver)
: ACE_Task_Base (ACE_Thread_Manager::instance ()),
queue_ (queue),
usecs_ (ACE_ONE_SECOND_IN_USECS),
@@ -173,7 +173,7 @@ Input_Task::shutdown_timer (void *argument)
void
Input_Task::dump (void)
{
- ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, this->queue_->lock ());
+ ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, this->queue_->mutex ());
ACE_DEBUG ((LM_DEBUG, "begin dumping timer queue\n"));
@@ -222,20 +222,20 @@ Thread_Timer_Queue_Test_Driver::init (void)
// initialize the <Command> objects with their corresponding
// methods from <Input_Task>
ACE_NEW_RETURN (schedule_cmd_,
- COMMAND (input_task_, &Input_Task::add_timer),
- -1);
+ COMMAND (input_task_, &Input_Task::add_timer),
+ -1);
ACE_NEW_RETURN (cancel_cmd_,
- COMMAND (input_task_, &Input_Task::cancel_timer),
- -1);
+ COMMAND (input_task_, &Input_Task::cancel_timer),
+ -1);
ACE_NEW_RETURN (list_cmd_,
- COMMAND (input_task_, &Input_Task::list_timer),
- -1);
+ COMMAND (input_task_, &Input_Task::list_timer),
+ -1);
ACE_NEW_RETURN (shutdown_cmd_,
- COMMAND (input_task_, &Input_Task::shutdown_timer),
- -1);
+ COMMAND (input_task_, &Input_Task::shutdown_timer),
+ -1);
if (this->input_task_.activate () == -1)
ACE_ERROR_RETURN ((LM_ERROR, "cannot activate input task"), -1);