- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for GoID (0.05 sec)
-
src/internal/trace/summary_test.go
} // Test the function. targetg := trace.GoID(86) got := trace.RelatedGoroutinesV2(events, targetg) want := map[trace.GoID]struct{}{ trace.GoID(86): struct{}{}, // N.B. Result includes target. trace.GoID(71): struct{}{}, trace.GoID(25): struct{}{}, trace.GoID(122): struct{}{}, } for goid := range got { if _, ok := want[goid]; ok { delete(want, goid) } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 13.4K bytes - Viewed (0) -
src/internal/trace/summary.go
Tasks: s.tasks, } } // RelatedGoroutinesV2 finds a set of goroutines related to goroutine goid for v2 traces. // The association is based on whether they have synchronized with each other in the Go // scheduler (one has unblocked another). func RelatedGoroutinesV2(events []Event, goid GoID) map[GoID]struct{} { // Process all the events, looking for transitions of goroutines
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K bytes - Viewed (0) -
src/internal/trace/oldtrace.go
case oldtrace.EvGoCreate: if it.preInit { it.createdPreInit[GoID(ev.Args[0])] = struct{}{} return Event{}, errSkip } mappedType = go122.EvGoCreate case oldtrace.EvGoStart: if it.preInit { mappedType = go122.EvGoStatus mappedArgs = timedEventArgs{ev.Args[0], ^uint64(0), uint64(go122.GoRunning)} delete(it.createdPreInit, GoID(ev.Args[0])) } else { mappedType = go122.EvGoStart }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
src/runtime/runtime-gdb.py
for ptr in SliceValue(gdb.parse_and_eval("'runtime.allgs'")): goids.append(int(ptr['goid'])) else: goids = [int(gdb.parse_and_eval(goid_str))] for goid in goids: self.invoke_per_goid(goid, cmd) def invoke_per_goid(self, goid, cmd): pc, sp = find_goroutine(goid) if not pc: print("No such goroutine: ", goid) return pc = pc_to_int(pc) save_frame = gdb.selected_frame()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 10 12:59:20 UTC 2023 - 15.4K bytes - Viewed (0) -
src/cmd/trace/pprof.go
// If the id string is empty, returns nil without an error. func pprofMatchingGoroutines(name string, t *parsedTrace) (map[trace.GoID][]interval, error) { res := make(map[trace.GoID][]interval) for _, g := range t.summary.Goroutines { if name != "" && g.Name != name { continue } endTime := g.EndTime if g.EndTime == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.1K bytes - Viewed (0) -
src/cmd/trace/gstate.go
resource uint64 stack trace.Stack } } // newGState constructs a new goroutine state for the goroutine // identified by the provided ID. func newGState[R resource](goID trace.GoID) *gState[R] { return &gState[R]{ baseName: fmt.Sprintf("G%d", goID), executing: R(noResource), activeRanges: make(map[string]activeRange), } } // augmentName attempts to use stk to augment the name of the goroutine
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
src/cmd/trace/goroutines.go
"log" "net/http" "slices" "sort" "strings" "time" ) // GoroutinesHandlerFunc returns a HandlerFunc that serves list of goroutine groups. func GoroutinesHandlerFunc(summaries map[trace.GoID]*trace.GoroutineSummary) http.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) { // goroutineGroup describes a group of goroutines grouped by name. type goroutineGroup struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.9K bytes - Viewed (0) -
src/internal/trace/generation.go
if err != nil { return nil, err } goid := GoID(g) if g == 0 { goid = NoGoroutine } // Read the sample's stack. s, err := binary.ReadUvarint(r) if err != nil { return nil, err } // Add the sample to the slice. samples = append(samples, cpuSample{ schedCtx: schedCtx{ M: mid, P: pid, G: goid, },
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 22:14:45 UTC 2024 - 12.1K bytes - Viewed (0) -
src/runtime/traceruntime.go
} tl.eventWriter(traceGoRunning, traceProcRunning).commit(ev, traceArg(newg.goid), tl.startPC(pc), tl.stack(2)) } // GoStart emits a GoStart event. // // Must be called with a valid P. func (tl traceLocker) GoStart() { gp := getg().m.curg pp := gp.m.p w := tl.eventWriter(traceGoRunnable, traceProcRunning) w = w.write(traceEvGoStart, traceArg(gp.goid), gp.trace.nextSeq(tl.gen))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0) -
src/internal/trace/testtrace/validation.go
type Validator struct { lastTs trace.Time gs map[trace.GoID]*goState ps map[trace.ProcID]*procState ms map[trace.ThreadID]*schedContext ranges map[trace.ResourceID][]string tasks map[trace.TaskID]string seenSync bool Go121 bool } type schedContext struct { M trace.ThreadID P trace.ProcID G trace.GoID } type goState struct { state trace.GoState
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.9K bytes - Viewed (0)