diff options
author | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-11-04 16:12:04 +0000 |
---|---|---|
committer | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1997-11-04 16:12:04 +0000 |
commit | 09074913aa2d110771e9e609a3656283af379158 (patch) | |
tree | eaef7193ed9a88442b5e1d8c1e1cd432de17ca95 /examples/Timer_Queue | |
parent | 42f3a5308b093a40285c754bb5d97e44070ff979 (diff) | |
download | ATCD-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.cpp | 32 |
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 ¤t_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); |