mirror of
https://github.com/wweir/sower.git
synced 2024-04-21 12:42:15 +00:00
39 lines
726 B
Go
39 lines
726 B
Go
package proxy
|
|
|
|
import (
|
|
"io"
|
|
"net"
|
|
"sync"
|
|
"sync/atomic"
|
|
"time"
|
|
|
|
"github.com/golang/glog"
|
|
)
|
|
|
|
func relay(conn1, conn2 net.Conn) {
|
|
wg := &sync.WaitGroup{}
|
|
exitFlag := new(int32)
|
|
wg.Add(2)
|
|
go redirect(conn2, conn1, wg, exitFlag)
|
|
redirect(conn1, conn2, wg, exitFlag)
|
|
wg.Wait()
|
|
}
|
|
|
|
func redirect(dst, src net.Conn, wg *sync.WaitGroup, exitFlag *int32) {
|
|
if _, err := io.Copy(dst, src); err != nil {
|
|
glog.V(1).Infof("%s<>%s -> %s<>%s: %s", src.RemoteAddr(), src.LocalAddr(), dst.LocalAddr(), dst.RemoteAddr(), err)
|
|
}
|
|
|
|
if atomic.CompareAndSwapInt32(exitFlag, 0, 1) {
|
|
// wakeup blocked goroutine
|
|
now := time.Now()
|
|
src.SetDeadline(now)
|
|
dst.SetDeadline(now)
|
|
} else {
|
|
src.Close()
|
|
dst.Close()
|
|
}
|
|
|
|
wg.Done()
|
|
}
|