Remove redundant error checking

This commit is contained in:
Qian Wang 2019-01-12 17:06:14 +00:00
parent 95c3dbfcf2
commit 9e454babe1
2 changed files with 4 additions and 4 deletions

View File

@ -28,13 +28,13 @@ func pipe(dst io.ReadWriteCloser, src io.ReadWriteCloser) {
buf := make([]byte, 16396)
for {
i, err := io.ReadAtLeast(src, buf, 1)
if err != nil || i == 0 {
if err != nil {
go dst.Close()
go src.Close()
return
}
i, err = dst.Write(buf[:i])
if err != nil || i == 0 {
if err != nil {
go dst.Close()
go src.Close()
return

View File

@ -29,13 +29,13 @@ func pipe(dst io.ReadWriteCloser, src io.ReadWriteCloser) {
buf := make([]byte, 16396)
for {
i, err := io.ReadAtLeast(src, buf, 1)
if err != nil || i == 0 {
if err != nil {
go dst.Close()
go src.Close()
return
}
i, err = dst.Write(buf[:i])
if err != nil || i == 0 {
if err != nil {
go dst.Close()
go src.Close()
return