diff options
| author | Hana Kim <hakim@google.com> | 2018-04-19 14:58:42 -0400 |
|---|---|---|
| committer | Hyang-Ah Hana Kim <hyangah@gmail.com> | 2018-04-24 16:33:15 +0000 |
| commit | c2d10243688194346f660591fe4159e30a8d20ec (patch) | |
| tree | 9c3bf5c9b2f307ce2a655ef97fac72f2e1fe430f /src/cmd/trace/pprof.go | |
| parent | fb017c60bc60f8df771ac2a9119ec55ea915929c (diff) | |
| download | go-c2d10243688194346f660591fe4159e30a8d20ec.tar.xz | |
runtime/trace: rename "Span" with "Region"
"Span" is a commonly used term in many distributed tracing systems
(Dapper, OpenCensus, OpenTracing, ...). They use it to refer to a
period of time, not necessarily tied into execution of underlying
processor, thread, or goroutine, unlike the "Span" of runtime/trace
package.
Since distributed tracing and go runtime execution tracing are
already similar enough to cause confusion, this CL attempts to avoid
using the same word if possible.
"Region" is being used in a certain tracing system to refer to a code
region which is pretty close to what runtime/trace.Span currently
refers to. So, replace that.
https://software.intel.com/en-us/itc-user-and-reference-guide-defining-and-recording-functions-or-regions
This CL also tweaks APIs a bit based on jbd and heschi's comments:
NewContext -> NewTask
and it now returns a Task object that exports End method.
StartSpan -> StartRegion
and it now returns a Region object that exports End method.
Also, changed WithSpan to WithRegion and it now takes func() with no
context. Another thought is to get rid of WithRegion. It is a nice
concept but in practice, it seems problematic (a lot of code churn,
and polluting stack trace). Already, the tracing concept is very low
level, and we hope this API to be used with great care.
Recommended usage will be
defer trace.StartRegion(ctx, "someRegion").End()
Left old APIs untouched in this CL. Once the usage of them are cleaned
up, they will be removed in a separate CL.
Change-Id: I73880635e437f3aad51314331a035dd1459b9f3a
Reviewed-on: https://go-review.googlesource.com/108296
Run-TryBot: Hyang-Ah Hana Kim <hyangah@gmail.com>
TryBot-Result: Gobot Gobot <gobot@golang.org>
Reviewed-by: JBD <jbd@google.com>
Diffstat (limited to 'src/cmd/trace/pprof.go')
| -rw-r--r-- | src/cmd/trace/pprof.go | 34 |
1 files changed, 17 insertions, 17 deletions
diff --git a/src/cmd/trace/pprof.go b/src/cmd/trace/pprof.go index c0972f2b46..3389d2799b 100644 --- a/src/cmd/trace/pprof.go +++ b/src/cmd/trace/pprof.go @@ -42,10 +42,10 @@ func init() { http.HandleFunc("/syscall", serveSVGProfile(pprofByGoroutine(computePprofSyscall))) http.HandleFunc("/sched", serveSVGProfile(pprofByGoroutine(computePprofSched))) - http.HandleFunc("/spanio", serveSVGProfile(pprofBySpan(computePprofIO))) - http.HandleFunc("/spanblock", serveSVGProfile(pprofBySpan(computePprofBlock))) - http.HandleFunc("/spansyscall", serveSVGProfile(pprofBySpan(computePprofSyscall))) - http.HandleFunc("/spansched", serveSVGProfile(pprofBySpan(computePprofSched))) + http.HandleFunc("/regionio", serveSVGProfile(pprofByRegion(computePprofIO))) + http.HandleFunc("/regionblock", serveSVGProfile(pprofByRegion(computePprofBlock))) + http.HandleFunc("/regionsyscall", serveSVGProfile(pprofByRegion(computePprofSyscall))) + http.HandleFunc("/regionsched", serveSVGProfile(pprofByRegion(computePprofSched))) } // Record represents one entry in pprof-like profiles. @@ -75,13 +75,13 @@ func pprofByGoroutine(compute func(io.Writer, map[uint64][]interval, []*trace.Ev } } -func pprofBySpan(compute func(io.Writer, map[uint64][]interval, []*trace.Event) error) func(w io.Writer, r *http.Request) error { +func pprofByRegion(compute func(io.Writer, map[uint64][]interval, []*trace.Event) error) func(w io.Writer, r *http.Request) error { return func(w io.Writer, r *http.Request) error { - filter, err := newSpanFilter(r) + filter, err := newRegionFilter(r) if err != nil { return err } - gToIntervals, err := pprofMatchingSpans(filter) + gToIntervals, err := pprofMatchingRegions(filter) if err != nil { return err } @@ -123,9 +123,9 @@ func pprofMatchingGoroutines(id string, events []*trace.Event) (map[uint64][]int return res, nil } -// pprofMatchingSpans returns the time intervals of matching spans +// pprofMatchingRegions returns the time intervals of matching regions // grouped by the goroutine id. If the filter is nil, returns nil without an error. -func pprofMatchingSpans(filter *spanFilter) (map[uint64][]interval, error) { +func pprofMatchingRegions(filter *regionFilter) (map[uint64][]interval, error) { res, err := analyzeAnnotations() if err != nil { return nil, err @@ -135,8 +135,8 @@ func pprofMatchingSpans(filter *spanFilter) (map[uint64][]interval, error) { } gToIntervals := make(map[uint64][]interval) - for id, spans := range res.spans { - for _, s := range spans { + for id, regions := range res.regions { + for _, s := range regions { if filter.match(id, s) { gToIntervals[s.G] = append(gToIntervals[s.G], interval{begin: s.firstTimestamp(), end: s.lastTimestamp()}) } @@ -144,10 +144,10 @@ func pprofMatchingSpans(filter *spanFilter) (map[uint64][]interval, error) { } for g, intervals := range gToIntervals { - // in order to remove nested spans and - // consider only the outermost spans, + // in order to remove nested regions and + // consider only the outermost regions, // first, we sort based on the start time - // and then scan through to select only the outermost spans. + // and then scan through to select only the outermost regions. sort.Slice(intervals, func(i, j int) bool { x := intervals[i].begin y := intervals[j].begin @@ -158,13 +158,13 @@ func pprofMatchingSpans(filter *spanFilter) (map[uint64][]interval, error) { }) var lastTimestamp int64 var n int - // select only the outermost spans. + // select only the outermost regions. for _, i := range intervals { if lastTimestamp <= i.begin { - intervals[n] = i // new non-overlapping span starts. + intervals[n] = i // new non-overlapping region starts. lastTimestamp = i.end n++ - } // otherwise, skip because this span overlaps with a previous span. + } // otherwise, skip because this region overlaps with a previous region. } gToIntervals[g] = intervals[:n] } |
