This commit is contained in:
Y. T. Chung
2015-07-09 20:25:27 +08:00
parent 7b4d662fa3
commit b810441ff5

View File

@@ -167,15 +167,10 @@ impl TcpRelayLocal {
let header = socks5::TcpResponseHeader::new(socks5::Reply::Succeeded,
socks5::Address::SocketAddress(sockname));
trace!("Send header to client {:?}", header);
if let Err(err) = header.write_to(&mut local_writer) {
if let Err(err) = header.write_to(&mut local_writer).and(local_writer.flush()) {
error!("Error occurs while writing header to local stream: {:?}", err);
return;
}
if let Err(err) = local_writer.flush() {
error!("Error occurs while flushing local writer: {:?}", err);
return;
}
}
// Send initialize vector to remote and create encryptor