mirror of
https://github.com/shadowsocks/shadowsocks-rust.git
synced 2026-11-07 00:13:33 +00:00
ignore the result
This commit is contained in:
@@ -169,8 +169,8 @@ impl TcpRelayLocal {
|
||||
error!("{} relay from local to remote stream: {}", addr_cloned, err)
|
||||
}
|
||||
}
|
||||
remote_stream_cloned.shutdown(Shutdown::Write).or(Ok(())).unwrap();
|
||||
local_stream_cloned.shutdown(Shutdown::Read).or(Ok(())).unwrap();
|
||||
let _ = remote_stream_cloned.shutdown(Shutdown::Write);
|
||||
let _ = local_stream_cloned.shutdown(Shutdown::Read);
|
||||
}
|
||||
}
|
||||
});
|
||||
@@ -199,8 +199,8 @@ impl TcpRelayLocal {
|
||||
error!("{} relay from local to remote stream: {}", addr, err)
|
||||
}
|
||||
}
|
||||
decrypt_stream.get_mut().shutdown(Shutdown::Write).or(Ok(())).unwrap();
|
||||
stream.shutdown(Shutdown::Read).or(Ok(())).unwrap();
|
||||
let _ = decrypt_stream.get_mut().shutdown(Shutdown::Write);
|
||||
let _ = stream.shutdown(Shutdown::Read);
|
||||
},
|
||||
Ok(..) => {},
|
||||
}
|
||||
|
||||
@@ -115,8 +115,8 @@ impl TcpRelayServer {
|
||||
error!("{} relay from local to remote stream: {}", addr_cloned, err)
|
||||
}
|
||||
}
|
||||
remote_stream_cloned.shutdown(Shutdown::Write).or(Ok(())).unwrap();
|
||||
decrypt_stream.get_mut().get_mut().shutdown(Shutdown::Write).or(Ok(())).unwrap();
|
||||
let _ = remote_stream_cloned.shutdown(Shutdown::Write);
|
||||
let _ = decrypt_stream.get_mut().get_mut().shutdown(Shutdown::Write);
|
||||
}
|
||||
}
|
||||
});
|
||||
@@ -145,8 +145,8 @@ impl TcpRelayServer {
|
||||
error!("{} relay from remote to local stream: {}", addr, err)
|
||||
}
|
||||
}
|
||||
encrypt_stream.get_mut().shutdown(Shutdown::Write).or(Ok(())).unwrap();
|
||||
buffered_remote_stream.get_mut().shutdown(Shutdown::Write).or(Ok(())).unwrap();
|
||||
let _ = encrypt_stream.get_mut().shutdown(Shutdown::Write);
|
||||
let _ = buffered_remote_stream.get_mut().shutdown(Shutdown::Write);
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user