gopkg/pgx
2
0
Fork 0
Code Activity

Only set c.fakeNonblockingReadWaitDuration when it will be decreased

Browse Source
This commit is contained in:
Jack Christensen
2023-01-31 20:24:44 -06:00
parent cf78472ce5
commit f46d35610e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/nbconn/nbconn.go
+3 -3
View File
@@ -432,10 +432,10 @@ func (c *NetConn) fakeNonblockingRead(b []byte) (n int, err error) {
// a Read deadline will not block a read before it has a chance to read data already in Go or the OS's receive // a Read deadline will not block a read before it has a chance to read data already in Go or the OS's receive
// buffer. // buffer.
proposedWait := endTime.Sub(startTime) * 2 proposedWait := endTime.Sub(startTime) * 2
if proposedWait < minNonblockingReadWaitDuration {
proposedWait = minNonblockingReadWaitDuration
}
if proposedWait < c.fakeNonblockingReadWaitDuration { if proposedWait < c.fakeNonblockingReadWaitDuration {
if proposedWait < minNonblockingReadWaitDuration {
proposedWait = minNonblockingReadWaitDuration
}
c.fakeNonblockingReadWaitDuration = proposedWait c.fakeNonblockingReadWaitDuration = proposedWait
} }
} }