on_demand_cache.hpp

Go to the documentation of this file.

#ifndef IROHA_ON_DEMAND_CACHE_HPP
#define IROHA_ON_DEMAND_CACHE_HPP

#include "ordering/impl/ordering_gate_cache/ordering_gate_cache.hpp"

#include <shared_mutex>

#include <boost/circular_buffer.hpp>

namespace iroha {
  namespace ordering {
    namespace cache {

      class OnDemandCache : public OrderingGateCache {
       public:
        void addToBack(const BatchesSetType &batches) override;

        BatchesSetType pop() override;

        void remove(const HashesSetType &hashes) override;

        virtual const BatchesSetType &head() const override;

        virtual const BatchesSetType &tail() const override;

       private:
        mutable std::shared_timed_mutex mutex_;
        using BatchesQueueType = boost::circular_buffer<BatchesSetType>;
        BatchesQueueType circ_buffer{3, BatchesSetType{}};
      };

    }  // namespace cache
  }    // namespace ordering
}  // namespace iroha

#endif  // IROHA_ON_DEMAND_CACHE_HPP