From c1aaec6159d38a7929edb7cdcbffa786f658bccc Mon Sep 17 00:00:00 2001 From: "B. Blechschmidt" Date: Tue, 21 Mar 2023 01:08:44 +0100 Subject: [PATCH] Make manager references immutable --- src/http.rs | 4 ++-- src/socks5.rs | 4 ++-- src/tun2proxy.rs | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/http.rs b/src/http.rs index 14c6c17..a1c40eb 100644 --- a/src/http.rs +++ b/src/http.rs @@ -163,14 +163,14 @@ impl ConnectionManager for HttpManager { connection.proto == smoltcp::wire::IpProtocol::Tcp.into() } - fn new_connection(&mut self, connection: &Connection) -> Option> { + fn new_connection(&self, connection: &Connection) -> Option> { if connection.proto != smoltcp::wire::IpProtocol::Tcp.into() { return None; } Some(std::boxed::Box::new(HttpConnection::new(connection))) } - fn close_connection(&mut self, _: &Connection) {} + fn close_connection(&self, _: &Connection) {} fn get_server(&self) -> SocketAddr { self.server diff --git a/src/socks5.rs b/src/socks5.rs index 1006750..6b9534c 100644 --- a/src/socks5.rs +++ b/src/socks5.rs @@ -233,14 +233,14 @@ impl ConnectionManager for Socks5Manager { connection.proto == smoltcp::wire::IpProtocol::Tcp.into() } - fn new_connection(&mut self, connection: &Connection) -> Option> { + fn new_connection(&self, connection: &Connection) -> Option> { if connection.proto != smoltcp::wire::IpProtocol::Tcp.into() { return None; } Some(std::boxed::Box::new(SocksConnection::new(connection))) } - fn close_connection(&mut self, _: &Connection) {} + fn close_connection(&self, _: &Connection) {} fn get_server(&self) -> SocketAddr { self.server diff --git a/src/tun2proxy.rs b/src/tun2proxy.rs index 76cba69..9b592ab 100644 --- a/src/tun2proxy.rs +++ b/src/tun2proxy.rs @@ -171,8 +171,8 @@ pub(crate) trait TcpProxy { pub(crate) trait ConnectionManager { fn handles_connection(&self, connection: &Connection) -> bool; - fn new_connection(&mut self, connection: &Connection) -> Option>; - fn close_connection(&mut self, connection: &Connection); + fn new_connection(&self, connection: &Connection) -> Option>; + fn close_connection(&self, connection: &Connection); fn get_server(&self) -> SocketAddr; }