spawner.h

#pragma once
 
//
// Copyright (c) 2022 Ivan Baidakou (basiliscos) (the dot dmol at gmail dot com)
//
// Distributed under the MIT Software License
//
 
#include "forward.hpp"
#include "policy.h"
 
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable : 4251)
#endif
 
namespace rotor {
 
namespace details {
enum class request_state_t { NONE, SENT, CONFIRMED };
}

struct ROTOR_API spawner_t {
    ~spawner_t();

    spawner_t &&restart_period(const pt::time_duration &) noexcept;

    spawner_t &&restart_policy(restart_policy_t) noexcept;

    spawner_t &&max_attempts(size_t) noexcept;

    spawner_t &&escalate_failure(bool = true) noexcept;

    void spawn() noexcept;
 
  private:
    spawner_t(factory_t factory, supervisor_t &supervisor) noexcept;
 
    factory_t factory;
    supervisor_t &supervisor;
    pt::time_duration period = pt::seconds{15};
    restart_policy_t policy = restart_policy_t::normal_only;
    size_t attempts = 0;
    bool done = false;
    bool escalate = false;
 
    friend struct supervisor_t;
};
 
} // namespace rotor
 
#if defined(_MSC_VER)
#pragma warning(pop)
#endif