RMMRing.h

#pragma once
 
#include <chrono>
#include <future>
#include <iostream>
#include <mutex>
#include <string>
#include <thread>
#include <unordered_map>
#include <vector>
 
#include "OptionalLock.h"
#include "RMMRegisterAccess.h"
#include "RMMRingTimestamps.h"
class FrontEndBase;  // Forward class declaration
 
constexpr int FE_WATCHDOG_TIMEOUT = 30;  // seconds
constexpr int STATUS_UPDATE_GAP = 1;     // seconds
constexpr int MAX_NUMBER_NODES = 16;
 
enum class FSMState { IDLE = 0, SYNC = 1, SLOW_CTRL = 2 };

struct RingState {
  bool enabled = true;     
  bool inTopology = false; 
  uint32_t nodeCount = 0;  
};

class RMMRing {
 public:
  RMMRing(uint32_t ringId, RMMRegisterAccess& regs, std::mutex* beMutex = nullptr);
  uint32_t getNumberOfFENs() const;
 
  void addEntry(std::shared_ptr<FrontEndBase> fen);
  void setLogMask(int mask);
  ringStatus check();
  rmmStatus tearDown(bool waitTime = true);
  rmmStatus bringup();
 
  int getPollTimeout();
  void setPollTimeout(int value);
 
  RingState getStatus() const;

  bool isOperational() const { return enabled_ && getNumberOfFENs() > 0; };
  rmmStatus setEnabled(bool enable);
 
  FrontEndBase* getFEN(int node);
  RMMLog log_;  
 
  rmmStatus startSendingBulkData();
 
 private:
  uint32_t ringId_;
  RMMRegisterAccess& regs_;
  std::mutex* beStateMutex_;
 
  std::mutex teardownMutex_;
  std::mutex fensMutex_;
 
  std::vector<std::shared_ptr<FrontEndBase>> fens_;
 
  std::atomic<bool> enabled_{true};
 
  static constexpr int TS_NODE_STATUS_ATTEMPTING_LOCK = 1;
  static constexpr int TS_NODE_STATUS_LOCKED = 2;
  static constexpr int NODEID_ON_RESET = 31;  // 0-indexed nodeid's (31 reserved for 'unassigned')
 
  RMMResult maskedSetXcvrEngineState(std::string txrx, FSMState fsm_st, bool use_dom_xcvr = true);
  std::string get3regSuffix();
  int getXcvrNum(bool use_dom_xcvr);
  void updateTouchScreen(int currentNode, int lockStatus, bool ringComplete);
 
  rmmStatus setupNode(int node);
  rmmStatus finalSetup(int finalNodeId);
  void finalEnterSlowCtrl();
  void beginNodeSync(bool useDomXcvr);
  RMMResult pollForLock(int node, bool useDomXcvr = true);
  void enterSlowCtrl(bool useDomXcvr = true);
 
  std::atomic<int> poll_timeout{10};
  bool inTopology() const;
 
  friend class FrontEndBase;
};