mirror of
https://github.com/lwch/natpass.git
synced 2026-10-21 07:26:15 +00:00
去除一处超时逻辑
This commit is contained in:
@@ -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
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -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 {
|
||||
|
||||
Reference in New Issue
Block a user