EchoMonitorNode.cpp

Go to the documentation of this file.

 
#include "timing/EchoMonitorNode.hpp"
 
#include "timing/TimingIssues.hpp"
#include "timing/toolbox.hpp"
#include "logging/Logging.hpp"
 
#include <string>
#include <chrono>
 
namespace dunedaq {
namespace timing {
 
UHAL_REGISTER_DERIVED_NODE(EchoMonitorNode)
 
//-----------------------------------------------------------------------------
EchoMonitorNode::EchoMonitorNode(const uhal::Node& node)
  : TimingNode(node)
{}
//-----------------------------------------------------------------------------
 
//-----------------------------------------------------------------------------
EchoMonitorNode::~EchoMonitorNode() {}
//-----------------------------------------------------------------------------
 
//-----------------------------------------------------------------------------
std::string
EchoMonitorNode::get_status(bool print_out) const
{
  std::stringstream status;
  auto subnodes = read_sub_nodes(getNode("csr.stat"));
  status << format_reg_table(subnodes, "Echo mon state");
  if (print_out)
    TLOG() << status.str();
  return status.str();
}
//-----------------------------------------------------------------------------
 
//-----------------------------------------------------------------------------
uint64_t // NOLINT(build/unsigned)
EchoMonitorNode::send_echo_and_measure_delay(int64_t timeout) const
{
 
  getNode("csr.ctrl.go").write(0x1);
  getClient().dispatch();
 
  auto start = std::chrono::high_resolution_clock::now();
 
  uhal::ValWord<uint32_t> done; // NOLINT(build/unsigned)
  uhal::ValWord<uint32_t> delta_t;
  
  while (true) {
 
    done = getNode("csr.stat.rx_done").read();
    delta_t = getNode("csr.stat.deltat").read();
    getClient().dispatch();
 
    TLOG_DEBUG(6) << "rx done: " << done.value() << ", delta_t: " << delta_t.value();
 
    if (done.value())
    {
      if (delta_t.value() == 0xffff)
      {
        throw EchoReplyTimeout(ERS_HERE);
      } 
      else
      {
        break;
      }
    }
    
    auto now = std::chrono::high_resolution_clock::now();
    auto ms_since_start = std::chrono::duration_cast<std::chrono::milliseconds>(now - start);
 
    if (ms_since_start.count() > timeout)
      throw EchoFlagTimeout(ERS_HERE, timeout);
 
    std::this_thread::sleep_for(std::chrono::microseconds(10));
  }
 
  TLOG_DEBUG(4) << "delta t: " << format_reg_value(delta_t.value(), 10);
 
  return delta_t.value();
}
//-----------------------------------------------------------------------------
 
} // namespace timing
} // namespace dunedaq