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 {