WorkerThread.inl

Go to the documentation of this file.

#ifndef _MADARA_THREADS_WORKER_THREAD_INL_
#define _MADARA_THREADS_WORKER_THREAD_INL_

#include "WorkerThread.h"
 

inline void
madara::threads::WorkerThread::change_frequency (
  double hertz,
  ACE_Time_Value & current, ACE_Time_Value & frequency,
  ACE_Time_Value & next_epoch,
  bool & one_shot, bool & blaster)
{
  hertz_ = hertz;
  if (hertz_ > 0.0)
  {
    madara_logger_ptr_log (logger::global_logger.get (), logger::LOG_MAJOR,
      "WorkerThread(%s)::svc:" \
      " thread repeating at %f hz\n", name_.c_str (), hertz_);

    one_shot = false;
    frequency.set (1.0 / hertz_);
    next_epoch = current + frequency;
  }
  else if (hertz_ == 0.0)
  {
    // infinite hertz until terminate

    madara_logger_ptr_log (logger::global_logger.get (), logger::LOG_MAJOR,
      "WorkerThread(%s)::svc:" \
      " thread blasting at infinite hz\n", name_.c_str ());

    one_shot = false;
    blaster = true;
  }
  else
  {
    madara_logger_ptr_log (logger::global_logger.get (), logger::LOG_MAJOR,
      "WorkerThread(%s)::svc:" \
      " thread running once\n", name_.c_str ());
  }
}

#endif // _MADARA_THREADS_WORKER_THREAD_H_