diff --git a/internal/nodes/client_conn.go b/internal/nodes/client_conn.go index 7b32053..e8be4c3 100644 --- a/internal/nodes/client_conn.go +++ b/internal/nodes/client_conn.go @@ -222,7 +222,11 @@ func (this *ClientConn) SetReadDeadline(t time.Time) error { return nil } this.readDeadlineTime = unixTime - if -time.Since(t) < HTTPIdleTimeout-1*time.Second { + var seconds = -time.Since(t) + if seconds <= 0 || seconds > HTTPIdleTimeout { + return nil + } + if seconds < HTTPIdleTimeout-1*time.Second { this.isShortReading = true } } diff --git a/internal/nodes/node.go b/internal/nodes/node.go index cd24fd4..857f5c1 100644 --- a/internal/nodes/node.go +++ b/internal/nodes/node.go @@ -898,9 +898,9 @@ func (this *Node) listenSock() error { lastErrString = lastErr.Error() } } - var age int64 - var lastReadAge int64 - var lastWriteAge int64 + var age int64 = -1 + var lastReadAge int64 = -1 + var lastWriteAge int64 = -1 var currentTime = time.Now().Unix() if createdAt > 0 { age = currentTime - createdAt