dunedaq::timing::MasterGlobalNode Class Reference

Class for master global node. More...

#include <MasterGlobalNode.hpp>

Inheritance diagram for dunedaq::timing::MasterGlobalNode:

Collaboration diagram for dunedaq::timing::MasterGlobalNode:

Public Member Functions
	MasterGlobalNode (const uhal::Node &node)
virtual	~MasterGlobalNode ()
void	enable_upstream_endpoint (uint32_t timeout=500) const
	Enable the upstream endpoint.
bool	read_upstream_endpoint_ready () const
	Read the upstream endpoint ready reg.
void	reset_command_counters (uint32_t timeout=500) const
	Enable the upstream endpoint.
bool	read_counters_ready () const
	Enable the upstream endpoint.
std::string	get_status (bool print_out=false) const override
	Get status string, optionally print.
Public Member Functions inherited from dunedaq::timing::TimingNode
	TimingNode (const uhal::Node &node)
virtual	~TimingNode ()
std::map< std::string, uhal::ValWord< uint32_t > >	read_sub_nodes (const uhal::Node &node, bool dispatch=true) const
	Read subnodes.
void	reset_sub_nodes (const uhal::Node &node, uint32_t aValue=0x0, bool dispatch=true) const
	Reset subnodes.

Detailed Description

Class for master global node.

Definition at line 29 of file MasterGlobalNode.hpp.

Constructor & Destructor Documentation

MasterGlobalNode()

dunedaq::timing::MasterGlobalNode::MasterGlobalNode ( const uhal::Node & node )

explicit

Definition at line 21 of file MasterGlobalNode.cpp.

  : TimingNode(node)
{}

~MasterGlobalNode()

dunedaq::timing::MasterGlobalNode::~MasterGlobalNode ( )

virtual

Definition at line 27 of file MasterGlobalNode.cpp.

{}

Member Function Documentation

enable_upstream_endpoint()

void dunedaq::timing::MasterGlobalNode::enable_upstream_endpoint

(

uint32_t

timeout = 500

)

const

Enable the upstream endpoint.

Definition at line 48 of file MasterGlobalNode.cpp.

{
  getNode("csr.ctrl.resync_cdr").write(0x1);
  getNode("csr.ctrl.resync").write(0x1);
  getClient().dispatch();
 
  getNode("csr.ctrl.resync_cdr").write(0x0);
  getNode("csr.ctrl.resync").write(0x0);
  getClient().dispatch();
 
  TLOG_DEBUG(4) << "Upstream CDR reset, waiting for lock";
 
  auto start = std::chrono::high_resolution_clock::now();
 
  // Wait for the rx and cdr to be happy
  while (true) {
    auto rx_ready = getNode("csr.stat.rx_rdy").read();
    auto cdr_ready = getNode("csr.stat.cdr_locked").read();
    getClient().dispatch();
 
    TLOG_DEBUG(6) << std::hex << "rx ready: 0x" << rx_ready.value() << ", cdr ready: " << cdr_ready.value();
 
    if (rx_ready.value() && cdr_ready.value())
    {
      TLOG_DEBUG(4) << "Master CDR and rx block ready!";
      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 ReceiverNotReady(ERS_HERE, cdr_ready.value(), rx_ready.value());
 
    std::this_thread::sleep_for(std::chrono::microseconds(10));
  }
}

get_status()

std::string dunedaq::timing::MasterGlobalNode::get_status ( bool print_out = false ) const

overridevirtual

Get status string, optionally print.

Implements dunedaq::timing::TimingNode.

Definition at line 32 of file MasterGlobalNode.cpp.

{
  std::stringstream status;
  auto ctrl = read_sub_nodes(getNode("csr.ctrl"));
  status << format_reg_table(ctrl, "Master global controls");
  
  auto stat = read_sub_nodes(getNode("csr.stat"));
  status << format_reg_table(stat, "Master global state");
  if (print_out)
    TLOG() << status.str();
  return status.str();
}

read_counters_ready()

bool dunedaq::timing::MasterGlobalNode::read_counters_ready

(

)

const

Enable the upstream endpoint.

Definition at line 141 of file MasterGlobalNode.cpp.

{
  auto counters_ready = getNode("csr.stat.ctrs_rdy").read();
  getClient().dispatch();
  return counters_ready.value();
}

read_upstream_endpoint_ready()

bool dunedaq::timing::MasterGlobalNode::read_upstream_endpoint_ready

(

)

const

Read the upstream endpoint ready reg.

Definition at line 89 of file MasterGlobalNode.cpp.

{
  auto rx_ready = getNode("csr.stat.rx_rdy").read();
  getClient().dispatch();
  return rx_ready.value();
}

reset_command_counters()

void dunedaq::timing::MasterGlobalNode::reset_command_counters

(

uint32_t

timeout = 500

)

const

Enable the upstream endpoint.

Definition at line 99 of file MasterGlobalNode.cpp.

{
  getNode("csr.ctrl.clr_ctrs").write(0x1);
  getClient().dispatch();
 
  TLOG_DEBUG(1) << "Command counters reset, waiting for them to be ready";
 
  auto start = std::chrono::high_resolution_clock::now();
 
  std::chrono::milliseconds ms_since_start(0);
 
  uhal::ValWord<uint32_t> counters_ready;  // NOLINT(build/unsigned)
 
  // Wait for the endpoint to be happy
  while (ms_since_start.count() < timeout) {
    auto now = std::chrono::high_resolution_clock::now();
    ms_since_start = std::chrono::duration_cast<std::chrono::milliseconds>(now - start);
 
    millisleep(10);
 
    counters_ready = getNode("csr.stat.ctrs_rdy").read();
    getClient().dispatch();
 
    TLOG_DEBUG(6) << "counters ready: 0x" << counters_ready.value();
 
    if (counters_ready.value()) {
      TLOG_DEBUG(4) << "Master command counters ready!";
      return;
    }
  }
 
  if (!counters_ready.value()) {
    // TODO throw something
    TLOG() << "Command counters did not become ready";
  } else {
    TLOG_DEBUG(4) << "Command counters ready";
  }
}

---

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

• /github/workspace/dunedaq/sourcecode/timing/include/timing/MasterGlobalNode.hpp
• /github/workspace/dunedaq/sourcecode/timing/src/MasterGlobalNode.cpp