This commit is contained in:
Y. T. Chung
2015-12-11 13:42:44 +08:00
parent 7472e67ed2
commit ee1e636804

View File

@@ -221,7 +221,7 @@ impl TcpRelayLocal {
}
}
info!("{} local -> remote is going to be closed", addr_cloned);
info!("LOCAL {} local -> remote is closing", addr_cloned);
let _ = encrypt_stream.get_ref().shutdown(Shutdown::Both);
let _ = local_reader.get_ref().shutdown(Shutdown::Both);
@@ -283,7 +283,7 @@ impl TcpRelayLocal {
let _ = local_writer.flush();
info!("{} remote -> local is going to be closed", addr);
info!("LOCAL {} remote -> local is closing", addr);
let _ = decrypt_stream.get_mut().shutdown(Shutdown::Both);
let _ = local_writer.shutdown(Shutdown::Both);