TimestampEstimatorBase.cpp

Go to the documentation of this file.

 
#include "utilities/TimestampEstimatorBase.hpp"
 
#include <thread>
 
namespace dunedaq {
namespace utilities {
 
TimestampEstimatorBase::WaitStatus
TimestampEstimatorBase::wait_for_valid_timestamp(std::atomic<bool>& continue_flag)
{
  auto sleep_time = std::chrono::microseconds(1);
  while (continue_flag.load() && get_timestamp_estimate() == std::numeric_limits<uint64_t>::max()) {
    std::this_thread::sleep_for(sleep_time);
    if (sleep_time < std::chrono::milliseconds(10)) {
      sleep_time *= 2;
    }
  }
 
  // 27-May-2025, KAB: modified this return statement so that the return code is based on whether a
  // valid timestamp is available (instead of whether the caller asked the method to wait or not)
  return (get_timestamp_estimate() != std::numeric_limits<uint64_t>::max()) ? TimestampEstimatorBase::kFinished : TimestampEstimatorBase::kInterrupted;
}
 
TimestampEstimatorBase::WaitStatus
TimestampEstimatorBase::wait_for_timestamp(uint64_t ts, std::atomic<bool>& continue_flag)
{
  auto get_sleep_time = [this, ts]() {
    auto est = get_wait_estimate(ts);
    auto pest = static_cast<long>(est.count() * 0.8);
    if (pest < 1 && est != std::chrono::microseconds(0))
      return std::chrono::microseconds(1);
    return std::chrono::microseconds(pest);
  };
  auto sleep_time = get_sleep_time();
  while (continue_flag.load() &&
         (get_timestamp_estimate() < ts || get_timestamp_estimate() == std::numeric_limits<uint64_t>::max())) {
    std::this_thread::sleep_for(sleep_time);
    sleep_time = get_sleep_time();
  }
 
  return continue_flag.load() ? TimestampEstimatorBase::kFinished : TimestampEstimatorBase::kInterrupted;
}
 
} // namespace utilities
} // namespace dunedaq