TimestampEstimatorSystem.cpp

Go to the documentation of this file.

 
#include "utilities/TimestampEstimatorSystem.hpp"
 
#include "logging/Logging.hpp"
 
#include <chrono>
 
namespace dunedaq {
namespace utilities {
 
TimestampEstimatorSystem::TimestampEstimatorSystem(uint64_t clock_frequency_hz) // NOLINT(build/unsigned)
  : m_clock_frequency_hz(clock_frequency_hz)
{
  TLOG_DEBUG(0) << "Clock frequency is " << m_clock_frequency_hz
                << " clock_frequency_hz/1000000.=" << (m_clock_frequency_hz / 1000000.);
}
 
uint64_t
TimestampEstimatorSystem::get_timestamp_estimate() const
{
  auto now = std::chrono::system_clock::now().time_since_epoch();
  auto now_us = std::chrono::duration_cast<std::chrono::microseconds>(now);
  return (m_clock_frequency_hz / 1000000.) * now_us.count();
}
 
std::chrono::microseconds
TimestampEstimatorSystem::get_wait_estimate(uint64_t ts) const
{
  auto now = std::chrono::system_clock::now().time_since_epoch();
  auto now_us = std::chrono::duration_cast<std::chrono::microseconds>(now);
  auto then = static_cast<long>(ts * 1000000. / m_clock_frequency_hz);
  auto then_us = std::chrono::microseconds(then);
  if (then_us < now_us)
    return std::chrono::microseconds(0);
  return then_us - now_us;
}
 
} // namespace utilities
} // namespace dunedaq