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.
94 lines
2.3 KiB
C++
94 lines
2.3 KiB
C++
#ifndef WEBCC_CONNECTION_H_
|
|
#define WEBCC_CONNECTION_H_
|
|
|
|
#include <memory>
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
#include "asio/ip/tcp.hpp"
|
|
|
|
#include "webcc/globals.h"
|
|
#include "webcc/queue.h"
|
|
#include "webcc/request.h"
|
|
#include "webcc/request_parser.h"
|
|
#include "webcc/response.h"
|
|
|
|
namespace webcc {
|
|
|
|
class Connection;
|
|
class ConnectionPool;
|
|
class Server;
|
|
|
|
using ConnectionPtr = std::shared_ptr<Connection>;
|
|
|
|
class Connection : public std::enable_shared_from_this<Connection> {
|
|
public:
|
|
Connection(asio::ip::tcp::socket socket, ConnectionPool* pool,
|
|
Queue<ConnectionPtr>* queue, ViewMatcher&& view_matcher);
|
|
|
|
~Connection() = default;
|
|
|
|
Connection(const Connection&) = delete;
|
|
Connection& operator=(const Connection&) = delete;
|
|
|
|
RequestPtr request() const {
|
|
return request_;
|
|
}
|
|
|
|
// Start to read and process the client request.
|
|
void Start();
|
|
|
|
// Close the socket.
|
|
void Close();
|
|
|
|
// Send a response to the client.
|
|
// `Connection` header will be set to "Close" if |no_keep_alive| is true no
|
|
// matter whether the client asked for Keep-Alive or not.
|
|
void SendResponse(ResponsePtr response, bool no_keep_alive = false);
|
|
|
|
// Send a response with the given status and an empty body to the client.
|
|
// `Connection` header will be set to "Close" if |no_keep_alive| is true no
|
|
// matter whether the client asked for Keep-Alive or not.
|
|
void SendResponse(Status status, bool no_keep_alive = false);
|
|
|
|
private:
|
|
void DoRead();
|
|
void OnRead(std::error_code ec, std::size_t length);
|
|
|
|
void DoWrite();
|
|
void OnWriteHeaders(std::error_code ec, std::size_t length);
|
|
void DoWriteBody();
|
|
void OnWriteBody(std::error_code ec, std::size_t length);
|
|
void OnWriteOK();
|
|
void OnWriteError(std::error_code ec);
|
|
|
|
// The socket for the connection.
|
|
asio::ip::tcp::socket socket_;
|
|
|
|
// The connection pool.
|
|
ConnectionPool* pool_;
|
|
|
|
// The connection queue.
|
|
Queue<ConnectionPtr>* queue_;
|
|
|
|
// A function for matching view once the headers of a request has been
|
|
// received.
|
|
ViewMatcher view_matcher_;
|
|
|
|
// The buffer for incoming data.
|
|
std::vector<char> buffer_;
|
|
|
|
// The incoming request.
|
|
RequestPtr request_;
|
|
|
|
// The parser for the incoming request.
|
|
RequestParser request_parser_;
|
|
|
|
// The response to be sent back to the client.
|
|
ResponsePtr response_;
|
|
};
|
|
|
|
} // namespace webcc
|
|
|
|
#endif // WEBCC_CONNECTION_H_
|