rtyler
/
libnetwork
1
0
Fork 0
Code Issues 1 Pull Requests Releases Wiki Activity

proxy: clean up code (addendum to #1598) 

Signed-off-by: Akihiro Suda <suda.akihiro@lab.ntt.co.jp>
This commit is contained in:
Akihiro Suda 2017-01-12 04:46:23 +00:00
parent e8431956af
commit 252567a063
1 changed files with 1 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cmd/proxy/tcp_proxy.go
View File

@ -5,7 +5,6 @@ import (
"log"
"net"
"sync"
"syscall"
)
// TCPProxy is a proxy for TCP connections. It implements the Proxy interface to
@ -41,13 +40,7 @@ func (proxy *TCPProxy) clientLoop(client *net.TCPConn, quit chan bool) {
var wg sync.WaitGroup
var broker = func(to, from *net.TCPConn) {
if _, err := io.Copy(to, from); 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()
}
}
io.Copy(to, from)
from.CloseRead()
to.CloseWrite()
wg.Done()