|
@ -55,6 +55,7 @@ func (h *tcpHandler) relay(localConn, remoteConn net.Conn) { |
|
|
closeOnce() |
|
|
closeOnce() |
|
|
} else { |
|
|
} else { |
|
|
localConn.SetDeadline(time.Now()) |
|
|
localConn.SetDeadline(time.Now()) |
|
|
|
|
|
remoteConn.SetDeadline(time.Now()) |
|
|
tcpCloseRead(remoteConn) |
|
|
tcpCloseRead(remoteConn) |
|
|
} |
|
|
} |
|
|
wg.Done() |
|
|
wg.Done() |
|
@ -65,6 +66,7 @@ func (h *tcpHandler) relay(localConn, remoteConn net.Conn) { |
|
|
closeOnce() |
|
|
closeOnce() |
|
|
} else { |
|
|
} else { |
|
|
localConn.SetDeadline(time.Now()) |
|
|
localConn.SetDeadline(time.Now()) |
|
|
|
|
|
remoteConn.SetDeadline(time.Now()) |
|
|
tcpCloseRead(localConn) |
|
|
tcpCloseRead(localConn) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|