task_timer.cpp

这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用于网络游戏医学图像网关的高qos要求.更详细的内容可阅读相应的材料

// Task_Timer.cpp,v 1.2 2004/01/04 21:17:14 bala Exp

#ifndef JAWS_BUILD_DLL
#define JAWS_BUILD_DLL
#endif

#include "jaws3/Task_Timer.h"
#include "jaws3/Timer_Helpers.h"


JAWS_Task_Timer::JAWS_Task_Timer (void)
{
  this->timer_queue_.activate ();
}


void 
JAWS_Task_Timer::schedule_timer ( long *timer_id
                                , const ACE_Time_Value &delta
                                , JAWS_Event_Completer *completer
                                , void *act
                                )
{
  JAWS_Timer_EH *eh = new JAWS_Timer_EH (completer, act);
  if (eh == 0
      || (*timer_id =
            this->timer_queue_.schedule ( eh
                                        , 0
                                        , delta + ACE_OS::gettimeofday ()))
         == -1)
    {
      JAWS_Event_Result timer_result ( 0
                                     , JAWS_Event_Result::JE_ERROR
                                     , JAWS_Event_Result::JE_TIMER_FAIL
                                     );

      if (completer)
        completer->timer_complete (timer_result, act);

      delete eh;
    }
}


void 
JAWS_Task_Timer::schedule_absolute_timer ( long *timer_id
                                         , const ACE_Time_Value &tv
                                         , JAWS_Event_Completer *completer
                                         , void *act
                                         )
{
  JAWS_Timer_EH *eh = new JAWS_Timer_EH (completer, act);
  if (eh == 0
      || (*timer_id = this->timer_queue_.schedule (eh, 0, tv)) == -1)
    {
      JAWS_Event_Result timer_result ( 0
                                     , JAWS_Event_Result::JE_ERROR
                                     , JAWS_Event_Result::JE_TIMER_FAIL
                                     );

      if (completer)
        completer->timer_complete (timer_result, act);

      delete eh;
    }
}


void
JAWS_Task_Timer::schedule_interval_timer ( long *timer_id
                                         , const ACE_Time_Value &interval
                                         , JAWS_Event_Completer *completer
                                         , void *act
                                         )
{
  JAWS_Timer_EH *eh = new JAWS_Timer_EH (completer, act);
  if (eh == 0
      || (*timer_id =
            this->timer_queue_.schedule ( eh
                                        , 0
                                        , interval + ACE_OS::gettimeofday ()
                                        , interval
                                        ))
          == -1)
    {
      JAWS_Event_Result timer_result ( 0
                                     , JAWS_Event_Result::JE_ERROR
                                     , JAWS_Event_Result::JE_TIMER_FAIL
                                     );

      if (completer)
        completer->timer_complete (timer_result, act);

      delete eh;
    }
}


void
JAWS_Task_Timer::cancel_timer (long timer_id)
{
  this->timer_queue_.cancel (timer_id);
}