sync_dispatcher_impl.hpp

Go to the documentation of this file.

#ifndef IROHA_SUBSCRIPTION_SYNC_DISPATCHER_IMPL_HPP
#define IROHA_SUBSCRIPTION_SYNC_DISPATCHER_IMPL_HPP

#include "subscription/dispatcher.hpp"

#include "common/common.hpp"
#include "subscription/thread_handler.hpp"

namespace iroha::subscription {

  template <uint32_t kCount, uint32_t kPoolSize>
  class SyncDispatcher final : public IDispatcher,
                               utils::NoCopy,
                               utils::NoMove {
   private:
    using Parent = IDispatcher;

   public:
    SyncDispatcher() = default;

    void dispose() override {}

    void add(typename Parent::Tid /*tid*/,
             typename Parent::Task &&task) override {
      task();
    }

    void addDelayed(typename Parent::Tid /*tid*/,
                    std::chrono::microseconds /*timeout*/,
                    typename Parent::Task &&task) override {
      task();
    }

    std::optional<Tid> bind(std::shared_ptr<IScheduler> scheduler) override {
      if (!scheduler)
        return std::nullopt;

      return kCount;
    }

    bool unbind(Tid tid) override {
      return tid == kCount;
    }
  };

}  // namespace iroha::subscription

#endif  // IROHA_SUBSCRIPTION_SYNC_DISPATCHER_IMPL_HPP