- Sort Score
- Num 10 results
- Language All
Results 1 - 1 of 1 for readDeadline (0.04 seconds)
-
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 } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Dec 02 13:21:17 GMT 2024 - 5.1K bytes - Click Count (0)