http_connection.hpp

Go to the documentation of this file.

#ifndef CPP_WEB_SERVER_HTTP_CONNECTION_HPP
#define CPP_WEB_SERVER_HTTP_CONNECTION_HPP

#include "async_web_server_cpp/http_request.hpp"
#include "async_web_server_cpp/http_request_handler.hpp"
#include "async_web_server_cpp/http_request_parser.hpp"

#include <boost/asio.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/noncopyable.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/thread/mutex.hpp>

namespace async_web_server_cpp
{

class HttpConnection;
typedef boost::shared_ptr<HttpConnection> HttpConnectionPtr;
typedef boost::weak_ptr<HttpConnection> HttpConnectionWeakPtr;

class HttpConnection : public boost::enable_shared_from_this<HttpConnection>,
                       private boost::noncopyable
{
public:
    typedef boost::function<void(const char* begin, const char* end)>
        ReadHandler;
    typedef boost::shared_ptr<const void> ResourcePtr;

    explicit HttpConnection(boost::asio::io_service& io_service,
                            HttpServerRequestHandler request_handler);

    boost::asio::ip::tcp::socket& socket();

    void start();

    void async_read(ReadHandler callback);

    void write_and_clear(std::vector<unsigned char>& data);

    void write(const std::string&);

    void write(const boost::asio::const_buffer& buffer, ResourcePtr resource);

    void write(const std::vector<boost::asio::const_buffer>& buffer,
               ResourcePtr resource);

private:
    void handle_read(const char* begin, const char* end);
    void handle_read_raw(ReadHandler callback,
                         const boost::system::error_code& e,
                         std::size_t bytes_transferred);

    // Must be called while holding write lock
    void write_pending();

    void handle_write(const boost::system::error_code& e,
                      std::vector<ResourcePtr> resources);

    boost::asio::io_service::strand strand_;
    boost::asio::ip::tcp::socket socket_;
    HttpServerRequestHandler request_handler_;
    boost::array<char, 8192> buffer_;
    HttpRequest request_;
    HttpRequestParser request_parser_;

    boost::mutex write_mutex_;
    bool write_in_progress_;
    std::vector<boost::asio::const_buffer> pending_write_buffers_;
    std::vector<ResourcePtr> pending_write_resources_;
    boost::system::error_code last_error_;
    ReadHandler read_handler_;
};

}  // namespace async_web_server_cpp

#endif