tcp_resolver.h

Go to the documentation of this file.

 
#ifndef CPPSERVER_ASIO_TCP_RESOLVER_H
#define CPPSERVER_ASIO_TCP_RESOLVER_H
 
#include "service.h"
 
namespace CppServer {
namespace Asio {


class TCPResolver
{
public:

    TCPResolver(const std::shared_ptr<Service>& service);
    TCPResolver(const TCPResolver&) = delete;
    TCPResolver(TCPResolver&&) = delete;
    virtual ~TCPResolver() { Cancel(); }
 
    TCPResolver& operator=(const TCPResolver&) = delete;
    TCPResolver& operator=(TCPResolver&&) = 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; }
    asio::ip::tcp::resolver& resolver() noexcept { return _resolver; }

    virtual void Cancel() { _resolver.cancel(); }
 
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;
    // TCP resolver
    asio::ip::tcp::resolver _resolver;
};
 
} // namespace Asio
} // namespace CppServer
 
#endif // CPPSERVER_ASIO_TCP_RESOLVER_H