Function Run

tunnel/tunnel.go:86–117

(zitiConn edge.Conn, clientConn net.Conn, halfClose bool)

}

func Run(zitiConn edge.Conn, clientConn net.Conn, halfClose bool) {
	loggerFields := logrus.Fields{
		"src-remote": clientConn.RemoteAddr().String(), "src-local": clientConn.LocalAddr().String(),
		"dst-local": zitiConn.LocalAddr().String(), "dst-remote": zitiConn.RemoteAddr().String(),
		"circuitId": zitiConn.GetCircuitId()}

	log := pfxlog.Logger().WithFields(loggerFields)
	log.Info("tunnel started")

	doneSend := make(chan int64)
	doneRecv := make(chan int64)

	go myCopy(clientConn, zitiConn, doneSend, halfClose, zitiConn.GetCircuitId())

	go myCopy(zitiConn, clientConn, doneRecv, halfClose, zitiConn.GetRouterId())

	defer func() {
		_ = clientConn.Close()
		_ = zitiConn.Close()
	}()

	var n1, n2 int64
	for count := 2; count > 0; {
		select {
		case n1 = <-doneSend:
		case n2 = <-doneRecv:
		}
		count = count - 1
	}

	log.Infof("tunnel closed: %d bytes sent; %d bytes received", n2, n1)
}

func myCopy(dst net.Conn, src net.Conn, done chan int64, halfClose bool, circuitId string) {
	loggerFields := logrus.Fields{