chore: make clippy happy

This commit is contained in:
zonyitoo
2024-04-21 15:49:41 +08:00
parent a40257c245
commit b719d49ce0
12 changed files with 26 additions and 37 deletions
+9 -5
View File
@@ -1528,8 +1528,12 @@ impl Config {
};
#[cfg(target_os = "macos")]
{
local_config.launchd_tcp_socket_name = config.launchd_tcp_socket_name.clone();
local_config.launchd_udp_socket_name = config.launchd_udp_socket_name.clone();
local_config
.launchd_tcp_socket_name
.clone_from(&config.launchd_tcp_socket_name);
local_config
.launchd_udp_socket_name
.clone_from(&config.launchd_udp_socket_name);
}
let local_instance = LocalInstanceConfig {
@@ -2613,8 +2617,8 @@ impl fmt::Display for Config {
#[cfg(target_os = "macos")]
{
jconf.launchd_tcp_socket_name = local.launchd_tcp_socket_name.clone();
jconf.launchd_udp_socket_name = local.launchd_udp_socket_name.clone();
jconf.launchd_tcp_socket_name.clone_from(&local.launchd_tcp_socket_name);
jconf.launchd_udp_socket_name.clone_from(&local.launchd_udp_socket_name);
}
if local.protocol != ProtocolType::Socks {
@@ -2981,7 +2985,7 @@ impl fmt::Display for Config {
}
jconf.outbound_bind_addr = self.outbound_bind_addr.map(|i| i.to_string());
jconf.outbound_bind_interface = self.outbound_bind_interface.clone();
jconf.outbound_bind_interface.clone_from(&self.outbound_bind_interface);
// Security
if self.security.replay_attack.policy != ReplayAttackPolicy::default() {
@@ -131,12 +131,8 @@ pub async fn connect_host(
} else {
let server = balancer.best_tcp_server();
match AutoProxyClientStream::connect_with_opts(
context,
server.as_ref(),
host,
server.connect_opts_ref()
).await {
match AutoProxyClientStream::connect_with_opts(context, server.as_ref(), host, server.connect_opts_ref()).await
{
Ok(s) => Ok((s, Some(server))),
Err(err) => {
error!(
@@ -85,8 +85,7 @@ impl AutoProxyClientStream {
if let Some(mapped_addr) = context.try_map_fake_address(&addr).await {
addr = mapped_addr;
}
let stream =
TcpStream::connect_remote_with_opts(context.context_ref(), &addr, connect_opts).await?;
let stream = TcpStream::connect_remote_with_opts(context.context_ref(), &addr, connect_opts).await?;
Ok(AutoProxyClientStream::Bypassed(stream))
}
@@ -99,13 +98,8 @@ impl AutoProxyClientStream {
where
A: Into<Address>,
{
AutoProxyClientStream::connect_proxied_with_opts(
context.clone(),
server,
addr,
context.connect_opts_ref()
)
.await
AutoProxyClientStream::connect_proxied_with_opts(context.clone(), server, addr, context.connect_opts_ref())
.await
}
/// Connect to target `addr` via shadowsocks' server configured by `svr_cfg`
@@ -572,8 +572,7 @@ where
let svr_cfg = server.server_config();
let socket =
ProxySocket::connect_with_opts(self.context.context(), svr_cfg, server.connect_opts_ref())
.await?;
ProxySocket::connect_with_opts(self.context.context(), svr_cfg, server.connect_opts_ref()).await?;
let socket = MonProxySocket::from_socket(socket, self.context.flow_stat());
self.proxied_socket.insert(socket)
@@ -47,7 +47,8 @@ async fn establish_client_tcp_redir<'a>(
let server = balancer.best_tcp_server();
let svr_cfg = server.server_config();
let mut remote = AutoProxyClientStream::connect_with_opts(context, &server, addr, server.connect_opts_ref()).await?;
let mut remote =
AutoProxyClientStream::connect_with_opts(context, &server, addr, server.connect_opts_ref()).await?;
establish_tcp_tunnel(svr_cfg, &mut stream, &mut remote, peer_addr, addr).await
}
@@ -106,7 +106,7 @@ impl Socks4TcpHandler {
self.context,
&server,
&target_addr,
server.connect_opts_ref()
server.connect_opts_ref(),
)
.await;
server_opt = Some(server);
@@ -258,7 +258,7 @@ impl Socks5TcpHandler {
self.context,
&server,
&target_addr,
server.connect_opts_ref()
server.connect_opts_ref(),
)
.await;
server_opt = Some(server);
@@ -576,7 +576,8 @@ async fn establish_client_tcp_redir<'a>(
let server = balancer.best_tcp_server();
let svr_cfg = server.server_config();
let mut remote = AutoProxyClientStream::connect_with_opts(context, &server, addr, server.connect_opts_ref()).await?;
let mut remote =
AutoProxyClientStream::connect_with_opts(context, &server, addr, server.connect_opts_ref()).await?;
establish_tcp_tunnel(svr_cfg, &mut stream, &mut remote, peer_addr, addr).await
}
@@ -138,12 +138,8 @@ async fn handle_tcp_client(
svr_cfg.addr(),
);
let mut remote = AutoProxyClientStream::connect_proxied_with_opts(
context,
&server,
forward_addr,
server.connect_opts_ref()
)
.await?;
let mut remote =
AutoProxyClientStream::connect_proxied_with_opts(context, &server, forward_addr, server.connect_opts_ref())
.await?;
establish_tcp_tunnel(svr_cfg, &mut stream, &mut remote, peer_addr, forward_addr).await
}
@@ -648,7 +648,7 @@ impl UdpAssociationContext {
return;
}
session_context.client_user = control.user.clone();
session_context.client_user.clone_from(&control.user);
}
if let Err(err) = self.dispatch_received_outbound_packet(target_addr, data).await {
@@ -822,7 +822,7 @@ impl UdpAssociationContext {
control.client_session_id = client_session.client_session_id;
control.server_session_id = self.server_session_id;
control.packet_id = self.server_packet_id;
control.user = client_session.client_user.clone();
control.user.clone_from(&client_session.client_user);
if let Err(err) = self
.inbound
@@ -37,7 +37,6 @@ use std::{
pin::Pin,
slice,
task::{self, Poll},
u16,
};
use byte_string::ByteStr;
@@ -51,7 +51,6 @@ use std::{
sync::Arc,
task::{self, Poll},
time::SystemTime,
u16,
};
use aes::{