- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for readDeadline (0.09 sec)
-
internal/deadlineconn/deadlineconn.go
// Do not set a Read deadline, if upstream wants to cancel all reads. if c.readDeadline <= 0 || c.abortReads.Load() || c.infReads.Load() { return } c.mu.Lock() defer c.mu.Unlock() if c.abortReads.Load() { return } now := time.Now() if now.Sub(c.readSetAt) > updateInterval { c.Conn.SetReadDeadline(now.Add(c.readDeadline + updateInterval)) c.readSetAt = now } }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Dec 02 13:21:17 UTC 2024 - 5.1K bytes - Viewed (0)