period_data_queue.hpp

Go to the documentation of this file.

#pragma once
 
#include <libp2p/Host.h>
 
#include <deque>
 
#include "pbft/period_data.hpp"
 
namespace taraxa {
 
class PeriodData;
 
class PeriodDataQueue {
 public:
  PeriodDataQueue() = default;
 
  bool push(PeriodData &&period_data, const dev::p2p::NodeID &node_id, uint64_t max_pbft_size,
            std::vector<std::shared_ptr<PbftVote>> &&cert_votes);
 
  std::tuple<PeriodData, std::vector<std::shared_ptr<PbftVote>>, dev::p2p::NodeID> pop();
 
  void clear();
 
  size_t size() const;
 
  bool empty() const;
 
  uint64_t getPeriod() const;
 
  std::shared_ptr<PbftBlock> lastPbftBlock() const;
 
  void cleanOldData(uint64_t period);
 
 private:
  std::deque<std::pair<PeriodData, dev::p2p::NodeID>> queue_;
  // We need this variable as for small amount of time block is not part of queue but still being processed
  uint64_t period_{0};
  mutable std::shared_mutex queue_access_;
  // Once fully synced, this will keep the cert votes for the last block in the chain
  std::vector<std::shared_ptr<PbftVote>> last_block_cert_votes_;
};
 
}  // namespace taraxa