Skip to content

Commit c4ffb55

Browse files
authored
Linearly increase timeout
1 parent 8fe1eb0 commit c4ffb55

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

modules/graceful/server.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -259,12 +259,8 @@ type wrappedConn struct {
259259

260260
func (w wrappedConn) Write(p []byte) (n int, err error) {
261261
if PerWriteWriteTimeout > 0 {
262-
minTimeout := PerWriteWriteTimeout + time.Duration(len(p)/1024)*PerWriteWriteTimeoutKbRate
263-
minDeadline := time.Now().Add(minTimeout)
264-
265-
if minTimeout < PerWriteWriteTimeout {
266-
minDeadline = time.Now().Add(PerWriteWriteTimeout)
267-
}
262+
minTimeout := time.Duration(len(p)/1024)*PerWriteWriteTimeoutKbRate
263+
minDeadline := time.Now().Add(minTimeout).Add(PerWriteWriteTimeout)
268264

269265
w.deadline = w.deadline.Add(minTimeout)
270266
if minDeadline.After(w.deadline) {

0 commit comments

Comments
 (0)