ClientIO::ClientIO(parser_type& parser, bool is_ssl,
const endpoint_type& local_endpoint,
- const endpoint_type& remote_endpoint,
- std::string_view extra_response_headers)
+ const endpoint_type& remote_endpoint)
: parser(parser), is_ssl(is_ssl),
local_endpoint(local_endpoint),
remote_endpoint(remote_endpoint),
- extra_response_headers(extra_response_headers),
txbuf(*this)
{
}
sent += txbuf.sputn(timestr, strlen(timestr));
}
- if (extra_response_headers.size()) {
- sent += txbuf.sputn(extra_response_headers.data(),
- extra_response_headers.size());
- }
-
if (parser.keep_alive()) {
constexpr char CONN_KEEP_ALIVE[] = "Connection: Keep-Alive\r\n";
sent += txbuf.sputn(CONN_KEEP_ALIVE, sizeof(CONN_KEEP_ALIVE) - 1);
#include "common/async/shared_mutex.h"
#include "common/errno.h"
#include "common/strtol.h"
-#include "ceph_ver.h"
#include "rgw_asio_client.h"
#include "rgw_asio_frontend.h"
rgw::asio::parser_type& parser, yield_context yield,
parse_buffer& buffer, bool is_ssl,
const tcp::endpoint& local_endpoint,
- const tcp::endpoint& remote_endpoint,
- std::string_view extra_response_headers)
- : ClientIO(parser, is_ssl, local_endpoint, remote_endpoint,
- extra_response_headers),
+ const tcp::endpoint& remote_endpoint)
+ : ClientIO(parser, is_ssl, local_endpoint, remote_endpoint),
cct(cct), stream(stream), timeout(timeout), yield(yield),
buffer(buffer)
{}
SharedMutex& pause_mutex,
rgw::dmclock::Scheduler *scheduler,
const std::string& uri_prefix,
- std::string_view extra_response_headers,
boost::system::error_code& ec,
yield_context yield)
{
}
StreamIO real_client{cct, stream, timeout, parser, yield, buffer,
- is_ssl, local_endpoint, remote_endpoint,
- extra_response_headers};
+ is_ssl, local_endpoint, remote_endpoint};
auto real_client_io = rgw::io::add_reordering(
rgw::io::add_buffering(cct,
std::unique_ptr<dmc::ClientConfig> client_config;
void accept(Listener& listener, boost::system::error_code ec);
- std::string extra_response_headers;
-
public:
AsioFrontend(RGWProcessEnv& env, RGWFrontendConfig* conf,
dmc::SchedulerCtx& sched_ctx)
boost::system::error_code ec;
auto& config = conf->get_config_map();
- // format the Server response header
- extra_response_headers = "Server: Ceph Object Gateway (" CEPH_RELEASE_NAME ")\r\n";
-
if (auto i = config.find("prefix"); i != config.end()) {
uri_prefix = i->second;
}
conn->buffer.consume(bytes);
handle_connection(context, env, stream, timeout, header_limit,
conn->buffer, true, pause_mutex, scheduler.get(),
- uri_prefix, extra_response_headers, ec, yield);
+ uri_prefix, ec, yield);
if (!ec) {
// ssl shutdown (ignoring errors)
stream.async_shutdown(yield[ec]);
boost::system::error_code ec;
handle_connection(context, env, conn->socket, timeout, header_limit,
conn->buffer, false, pause_mutex, scheduler.get(),
- uri_prefix, extra_response_headers, ec, yield);
+ uri_prefix, ec, yield);
conn->socket.shutdown(tcp_socket::shutdown_both, ec);
}, make_stack_allocator());
}