- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 470 for gStates (0.1 sec)
-
src/cmd/trace/goroutinegen.go
gs := g.gStates[r.Scope.Goroutine()] gs.rangeEnd(ev.Time(), r.Name, ev.Stack(), ctx) } } func (g *goroutineGenerator) GoroutineTransition(ctx *traceContext, ev *trace.Event) { st := ev.StateTransition() goID := st.Resource.Goroutine() // If we haven't seen this goroutine before, create a new // gState for it. gs, ok := g.gStates[goID] if !ok { gs = newGState[trace.GoID](goID) g.gStates[goID] = gs }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.6K bytes - Viewed (0) -
src/cmd/trace/procgen.go
logEventGenerator[trace.ProcID] gStates map[trace.GoID]*gState[trace.ProcID] inSyscall map[trace.ProcID]*gState[trace.ProcID] maxProc trace.ProcID } func newProcGenerator() *procGenerator { pg := new(procGenerator) rg := func(ev *trace.Event) trace.ProcID { return ev.Proc() } pg.stackSampleGenerator.getResource = rg pg.logEventGenerator.getResource = rg pg.gStates = make(map[trace.GoID]*gState[trace.ProcID])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.1K bytes - Viewed (0) -
src/cmd/trace/threadgen.go
logEventGenerator[trace.ThreadID] gStates map[trace.GoID]*gState[trace.ThreadID] threads map[trace.ThreadID]struct{} } func newThreadGenerator() *threadGenerator { tg := new(threadGenerator) rg := func(ev *trace.Event) trace.ThreadID { return ev.Thread() } tg.stackSampleGenerator.getResource = rg tg.logEventGenerator.getResource = rg tg.gStates = make(map[trace.GoID]*gState[trace.ThreadID])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 5.7K bytes - Viewed (0) -
src/internal/trace/traceviewer/emitter.go
func (e *Emitter) GoroutineTransition(ts time.Duration, from, to GState) { e.gstates[from]-- e.gstates[to]++ if e.prevGstates == e.gstates { return } if e.tsWithinRange(ts) { e.OptionalEvent(&format.Event{ Name: "Goroutines", Phase: "C", Time: viewerTime(ts), PID: 1, Arg: &format.GoroutineCountersArg{ Running: uint64(e.gstates[GRunning]), Runnable: uint64(e.gstates[GRunnable]),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:29:58 UTC 2023 - 20.4K bytes - Viewed (0) -
src/internal/trace/order.go
// add completed events to the ordering. Next is used to pick // off events in the ordering. type ordering struct { gStates map[GoID]*gState pStates map[ProcID]*pState // TODO: The keys are dense, so this can be a slice. mStates map[ThreadID]*mState activeTasks map[TaskID]taskState gcSeq uint64 gcState gcState initialGen uint64 queue queue[Event] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
src/internal/trace/reader.go
return &Reader{ go121Events: convertOldFormat(tr), }, nil case version.Go122, version.Go123: return &Reader{ r: br, order: ordering{ mStates: make(map[ThreadID]*mState), pStates: make(map[ProcID]*pState), gStates: make(map[GoID]*gState), activeTasks: make(map[TaskID]taskState), }, // Don't emit a sync event when we first go to emit events. emittedSync: true, }, nil default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.7K bytes - Viewed (0) -
src/cmd/trace/gstate.go
// further events will be processed. This method may leave the gState in // an inconsistent state. func (gs *gState[R]) finish(ctx *traceContext) { if gs.executing != R(noResource) { gs.syscallEnd(ctx.endTime, false, ctx) gs.stop(ctx.endTime, trace.NoStack, ctx) } } // rangeBegin indicates the start of a special range of time. func (gs *gState[R]) rangeBegin(ts trace.Time, name string, stack trace.Stack) {
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/internal/trace/internal/oldtrace/order.go
return case EvGoUnblock, EvGoSysExit: g = ev.Args[0] init = gState{ev.Args[1], gWaiting} next = gState{ev.Args[1] + 1, gRunnable} return case EvGoUnblockLocal, EvGoSysExitLocal: g = ev.Args[0] init = gState{noseq, gWaiting} next = gState{seqinc, gRunnable} return case EvGCStart: g = garbage init = gState{ev.Args[0], gDead} next = gState{ev.Args[0] + 1, gDead} return default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 4K bytes - Viewed (0) -
test/escape_mutations.go
package p import "fmt" type B struct { x int px *int pb *B } func F1(b *B) { // ERROR "mutates param: b derefs=0" b.x = 1 } func F2(b *B) { // ERROR "mutates param: b derefs=1" *b.px = 1 } func F2a(b *B) { // ERROR "mutates param: b derefs=0" b.px = nil } func F3(b *B) { // ERROR "leaking param: b" fmt.Println(b) // ERROR "\.\.\. argument does not escape" }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 18 11:58:37 UTC 2023 - 1.8K bytes - Viewed (0) -
pilot/pkg/request/command_test.go
if err := util.Compare(body, p.States[0].wantBody); err == nil { w.WriteHeader(p.States[0].StatusCode) w.Write([]byte(p.States[0].Response)) } else { w.WriteHeader(http.StatusBadRequest) w.Write([]byte(fmt.Sprintf("wanted body %q got %q", string(p.States[0].wantBody), string(body)))) } } else { w.WriteHeader(http.StatusBadRequest) w.Write([]byte(fmt.Sprintf("wanted path %q got %q", p.States[0].wantPath, r.URL.Path))) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 11 19:11:01 UTC 2023 - 4.1K bytes - Viewed (0)