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_service>& io_service() noexcept { return _io_service; }
    asio::io_service::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 service
    std::shared_ptr<asio::io_service> _io_service;
    // Asio service strand for serialized handler execution
    asio::io_service::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