1
0
mirror of https://github.com/golang/go synced 2024-11-26 04:17:59 -07:00

runtime: don't clear timerModifiedEarliest if adjustTimers is 0

This avoids a race when a new timerModifiedEarlier timer is created by
a different goroutine.

Fixes #47329

Change-Id: I6f6c87b4a9b5491b201c725c10bc98e23e0ed9d1
Reviewed-on: https://go-review.googlesource.com/c/go/+/336432
Trust: Ian Lance Taylor <iant@golang.org>
Run-TryBot: Ian Lance Taylor <iant@golang.org>
TryBot-Result: Go Bot <gobot@golang.org>
Reviewed-by: Michael Knyszek <mknyszek@google.com>
This commit is contained in:
Ian Lance Taylor 2021-07-21 19:57:56 -07:00
parent fdb45acd1f
commit 798ec73519
3 changed files with 35 additions and 6 deletions

View File

@ -681,7 +681,7 @@ type p struct {
// timerModifiedEarlier status. Because the timer may have been // timerModifiedEarlier status. Because the timer may have been
// modified again, there need not be any timer with this value. // modified again, there need not be any timer with this value.
// This is updated using atomic functions. // This is updated using atomic functions.
// This is 0 if the value is unknown. // This is 0 if there are no timerModifiedEarlier timers.
timerModifiedEarliest uint64 timerModifiedEarliest uint64
// Per-P GC state // Per-P GC state

View File

@ -668,11 +668,6 @@ func adjusttimers(pp *p, now int64) {
if verifyTimers { if verifyTimers {
verifyTimerHeap(pp) verifyTimerHeap(pp)
} }
// There are no timers to adjust, so it is safe to clear
// timerModifiedEarliest. Do so in case it is stale.
// Everything will work if we don't do this,
// but clearing here may save future calls to adjusttimers.
atomic.Store64(&pp.timerModifiedEarliest, 0)
return return
} }

View File

@ -527,6 +527,40 @@ func TestZeroTimer(t *testing.T) {
} }
} }
// Test that rapidly moving a timer earlier doesn't cause it to get dropped.
// Issue 47329.
func TestTimerModifiedEarlier(t *testing.T) {
past := Until(Unix(0, 0))
count := 1000
fail := 0
for i := 0; i < count; i++ {
timer := NewTimer(Hour)
for j := 0; j < 10; j++ {
if !timer.Stop() {
<-timer.C
}
timer.Reset(past)
}
deadline := NewTimer(10 * Second)
defer deadline.Stop()
now := Now()
select {
case <-timer.C:
if since := Since(now); since > 8*Second {
t.Errorf("timer took too long (%v)", since)
fail++
}
case <-deadline.C:
t.Error("deadline expired")
}
}
if fail > 0 {
t.Errorf("%d failures", fail)
}
}
// Benchmark timer latency when the thread that creates the timer is busy with // Benchmark timer latency when the thread that creates the timer is busy with
// other work and the timers must be serviced by other threads. // other work and the timers must be serviced by other threads.
// https://golang.org/issue/38860 // https://golang.org/issue/38860