Merge pull request #197 from NodeFactoryIo/hotfix/tunnel-fix

Tunnel connections not closing fix

Author: mpetrunic

CHANGELOG.md

@@ -1,7 +1,17 @@
 # Changelog
 
-## [v0.5.3]((https://github.com/NodeFactoryIo/vedran/tree/HEAD))
-[Full Changelog](https://github.com/NodeFactoryIo/vedran/compare/v0.5.2...HEAD)
+## [unreleased]((https://github.com/NodeFactoryIo/vedran/tree/HEAD))
+[Full Changelog](https://github.com/NodeFactoryIo/vedran/compare/v0.5.3...HEAD)
+
+### Added
+
+### Fix
+- Fix tunnel tcp connections not closing after requests finish [\#197](https://github.com/NodeFactoryIo/vedran/pull/197) ([mpetrun5](https://github.com/mpetrun5))
+
+### Changed
+
+## [v0.5.3]((https://github.com/NodeFactoryIo/vedran/tree/v0.5.3))
+[Full Changelog](https://github.com/NodeFactoryIo/vedran/compare/v0.5.2...v0.5.3)
 
 ### Added
 

pkg/http-tunnel/server/tcpproxy.go

@@ -6,11 +6,12 @@ package server
 
 import (
 	"fmt"
-	"github.com/NodeFactoryIo/vedran/pkg/http-tunnel"
-	"github.com/NodeFactoryIo/vedran/pkg/http-tunnel/proto"
-	log "github.com/sirupsen/logrus"
 	"io"
 	"net"
+
+	tunnel "github.com/NodeFactoryIo/vedran/pkg/http-tunnel"
+	"github.com/NodeFactoryIo/vedran/pkg/http-tunnel/proto"
+	log "github.com/sirupsen/logrus"
 )
 
 // TCPProxy forwards TCP streams.
@@ -80,22 +81,19 @@ func (p *TCPProxy) Proxy(w io.Writer, r io.ReadCloser, msg *proto.ControlMessage
 		}).Error("dial failed", err)
 		return
 	}
-	defer local.Close()
 
 	if err := tunnel.KeepAlive(local); err != nil {
 		clogger.WithFields(log.Fields{
 			"target": target,
 		}).Error("TCP keepalive for tunneled connection failed", err)
 	}
 
-	done := make(chan struct{})
 	go func() {
 		loggerWithContext := log.WithContext(p.logger.Context).WithFields(log.Fields{
 			"dst": msg.ForwardedHost,
 			"src": target,
 		})
 		transfer(flushWriter{w}, local, loggerWithContext)
-		close(done)
 	}()
 
 	loggerWithContext := log.WithContext(p.logger.Context).WithFields(log.Fields{
@@ -104,7 +102,10 @@ func (p *TCPProxy) Proxy(w io.Writer, r io.ReadCloser, msg *proto.ControlMessage
 	})
 	transfer(local, r, loggerWithContext)
 
-	<-done
+	err = local.Close()
+	if err != nil {
+		clogger.Errorf("Transfer close failed because of %v", err)
+	}
 }
 
 func (p *TCPProxy) localAddrFor(hostPort string) string {

pkg/http-tunnel/server/utils.go

@@ -5,22 +5,16 @@
 package server
 
 import (
-	log "github.com/sirupsen/logrus"
 	"io"
 	"net"
 	"net/http"
 	"strings"
+
+	log "github.com/sirupsen/logrus"
 )
 
 func transfer(dst io.Writer, src io.Reader, logger *log.Entry) {
-	n, err := io.Copy(dst, src)
-	if err != nil {
-		if (!strings.Contains(err.Error(), "context canceled") &&
-			!strings.Contains(err.Error(), "CANCEL")) &&
-			!strings.Contains(err.Error(), "stream closed") {
-			logger.Error("copy error ", err)
-		}
-	}
+	n, _ := io.Copy(dst, src)
 	log.Debugf("transferred %d bytes", n)
 }