github/linuxkit
1
0
Fork 0
mirror of https://github.com/linuxkit/linuxkit.git synced 2025-07-24 11:25:40 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #196 from rneugeba/win-proxy-fix

Browse Source 
proxy: fix handling of CloseRead/CloseWrite for TCP port proxy
This commit is contained in:
Justin Cormack 2016-06-13 14:22:30 +01:00 committed by GitHub
commit 51b049c836
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
alpine/packages/proxy/libproxy/tcp_proxy.go
View File

@ -3,7 +3,6 @@ package libproxy
import (
"io"
"net"
"syscall"
"github.com/Sirupsen/logrus"
)
@ -47,13 +46,16 @@ func HandleTCPConnection(client Conn, backendAddr *net.TCPAddr, quit chan bool)
var broker = func(to, from Conn) {
written, err := io.Copy(to, from)
if err != nil {
// If the socket we are writing to is shutdown with
// SHUT_WR, forward it to the other end of the pipe:
if err, ok := err.(*net.OpError); ok && err.Err == syscall.EPIPE {
from.CloseWrite()
}
logrus.Println("error copying:", err)
}
err = from.CloseRead()
if err != nil {
logrus.Println("error CloseRead from:", err)
}
err = to.CloseWrite()
if err != nil {
logrus.Println("error CloseWrite to:", err)
}
to.CloseRead()
event <- written
}