diff options
Diffstat (limited to 'ACE/Kokyu/Dispatch_Deferrer.cpp')
| -rw-r--r-- | ACE/Kokyu/Dispatch_Deferrer.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/ACE/Kokyu/Dispatch_Deferrer.cpp b/ACE/Kokyu/Dispatch_Deferrer.cpp index 0d62bb28c58..6db734c8205 100644 --- a/ACE/Kokyu/Dispatch_Deferrer.cpp +++ b/ACE/Kokyu/Dispatch_Deferrer.cpp @@ -40,14 +40,14 @@ Dispatch_Deferrer::dispatch (Dispatch_Queue_Item *qitem) ACE_Time_Value tv; tv = ACE_OS::gettimeofday() + qitem->qos_info().deadline_; long timer_id = this->react_.schedule_timer(this, - 0, //NULL arg - tv); + 0, //NULL arg + tv); if (timer_id < 0) { ACE_ERROR_RETURN ((LM_ERROR, - ACE_TEXT ("EC (%P|%t) cannot schedule Release Guard timer.") - ACE_TEXT ("ACE_Reactor.schedule_timer() returned -1\n")), - -1); + ACE_TEXT ("EC (%P|%t) cannot schedule Release Guard timer.") + ACE_TEXT ("ACE_Reactor.schedule_timer() returned -1\n")), + -1); } //else valid timer_id this->timers_.bind(qitem,timer_id); @@ -68,8 +68,8 @@ Dispatch_Deferrer::handle_timeout (const ACE_Time_Value &, //get all expired Dispatch_Queue_Items ACE_Message_Block *begin,*end; this->rgq_.remove_messages(begin,end, - (u_int) (ACE_Dynamic_Message_Strategy::LATE - | ACE_Dynamic_Message_Strategy::BEYOND_LATE)); + (u_int) (ACE_Dynamic_Message_Strategy::LATE | + ACE_Dynamic_Message_Strategy::BEYOND_LATE)); //dispatch them back to Dispatcher_Impl while (begin <= end) @@ -87,12 +87,12 @@ Dispatch_Deferrer::handle_timeout (const ACE_Time_Value &, //remove timer for each enqueued qitem from reactor long timer_id; if (this->timers_.find(qitem,timer_id) < 0) - { + { ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("Could not cancel Release Guard timer.") ACE_TEXT ("Unknown timer ID\n")), -1); - } + } //else got timer_id this->react_.cancel_timer(timer_id); |