diff --git a/pkg/core/tunhandlerclient.go b/pkg/core/tunhandlerclient.go
index b5df7154..eccd4e11 100644
--- a/pkg/core/tunhandlerclient.go
+++ b/pkg/core/tunhandlerclient.go
@@ -4,7 +4,6 @@ import (
 	"context"
 	"fmt"
 	"net"
-	"time"
 
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"
@@ -39,13 +38,12 @@ func (h *tunHandler) HandleClient(ctx context.Context, tun net.Conn) {
 		for ctx.Err() == nil {
 			packetConn, err := getRemotePacketConn(ctx, h.chain)
 			if err != nil {
-				log.Errorf("[TUN-CLIENT] Failed to get remote conn from %s -> %s: %s", tun.LocalAddr(), remoteAddr, err)
-				time.Sleep(time.Second * 2)
+				log.Debugf("[TUN-CLIENT] Failed to get remote conn from %s -> %s: %s", tun.LocalAddr(), remoteAddr, err)
 				continue
 			}
 			err = transportTunClient(ctx, tunInbound, tunOutbound, packetConn, remoteAddr)
 			if err != nil {
-				log.Errorf("[TUN-CLIENT] %s: %v", tun.LocalAddr(), err)
+				log.Debugf("[TUN-CLIENT] %s: %v", tun.LocalAddr(), err)
 			}
 		}
 	})
diff --git a/pkg/ssh/ssh.go b/pkg/ssh/ssh.go
index 0a3ebe15..d132fe6e 100644
--- a/pkg/ssh/ssh.go
+++ b/pkg/ssh/ssh.go
@@ -247,7 +247,7 @@ func copyStream(ctx context.Context, local net.Conn, remote net.Conn) {
 		defer config.LPool.Put(buf[:])
 		_, err := io.CopyBuffer(local, remote, buf)
 		if err != nil && !errors.Is(err, net.ErrClosed) && !errors.Is(err, io.EOF) {
-			log.Errorf("Failed to copy remote -> local: %s", err)
+			log.Debugf("Failed to copy remote -> local: %s", err)
 		}
 		select {
 		case chDone <- true:
@@ -261,7 +261,7 @@ func copyStream(ctx context.Context, local net.Conn, remote net.Conn) {
 		defer config.LPool.Put(buf[:])
 		_, err := io.CopyBuffer(remote, local, buf)
 		if err != nil && !errors.Is(err, net.ErrClosed) && !errors.Is(err, io.EOF) {
-			log.Errorf("Failed to copy local -> remote: %s", err)
+			log.Debugf("Failed to copy local -> remote: %s", err)
 		}
 		select {
 		case chDone <- true:
@@ -513,39 +513,11 @@ func PortMapUntil(ctx context.Context, conf *SshConfig, remote, local netip.Addr
 		return err
 	}
 
-	var lock sync.Mutex
-	var sshClient *ssh.Client
-
-	var getRemoteConnFunc = func() (net.Conn, error) {
-		lock.Lock()
-		defer lock.Unlock()
-
-		if sshClient != nil {
-			ctx1, cancelFunc := context.WithTimeout(ctx, time.Second*10)
-			defer cancelFunc()
-			remoteConn, err := sshClient.DialContext(ctx1, "tcp", remote.String())
-			if err == nil {
-				return remoteConn, nil
-			}
-			sshClient.Close()
-			sshClient = nil
-		}
-		sshClient, err = DialSshRemote(ctx, conf)
-		if err != nil {
-			log.Errorf("failed to dial remote ssh server: %v", err)
-			return nil, err
-		}
-		return sshClient.Dial("tcp", remote.String())
-	}
-
 	go func() {
 		defer localListen.Close()
 		go func() {
 			<-ctx.Done()
 			localListen.Close()
-			if sshClient != nil {
-				sshClient.Close()
-			}
 		}()
 
 		for ctx.Err() == nil {
@@ -559,9 +531,16 @@ func PortMapUntil(ctx context.Context, conf *SshConfig, remote, local netip.Addr
 			go func() {
 				defer localConn.Close()
 
-				remoteConn, err := getRemoteConnFunc()
+				sshClient, err := DialSshRemote(ctx, conf)
 				if err != nil {
-					log.Errorf("Failed to dial %s: %s", remote.String(), err)
+					marshal, _ := json.Marshal(conf)
+					log.Debugf("Failed to dial remote ssh server %v : %v", string(marshal), err)
+					return
+				}
+				defer sshClient.Close()
+				remoteConn, err := sshClient.DialContext(ctx, "tcp", remote.String())
+				if err != nil {
+					log.Debugf("Failed to dial %s: %s", remote.String(), err)
 					return
 				}
 				defer remoteConn.Close()