HttpServer.hpp

Go to the documentation of this file.

#ifndef _IDENTT_HTTP_SERVER_HPP_
#define _IDENTT_HTTP_SERVER_HPP_

#include "HttpServerBase.hpp"

namespace identt {
namespace http {

template <class socket_type>
class HttpServer : public HttpServerBase<socket_type> {};

using HTTP = asio::ip::tcp::socket;

template <>
class HttpServer<HTTP> : public HttpServerBase<HTTP> {
public:
    HttpServer(unsigned short port) noexcept
        : HttpServerBase<HTTP>::HttpServerBase(port) {}

protected:
    void accept() override
    {
        auto connection = create_connection(*io_whatever);

        acceptor->async_accept(*connection->socket, [this, connection](const error_code &ec) {
            auto lock = connection->handler_runner->continue_lock();
            if(!lock)
                return;

            // Immediately start accepting a new connection (unless io_service has been stopped)
            if(ec != error::operation_aborted)
                this->accept();

            auto session = std::make_shared<Session>(config.max_request_streambuf_size, connection);

            if(!ec) {
                asio::ip::tcp::no_delay option(true);
                error_code ec;
                session->connection->socket->set_option(option, ec);

                this->read(session);
            }
            else if(this->on_error)
                this->on_error(session->request, ec);
        });
    }
};

} // namespace http
} // namespace identt
#endif  /* _IDENTT_HTTP_SERVER_HPP_ */