]> Cypherpunks.ru repositories - gostls13.git/commitdiff
runtime: fix pprof cpu profile corruption on arm/mips/mipsle
authorRuss Cox <rsc@golang.org>
Fri, 28 Jun 2019 05:42:08 +0000 (01:42 -0400)
committerRuss Cox <rsc@golang.org>
Fri, 28 Jun 2019 20:09:48 +0000 (20:09 +0000)
CL 42652 changed the profile handler for mips/mipsle to
avoid recording a profile when in atomic functions, for fear
of interrupting the 32-bit simulation of a 64-bit atomic with
a lock. The profile logger itself uses 64-bit atomics and might
deadlock (#20146).

The change was to accumulate a count of dropped profile events
and then send the count when the next ordinary event was sent:

if prof.hz != 0 {
+ if (GOARCH == "mips" || GOARCH == "mipsle") && lostAtomic64Count > 0 {
+ cpuprof.addLostAtomic64(lostAtomic64Count)
+ lostAtomic64Count = 0
+ }
  cpuprof.add(gp, stk[:n])
  }

CL 117057 extended this behavior to include GOARCH == "arm".

Unfortunately, the inserted cpuprof.addLostAtomic64 differs from
the original cpuprof.add in that it neglects to acquire the lock
protecting the profile buffer.

This has caused a steady stream of flakes on the arm builders
for the past 12 months, ever since CL 117057 landed.

This CL moves the lostAtomic count into the profile buffer and
then lets the existing addExtra calls take care of it, instead of
duplicating the locking logic.

Fixes #24991.

Change-Id: Ia386c40034fcf46b31f080ce18f2420df4bb8004
Reviewed-on: https://go-review.googlesource.com/c/go/+/184164
Run-TryBot: Russ Cox <rsc@golang.org>
TryBot-Result: Gobot Gobot <gobot@golang.org>
Reviewed-by: Cherry Zhang <cherryyz@google.com>
src/runtime/cpuprof.go
src/runtime/proc.go

index 81038f5c48cf55074583b4b52a7adf6c123cd133..9bfdfe7c7461a76fef305bd79c63ef71f5c56b62 100644 (file)
@@ -36,9 +36,10 @@ type cpuProfile struct {
        // 300 words per second.
        // Hopefully a normal Go thread will get the profiling
        // signal at least once every few seconds.
-       extra     [1000]uintptr
-       numExtra  int
-       lostExtra uint64 // count of frames lost because extra is full
+       extra      [1000]uintptr
+       numExtra   int
+       lostExtra  uint64 // count of frames lost because extra is full
+       lostAtomic uint64 // count of frames lost because of being in atomic64 on mips/arm; updated racily
 }
 
 var cpuprof cpuProfile
@@ -94,7 +95,7 @@ func (p *cpuProfile) add(gp *g, stk []uintptr) {
        }
 
        if prof.hz != 0 { // implies cpuprof.log != nil
-               if p.numExtra > 0 || p.lostExtra > 0 {
+               if p.numExtra > 0 || p.lostExtra > 0 || p.lostAtomic > 0 {
                        p.addExtra()
                }
                hdr := [1]uint64{1}
@@ -159,18 +160,20 @@ func (p *cpuProfile) addExtra() {
                        funcPC(_LostExternalCode) + sys.PCQuantum,
                        funcPC(_ExternalCode) + sys.PCQuantum,
                }
-               cpuprof.log.write(nil, 0, hdr[:], lostStk[:])
+               p.log.write(nil, 0, hdr[:], lostStk[:])
                p.lostExtra = 0
        }
-}
 
-func (p *cpuProfile) addLostAtomic64(count uint64) {
-       hdr := [1]uint64{count}
-       lostStk := [2]uintptr{
-               funcPC(_LostSIGPROFDuringAtomic64) + sys.PCQuantum,
-               funcPC(_System) + sys.PCQuantum,
+       if p.lostAtomic > 0 {
+               hdr := [1]uint64{p.lostAtomic}
+               lostStk := [2]uintptr{
+                       funcPC(_LostSIGPROFDuringAtomic64) + sys.PCQuantum,
+                       funcPC(_System) + sys.PCQuantum,
+               }
+               p.log.write(nil, 0, hdr[:], lostStk[:])
+               p.lostAtomic = 0
        }
-       cpuprof.log.write(nil, 0, hdr[:], lostStk[:])
+
 }
 
 // CPUProfile panics.
index b5cf9d442d62b337048e24b64d5ee18a0217da83..93d329d15e7a9c7cc5c98514a60aba178216d121 100644 (file)
@@ -3634,9 +3634,6 @@ func _GC()                        { _GC() }
 func _LostSIGPROFDuringAtomic64() { _LostSIGPROFDuringAtomic64() }
 func _VDSO()                      { _VDSO() }
 
-// Counts SIGPROFs received while in atomic64 critical section, on mips{,le}
-var lostAtomic64Count uint64
-
 // Called if we receive a SIGPROF signal.
 // Called by the signal handler, may run during STW.
 //go:nowritebarrierrec
@@ -3654,7 +3651,7 @@ func sigprof(pc, sp, lr uintptr, gp *g, mp *m) {
        if GOARCH == "mips" || GOARCH == "mipsle" || GOARCH == "arm" {
                if f := findfunc(pc); f.valid() {
                        if hasPrefix(funcname(f), "runtime/internal/atomic") {
-                               lostAtomic64Count++
+                               cpuprof.lostAtomic++
                                return
                        }
                }
@@ -3794,10 +3791,6 @@ func sigprof(pc, sp, lr uintptr, gp *g, mp *m) {
        }
 
        if prof.hz != 0 {
-               if (GOARCH == "mips" || GOARCH == "mipsle" || GOARCH == "arm") && lostAtomic64Count > 0 {
-                       cpuprof.addLostAtomic64(lostAtomic64Count)
-                       lostAtomic64Count = 0
-               }
                cpuprof.add(gp, stk[:n])
        }
        getg().m.mallocing--