]> Cypherpunks repositories - gostls13.git/commitdiff
Revert "runtime: drop stack-allocated pcvalueCaches"
authorAustin Clements <austin@google.com>
Mon, 7 Aug 2023 22:11:17 +0000 (18:11 -0400)
committerGopher Robot <gobot@golang.org>
Mon, 7 Aug 2023 22:27:50 +0000 (22:27 +0000)
This reverts CL 515277

Change-Id: Ie10378eed4993cb69f4a9b43a38af32b9d743155
Reviewed-on: https://go-review.googlesource.com/c/go/+/516855
Run-TryBot: Austin Clements <austin@google.com>
Reviewed-by: Matthew Dempsky <mdempsky@google.com>
TryBot-Result: Gopher Robot <gobot@golang.org>
Auto-Submit: Austin Clements <austin@google.com>
Reviewed-by: Michael Knyszek <mknyszek@google.com>
14 files changed:
src/runtime/debugcall.go
src/runtime/heapdump.go
src/runtime/mbitmap.go
src/runtime/mgcmark.go
src/runtime/mgcstack.go
src/runtime/preempt.go
src/runtime/race.go
src/runtime/stack.go
src/runtime/stkframe.go
src/runtime/symtab.go
src/runtime/symtabinl.go
src/runtime/symtabinl_test.go
src/runtime/trace.go
src/runtime/traceback.go

