You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
83 lines
1.9 KiB
C++
83 lines
1.9 KiB
C++
#ifndef WEBCC_HTTP_CONNECTION_H_
|
|
#define WEBCC_HTTP_CONNECTION_H_
|
|
|
|
#include <memory>
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
#include "boost/asio/ip/tcp.hpp" // for ip::tcp::socket
|
|
|
|
#include "webcc/globals.h"
|
|
#include "webcc/http_request.h"
|
|
#include "webcc/http_request_parser.h"
|
|
#include "webcc/http_response.h"
|
|
|
|
namespace webcc {
|
|
|
|
class HttpConnection;
|
|
class HttpConnectionPool;
|
|
class HttpRequestHandler;
|
|
|
|
typedef std::shared_ptr<HttpConnection> HttpConnectionPtr;
|
|
|
|
class HttpConnection : public std::enable_shared_from_this<HttpConnection> {
|
|
public:
|
|
HttpConnection(boost::asio::ip::tcp::socket socket, HttpConnectionPool* pool,
|
|
HttpRequestHandler* handler);
|
|
|
|
~HttpConnection() = default;
|
|
|
|
HttpConnection(const HttpConnection&) = delete;
|
|
HttpConnection& operator=(const HttpConnection&) = delete;
|
|
|
|
HttpRequestPtr request() const {
|
|
return request_;
|
|
}
|
|
|
|
// Start to read and process the client request.
|
|
void Start();
|
|
|
|
// Close the socket.
|
|
void Close();
|
|
|
|
// Send response to client.
|
|
void SendResponse(HttpResponsePtr response);
|
|
|
|
void SendResponse(http::Status status);
|
|
|
|
private:
|
|
void DoRead();
|
|
void OnRead(boost::system::error_code ec, std::size_t length);
|
|
|
|
void DoWrite();
|
|
void OnWrite(boost::system::error_code ec, std::size_t length);
|
|
|
|
// Shutdown the socket.
|
|
void Shutdown();
|
|
|
|
// Socket for the connection.
|
|
boost::asio::ip::tcp::socket socket_;
|
|
|
|
// The pool for this connection.
|
|
HttpConnectionPool* pool_;
|
|
|
|
// Buffer for incoming data.
|
|
std::vector<char> buffer_;
|
|
|
|
// The handler used to process the incoming request.
|
|
HttpRequestHandler* request_handler_;
|
|
|
|
// The incoming request.
|
|
HttpRequestPtr request_;
|
|
|
|
// The parser for the incoming request.
|
|
HttpRequestParser request_parser_;
|
|
|
|
// The response to be sent back to the client.
|
|
HttpResponsePtr response_;
|
|
};
|
|
|
|
} // namespace webcc
|
|
|
|
#endif // WEBCC_HTTP_CONNECTION_H_
|