timer.h

Go to the documentation of this file.

 
#ifndef CPPSERVER_ASIO_TIMER_H
#define CPPSERVER_ASIO_TIMER_H
 
#include "service.h"
 
#include "time/time.h"
#include "time/timespan.h"
 
#include <cassert>
#include <functional>
 
namespace CppServer {
namespace Asio {


class Timer : public std::enable_shared_from_this<Timer>
{
public:

    Timer(const std::shared_ptr<Service>& service);

    Timer(const std::shared_ptr<Service>& service, const CppCommon::UtcTime& time);

    Timer(const std::shared_ptr<Service>& service, const CppCommon::Timespan& timespan);

    Timer(const std::shared_ptr<Service>& service, const std::function<void(bool)>& action);

    Timer(const std::shared_ptr<Service>& service, const std::function<void(bool)>& action, const CppCommon::UtcTime& time);

    Timer(const std::shared_ptr<Service>& service, const std::function<void(bool)>& action, const CppCommon::Timespan& timespan);
    Timer(const Timer&) = delete;
    Timer(Timer&&) = delete;
    virtual ~Timer() = default;
 
    Timer& operator=(const Timer&) = delete;
    Timer& operator=(Timer&&) = delete;

    std::shared_ptr<Service>& service() noexcept { return _service; }
    std::shared_ptr<asio::io_context>& io_context() noexcept { return _io_context; }
    asio::io_context::strand& strand() noexcept { return _strand; }

    CppCommon::UtcTime expire_time() const;
    CppCommon::Timespan expire_timespan() const;


    virtual bool Setup(const CppCommon::UtcTime& time);

    virtual bool Setup(const CppCommon::Timespan& timespan);

    virtual bool Setup(const std::function<void(bool)>& action);

    virtual bool Setup(const std::function<void(bool)>& action, const CppCommon::UtcTime& time);

    virtual bool Setup(const std::function<void(bool)>& action, const CppCommon::Timespan& timespan);


    virtual bool WaitAsync();

    virtual bool WaitSync();


    virtual bool Cancel();
 
protected:
    virtual void onTimer(bool canceled) {}


    virtual void onError(int error, const std::string& category, const std::string& message) {}
 
private:
    // Asio service
    std::shared_ptr<Service> _service;
    // Asio IO context
    std::shared_ptr<asio::io_context> _io_context;
    // Asio service strand for serialized handler execution
    asio::io_context::strand _strand;
    bool _strand_required;
    // Deadline timer
    asio::system_timer _timer;
    // Action function
    std::function<void(bool)> _action;

    void SendError(std::error_code ec);
    void SendTimer(bool canceled);
};

 
} // namespace Asio
} // namespace CppServer
 
#endif // CPPSERVER_ASIO_TIMER_H