TimestampEstimatorBase is the base class for timestamp-based logic in test systems where the current timestamp must be estimated somehow (eg, because there is no hardware timing system). More...

#include <TimestampEstimatorBase.hpp>

Inheritance diagram for dunedaq::utilities::TimestampEstimatorBase:

[legend]

Public Types
enum	WaitStatus { kFinished , kInterrupted }

Public Member Functions
virtual	~TimestampEstimatorBase ()=default

virtual uint64_t	get_timestamp_estimate () const =0

virtual std::chrono::microseconds	get_wait_estimate (uint64_t ts) const =0

WaitStatus	wait_for_valid_timestamp (std::atomic< bool > &continue_flag)
	Waits for a valid timestamp to become available. Returns a status value that indicates whether a valid timestamp is available or not.

WaitStatus	wait_for_timestamp (uint64_t ts, std::atomic< bool > &continue_flag)

Detailed Description

TimestampEstimatorBase is the base class for timestamp-based logic in test systems where the current timestamp must be estimated somehow (eg, because there is no hardware timing system).

Definition at line 23 of file TimestampEstimatorBase.hpp.

Member Enumeration Documentation

◆ WaitStatus

enum dunedaq::utilities::TimestampEstimatorBase::WaitStatus

Enumerator
kFinished
kInterrupted

Definition at line 30 of file TimestampEstimatorBase.hpp.

  {
    kFinished,
    kInterrupted
  };

Constructor & Destructor Documentation

◆ ~TimestampEstimatorBase()

virtual dunedaq::utilities::TimestampEstimatorBase::~TimestampEstimatorBase ( )

virtualdefault

Member Function Documentation

◆ get_timestamp_estimate()

virtual uint64_t dunedaq::utilities::TimestampEstimatorBase::get_timestamp_estimate ( ) const

pure virtual

Implemented in dunedaq::utilities::TimestampEstimator, and dunedaq::utilities::TimestampEstimatorSystem.

◆ get_wait_estimate()

virtual std::chrono::microseconds dunedaq::utilities::TimestampEstimatorBase::get_wait_estimate ( uint64_t ts ) const

pure virtual

Implemented in dunedaq::utilities::TimestampEstimator, and dunedaq::utilities::TimestampEstimatorSystem.

◆ wait_for_timestamp()

TimestampEstimatorBase::WaitStatus dunedaq::utilities::TimestampEstimatorBase::wait_for_timestamp	(	uint64_t	ts,
		std::atomic< bool > &	continue_flag )

Wait for the current timestamp estimate to reach ts, or for continue_flag to become false.

Returns kFinished if the timestamp became valid, or kInterrupted if continue_flag became false first

Definition at line 43 of file TimestampEstimatorBase.cpp.

{
  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;
}

◆ wait_for_valid_timestamp()

TimestampEstimatorBase::WaitStatus dunedaq::utilities::TimestampEstimatorBase::wait_for_valid_timestamp ( std::atomic< bool > & continue_flag )

Waits for a valid timestamp to become available. Returns a status value that indicates whether a valid timestamp is available or not.

Wait for the current timestamp estimate to become valid, or for continue_flag to become false. The timestamp becomes valid once at least one TimeSync message has been received.

Returns kFinished if the timestamp became valid, or kInterrupted if continue_flag became false first

Parameters

continue_flag whether to continue waiting until a valid timestamp is available or return immediately

The value of the continue_flag can be changed from true to false externally to this method, and that will cause the method to exit soon thereafter (on the order of 10 msec) and return the current status.

Returns: kFinished if a valid timestamp is available or kInterrupted if one is not

Definition at line 27 of file TimestampEstimatorBase.cpp.

{
  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;
}

The documentation for this class was generated from the following files:

/github/workspace/dunedaq/sourcecode/utilities/include/utilities/TimestampEstimatorBase.hpp
/github/workspace/dunedaq/sourcecode/utilities/src/TimestampEstimatorBase.cpp

Public Types

Public Member Functions