TimeoutCounter.h

#ifndef XRPL_APP_LEDGER_TIMEOUTCOUNTER_H_INCLUDED
#define XRPL_APP_LEDGER_TIMEOUTCOUNTER_H_INCLUDED
 
#include <xrpld/app/main/Application.h>
#include <xrpld/core/Job.h>
 
#include <xrpl/beast/utility/Journal.h>
 
#include <boost/asio/basic_waitable_timer.hpp>
 
#include <mutex>
 
namespace ripple {
 
class TimeoutCounter
{
public:
    virtual void
    cancel();
 
protected:
    using ScopedLockType = std::unique_lock<std::recursive_mutex>;
 
    struct QueueJobParameter
    {
        JobType jobType;
        std::string jobName;
        std::optional<std::uint32_t> jobLimit;
    };
 
    TimeoutCounter(
        Application& app,
        uint256 const& targetHash,
        std::chrono::milliseconds timeoutInterval,
        QueueJobParameter&& jobParameter,
        beast::Journal journal);
 
    virtual ~TimeoutCounter() = default;
 
    void
    setTimer(ScopedLockType&);
 
    void
    queueJob(ScopedLockType&);
 
    virtual void
    onTimer(bool progress, ScopedLockType&) = 0;
 
    virtual std::weak_ptr<TimeoutCounter>
    pmDowncast() = 0;
 
    bool
    isDone() const
    {
        return complete_ || failed_;
    }
 
    // Used in this class for access to boost::asio::io_context and
    // ripple::Overlay. Used in subtypes for the kitchen sink.
    Application& app_;
    beast::Journal journal_;
    mutable std::recursive_mutex mtx_;
 
    uint256 const hash_;
    int timeouts_;
    bool complete_;
    bool failed_;
    bool progress_;
    std::chrono::milliseconds timerInterval_;
 
    QueueJobParameter queueJobParameter_;
 
private:
    void
    invokeOnTimer();
 
    boost::asio::basic_waitable_timer<std::chrono::steady_clock> timer_;
};
 
}  // namespace ripple
 
#endif