index f8b3494ec3053ff7cef33e751523a1d1e2a58679..ea413bd0c5644a980d34e70bbf34821648e8b547 100644 (file)
@@ -83,7 +83,7 @@ func debugCallCheck(pc uintptr) string {
                if pc != f.entry() {
                        pc--
                }
-               up := pcdatavalue(f, abi.PCDATA_UnsafePoint, pc)
+               up := pcdatavalue(f, abi.PCDATA_UnsafePoint, pc, nil)
                if up != abi.UnsafePointSafe {
                        // Not at a safe point.
                        ret = debugCallUnsafePoint
index 430e4bccb5e89d6d853c07da81c04f45b3498044..8ddec8b2d5d9193297247c8f558fe191e09d0877 100644 (file)
@@ -259,7 +259,7 @@ func dumpframe(s *stkframe, child *childInfo) {
        pcdata := int32(-1) // Use the entry map at function entry
        if pc != f.entry() {
                pc--
-               pcdata = pcdatavalue(f, abi.PCDATA_StackMapIndex, pc)
+               pcdata = pcdatavalue(f, abi.PCDATA_StackMapIndex, pc, nil)
        }
        if pcdata == -1 {
                // We do not have a valid pcdata value but there might be a
index 4ba25901d43077bdb0557d645e9e81801eeaa8d4..a24287288472282d388274b3ba110cb31c380e4b 100644 (file)
@@ -1479,7 +1479,7 @@ func getgcmask(ep any) (mask []byte) {
                        }
                }
                if found {
-                       locals, _, _ := u.frame.getStackMap(false)
+                       locals, _, _ := u.frame.getStackMap(nil, false)
                        if locals.n == 0 {
                                return
                        }
index 2b4e23823b96edb2fed4bdd07797233778613f72..c49eba030225d3b0e1bfb2243195a1ea85fe7b44 100644 (file)
@@ -964,7 +964,7 @@ func scanframeworker(frame *stkframe, state *stackScanState, gcw *gcWork) {
                return
        }
 
-       locals, args, objs := frame.getStackMap(false)
+       locals, args, objs := frame.getStackMap(&state.cache, false)
 
        // Scan local variables if stack frame has been allocated.
        if locals.n > 0 {
index f4a83f5f59c27ab350895faec0980687444e7880..6b552203ee42437691cc207bedf8777b0c65dbb1 100644 (file)
@@ -166,6 +166,8 @@ func (obj *stackObject) setRecord(r *stackObjectRecord) {
 // A stackScanState keeps track of the state used during the GC walk
 // of a goroutine.
 type stackScanState struct {
+       cache pcvalueCache
+
        // stack limits
        stack stack
 
index 82d85cd707619a5e140c018ad005f7e9e2c5779f..76d8ba4cdf49e0daf74dd9a8df24f733e319e2bc 100644 (file)
@@ -385,7 +385,7 @@ func isAsyncSafePoint(gp *g, pc, sp, lr uintptr) (bool, uintptr) {
                // Not Go code.
                return false, 0
        }
-       if (GOARCH == "mips" || GOARCH == "mipsle" || GOARCH == "mips64" || GOARCH == "mips64le") && lr == pc+8 && funcspdelta(f, pc) == 0 {
+       if (GOARCH == "mips" || GOARCH == "mipsle" || GOARCH == "mips64" || GOARCH == "mips64le") && lr == pc+8 && funcspdelta(f, pc, nil) == 0 {
                // We probably stopped at a half-executed CALL instruction,
                // where the LR is updated but the PC has not. If we preempt
                // here we'll see a seemingly self-recursive call, which is in
@@ -414,7 +414,7 @@ func isAsyncSafePoint(gp *g, pc, sp, lr uintptr) (bool, uintptr) {
                return false, 0
        }
        // Check the inner-most name
-       u, uf := newInlineUnwinder(f, pc)
+       u, uf := newInlineUnwinder(f, pc, nil)
        name := u.srcFunc(uf).name()
        if hasPrefix(name, "runtime.") ||
                hasPrefix(name, "runtime/internal/") ||
index 496e3725bf9712f41d2760de461433cb5ea883cd..e2767f0324e7b2f0985d506312d82242adb4b441 100644 (file)
@@ -172,7 +172,7 @@ func raceSymbolizeCode(ctx *symbolizeCodeContext) {
        pc := ctx.pc
        fi := findfunc(pc)
        if fi.valid() {
-               u, uf := newInlineUnwinder(fi, pc)
+               u, uf := newInlineUnwinder(fi, pc, nil)
                for ; uf.valid(); uf = u.next(uf) {
                        sf := u.srcFunc(uf)
                        if sf.funcID == abi.FuncIDWrapper && u.isInlined(uf) {
index 61cd0a0fddd6dbebd45b60743c839537fd4ec2ac..903b096f08279311c1fcf5b6ad1f467a6db33408 100644 (file)
@@ -555,6 +555,7 @@ var ptrnames = []string{
 type adjustinfo struct {
        old   stack
        delta uintptr // ptr distance from old to new stack (newbase - oldbase)
+       cache pcvalueCache
 
        // sghi is the highest sudog.elem on the stack.
        sghi uintptr
@@ -675,7 +676,7 @@ func adjustframe(frame *stkframe, adjinfo *adjustinfo) {
                adjustpointer(adjinfo, unsafe.Pointer(frame.varp))
        }
 
-       locals, args, objs := frame.getStackMap(true)
+       locals, args, objs := frame.getStackMap(&adjinfo.cache, true)
 
        // Adjust local variables if stack frame has been allocated.
        if locals.n > 0 {
index bfd9eac2b0e2e8e3c85676d990fe00ed88a422be..5caacbacbab8b6d1b409ea73df737253706db248 100644 (file)
@@ -154,7 +154,7 @@ func (frame *stkframe) argMapInternal() (argMap bitvector, hasReflectStackObj bo
 
 // getStackMap returns the locals and arguments live pointer maps, and
 // stack object list for frame.
-func (frame *stkframe) getStackMap(debug bool) (locals, args bitvector, objs []stackObjectRecord) {
+func (frame *stkframe) getStackMap(cache *pcvalueCache, debug bool) (locals, args bitvector, objs []stackObjectRecord) {
        targetpc := frame.continpc
        if targetpc == 0 {
                // Frame is dead. Return empty bitvectors.
@@ -169,7 +169,7 @@ func (frame *stkframe) getStackMap(debug bool) (locals, args bitvector, objs []s
                // the first instruction of the function changes the
                // stack map.
                targetpc--
-               pcdata = pcdatavalue(f, abi.PCDATA_StackMapIndex, targetpc)
+               pcdata = pcdatavalue(f, abi.PCDATA_StackMapIndex, targetpc, cache)
        }
        if pcdata == -1 {
                // We do not have a valid pcdata value but there might be a
index 0397b6ecf5fda5c7d6ad23018d3b78b37261318a..18ba683d69ddc867c0815033b5056f3b1f132589 100644 (file)
@@ -119,7 +119,7 @@ func (ci *Frames) Next() (frame Frame, more bool) {
                }
                // It's important that interpret pc non-strictly as cgoTraceback may
                // have added bogus PCs with a valid funcInfo but invalid PCDATA.
-               u, uf := newInlineUnwinder(funcInfo, pc)
+               u, uf := newInlineUnwinder(funcInfo, pc, nil)
                sf := u.srcFunc(uf)
                if u.isInlined(uf) {
                        // Note: entry is not modified. It always refers to a real frame, not an inlined one.
@@ -180,7 +180,7 @@ func runtime_FrameSymbolName(f *Frame) string {
        if !f.funcInfo.valid() {
                return f.Function
        }
-       u, uf := newInlineUnwinder(f.funcInfo, f.PC)
+       u, uf := newInlineUnwinder(f.funcInfo, f.PC, nil)
        sf := u.srcFunc(uf)
        return sf.name()
 }
@@ -204,7 +204,8 @@ func runtime_expandFinalInlineFrame(stk []uintptr) []uintptr {
                return stk
        }
 
-       u, uf := newInlineUnwinder(f, tracepc)
+       var cache pcvalueCache
+       u, uf := newInlineUnwinder(f, tracepc, &cache)
        if !u.isInlined(uf) {
                // Nothing inline at tracepc.
                return stk
@@ -657,7 +658,7 @@ func FuncForPC(pc uintptr) *Func {
        // We just report the preceding function in that situation. See issue 29735.
        // TODO: Perhaps we should report no function at all in that case.
        // The runtime currently doesn't have function end info, alas.
-       u, uf := newInlineUnwinder(f, pc)
+       u, uf := newInlineUnwinder(f, pc, nil)
        if !u.isInlined(uf) {
                return f._Func()
        }
@@ -842,7 +843,7 @@ func pcvalueCacheKey(targetpc uintptr) uintptr {
 }
 
 // Returns the PCData value, and the PC where this value starts.
-func pcvalue(f funcInfo, off uint32, targetpc uintptr, strict bool) (int32, uintptr) {
+func pcvalue(f funcInfo, off uint32, targetpc uintptr, _ *pcvalueCache, strict bool) (int32, uintptr) {
        if off == 0 {
                return -1, 0
        }
@@ -978,8 +979,8 @@ func funcline1(f funcInfo, targetpc uintptr, strict bool) (file string, line int
        if !f.valid() {
                return "?", 0
        }
-       fileno, _ := pcvalue(f, f.pcfile, targetpc, strict)
-       line, _ = pcvalue(f, f.pcln, targetpc, strict)
+       fileno, _ := pcvalue(f, f.pcfile, targetpc, nil, strict)
+       line, _ = pcvalue(f, f.pcln, targetpc, nil, strict)
        if fileno == -1 || line == -1 || int(fileno) >= len(datap.filetab) {
                // print("looking for ", hex(targetpc), " in ", funcname(f), " got file=", fileno, " line=", lineno, "\n")
                return "?", 0
@@ -992,8 +993,8 @@ func funcline(f funcInfo, targetpc uintptr) (file string, line int32) {
        return funcline1(f, targetpc, true)
 }
 
-func funcspdelta(f funcInfo, targetpc uintptr) int32 {
-       x, _ := pcvalue(f, f.pcsp, targetpc, true)
+func funcspdelta(f funcInfo, targetpc uintptr, cache *pcvalueCache) int32 {
+       x, _ := pcvalue(f, f.pcsp, targetpc, cache, true)
        if debugPcln && x&(goarch.PtrSize-1) != 0 {
                print("invalid spdelta ", funcname(f), " ", hex(f.entry()), " ", hex(targetpc), " ", hex(f.pcsp), " ", x, "\n")
                throw("bad spdelta")
@@ -1024,28 +1025,29 @@ func pcdatastart(f funcInfo, table uint32) uint32 {
        return *(*uint32)(add(unsafe.Pointer(&f.nfuncdata), unsafe.Sizeof(f.nfuncdata)+uintptr(table)*4))
 }
 
-func pcdatavalue(f funcInfo, table uint32, targetpc uintptr) int32 {
+func pcdatavalue(f funcInfo, table uint32, targetpc uintptr, cache *pcvalueCache) int32 {
        if table >= f.npcdata {
                return -1
        }
-       r, _ := pcvalue(f, pcdatastart(f, table), targetpc, true)
+       r, _ := pcvalue(f, pcdatastart(f, table), targetpc, cache, true)
        return r
 }
 
-func pcdatavalue1(f funcInfo, table uint32, targetpc uintptr, strict bool) int32 {
+func pcdatavalue1(f funcInfo, table uint32, targetpc uintptr, cache *pcvalueCache, strict bool) int32 {
        if table >= f.npcdata {
                return -1
        }
-       r, _ := pcvalue(f, pcdatastart(f, table), targetpc, strict)
+       r, _ := pcvalue(f, pcdatastart(f, table), targetpc, cache, strict)
        return r
 }
 
 // Like pcdatavalue, but also return the start PC of this PCData value.
+// It doesn't take a cache.
 func pcdatavalue2(f funcInfo, table uint32, targetpc uintptr) (int32, uintptr) {
        if table >= f.npcdata {
                return -1, 0
        }
-       return pcvalue(f, pcdatastart(f, table), targetpc, true)
+       return pcvalue(f, pcdatastart(f, table), targetpc, nil, true)
 }
 
 // funcdata returns a pointer to the ith funcdata for f.
index 9273b49b11e51f4a6e6e63d29d9588b769df514c..2bb1c4bc6af5c1f34a98fa097e3fa34867378492 100644 (file)
@@ -30,6 +30,7 @@ type inlinedCall struct {
 // code.
 type inlineUnwinder struct {
        f       funcInfo
+       cache   *pcvalueCache
        inlTree *[1 << 20]inlinedCall
 }
 
@@ -51,13 +52,13 @@ type inlineFrame struct {
 // This unwinder uses non-strict handling of PC because it's assumed this is
 // only ever used for symbolic debugging. If things go really wrong, it'll just
 // fall back to the outermost frame.
-func newInlineUnwinder(f funcInfo, pc uintptr) (inlineUnwinder, inlineFrame) {
+func newInlineUnwinder(f funcInfo, pc uintptr, cache *pcvalueCache) (inlineUnwinder, inlineFrame) {
        inldata := funcdata(f, abi.FUNCDATA_InlTree)
        if inldata == nil {
                return inlineUnwinder{f: f}, inlineFrame{pc: pc, index: -1}
        }
        inlTree := (*[1 << 20]inlinedCall)(inldata)
-       u := inlineUnwinder{f: f, inlTree: inlTree}
+       u := inlineUnwinder{f: f, cache: cache, inlTree: inlTree}
        return u, u.resolveInternal(pc)
 }
 
@@ -66,7 +67,7 @@ func (u *inlineUnwinder) resolveInternal(pc uintptr) inlineFrame {
                pc: pc,
                // Conveniently, this returns -1 if there's an error, which is the same
                // value we use for the outermost frame.
-               index: pcdatavalue1(u.f, abi.PCDATA_InlTreeIndex, pc, false),
+               index: pcdatavalue1(u.f, abi.PCDATA_InlTreeIndex, pc, u.cache, false),
        }
 }
 
index df524aec4a039b5378679001caf2844bf23c3947..9e75f79281fa4e55cb7d653ae2145ca247743c7c 100644 (file)
@@ -34,9 +34,10 @@ func XTestInlineUnwinder(t TestingT) {
 
        // Iterate over the PCs in tiuTest and walk the inline stack for each.
        prevStack := "x"
+       var cache pcvalueCache
        for pc := pc1; pc < pc1+1024 && findfunc(pc) == f; pc += sys.PCQuantum {
                stack := ""
-               u, uf := newInlineUnwinder(f, pc)
+               u, uf := newInlineUnwinder(f, pc, &cache)
                if file, _ := u.fileLine(uf); file == "?" {
                        // We're probably in the trailing function padding, where findfunc
                        // still returns f but there's no symbolic information. Just keep
index 125b8678db3460037d5eba752490968c97f5cb74..a4d50d77a0102d880dd9b0d0efc5df6917b05bbc 100644 (file)
@@ -1345,6 +1345,7 @@ func fpunwindExpand(pcBuf []uintptr) []uintptr {
        }
 
        var (
+               cache      pcvalueCache
                lastFuncID = abi.FuncIDNormal
                newPCBuf   = make([]uintptr, 0, traceStackSize)
                skip       = pcBuf[0]
@@ -1373,7 +1374,7 @@ outer:
                        continue
                }
 
-               u, uf := newInlineUnwinder(fi, callPC)
+               u, uf := newInlineUnwinder(fi, callPC, &cache)
                for ; uf.valid(); uf = u.next(uf) {
                        sf := u.srcFunc(uf)
                        if sf.funcID == abi.FuncIDWrapper && elideWrapperCalling(lastFuncID) {
index 5dfac4fa011d01dd7879cdaf119463fe09dd7639..86df1155b5c114bdcf3588039b1109e675b1d07b 100644 (file)
@@ -112,6 +112,9 @@ type unwinder struct {
        // flags are the flags to this unwind. Some of these are updated as we
        // unwind (see the flags documentation).
        flags unwindFlags
+
+       // cache is used to cache pcvalue lookups.
+       cache pcvalueCache
 }
 
 // init initializes u to start unwinding gp's stack and positions the
@@ -304,7 +307,7 @@ func (u *unwinder) resolveInternal(innermost, isSyscall bool) {
                        case abi.FuncID_systemstack:
                                // systemstack returns normally, so just follow the
                                // stack transition.
-                               if usesLR && funcspdelta(f, frame.pc) == 0 {
+                               if usesLR && funcspdelta(f, frame.pc, &u.cache) == 0 {
                                        // We're at the function prologue and the stack
                                        // switch hasn't happened, or epilogue where we're
                                        // about to return. Just unwind normally.
@@ -322,7 +325,7 @@ func (u *unwinder) resolveInternal(innermost, isSyscall bool) {
                                flag &^= abi.FuncFlagSPWrite
                        }
                }
-               frame.fp = frame.sp + uintptr(funcspdelta(f, frame.pc))
+               frame.fp = frame.sp + uintptr(funcspdelta(f, frame.pc, &u.cache))
                if !usesLR {
                        // On x86, call instruction pushes return PC before entering new function.
                        frame.fp += goarch.PtrSize
@@ -497,7 +500,7 @@ func (u *unwinder) next() {
                frame.fn = f
                if !f.valid() {
                        frame.pc = x
-               } else if funcspdelta(f, frame.pc) == 0 {
+               } else if funcspdelta(f, frame.pc, &u.cache) == 0 {
                        frame.lr = x
                }
        }
@@ -617,7 +620,7 @@ func tracebackPCs(u *unwinder, skip int, pcBuf []uintptr) int {
                cgoN := u.cgoCallers(cgoBuf[:])
 
                // TODO: Why does &u.cache cause u to escape? (Same in traceback2)
-               for iu, uf := newInlineUnwinder(f, u.symPC()); n < len(pcBuf) && uf.valid(); uf = iu.next(uf) {
+               for iu, uf := newInlineUnwinder(f, u.symPC(), noEscapePtr(&u.cache)); n < len(pcBuf) && uf.valid(); uf = iu.next(uf) {
                        sf := iu.srcFunc(uf)
                        if sf.funcID == abi.FuncIDWrapper && elideWrapperCalling(u.calleeFuncID) {
                                // ignore wrappers
@@ -667,7 +670,7 @@ func printArgs(f funcInfo, argp unsafe.Pointer, pc uintptr) {
        }
 
        liveInfo := funcdata(f, abi.FUNCDATA_ArgLiveInfo)
-       liveIdx := pcdatavalue(f, abi.PCDATA_ArgLiveIndex, pc)
+       liveIdx := pcdatavalue(f, abi.PCDATA_ArgLiveIndex, pc, nil)
        startOffset := uint8(0xff) // smallest offset that needs liveness info (slots with a lower offset is always live)
        if liveInfo != nil {
                startOffset = *(*uint8)(liveInfo)
@@ -974,7 +977,7 @@ func traceback2(u *unwinder, showRuntime bool, skip, max int) (n, lastN int) {
        for ; u.valid(); u.next() {
                lastN = 0
                f := u.frame.fn
-               for iu, uf := newInlineUnwinder(f, u.symPC()); uf.valid(); uf = iu.next(uf) {
+               for iu, uf := newInlineUnwinder(f, u.symPC(), noEscapePtr(&u.cache)); uf.valid(); uf = iu.next(uf) {
                        sf := iu.srcFunc(uf)
                        callee := u.calleeFuncID
                        u.calleeFuncID = sf.funcID
@@ -1075,7 +1078,7 @@ func printAncestorTraceback(ancestor ancestorInfo) {
 // due to only have access to the pcs at the time of the caller
 // goroutine being created.
 func printAncestorTracebackFuncInfo(f funcInfo, pc uintptr) {
-       u, uf := newInlineUnwinder(f, pc)
+       u, uf := newInlineUnwinder(f, pc, nil)
        file, line := u.fileLine(uf)
        printFuncName(u.srcFunc(uf).name())
        print("(...)\n")