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 {
  namespace consensus {
    namespace 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 yac
  }    // namespace consensus
}  // namespace iroha

#endif  // IROHA_BUFFERED_CLEANUP_STRATEGY_HPP