buffered_cleanup_strategy.hpp

Go to the documentation of this file.

#ifndef IROHA_BUFFERED_CLEANUP_STRATEGY_HPP
#define IROHA_BUFFERED_CLEANUP_STRATEGY_HPP

#include "consensus/yac/storage/cleanup_strategy.hpp"

#include <boost/optional.hpp>
#include <queue>

#include "consensus/yac/outcome_messages.hpp"

namespace iroha::consensus::yac {
  class BufferedCleanupStrategy : public CleanupStrategy {
   public:
    using RoundType = Round;

    boost::optional<CleanupStrategy::RoundsType> finalize(
        RoundType consensus_round, Answer answer) override;

    bool shouldCreateRound(const RoundType &round) override;

   private:
    RoundsType truncateCreatedRounds();

    boost::optional<RoundType> minimalRound() const;

    void createRound(const Round &round);

    bool isRequiredCreation(const Round &round) const;

    std::priority_queue<RoundType,
                        std::vector<RoundType>,
                        std::greater<RoundType>>
        created_rounds_;

    boost::optional<RoundType> last_reject_round_;
    boost::optional<RoundType> last_commit_round_;
  };
}  // namespace iroha::consensus::yac

#endif  // IROHA_BUFFERED_CLEANUP_STRATEGY_HPP