pbft_syncing_state.hpp

Go to the documentation of this file.

#pragma once
 
#include <atomic>
#include <memory>
#include <shared_mutex>
 
#include "common/types.hpp"
 
namespace taraxa::network::tarcap {
 
class TaraxaPeer;
 
class PbftSyncingState {
 public:
  PbftSyncingState(uint16_t deep_syncing_threshold);
 
  bool setPbftSyncing(bool syncing, PbftPeriod current_period = 0, std::shared_ptr<TaraxaPeer> peer = nullptr);
 
  void setSyncStatePeriod(PbftPeriod period);
 
  bool isDeepPbftSyncing() const;
 
  bool isPbftSyncing();
 
  std::shared_ptr<TaraxaPeer> syncingPeer() const;
 
  std::shared_ptr<TaraxaPeer> lastSyncingPeer() const;
 
  void setLastSyncPacketTime();
 
  bool isActivelySyncing() const;
 
 private:
  std::atomic<bool> deep_pbft_syncing_{false};
  std::atomic<bool> pbft_syncing_{false};
 
  const uint16_t kDeepSyncingThreshold;
 
  // Number of seconds needed for ongoing syncing to be declared as inactive
  static constexpr std::chrono::seconds kSyncingInactivityThreshold{60};
 
  // What time was received last syncing packet
  std::chrono::steady_clock::time_point last_received_sync_packet_time_{std::chrono::steady_clock::now()};
  mutable std::shared_mutex time_mutex_;
 
  // Peer that the node is syncing with
  std::shared_ptr<TaraxaPeer> peer_;
  // Last syncing peer - it is not reset to null, it is only replaced when new syncing starts
  std::shared_ptr<TaraxaPeer> last_syncing_peer_;
  mutable std::shared_mutex peer_mutex_;
};
 
}  // namespace taraxa::network::tarcap