proc: stacktrace refactoring

- made GoroutineStacktrace a method of struct G
- made stacktrace a method of StackIterator
- renamed StackIterator to stackIterator
- factored out logic to obtain a stackIterator from a goroutine that's
used by both (*G).Stacktrace and by (*G).UserCurrent
This commit is contained in:
aarzilli
2016-03-18 09:51:48 +01:00
committed by Derek Parker
parent 43756cd864
commit 497b526194
5 changed files with 41 additions and 32 deletions

View File

@ -876,7 +876,7 @@ func (dbp *Process) ConvertEvalScope(gid, frame int) (*EvalScope, error) {
out.Thread = g.thread out.Thread = g.thread
} }
locs, err := dbp.GoroutineStacktrace(g, frame) locs, err := g.Stacktrace(frame)
if err != nil { if err != nil {
return nil, err return nil, err
} }

View File

@ -758,7 +758,7 @@ func TestStacktraceGoroutine(t *testing.T) {
mainCount := 0 mainCount := 0
for i, g := range gs { for i, g := range gs {
locations, err := p.GoroutineStacktrace(g, 40) locations, err := g.Stacktrace(40)
assertNoError(err, t, "GoroutineStacktrace()") assertNoError(err, t, "GoroutineStacktrace()")
if stackMatch(mainStack, locations, false) { if stackMatch(mainStack, locations, false) {
@ -1053,7 +1053,7 @@ func TestFrameEvaluation(t *testing.T) {
found := make([]bool, 10) found := make([]bool, 10)
for _, g := range gs { for _, g := range gs {
frame := -1 frame := -1
frames, err := p.GoroutineStacktrace(g, 10) frames, err := g.Stacktrace(10)
assertNoError(err, t, "GoroutineStacktrace()") assertNoError(err, t, "GoroutineStacktrace()")
for i := range frames { for i := range frames {
if frames[i].Call.Fn != nil && frames[i].Call.Fn.Name == "main.agoroutine" { if frames[i].Call.Fn != nil && frames[i].Call.Fn.Name == "main.agoroutine" {

View File

@ -45,24 +45,39 @@ func (t *Thread) ReturnAddress() (uint64, error) {
return locations[1].Current.PC, nil return locations[1].Current.PC, nil
} }
// Stacktrace returns the stack trace for thread. func (t *Thread) stackIterator() (*stackIterator, error) {
// Note the locations in the array are return addresses not call addresses.
func (t *Thread) Stacktrace(depth int) ([]Stackframe, error) {
regs, err := t.Registers() regs, err := t.Registers()
if err != nil { if err != nil {
return nil, err return nil, err
} }
return t.dbp.stacktrace(regs.PC(), regs.SP(), depth) return newStackIterator(t.dbp, regs.PC(), regs.SP()), nil
} }
// GoroutineStacktrace returns the stack trace for a goroutine. // Stacktrace returns the stack trace for thread.
// Note the locations in the array are return addresses not call addresses. // Note the locations in the array are return addresses not call addresses.
func (dbp *Process) GoroutineStacktrace(g *G, depth int) ([]Stackframe, error) { func (t *Thread) Stacktrace(depth int) ([]Stackframe, error) {
if g.thread != nil { it, err := t.stackIterator()
return g.thread.Stacktrace(depth) if err != nil {
return nil, err
} }
locs, err := dbp.stacktrace(g.PC, g.SP, depth) return it.stacktrace(depth)
return locs, err }
func (g *G) stackIterator() (*stackIterator, error) {
if g.thread != nil {
return g.thread.stackIterator()
}
return newStackIterator(g.dbp, g.PC, g.SP), nil
}
// Stacktrace returns the stack trace for a goroutine.
// Note the locations in the array are return addresses not call addresses.
func (g *G) Stacktrace(depth int) ([]Stackframe, error) {
it, err := g.stackIterator()
if err != nil {
return nil, err
}
return it.stacktrace(depth)
} }
// GoroutineLocation returns the location of the given // GoroutineLocation returns the location of the given
@ -79,10 +94,10 @@ func (n NullAddrError) Error() string {
return "NULL address" return "NULL address"
} }
// StackIterator holds information // stackIterator holds information
// required to iterate and walk the program // required to iterate and walk the program
// stack. // stack.
type StackIterator struct { type stackIterator struct {
pc, sp uint64 pc, sp uint64
top bool top bool
atend bool atend bool
@ -91,12 +106,12 @@ type StackIterator struct {
err error err error
} }
func newStackIterator(dbp *Process, pc, sp uint64) *StackIterator { func newStackIterator(dbp *Process, pc, sp uint64) *stackIterator {
return &StackIterator{pc: pc, sp: sp, top: true, dbp: dbp, err: nil, atend: false} return &stackIterator{pc: pc, sp: sp, top: true, dbp: dbp, err: nil, atend: false}
} }
// Next points the iterator to the next stack frame. // Next points the iterator to the next stack frame.
func (it *StackIterator) Next() bool { func (it *stackIterator) Next() bool {
if it.err != nil || it.atend { if it.err != nil || it.atend {
return false return false
} }
@ -132,7 +147,7 @@ func (it *StackIterator) Next() bool {
} }
// Frame returns the frame the iterator is pointing at. // Frame returns the frame the iterator is pointing at.
func (it *StackIterator) Frame() Stackframe { func (it *stackIterator) Frame() Stackframe {
if it.err != nil { if it.err != nil {
panic(it.err) panic(it.err)
} }
@ -140,7 +155,7 @@ func (it *StackIterator) Frame() Stackframe {
} }
// Err returns the error encountered during stack iteration. // Err returns the error encountered during stack iteration.
func (it *StackIterator) Err() error { func (it *stackIterator) Err() error {
return it.err return it.err
} }
@ -171,12 +186,11 @@ func (dbp *Process) frameInfo(pc, sp uint64, top bool) (Stackframe, error) {
return r, nil return r, nil
} }
func (dbp *Process) stacktrace(pc, sp uint64, depth int) ([]Stackframe, error) { func (it *stackIterator) stacktrace(depth int) ([]Stackframe, error) {
if depth < 0 { if depth < 0 {
return nil, errors.New("negative maximum stack depth") return nil, errors.New("negative maximum stack depth")
} }
frames := make([]Stackframe, 0, depth+1) frames := make([]Stackframe, 0, depth+1)
it := newStackIterator(dbp, pc, sp)
for it.Next() { for it.Next() {
frames = append(frames, it.Frame()) frames = append(frames, it.Frame())
if len(frames) >= depth+1 { if len(frames) >= depth+1 {

View File

@ -317,7 +317,7 @@ func (g *G) ChanRecvBlocked() bool {
// chanRecvReturnAddr returns the address of the return from a channel read. // chanRecvReturnAddr returns the address of the return from a channel read.
func (g *G) chanRecvReturnAddr(dbp *Process) (uint64, error) { func (g *G) chanRecvReturnAddr(dbp *Process) (uint64, error) {
locs, err := dbp.GoroutineStacktrace(g, 4) locs, err := g.Stacktrace(4)
if err != nil { if err != nil {
return 0, err return 0, err
} }
@ -411,15 +411,10 @@ func isExportedRuntime(name string) bool {
// UserCurrent returns the location the users code is at, // UserCurrent returns the location the users code is at,
// or was at before entering a runtime function. // or was at before entering a runtime function.
func (g *G) UserCurrent() Location { func (g *G) UserCurrent() Location {
pc, sp := g.PC, g.SP it, err := g.stackIterator()
if g.thread != nil { if err != nil {
regs, err := g.thread.Registers() return g.CurrentLoc
if err != nil {
return g.CurrentLoc
}
pc, sp = regs.PC(), regs.SP()
} }
it := newStackIterator(g.dbp, pc, sp)
for it.Next() { for it.Next() {
frame := it.Frame() frame := it.Frame()
if frame.Call.Fn != nil { if frame.Call.Fn != nil {

View File

@ -691,7 +691,7 @@ func (d *Debugger) Stacktrace(goroutineID, depth int, full bool) ([]api.Stackfra
if g == nil { if g == nil {
rawlocs, err = d.process.CurrentThread.Stacktrace(depth) rawlocs, err = d.process.CurrentThread.Stacktrace(depth)
} else { } else {
rawlocs, err = d.process.GoroutineStacktrace(g, depth) rawlocs, err = g.Stacktrace(depth)
} }
if err != nil { if err != nil {
return nil, err return nil, err