|
@@ -246,7 +246,7 @@ func (m *ConnectionManager) connectionCopy(ctx context.Context, source net.Conn,
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
- _, err := bufio.CopyWithCounters(destination, sourceReader, source, readCounters, writeCounters)
|
|
|
+ _, err := bufio.CopyWithCounters(destinationWriter, sourceReader, source, readCounters, writeCounters)
|
|
|
if err != nil {
|
|
|
common.Close(source, destination)
|
|
|
} else if duplexDst, isDuplex := destination.(N.WriteCloser); isDuplex {
|