From 064d52eae2f67dfb2d41efc0a69e411d17634a41 Mon Sep 17 00:00:00 2001
From: lwch <lwch748@gmail.com>
Date: Fri, 27 Aug 2021 12:23:45 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4=E4=B8=80=E5=A4=84=E8=B6=85?=
 =?UTF-8?q?=E6=97=B6=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 code/client/pool/conn.go   | 10 +---------
 code/client/tunnel/link.go |  2 +-
 2 files changed, 2 insertions(+), 10 deletions(-)

diff --git a/code/client/pool/conn.go b/code/client/pool/conn.go
index 6184526..cf1c82d 100644
--- a/code/client/pool/conn.go
+++ b/code/client/pool/conn.go
@@ -114,15 +114,7 @@ func (conn *Conn) loopRead(cancel context.CancelFunc) {
 		if ch == nil {
 			ch = conn.unknownRead
 		}
-		select {
-		case ch <- msg:
-		case <-time.After(conn.parent.cfg.ReadTimeout):
-			logging.Error("write read channel for link %s timeouted", linkID)
-			if ch == conn.unknownRead {
-				continue
-			}
-			close(ch)
-		}
+		ch <- msg
 	}
 }
 
diff --git a/code/client/tunnel/link.go b/code/client/tunnel/link.go
index 82305fd..5d9d062 100644
--- a/code/client/tunnel/link.go
+++ b/code/client/tunnel/link.go
@@ -89,7 +89,7 @@ func (link *Link) localRead() {
 			if !link.closeFromRemote {
 				link.remote.SendDisconnect(link.target, link.targetIdx, link.id)
 			}
-			// logging.Error("read data on tunnel %s link %s failed, err=%v", link.parent.Name, link.id, err)
+			logging.Error("read data on tunnel %s link %s failed, err=%v", link.parent.Name, link.id, err)
 			return
 		}
 		if n == 0 {