26#ifndef ROUTER_SRC_HTTP_INCLUDE_HTTP_BASE_CONNECTION_H_
27#define ROUTER_SRC_HTTP_INCLUDE_HTTP_BASE_CONNECTION_H_
79 return &s->lower_layer();
89 s->set_parent(parent);
103template <
typename IOLayer>
117 CNO_CONNECTION_KIND kind, CNO_HTTP_VERSION
version)
121 std::stringstream ss;
122 ss <<
"HTTP-" <<
this;
124 socket_.set_option(net::ip::tcp::no_delay{
true});
126 cno_init(&
cno_, kind);
127 cno_.disallow_h2_prior_knowledge = 1;
143 bool send(
const uint32_t *stream_id_ptr,
const int status_code,
144 const std::string &method,
const std::string &
path,
146 cno_message_t message;
147 std::vector<cno_header_t> cno_header(headers.
size(), cno_header_t());
148 std::vector<std::string> http2_headers_names;
149 const bool only_header = 0 == data.
length();
151 if (CNO_HTTP2 ==
cno_.mode) {
152 http2_headers_names.reserve(headers.
size());
155 auto output = cno_header.data();
157 for (
const auto &
entry : headers) {
158 if (CNO_HTTP2 ==
cno_.mode) {
161 output->name.size = header_name.length();
162 output->name.data = header_name.c_str();
164 output->name.size =
entry.first.length();
165 output->name.data =
entry.first.c_str();
168 output->value.size =
entry.second.length();
169 output->value.data =
entry.second.c_str();
173 message.code = status_code;
174 message.headers = cno_header.data();
175 message.headers_len = cno_header.size();
176 message.path.data =
path.c_str();
177 message.path.size =
path.length();
178 message.method.data = method.c_str();
179 message.method.size = method.length();
182 stream_id_ptr ? *stream_id_ptr : cno_next_stream(&
cno_);
183 if (CNO_OK != cno_write_head(&
cno_, stream_id, &message, only_header)) {
188 return CNO_OK == cno_write_data(&
cno_, stream_id, data.
get().c_str(),
197 if (
auto e = s->remote_endpoint()) {
198 return e->address().to_string();
206 if (
auto e = s->remote_endpoint()) {
225 [
this](std::error_code
error,
auto size) {
269 std::size_t bytes_transferred) {
279 const int result = cno_consume(
302 bool has_more =
true;
303 bool should_close =
false;
310 auto size_on_page = std::min(
page.size(),
size);
311 page += size_on_page;
312 size -= size_on_page;
375 bool was_first =
false;
380 bool expected =
false;
383 auto source_it = buffers.begin();
385 while (source_it != buffers.end()) {
392 if (0 == source_it->size()) {
397 if (0 == obuffer.space_left()) {
402 (*source_it) += obuffer.write(
403 static_cast<const uint8_t *
>(source_it->data()), source_it->size());
415 [[maybe_unused]]
const cno_tail_t *tail)
override {
Definition: connection_interface.h:41
Definition: connection_status_callbacks.h:35
virtual void on_connection_io_error(Connection *connection, const std::error_code &ec)=0
virtual void on_connection_close(Connection *connection)=0
Definition: connection.h:104
int on_cno_close() override
Definition: connection.h:424
void shutdown(bool) override
Definition: connection.h:139
void start() override
Definition: connection.h:215
int on_cno_message_tail(const uint32_t session_id, const cno_tail_t *tail) override
Definition: connection.h:414
std::string make_lower(std::string s)
Definition: connection.h:218
bool stop_running()
Mark the connection that it should stop running.
Definition: connection.h:363
base::method::Bitset Methods
Definition: connection.h:108
virtual void on_output_buffer_empty()
Definition: connection.h:371
std::atomic< bool > suspend_
Definition: connection.h:444
Pending on_net_send(const std::error_code &ec, size_t size)
Definition: connection.h:301
Methods * allowed_method_
Definition: connection.h:432
ConnectionStatusCallbacks * connection_handler_
Definition: connection.h:446
int on_cno_writev(const cno_buffer_t *buffer, size_t count) override
Definition: connection.h:374
std::string get_peer_address() const override
Definition: connection.h:195
void do_net_recv()
Definition: connection.h:245
uint16_t get_peer_port() const override
Definition: connection.h:204
bool send(const uint32_t *stream_id_ptr, const int status_code, const std::string &method, const std::string &path, const Headers &headers, const IOBuffer &data) override
Definition: connection.h:143
IOLayer IO
Definition: connection.h:112
http::base::details::ref_buffers< std::list< owned_buffer > > ref_buffers
Definition: connection.h:111
void suspend()
Definition: connection.h:354
cno_connection_t cno_
Definition: connection.h:433
std::atomic< bool > reading_pending_
Definition: connection.h:442
bool keep_alive_
Definition: connection.h:430
std::list< owned_buffer > output_buffers_
Definition: connection.h:439
Pending on_net_receive(const std::error_code &ec, std::size_t bytes_transferred)
Definition: connection.h:268
void resume()
Definition: connection.h:353
std::atomic< bool > output_pending_
Definition: connection.h:441
uint8_t input_buffer_[512]
Definition: connection.h:435
IOLayer & get_socket()
Definition: connection.h:213
std::mutex output_buffer_mutex_
Definition: connection.h:438
IOLayer socket_
Definition: connection.h:431
int on_cno_stream_start(const uint32_t id) override
Definition: connection.h:420
std::atomic< bool > running_
Definition: connection.h:443
~Connection() override
Definition: connection.h:133
net::mutable_buffer input_mutable_buffer_
Definition: connection.h:436
void do_net_send()
Definition: connection.h:223
Connection(IOLayer s, base::method::Bitset *allowed_method, ConnectionStatusCallbacks *connection_handler, CNO_CONNECTION_KIND kind, CNO_HTTP_VERSION version)
Definition: connection.h:115
Definition: io_buffer.h:41
virtual const std::string & get() const
Definition: io_buffer.h:82
virtual size_t length() const
Definition: io_buffer.h:52
Definition: owned_buffer.h:83
Definition: owned_buffer.h:68
Definition: buffer_sequence.h:53
Definition: cno_interface.h:36
Definition: socket.h:1090
static constexpr shutdown_type shutdown_send
Definition: socket.h:185
int page
Definition: ctype-mb.cc:1234
static int count
Definition: myisam_ftdump.cc:45
void error(const char *format,...)
static char * path
Definition: mysqldump.cc:149
bool transform(const dd::Spatial_reference_system *source_srs, const Geometry &in, const dd::Spatial_reference_system *target_srs, const char *func_name, std::unique_ptr< Geometry > *out) noexcept
Transforms a geometry from one SRS to another.
Definition: transform.cc:216
void set_socket_parent(net::ip::tcp::socket *, const char *)
Definition: connection.h:62
auto * get_socket1(T *s)
Definition: connection.h:78
net::ip::tcp::socket * get_socket(net::ip::tcp::socket *s)
Definition: connection.h:67
std::bitset< Pos::_LAST+1 > Bitset
Definition: method.h:57
Pending
Definition: connection.h:96
@ k_pending_none
Definition: connection.h:97
@ k_pending_reading
Definition: connection.h:99
@ k_pending_closing
Definition: connection.h:98
@ k_pending_writing
Definition: connection.h:100
Request::Headers Headers
Definition: request.cc:35
HTTP_COMMON_EXPORT void callback_init(cno_connection_t *cno, CnoInterface *)
Definition: callback_init.cc:91
Definition: connection.h:57
Definition: http_server_component.cc:34
char tolower(const char &ch)
Definition: parsing_helpers.h:41
std::error_code make_error_code(DynamicLoaderErrc ec)
make error_code from a DynamicLoaderErrc.
Definition: dynamic_loader.cc:79
size_t size(const char *const c)
Definition: base64.h:46
mutable_buffer buffer(void *p, size_t n) noexcept
Definition: buffer.h:418
Definition: gcs_xcom_synode.h:64
static std::mutex lock
Definition: net_ns.cc:56
required uint64 version
Definition: replication_group_member_actions.proto:41
Definition: completion_hash.h:35