Skip to content

Commit

Permalink
Merge pull request #5493 from BenPope/net-remove-mtls
Browse files Browse the repository at this point in the history
net: Remove security::tls::principal_mapper
  • Loading branch information
dotnwat committed Jul 17, 2022
2 parents b9e9346 + 57a9a8e commit e481a87
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 43 deletions.
6 changes: 2 additions & 4 deletions src/v/net/connection.cc
Original file line number Diff line number Diff line change
Expand Up @@ -56,16 +56,14 @@ connection::connection(
ss::connected_socket f,
ss::socket_address a,
server_probe& p,
std::optional<size_t> in_max_buffer_size,
std::optional<security::tls::principal_mapper> tls_pm)
std::optional<size_t> in_max_buffer_size)
: addr(a)
, _hook(hook)
, _name(std::move(name))
, _fd(std::move(f))
, _in(_fd.input())
, _out(_fd.output())
, _probe(p)
, _tls_pm(std::move(tls_pm)) {
, _probe(p) {
if (in_max_buffer_size.has_value()) {
auto in_config = ss::connected_socket_input_stream_config{};
in_config.max_buffer_size = in_max_buffer_size.value();
Expand Down
10 changes: 1 addition & 9 deletions src/v/net/connection.h
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@
#include "net/batched_output_stream.h"
#include "net/server_probe.h"
#include "seastarx.h"
#include "security/mtls.h"

#include <seastar/core/iostream.hh>
#include <seastar/net/api.hh>
Expand All @@ -39,8 +38,7 @@ class connection : public boost::intrusive::list_base_hook<> {
ss::connected_socket f,
ss::socket_address a,
server_probe& p,
std::optional<size_t> in_max_buffer_size,
std::optional<security::tls::principal_mapper> tls_pm);
std::optional<size_t> in_max_buffer_size);
~connection() noexcept;
connection(const connection&) = delete;
connection& operator=(const connection&) = delete;
Expand All @@ -64,19 +62,13 @@ class connection : public boost::intrusive::list_base_hook<> {
return ss::tls::get_dn_information(_fd);
}

const std::optional<security::tls::principal_mapper>&
get_principal_mapping() const {
return _tls_pm;
}

private:
boost::intrusive::list<connection>& _hook;
ss::sstring _name;
ss::connected_socket _fd;
ss::input_stream<char> _in;
net::batched_output_stream _out;
server_probe& _probe;
std::optional<security::tls::principal_mapper> _tls_pm;
};

} // namespace net
12 changes: 1 addition & 11 deletions src/v/net/server.cc
Original file line number Diff line number Diff line change
Expand Up @@ -215,23 +215,13 @@ ss::future<> server::accept(listener& s) {
}
}

std::optional<security::tls::principal_mapper> tls_pm;
auto se_it = std::find_if(
cfg.addrs.begin(), cfg.addrs.end(), [&name](const auto& a) {
return a.name == name;
});
if (se_it != cfg.addrs.end()) {
tls_pm = se_it->principal_mapper;
}

auto conn = ss::make_lw_shared<net::connection>(
_connections,
name,
std::move(ar.connection),
ar.remote_address,
_probe,
cfg.stream_recv_buf,
tls_pm);
cfg.stream_recv_buf);
vlog(
rpc::rpclog.trace,
"{} - Incoming connection from {} on \"{}\"",
Expand Down
19 changes: 0 additions & 19 deletions src/v/net/server.h
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@
#include "net/connection.h"
#include "net/connection_rate.h"
#include "net/types.h"
#include "security/mtls.h"
#include "utils/hdr_hist.h"

#include <seastar/core/abort_source.hh>
Expand All @@ -43,7 +42,6 @@ struct server_endpoint {
ss::sstring name;
ss::socket_address addr;
ss::shared_ptr<ss::tls::server_credentials> credentials;
std::optional<security::tls::principal_mapper> principal_mapper;

server_endpoint(ss::sstring name, ss::socket_address addr)
: name(std::move(name))
Expand All @@ -57,28 +55,11 @@ struct server_endpoint {
, addr(addr)
, credentials(std::move(creds)) {}

server_endpoint(
ss::sstring name,
ss::socket_address addr,
ss::shared_ptr<ss::tls::server_credentials> creds,
std::optional<security::tls::principal_mapper> principal_mapper)
: name(std::move(name))
, addr(addr)
, credentials(std::move(creds))
, principal_mapper(std::move(principal_mapper)) {}

server_endpoint(
ss::socket_address addr,
ss::shared_ptr<ss::tls::server_credentials> creds)
: server_endpoint("", addr, std::move(creds)) {}

server_endpoint(
ss::socket_address addr,
ss::shared_ptr<ss::tls::server_credentials> creds,
security::tls::principal_mapper principal_mapper)
: server_endpoint(
"", addr, std::move(creds), std::move(principal_mapper)) {}

explicit server_endpoint(ss::socket_address addr)
: server_endpoint("", addr) {}

Expand Down

0 comments on commit e481a87

Please sign in to comment.