app_state_manager_impl.hpp

Go to the documentation of this file.

#ifndef KAGOME_APP_STATE_MANAGER
#define KAGOME_APP_STATE_MANAGER

#include "application/app_state_manager.hpp"

#include <condition_variable>
#include <csignal>
#include <mutex>
#include <queue>

#include "log/logger.hpp"

namespace kagome::application {

  class AppStateManagerImpl : public AppStateManager {
   public:
    AppStateManagerImpl();
    AppStateManagerImpl(const AppStateManagerImpl &) = delete;
    AppStateManagerImpl(AppStateManagerImpl &&) noexcept = delete;

    ~AppStateManagerImpl() override;

    AppStateManagerImpl &operator=(AppStateManagerImpl const &) = delete;
    AppStateManagerImpl &operator=(AppStateManagerImpl &&) noexcept = delete;

    void atPrepare(OnPrepare &&cb) override;
    void atLaunch(OnLaunch &&cb) override;
    void atShutdown(OnShutdown &&cb) override;

    void run() override;
    void shutdown() override;

    State state() const override {
      return state_;
    }

   protected:
    void reset();

    void doPrepare() override;
    void doLaunch() override;
    void doShutdown() override;

   private:
    static std::weak_ptr<AppStateManager> wp_to_myself;
    static void shuttingDownSignalsHandler(int);

    log::Logger logger_;

    std::atomic<State> state_ = State::Init;

    std::recursive_mutex mutex_;

    std::mutex cv_mutex_;
    std::condition_variable cv_;

    std::queue<OnPrepare> prepare_;
    std::queue<OnLaunch> launch_;
    std::queue<OnShutdown> shutdown_;

    std::atomic_bool shutdown_requested_{false};
  };

}  // namespace kagome::application

#endif  // KAGOME_APP_STATE_MANAGER